Clase: Mongo::BulkWrite

Hereda:
Objeto
  • Objeto
Mostrar todo
Ampliado por:
Reenviable
Incluye:
Operación::Gestión de respuestas
Definido en:
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 bajo Namespace

Modules: Combinable, Transformable, Validable Clases: Combinador ordenado, Resultado, Combinador de Resultados, Combinador no ordenado

Resumen de atributos de la instancia colapsar

Resumen del método de instancia colapsar

Detalles del constructor

#initialize(colección, solicitudes, opciones = {}) ⇒ BulkWrite

Este método forma parte de una API privada. Debe evitarlo si es posible, ya que podría eliminarse o modificarse en el futuro.

Crear la nueva operación de escritura masiva.

Ejemplos:

Crea un guardado por lotes ordenado.

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

Crear una escritura masiva desordenada.

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

Crea un guardado masivo mixto ordenado.

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

Parámetros:

  • Colección (Mongo::Collection) —

    La colección.

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

    Las solicitudes, no pueden estar vacías.

  • opciones (Hash, BSON::Document) (por defecto: {}) —

    Las opciones.

Desde:

  • 2.1.0



128
129
130
131
132
133
134
135
 
# Archivo 'lib/mongo/bulk_write.rb', línea 128

def inicializar(Colección, solicitud, opciones = {})
  @colección = Colección
  @solicitudes = solicitud
  @options = opciones || {}
  si @options[:timeout_ms] && @options[:timeout_ms] < 0
    propagar ArgumentError, "las opciones de timeout_ms deben ser un número entero no negativo"
  end
end

Detalles de los atributos de instancia

#colección ⇒ Mongo::Collection (solo lectura)

Devuelve la colección La colección.

Devuelve:



32
33
34
 
# Archivo 'lib/mongo/bulk_write.rb', línea 32

def Colección
  @colección
end

#opciones ⇒ Hash, BSON::Documento (solo lectura)

Devuelve opciones Las opciones.

Devuelve:

  • (Hash, BSON::Documento) —

    opciones Las opciones.



38
39
40
 
# Archivo 'lib/mongo/bulk_write.rb', línea 38

def opciones
  @options
end

#solicitudes ⇒ Array<Hash, BSON::Document> (solo lectura)

Devuelve las solicitudes Las solicitudes.

Devuelve:

  • (Matriz<Hash, BSON::Documento>) —

    solicitudes Las solicitudes.



35
36
37
 
# Archivo 'lib/mongo/bulk_write.rb', línea 35

def solicitud
  @solicitudes
end

Detalles del método de instancia

#ejecutar ⇒ Mongo::BulkWrite::Result

Ejecutar la operación de escritura masiva.

Ejemplos:

Ejecutar la escritura masiva.

bulk_write.execute

Devuelve:

Desde:

  • 2.1.0



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
 
# Archivo 'lib/mongo/bulk_write.rb', línea 58

def ejecutar
  operation_id = Monitoring.id_de_próxima_operación
  result_combiner = ResultCombiner.Nuevo
  Operaciones = op_combiner.combinar
  validate_requests!
  fecha límite = calcular_fecha_límite

  Cliente.con_sesión(@options) hacer |sesión|
    Operaciones.cada hacer |operación|
      context = Operación::Context.Nuevo(
        cliente: Cliente,
        sesión: sesión,
        operation_timeouts: { operation_timeout_ms: op_timeout_ms(fecha límite) }
      )
      si single_statement?(operación)
        escribir_preocupación = escribir_preocupación(sesión)
        escribir_con_reintento(escribir_preocupación, context: context) hacer |Conexión, txn_num, context|
          execute_operation(
            operación.claves.primero,
            operación.values.nivelar,
            Conexión,
            context,
            operation_id,
            result_combiner,
            sesión,
            txn_num)
        end
      else
        nro_write_with_retry(escribir_preocupación, context: context) hacer |Conexión, txn_num, context|
          execute_operation(
            operación.claves.primero,
            operación.values.nivelar,
            Conexión,
            context,
            operation_id,
            result_combiner,
            sesión)
        end
      end
    end
  end
  result_combiner.Resultado
end

#¿ordenado? ⇒ true, false

Este método forma parte de una API privada. Debe evitarlo si es posible, ya que podría eliminarse o modificarse en el futuro.

¿Está la escritura masiva ordenada?

Ejemplos:

¿Está la escritura masiva ordenada?

bulk_write.ordered?

Devuelve:

  • (verdadero,falso) —

    Si se ordena la escritura masiva.

Desde:

  • 2.1.0



147
148
149
 
# Archivo 'lib/mongo/bulk_write.rb', línea 147

def ¿ordenado?
  @ordered ||= opciones.obtener(:ordered, true)
end

#write_concern(session = nil) ⇒ WriteConcern

Este método forma parte de una API privada. Debe evitarlo si es posible, ya que podría eliminarse o modificarse en el futuro.

Obtener el nivel de confirmación de escritura (write concern) para la guardar masiva.

Ejemplos:

Obtenga la preocupación escrita.

bulk_write.write_concern

Devuelve:

  • (WriteConcern) —

    El nivel de confirmación de escritura (write concern).

Desde:

  • 2.1.0



161
162
163
164
165
 
# Archivo 'lib/mongo/bulk_write.rb', línea 161

def escribir_preocupación(sesión = nulo)
  @write_concern ||= opciones[:escribir_preocupación] ?
    Nivel de confirmación de escritura (write concern).Obtener(opciones[:escribir_preocupación]) :
    Colección.escribir_preocupación_con_la_sesión(sesión)
end