Classe: Mongo::BulkWrite

Herda:
Objeto
  • Objeto
mostrar tudo
Estendido por:
Encaminhável
Inclui:
Operação::ResponseHandling
Definido em:
lib/mongo/bulk_write.rb,
lib/mongo/bulk_write/result.rb,
lib/mongo/bulk_write/combineable.rb,
lib/mongo/bulk_write/validatable.rb,
lib/mongo/bulk_write/transformable.rb,
lib/ mongo/bulk_write/result_combiner.rb,
lib/mongo/bulk_write/ordered_combiner.rb,
lib/mongo/bulk_write/unordered_combiner.rb

Definido sob namespace

Módulos: Classes Combineable, Transformable, Validable : OrderedCombiner, Result, ResultCombiner, UnorderedCombiner

Recolhimento do Resumo do atributo de instância

Recolhimento do Resumo do método de instância

Detalhes do construtor

#initialize(collection, requests, opções = {}) ➤ BulkWrite

Este método faz parte de uma API privada. Evite usar esse método, se possível, pois ele pode ser removido ou alterado no futuro.

Crie a nova operação de escrita em massa.

Exemplos:

Crie uma escrita em massa ordenada.

Mongo::BulkWrite.new(collection, [{ insert_one: { _id: 1 }}])

Crie uma escrita em massa não ordenada.

Mongo::BulkWrite.new(collection, [{ insert_one: { _id: 1 }}], ordered: false)

Crie uma escrita em massa mista ordenada.

Mongo::BulkWrite.new(
  collection,
  [
    { insert_one: { _id: 1 }},
    { update_one: { filter: { _id: 0 }, update: { '$set' => { name: 'test' }}}},
    { delete_one: { filter: { _id: 2 }}}
  ]
)

Parâmetros:

  • collection (Mongo::Collection) —

    A coleção.

  • pedidos (Enumerable<Hash, BSON::Document>) —

    As solicitações não podem estar vazias.

  • opções (Hash, BSON::Documento) (padrão para: {}) —

    As opções.

Aumenta:

  • (ArgumentError)

Desde:

  • 2.1.0



129
130
131
132
133
134
135
136
 
# Arquivo 'lib/mongo/bulk_write.rb', linha 129

def inicializar(collection, pedidos, opções = {})
  @collection = collection
  @requests = pedidos
  @opções = opções || {}
  Método a menos que @opções[:timeout_ms] && @opções[:timeout_ms] < 0

  aumentar ArgumentError, 'as opções detimeout_ms devem ser número inteiro não negativo'
end

Detalhes do atributo da instância

#collection ➤ Mongo::Collection (readonly)

Retorna a collection A collection.

Retorna:



31
32
33
 
# Arquivo 'lib/mongo/bulk_write.rb', linha 31

def collection
  @collection
end

#options ➤ Hash, BSON::Document (somente leitura)

Retorna as opções As opções.

Retorna:

  • (Hash, BSON::Document) —

    opções As opções.



37
38
39
 
# Arquivo 'lib/mongo/bulk_write.rb', linha 37

def opções
  @opções
end

#requests ➤ Array<Hash, BSON::Document> (somente leitura)

Retorna solicitações As solicitações.

Retorna:

  • (Array<Hash, BSON::Document>) —

    solicita Os pedidos.



34
35
36
 
# Arquivo 'lib/mongo/bulk_write.rb', linha 34

def pedidos
  @requests
end

Detalhes do método de instância

#execute ➤ Mongo::BulkWrite::Result

Execute a operação de escrita em massa.

Exemplos:

Execute a escrita em massa.

bulk_write.execute

Retorna:

Desde:

  • 2.1.0



57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
 
# Arquivo 'lib/mongo/bulk_write.rb', linha 57

def executar, executar
  operation_id = Monitoramento.Next_operation_id
  result_combiner = ResultCombiner.Novo
  operations = op_combiner.combinar
  validate_requests!
  prazo = calculate_deadline

  Cliente.with_session(@opções) fazer |session|
    operations.cada fazer |operação|
      Contexto = (operação)::Contexto.Novo(
        cliente: Cliente,
        sessão: session,
        operation_timeouts: operation_timeouts(prazo)
      )
      se declaração única?(operação)
        write_concern = write_concern(session)
        write_with_retry(write_concern, contexto: Contexto) fazer |Conexão, txn_num, Contexto|
          execute_operation(
            operação.keys.primeiro,
            operação.values.achatar,
            Conexão,
            Contexto,
            operation_id,
            result_combiner,
            session,
            txn_num
          )
        end
      mais
        nro_write_with_retry(write_concern, contexto: Contexto) fazer |Conexão, _txn_num, Contexto|
          execute_operation(
            operação.keys.primeiro,
            operação.values.achatar,
            Conexão,
            Contexto,
            operation_id,
            result_combiner,
            session
          )
        end
      end
    end
  end
  result_combiner.Resultado
end

# fez opedido? ➤ true, false

Este método faz parte de uma API privada. Evite usar esse método, se possível, pois ele pode ser removido ou alterado no futuro.

A escrita em massa está ordenada?

Exemplos:

A escrita em massa está ordenada?

bulk_write.ordered?

Retorna:

  • (verdadeiro, falso) —

    Se a gravação em massa for ordenada.

Desde:

  • 2.1.0



148
149
150
 
# Arquivo 'lib/mongo/bulk_write.rb', linha 148

def ordenado?
  @ordered ||= opções.buscar(:ordered, true)
end

#write_concern(session = nil) ➤ WriteConcern

Este método faz parte de uma API privada. Evite usar esse método, se possível, pois ele pode ser removido ou alterado no futuro.

Obtenha a preocupação de gravação para a escrita em massa.

Exemplos:

Obtenha a preocupação de gravação.

bulk_write.write_concern

Retorna:

Desde:

  • 2.1.0



162
163
164
165
166
167
168
 
# Arquivo 'lib/mongo/bulk_write.rb', linha 162

def write_concern(session = nada)
  @write_concern ||= se opções[:write_concern]
                       Escreva preocupação.obter(opções[:write_concern])
                     mais
                       collection.write_concern_with_session(session)
                     end
end