Módulo: Mongo::operación::guardar Privado

Incluye:
ResponseHandling
Incluido en:
Borrar, Insertar, Actualizar
Definido en:
lib/mongo/operación/shared/guardar.rb

Overview

Este módulo es parte de una API privada. Deberías evitar usar este módulo si es posible, ya que puede ser removido o cambiado en el futuro.

Comportamiento compartido de las operaciones que guardan (actualizan, insertan, eliminan).

Desde:

  • 2.5.2

Resumen del método de instancia colapsar

Detalles del método de instancia

#bulk_execute(connection, context:) ⇒ Mongo::operación::borrar::BulkResult, ...

Este método es parte de una API privada. Se debe evitar el uso de este método si es posible, ya que podría eliminarse o modificarse en el futuro.

Ejecutar la operación de guardado masivo.

Parámetros:

Devuelve:

Desde:

  • 2.5.2



70
71
72
73
74
 
# Archivo 'lib/mongo/operación/shared/guardar.rb', línea 70

def bulk_execute(Conexión, context:)
  Lint.assert_type(Conexión, Server::Conexión)

  sí mismo.clase::OpMsg.Nuevo(especificación).ejecutar(Conexión, context: context).bulk_result
end

#ejecutar(servidor, contexto:) ⇒ Mongo::Operation::Result

Este método es parte de una API privada. Se debe evitar el uso de este método si es posible, ya que podría eliminarse o modificarse en el futuro.

Ejecuta la operación.

Parámetros:

Devuelve:

Desde:

  • 2.5.2



34
35
36
37
38
39
40
41
 
# Archivo 'lib/mongo/operación/shared/guardar.rb', línea 34

def ejecutar(Server, context:)
  Server.with_connection(
    connection_global_id: context.connection_global_id,
    context: context
  ) hacer |Conexión|
    execute_with_connection(Conexión, context: context)
  end
end

#ejecutar_con_conexión(conexión, contexto:) ⇒ Mongo::Operación::Result

Este método es parte de una API privada. Se debe evitar el uso de este método si es posible, ya que podría eliminarse o modificarse en el futuro.

Ejecuta la operación.

Parámetros:

Devuelve:

Desde:

  • 2.5.2



51
52
53
54
55
56
57
 
# Archivo 'lib/mongo/operación/shared/guardar.rb', línea 51

def execute_with_connection(Conexión, context:)
  validate!(Conexión)
  op = sí mismo.clase::OpMsg.Nuevo(especificación)

  Resultado = op.ejecutar(Conexión, context: context)
  validate_result(Resultado, Conexión, context)
end