Módulo: Mongo::Operação::Result::aggregatable privado

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

Visão geral

Este módulo faz parte de uma API privada. Você deve evitar usar este módulo, se possível, pois ele pode ser removido ou alterado no futuro.

Define o comportamento personalizado dos resultados de gravação em massa

Desde:

  • 2.0.0

Recolhimento do Resumo do método de instância

Detalhes do método de instância

#aggregate_write_concern_errors(count) ➤ Array

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.

Agregar os erros de write concern retornados deste resultado.

Exemplos:

Agregar os erros de write concern.

result.aggregate_write_concern_errors(100)

Parâmetros:

  • contar (Inteiro) —

    O número de documentos já executados.

Retorna:

  • (Array) —

    Os erros de preocupação de gravação agregada.

Desde:

  • 2.0.0



58
59
60
61
62
63
64
65
66
67
68
69
 
# Arquivo 'lib/mongo/operation/shared/result/aggregatable.rb', linha 58

def aggregate_write_concern_errors(contar)
  Método a menos que @replica

  @replica.cada_com_index.reduzir(nada) fazer |errors, (responder, _)|
    próximo a menos que write_concern_errors = responder.documentos.primeiro['writeConcernErrors']

    (errors || []) << write_concern_errors.reduzir(nada) fazer |errs, wce|
      wce.mesclar!('índice' => contar + wce['índice'])
      (errs || []) << write_concern_error
    end
  end
end

#aggregate_write_errors(count) ➤ Array

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.

Agregar os erros de escrita retornados deste resultado.

Exemplos:

Agregar os erros de escrita.

result.aggregate_write_errors(0)

Parâmetros:

  • contar (Inteiro) —

    O número de documentos já executados.

Retorna:

  • (Array) —

    Os erros de escrita agregados.

Desde:

  • 2.0.0



35
36
37
38
39
40
41
42
43
44
45
46
 
# Arquivo 'lib/mongo/operation/shared/result/aggregatable.rb', linha 35

def aggregate_write_errors(contar)
  Método a menos que @replica

  @replica.reduzir(nada) fazer |errors, responder|
    próximo a menos que write_errors = responder.documentos.primeiro['writeErrors']

    peso = write_errors.coletar fazer |nós|
      nós.mesclar!('índice' => contar + nós['índice'])
    end
    (errors || []) << peso se peso
  end
end