모듈: Mongo::Operation::Result::Aggregatable Private

다음에 정의됨:
build/ruby-driver-v2.19/lib/mongo/operation/shared/result/aggregatable.rb

개요

이 모듈은 비공개 API의 일부입니다. 이 모듈은 향후 제거되거나 변경될 수 있으므로 가능하면 사용하지 않는 것이 좋습니다.

대량 쓰기 결과의 사용자 지정 동작을 정의합니다.

이후:

  • 2.0.0

인스턴스 메서드 요약 접기

인스턴스 메서드 세부 정보

#aggregate_write_concern_errors(count) ⇒ 배열

이 메서드는 비공개 API의 일부입니다. 이 방법은 향후 제거되거나 변경될 수 있으므로 가능하면 사용하지 않는 것이 좋습니다.

이 결과에서 반환된 쓰기 고려 오류를 집계합니다.

예시:

쓰기 고려 오류를 집계합니다.

result.aggregate_write_concern_errors(100)

매개변수:

  • 카운트 (정수) —

    이미 실행된 문서 수입니다.

반환합니다:

  • (배열) —

    집계 쓰기 고려 (write concern) 오류입니다.

이후:

  • 2.0.0



60
61
62
63
64
65
66
67
68
69
70
 
# 파일 'build/ruby-driver-v2.19/lib/mongo/operation/shared/result/aggregatable.rb', 줄 60

def aggregate_write_concern_errors(카운트)
  반환 하지 않는 한 @replies
  @replies.each_with_index.reduce(nil) do |errors, (회신, _)|
    만약 write_concern_errors = 회신.문서.first['writeConcernErrors']
      (errors || []) << write_concern_errors.reduce(nil) do |errs, wce|
        wce.병합!('인덱스' => 카운트 + wce['인덱스'])
        (errs || []) << write_concern_error
      end
    end
  end
end

#aggregate_write_errors(count) ⇒ 배열

이 메서드는 비공개 API의 일부입니다. 이 방법은 향후 제거되거나 변경될 수 있으므로 가능하면 사용하지 않는 것이 좋습니다.

이 결과에서 반환된 쓰기 오류를 집계합니다.

예시:

쓰기 (write) 오류를 집계합니다.

result.aggregate_write_errors(0)

매개변수:

  • 카운트 (정수) —

    이미 실행된 문서 수입니다.

반환합니다:

  • (배열) —

    집계 쓰기 (write) 오류입니다.

이후:

  • 2.0.0



38
39
40
41
42
43
44
45
46
47
48
 
# 파일 'build/ruby-driver-v2.19/lib/mongo/operation/shared/result/aggregatable.rb', 줄 38

def aggregate_write_errors(카운트)
  반환 하지 않는 한 @replies
  @replies.reduce(nil) do |errors, 회신|
    만약 write_errors = 회신.문서.first['writeErrors']
      웨스 = write_errors.수집 do |우리|
        우리.병합!('인덱스' => 카운트 + 우리['인덱스'])
      end
      (errors || []) << 웨스 만약 웨스
    end
  end
end