클래스: Mongo::BulkWrite::ResultCombiner Private

상속:
객체
  • 객체
모두 표시
다음에 정의됨:
lib/ Mongo/bulk_write/result_combiner.rb

개요

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

대량 쓰기 (write) 결과를 함께 결합합니다.

이후:

  • 2.1.0

인스턴스 속성 요약 접기

인스턴스 메서드 요약 접기

생성자 세부 정보

#initialize ⇒ ResultCombiner

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

새 결과 결합기를 만듭니다.

예시:

결과 결합기를 만듭니다.

ResultCombiner.new

이후:

  • 2.1.0



43
44
45
46
47
 
# 파일 'lib/ Mongo/bulk_write/result_combiner.rb', 43줄

def 초기화
  @results = {}
  @count = 0
  @server_addresses = []
end

인스턴스 속성 세부 정보

#count ⇒ 정수 (읽기 전용)

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

count 전체 배치 의 문서 수를 반환합니다.

반환합니다:

  • (정수) —

    count 전체 배치 의 문서 수입니다.

이후:

  • 2.1.0



26
27
28
 
# 파일 'lib/ Mongo/bulk_write/result_combiner.rb', 26줄

def 카운트
  @count
end

#결과 ⇒ 해시 (읽기 전용)

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

결과를 반환합니다. 결과 해시를 반환합니다.

반환합니다:

  • (해시) —

    결과 해시입니다.

이후:

  • 2.1.0



29
30
31
 
# 파일 'lib/ Mongo/bulk_write/result_combiner.rb', 29줄

def 결과
  @results
end

#server_addresses ⇒ 배열<String> (읽기 전용)

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

결합된 작업 결과를 생성한 서버의 "호스팅:포트" 주소의 중복 제거된 목록을 반환합니다.

반환합니다:

  • (Array<String>) —

    결합된 작업 결과를 생성한 서버의 "호스팅하다:port" 주소의 중복 제거된 목록입니다.

이후:

  • 2.1.0



33
34
35
 
# 파일 'lib/ Mongo/bulk_write/result_combiner.rb', 33줄

def server_addresses
  @server_addresses
end

인스턴스 메서드 세부 정보

#결합!(result, count) ⇒ 객체

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

전체 결과에 결과를 추가합니다.

예시:

결과를 추가합니다.

combiner.combine!(result, count)

매개변수:

  • 결과 (Operation::Result) —

    결합할 결과입니다.

  • 카운트 (정수) —

    배치 의 요청 수입니다.

이후:

  • 2.1.0



60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
 
# 파일 'lib/ Mongo/bulk_write/result_combiner.rb', 60줄

def 결합!(결과, 카운트)
  # 서버 는 다양한 필드에서 오류를 전달할 수 있습니다.
  # writeError, writeErrors, writeConcernError, writeConcernErrors.
  # 현재는 writeConcernErrors에 지정된 오류만
  이 동작은 다음에서 다루기 때문에 # 추가되지 않는 카운트
  # 재시도 가능 쓰기 테스트. 다음 중 일부 또는 전부가
  카운트를 결합할 때 # 다른 오류도 제외해야 합니다.
  # ids이며 이러한 오류의 하위 집합만
  # 필드는 대량 쓰기의 맥락에서 실제로 가능합니다.
  하지 않는 한 결과.write_concern_error?
    combine_counts!(결과)
    combine_ids!(결과)
  end
  combine_errors!(결과)
  @count += 카운트
  @acknowledged = 결과.인정?
  시드 = 결과.connection_description&.주소&.시드
  @server_addresses << 시드 만약 시드 && !@server_addresses.포함?(시드)
end

#결과 ⇒ BulkWrite::Result

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

최종 결과를 가져옵니다.

반환합니다:

이후:

  • 2.1.0



87
88
89
 
# 파일 'lib/ Mongo/bulk_write/result_combiner.rb', 87줄

def 결과
  대량 쓰기::결과.신규(결과, @acknowledged, @server_addresses).유효성을 검사합니다!
end