モジュール: Mongo::Operation::Result::Aggregate Private

定義:
lib/mongo/ 操作/shared/result/aggregate.rb

Overview

このモジュールはプライベート API の一部です。 このモジュールは将来削除または変更される可能性があるため、可能な限り使用しないでください。

一括書き込み結果のカスタム動作を定義します

以来

  • 2.0.0

インスタンス メソッドの概要を折りたたむ

インスタンス メソッドの詳細

# aggregate_write_concern_errors (count) =配列

このメソッドは、プライベート API の一部です。 このメソッドは将来削除または変更される可能性があるため、可能な限り使用しないでください。

この結果から返された書込み保証 (write concern) エラーを集計します。

例:

書込み保証 (write concern) エラーを集計します。

result.aggregate_write_concern_errors(100)

パラメーター:

  • count (整数) —

    すでに実行されたドキュメントの数。

次の値を返します。

  • （配列） —

    書込み保証 (write concern) エラーの集計。

以来

  • 2.0.0



58
59
60
61
62
63
64
65
66
67
68
69
 
# ファイル 'lib/mongo/操作/shared/result/aggregate.rb' 行 58

デフォルト aggregate_write_concern_errors(count)
  return ただし、 @reprise

  @reprise.each_with_index.reduce(nil) 行う |errors, (応答, _)|
    次へ ただし、 write_concern_errors = 応答.ドキュメント.最初に[' writeConcernErrors ']

    (errors || []) < write_concern_errors.reduce(nil) 行う |errs, wce|
      wce.mergeします。('index' => count + wce['index'])
      (errs || []) < write_concern_error
    end
  end
end

# aggregate_write_errors (count) =配列

このメソッドは、プライベート API の一部です。 このメソッドは将来削除または変更される可能性があるため、可能な限り使用しないでください。

この結果から返された書込み (write) エラーを集計します。

例:

書込み (write) エラーを集計します。

result.aggregate_write_errors(0)

パラメーター:

  • count (整数) —

    すでに実行されたドキュメントの数。

次の値を返します。

  • （配列） —

    の集計エラー。

以来

  • 2.0.0



35
36
37
38
39
40
41
42
43
44
45
46
 
# ファイル 'lib/mongo/操作/shared/result/aggregate.rb' 行 35

デフォルト aggregate_write_errors(count)
  return ただし、 @reprise

  @reprise.reduce(nil) 行う |errors, 応答|
    次へ ただし、 write_errors = 応答.ドキュメント.最初に[' writeErrors ']

    Wes = write_errors.コレクション 行う |Webhook|
      Webhook.mergeします。('index' => count + Webhook['index'])
    end
    (errors || []) < Wes 場合 Wes
  end
end