Módulo: Mongo::Operación::Resultado::Agregable Privado

Definido en:
lib/mongo/operation/shared/result/aggregatable.rb

Overview

Este módulo forma parte de una API privada. Debe evitar su uso siempre que sea posible, ya que podría eliminarse o modificarse en el futuro.

Define el comportamiento personalizado de los resultados de guardado por lotes

Desde:

  • 2.0.0

Resumen del método de instancia colapsar

Detalles del método de instancia

#aggregate_write_concern_errors(count) ⇒ arreglo

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

Agrega los errores de nivel de confirmación de escritura (write concern) devueltos por este resultado.

Ejemplos:

Agrega los errores de nivel de confirmación de escritura (write concern).

result.aggregate_write_concern_errors(100)

Parámetros:

  • count (Número entero) —

    La cantidad de documentos ya ejecutados.

Devuelve:

  • (arreglo) —

    Los errores de escritura agregados preocupan.

Desde:

  • 2.0.0



60
61
62
63
64
65
66
67
68
69
70
 
# Archivo 'lib/mongo/operation/shared/result/aggregatable.rb', línea 60

def aggregate_write_concern_errors(count)
  return a menos que @replies
  @replies.cada_con_índice.disminuir(nulo) hacer |errors, (respuesta, _)|
    si write_concern_errors = respuesta.Documentos.primero['escribirErrores de Preocupación ']
      (errors || []) << write_concern_errors.disminuir(nulo) hacer |errs, wce|
        wce.¡unir!('index' => count + wce['index'])
        (errs || []) << write_concern_error
      end
    end
  end
end

#added_write_errors(conteo) ⇒ Matriz

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

Agregue los errores de escritura devueltos a partir de este resultado.

Ejemplos:

Agrega los errores de guardado.

result.aggregate_write_errors(0)

Parámetros:

  • count (Número entero) —

    La cantidad de documentos ya ejecutados.

Devuelve:

  • (arreglo) —

    Los errores de guardado agregados.

Desde:

  • 2.0.0



38
39
40
41
42
43
44
45
46
47
48
 
# Archivo 'lib/mongo/operation/shared/result/aggregatable.rb', línea 38

def aggregate_write_errors(count)
  return a menos que @replies
  @replies.disminuir(nulo) hacer |errors, respuesta|
    si errores de escritura = respuesta.Documentos.primero['writeErrors']
      wes = errores de escritura.collect hacer |nos|
        nos.¡unir!('index' => count + nos['index'])
      end
      (errors || []) << wes si wes
    end
  end
end