クラス: Mongo::Session

継承:
オブジェクト
  • オブジェクト
すべて表示
次による拡張機能。
転送可能
次のことが含まれます。
ClusterTime ::Consumer 、 ログ可能 、 再試行可能
定義:
build/ruby-Driver-v 2.19 /lib/mongo/session.rb 、
build/ruby-Driver-v 2.19 /lib/mongo/session/session_Pool.rb,
build/ruby-Driver-v 2.19 /lib/mongo/session/server_session.rb

Overview

注：

セッション オブジェクトはスレッドセーフではありません。 アプリケーションは一度に 1 つのスレッドまたはプロセスからのセッションのみを使用できます。

何らかの方法で関連するアプリケーションによって実行される一連の連続操作を表す論理セッション。

以来

  • 2.5.0

名前空間で定義済み

クラス: ServerSession, SessionPool

定数の概要の削減

MISMATCHED_CLUSTER_ERROR_MSG =

現在使用されているクライアントとは異なるクラスターを持つクライアントからセッションが取得されたことを示すエラーメッセージ。

以来

  • 2.5.0

「このセッションを作成するために使用されるクライアントの構成は、次と一致しません」 +
この操作を所有するクライアントの。このセッションは、その親である を介した操作にのみ使用してください。 +
'クライアント。 '.freeze
SESSION_ENDED_ERROR_MSG =

セッションはすでに終了しているため、使用できないことを説明するエラー メッセージ。

以来

  • 2.5.0

'このセッションは終了したため、使用できなくなります。新しい作成してください。 '.freeze
SESSIONS_NOT_SUPportED =
非推奨。

セッションがサーバー バージョンでサポートされていないことを説明するエラー メッセージ。

以来

  • 2.5.0

セッションは接続されたサーバーでサポートされていません 。 '.freeze
NO_TRANSACTION_STATE =

最後の操作がどのトランザクションにも関連していないか、操作がまだ発生していないセッションの状態を指します。

以来

  • 2.6.0

:no_transaction
STARTING_TRANSACTION_STATE =

ユーザーによってトランザクションが開始されたが、トランザクション内の操作はまだ発生していないセッションの状態です。

以来

  • 2.6.0

:starting_transaction
TRANSACTION_IN_PROGESS_STATE =

トランザクションが開始され、少なくとも 1 つの操作が発生しているが、トランザクションがまだコミットまたは中止されていないセッションの状態を指します。

以来

  • 2.6.0

:transaction_in_progress
TRACTION_COMMITED_STATE =

最後に実行された操作がトランザクションでコミットされたセッションの状態を指します。

以来

  • 2.6.0

:transaction_commited
TRANSACTION_aborted_STATE =

最後に操作が実行されたセッションの状態は、トランザクションが中止されました。

以来

  • 2.6.0

:transaction_aborted
UNILED_WRITE_CONCERN_CODES =

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

以来

  • 2.5.0

[
  79,  #UnknownReplWriteConcern
  100, #CancelsifyWriteConcern、
].freeze

Loggableに含まれる定数

ログ可能::PRFIX

インスタンス属性の概要を折りたたむ

ClusterTime::Consumerに含まれる属性

#cluster_time

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

ClusterTime::Consumerに含まれるメソッド

#advanced_cluster_time

Loggableに含まれるメソッド

#log_debug, #log_error, #log_fatal, #log_info, #log_warn, #logger

再試行可能な に含まれるメソッド

#read_worker 、 #select_server 、 #write_worker

コンストラクターの詳細

#初期化（server_session, クライアント, オプション = {}) =セッション

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

注：

アプリケーションは Client#start_session を使用してセッションを開始する必要があります。 このコンストラクターは、ドライバー内部でのみ使用します。

セッションを初期化します。

セッションは明示的または暗黙的に実行できます。 明示的なセッションの有効期間はアプリケーションによって管理されます。アプリケーションはこのようなセッションを明示的に作成し、明示的に終了します。 暗黙的なセッションは、セッション（ 3.6 +）をサポートするサーバーに操作を送信するときにドライバーによって自動的に作成され、その有効期間はドライバーによって管理されます。

暗黙的なセッションが作成される場合、そのセッションに関連付けられたサーバー セッションを持つことはできません。 このセッションを使用する操作が実際に実行されると、サーバー セッションはセッション プールからチェックアウトされます。 明示的なセッションが作成される場合は、すでに割り当てられているサーバー セッションを参照する必要があります。

パラメーター:

  • server_session （ ServerSession | nil ） —

    このセッションが関連付けられているサーバー セッション。 :暗黙的な オプションが true の場合、これは nil である必要があります。

  • クライアント （クライアント） —

    このセッションが作成されるクライアント。

  • options （ハッシュ） （デフォルトは{}です） —

    このセッションのオプション。

オプション ハッシュ（ options ）:

  • :causal_consistency （ true|false ） —

    このセッションで因果整合性を有効にするかどうか。

  • :default_transaction_options （ハッシュ） —

    デフォルトで start_transaction に渡すオプションには、 start_transaction が受け入れるオプションのいずれかを含めることができます。

  • :implicit （ true|false ） —

    内部ドライバーのみで使用します - セッションが暗黙的かどうかを指定します。 これが true の場合、 server_session は nil になります。 これは、接続がチェックアウトされた後にのみサーバー セッションがチェックアウトされるようにするものです。

  • :read_preference （ハッシュ） —

    読み込み設定（read preference）オプションは、次の任意キーを持つ ハッシュとなります。

    • : モード- string またはシンボルとしての読み込み設定（read preference）。有効な値は、 :primary 、 :primary_preferred 、 :secondary 、 :secondary_preferred 、 :nearestです。

  • :snapshot （ true | false ） —

    スナップショット読み取り用にセッションを設定します。

以来

  • 2.5.0



77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は77行

デフォルト 初期化(server_session, クライアント, options = {})
  場合 options[:causal_consistency] & & options[:snapshot]
    発生 ArgumentError, :causal_consistency と :snapshot の 両方 の オプションは、セッションで両方に設定することはできません 。
  end

  場合 options[:implicit]
    ただし、 server_session.nil?
      発生 ArgumentError, 暗黙的 な セッションは構築中にサーバー セッションを参照できません 。
    end
  else
    場合 server_session.nil?
      発生 ArgumentError, '明示的なセッションは構築中にサーバー セッションを参照する必要があります'
    end
  end

  @server_session = server_session
  options = options.dup

  @client = クライアント.使用(:admin)
  @options = options.dup.freeze
  @cluster_time = nil
  @ State = NO_TRANSACTION_STATE
end

インスタンス属性の詳細

#クライアント=クライアント(読み取り専用)

このセッションが作成されたクライアントを返します。

次の値を返します。

  • （クライアント） —

    このセッションが作成されたクライアント。

以来

  • 2.5.1



109
110
111
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は109行

デフォルト クライアント
  @client
end

# operation_time = BSON::Timestamp (readonly)

このセッションの最新のoptimeを返します。

次の値を返します。

  • （ BSON::Timestamp ） —

    このセッションの最新のoptime 。

以来

  • 2.5.0



124
125
126
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は124行

デフォルト operation_time
  @operation_time
end

オプション=ハッシュ（読み取り専用）

このセッションの オプションを返します。

次の値を返します。

  • （ハッシュ） —

    このセッションのオプション。

以来

  • 2.5.0



104
105
106
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は104行

デフォルト options
  @options
end

#ピン留め_接続_グローバル_id =整数 | 整数 | nil （読み取り専用）

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

このセッションが固定されている場合は、接続グローバル ID を返します。

次の値を返します。

  • (Integer | nil) —

    このセッションが固定されている接続グローバル ID（存在する場合）。

以来

  • 2.5.0



260
261
262
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は260行

デフォルト ピン留め_接続_グローバル_id
  @finned_ connection_ global_id
end

#ピン留め_サーバー =サーバー| nil （読み取り専用）

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

このセッションが固定されているサーバー（mongos である必要がある場合）を返します。

次の値を返します。

  • (Server | nil) —

    このセッションが固定されているサーバー（ mongos である必要がある場合）。

以来

  • 2.5.0



254
255
256
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は254行

デフォルト completed_server
  @finned_server
end

#recovery_token ⇒ BSON::Document | nil

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

このセッションで実行されているシャーディングされたトランザクションのリカバリ トークン（存在する場合）を返します。

次の値を返します。

  • (BSON::Document | nil) —

    このセッションで実行されているシャーディングされたトランザクションのリカバリ トークン（存在する場合）。

以来

  • 2.5.0



266
267
268
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は266行

デフォルト リカバリ_トークン
  @recury_token
end

# snapshot_timestamp =オブジェクト

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

以来

  • 2.5.0



1120
1121
1122
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は1120行

デフォルト snapshot_timestamp
  @snapshot_timestamp
end

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

#abort_transaction ⇒ Object

データベースに変更を加えずに、現在アクティブなトランザクションを中止します。

例:

トランザクションを中止します。

session.abort_transaction

次の値が発生します。

以来

  • 2.6.0



672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は672行

デフォルト abort_transaction
  クエリ キャッシュ.クリア

  checkpoint_if_endd.
  checkpoint_if_no_transaction.

  場合 Within(TRACTION_COMMITED_STATE)
    発生 mongo::エラー::InvalidTransactionOperation.新着情報(
      mongo::エラー::InvalidTransactionOperation.canド_back_ after_msg(
        :commitTransaction, :abortTransaction))
  end

  場合 Within(TRANSACTION_ABORTED_STATE)
    発生 mongo::エラー::InvalidTransactionOperation.新着情報(
      mongo::エラー::InvalidTransactionOperation.canド_呼び出し_twice_msg(:abortTransaction))
  end

  begin
    ただし、 start_transaction?
      @aboring_transaction = true
      context = 操作::Context.新着情報(クライアント: @client, セッション: 自己)
      write_with_retry(txn_options[:write_concern],
        termination_transaction: true, context: context,
      ) 行う |接続, txn_num, context|
        begin
          操作::コマンド.新着情報(
            セレクター: { abortTransaction: 1 },
            db_name: ' admin ',
            セッション: 自己,
            txn_num: txn_num
          ).execution_with_ connection(接続, context: context)
        保証する
          unpin
        end
      end
    end

    @ State = TRANSACTION_ABORTED_STATE
  ヘルプ mongo::エラー::InvalidTransactionOperation
    発生
  ヘルプ mongo::エラー
    @ State = TRANSACTION_ABORTED_STATE
  ヘルプ 例外
    @ State = TRANSACTION_ABORTED_STATE
    発生
  保証する
    @aboring_transaction = false
  end

  #正規の戻り値ではありませんが、true を返すため、対話型では
  成功したことを示す メソッドを使用します。
  true
end

中止_トランザクション= true | false

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

セッションが現在トランザクションを中止しているかどうかを返します。

次の値を返します。

  • （ true | false ） —

    セッションが現在トランザクションを中止しているかどうか。

以来

  • 2.5.0



755
756
757
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は755行

デフォルト aborting_transaction
  !!@aboring_transaction
end

#add_ autocommit （コマンド） =ハッシュ、 BSON::Document

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

該当する場合は、コマンド ドキュメントにオートコミット フィールドを追加します。

例:

session.add_autocommit!(cmd)

次の値を返します。

  • （ハッシュ、 BSON ::Document ） —

    コマンド ドキュメント。

以来

  • 2.6.0



835
836
837
838
839
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は835行

デフォルト Add_Autocommit.(コマンド)
  コマンド.タップ 行う |c|
    c[: 自動コミット] = false 場合 in_transaction?
  end
end

Add_start_transaction。 （コマンド） =ハッシュ、 BSON::Document

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

該当する場合は、 コマンド ドキュメントに startTransaction フィールドを追加します。

例:

session.add_start_transaction!(cmd)

次の値を返します。

  • （ハッシュ、 BSON ::Document ） —

    コマンド ドキュメント。

以来

  • 2.6.0



850
851
852
853
854
855
856
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は850行

デフォルト add_start_transaction.(コマンド)
  コマンド.タップ 行う |c|
    場合 start_transaction?
      c[:startTransaction] = true
    end
  end
end

#add_txn_num （コマンド） =ハッシュ、 BSON::Document

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

該当する場合は、コマンド ドキュメントにトランザクション番号を追加します。

例:

session.add_txn_num!(cmd)

次の値を返します。

  • （ハッシュ、 BSON ::Document ） —

    コマンド ドキュメント。

以来

  • 2.6.0



867
868
869
870
871
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は867行

デフォルト add_txn_num!(コマンド)
  コマンド.タップ 行う |c|
    c[:txnNumber] = BSON::Int64.新着情報(@server_session.txn_num) 場合 in_transaction?
  end
end

# add_txn_opts を使用します。 （コマンド、読み取り）=ハッシュ、 BSON::Document

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

該当する場合は、トランザクション オプションを追加します。

例:

session.add_txn_opts!(cmd)

次の値を返します。

  • （ハッシュ、 BSON ::Document ） —

    コマンド ドキュメント。

以来

  • 2.6.0



882
883
884
885
886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
919
920
921
922
923
924
925
926
927
928
929
930
931
932
933
934
935
936
937
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は882行

デフォルト add_txn_opts。(コマンド, 読み取り)
  コマンド.タップ 行う |c|
    # 読み取り保証は、トランザクションを開始する任意のコマンドに追加する必要があります。
    場合 start_transaction?
      # https://JIRA.mongodb.org/browse/Spec-{0 1161 : トランザクションの
      読み取り保証 (read concern) がコレクション/データベース/クライアントの読み取り保証 (read concern) を上書きする
      トランザクションの読み取り保証（read concern）が設定されていない場合でも。
      # 読み取り保証 (read concern) はサーバーに送信されたものであり、
      # afterClusterTime を含みます。
      場合 rc = c[:readConcern]
        rc = rc.dup
        rc.削除(: レベル)
      end
      場合 txn_read_concern
        場合 rc
          rc.update(txn_read_concern)
        else
          rc = txn_read_concern.dup
        end
      end
      場合 rc.nil? || rc.空の場合
        c.削除(:readConcern)
      else
        c[:readConcern ] = オプション::マッパー.transform_values_to_strings(rc)
      end
    end

    # 読み取り保証レベルは、シンボルではなく string として送信する必要があります。
    場合 c[:readConcern]
      c[:readConcern] = オプション::マッパー.transform_values_to_strings(c[:readConcern])
    end

    場合 c[:commitTransaction]
      場合 max_time_ms = txn_options[:max_commit_time_ms]
        c[:maxTimeMS] = max_time_ms
      end
    end

    書込み保証 (write concern) は、任意の abortTransaction コマンドまたは commitTransaction コマンドに追加する必要があります。
    場合 (c[:abortTransaction] || c[:commitTransaction])
      場合 @already_commited
        wc = BSON::ドキュメント.新着情報(c[:writeConcern] || txn_write_concern || {})
        wc.mergeします。(w: :majority)
        wc[:wtimeout] ||= 10000
        c[:writeConcern] = wc
      elsif txn_write_concern
        c[:writeConcern] ||= txn_write_concern
      end
    end

    非数値の書込み保証 (write concern) w 値は、記号ではなく string として送信する必要があります。
    場合 c[:writeConcern] & & c[:writeConcern][:w] & & c[:writeConcern][:w].is_a?(シンボル)
      c[:writeConcern][:w] = c[:writeConcern][:w].to_s
    end
  end
end

# advanced_operation_time ( new_operation_time ) = BSON::Timestamp

このセッションのキャッシュされたoptimeを進める。

例:

optimeを進める。

session.advance_operation_time(timestamp)

パラメーター:

  • new_operation_time （ BSON::Timestamp ） —

    新しいoptime 。

次の値を返します。

  • （ BSON::Timestamp ） —

    現在の時間と新しい時間を考慮した最大optime 。

以来

  • 2.5.0



1051
1052
1053
1054
1055
1056
1057
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は1051行

デフォルト advanced_operation_time(new_operation_time)
  場合 @operation_time
    @operation_time = [ @operation_time, new_operation_time ].最大
  else
    @operation_time = new_operation_time
  end
end

#cluster ⇒ Object

以来

  • 2.5.0



111
112
113
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は111行

デフォルト クラスター
  @client.クラスター
end

# commit_transaction (options = nil) =オブジェクト

セッションで現在アクティブなトランザクションをコミットします。

例:

トランザクションをコミットします。

session.commit_transaction

パラメーター:

  • options （ハッシュ） （デフォルトはnil ） —

    カスタマイズ可能なオプションのセット

オプション ハッシュ（ options ）:

  • :write_concern （ nil | WriteConcern ::Base ） —

    この操作に使用する書込み保証 (write concern) です。

次の値が発生します。

以来

  • 2.6.0



599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は599行

デフォルト commit_transaction(options=nil)
  クエリ キャッシュ.クリア
  checkpoint_if_endd.
  checkpoint_if_no_transaction.

  場合 Within(TRANSACTION_ABORTED_STATE)
    発生 mongo::エラー::InvalidTransactionOperation.新着情報(
      mongo::エラー::InvalidTransactionOperation.canド_back_ after_msg(
        :abortTransaction, :commitTransaction))
  end

  options ||= {}

  begin
    # commitTransaction が 2 回呼び出される場合は、同じコミットを実行する必要があります
    # 操作が再度実行されるため、セッションは以前の状態に戻ります。
    場合 Within(TRACTION_COMMITED_STATE)
      @ State = @last_commit_skip ? STARTING_TRANSACTION_STATE : TRANSACTION_IN_PROGESS_STATE
      @already_commited = true
    end

    場合 start_transaction?
      @last_commit_skip = true
    else
      @last_commit_skip = false
      @commiting_transaction = true

      write_concern = options[:write_concern] || txn_options[:write_concern]
      場合 write_concern & & !write_concern.is_a?(WriteConcern::Base)
        write_concern = WriteConcern.得る(write_concern)
      end

      context = 操作::Context.新着情報(クライアント: @client, セッション: 自己)
      write_with_retry(write_concern, termination_transaction: true,
        context: context,
      ) 行う |接続, txn_num, context|
        場合 context.再試行しますか？
          場合 write_concern
            wco = write_concern.options.merge(w: :majority)
            wco[:wtimeout] ||= 10000
            write_concern = WriteConcern.得る(wco)
          else
            write_concern = WriteConcern.得る(w: :majority, wtimeout: 10000)
          end
        end
        スペック = {
          セレクター: { commitTransaction: 1 },
          db_name: ' admin ',
          セッション: 自己,
          txn_num: txn_num,
          write_concern: write_concern,
        }
        操作::コマンド.新着情報(スペック).execution_with_ connection(接続, context: context)
      end
    end
  保証する
    @ State = TRACTION_COMMITED_STATE
    @commiting_transaction = false
  end

  #正規の戻り値ではありませんが、true を返すため、対話型では
  成功したことを示す メソッドを使用します。
  true
end

commit_transaction は次のとおりです。 = true | false

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

セッションが現在トランザクションをコミットしているかどうかを返します。

次の値を返します。

  • （ true | false ） —

    セッションが現在トランザクションをコミットしているかどうか。

以来

  • 2.5.0



747
748
749
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は747行

デフォルト commit_transaction?
  !!@commiting_transaction
end

#end_session ⇒ nil

このセッションを終了します。

このセッションで進行中のトランザクションがある場合、そのトランザクションは中止されます。 このセッションに関連付けられたサーバー セッションは、サーバー セッション プールに返されます。 最後に、このセッションは終了としてマークされ、使用できなくなります。

このセッションがすでに終了している場合、このメソッドは何も行いません。

このメソッドでは、名前から提案される内容とは異なり、このサーバーに endSessions コマンドを直接発行しないことに注意してください。

例:

session.end_session

次の値を返します。

  • (nil) —

    常に nil です。

以来

  • 2.5.0



353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は353行

デフォルト end_session
  場合 !終了しました & & @client
    場合 Within(TRANSACTION_IN_PROGESS_STATE)
      begin
        abort_transaction
      ヘルプ mongo::エラー, エラー::AuthError
      end
    end
    場合 @server_session
      @client.クラスター.session_pool.checkin(@server_session)
    end
  end
保証する
  @server_session = nil
  @end = true
end

#は終了しましたか？ = true 、 false

このセッションが終了したかどうか。

例:

session.ended?

次の値を返します。

  • （ true 、 false ） —

    セッションが終了したかどうか。

以来

  • 2.5.0



219
220
221
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は219行

デフォルト 終了しました
  !!@end
end

明示的かどうか = true 、 false

このセッションは明示的なもの（つまり ユーザーが作成した）。

例:

セッションは明示的か?

session.explicit?

次の値を返します。

  • （ true 、 false ） —

    このセッションが明示的であるかどうか。

以来

  • 2.5.2



154
155
156
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は154行

デフォルト explicit?
  !implicit?
end

暗黙的な ではありませんか。 = true 、 false

このセッションは暗黙的なセッション（ユーザーが作成したものではない）。

例:

セッションは暗黙的か？

session.implicit?

次の値を返します。

  • （ true 、 false ） —

    このセッションが暗黙的かどうか。

以来

  • 2.5.1



142
143
144
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は142行

デフォルト implicit?
  @implicit ||= !!(@options.key?(:implicit) & & @options[:implicit] == true)
end

in_transaction は をサポートしていますか。 = true | false

セッションが現在トランザクション内であるかどうか。

例:

セッションはトランザクション内かどうか

session.in_transaction?

次の値を返します。

  • （ true | false ） —

    セッションがトランザクションに含まれているかどうか。

以来

  • 2.6.0



739
740
741
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は739行

デフォルト in_transaction?
  Within(STARTING_TRANSACTION_STATE, TRANSACTION_IN_PROGESS_STATE)
end

詳しくは、 を 検査しstring ます

検査で使用するための書式設定された string を取得します。

例:

セッション オブジェクトを調べます。

session.inspect

次の値を返します。

  • ( string ) —

    セッション検査。

以来

  • 2.5.0



331
332
333
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は331行

デフォルト 検査する
  " #< Mongo::Session: 0 x #{ object_id } session_id= #{ session_id } options= #{ @options } > "
end

Atlas の サンプル データ セット からの映画 データを含むコレクションを使用します 。

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

まだ設定されていない場合は、セッション プールからセッションをチェックアウトして、セッション オブジェクトの server_session を入力します。

次の値を返します。

以来

  • 2.5.0



1065
1066
1067
1068
1069
1070
1071
1072
1073
1074
1075
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は1065行

デフォルト マテリアライズドの場合
  場合 終了しました
    発生 エラー::SessionEned
  end

  return ただし、 implicit? & & !@server_session

  @server_session = クラスター.session_pool.チェックアウト

  自己
end

#マテリアライズド? =ブール値

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

次の値を返します。

  • （ブール値）

以来

  • 2.5.0



1078
1079
1080
1081
1082
1083
1084
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は1078行

デフォルト マテリアライズド？
  場合 終了しました
    発生 エラー::SessionEned
  end

  !@server_session.nil?
end

# next_txn_num =整数

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

インクリメントして次のトランザクション番号を返します。

例:

次のトランザクション番号を取得します。

session.next_txn_num

次の値を返します。

  • (整数) —

    次のトランザクション番号。

以来

  • 2.5.0



1095
1096
1097
1098
1099
1100
1101
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は1095行

デフォルト next_txn_num
  場合 終了しました
    発生 エラー::SessionEned
  end

  @server_session.next_txn_num
end

#ping_to_ connection ( connection_ global_id) = Object

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

このセッションを指定された接続に固定します。

このセッションは になります。

パラメーター:

  • connection_ global_id (整数) —

    固定する接続のグローバル ID

以来

  • 2.5.0



782
783
784
785
786
787
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は782行

デフォルト point_to_ connection(connection_ global_id)
  場合 connection_ global_id.nil?
    発生 ArgumentError, ' nil 接続 ID にピン留めできません'
  end
  @finned_ connection_ global_id = connection_ global_id
end

#ping_to_server (サーバー) = Object

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

は、このセッションを指定されたサーバー（ mongos である必要がある）に固定します。

パラメーター:

  • サーバー （サーバー） —

    このセッションを固定するサーバー。

以来

  • 2.5.0



764
765
766
767
768
769
770
771
772
773
774
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は764行

デフォルト point_to_server(サーバー)
  場合 サーバー.nil?
    発生 ArgumentError, ' nil サーバーにピン留めできません'
  end
  場合 Lint.有効か
    ただし、 サーバー.mongos?
      発生 エラー::LintError, 「 セッションを mongos ではない サーバー #{ server . Summary } に固定しようとしました 。
    end
  end
  @finned_server = サーバー
end

プロセス(結果) = プロセス::結果

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

このセッションを使用したサーバーからの応答を処理します。

例:

サーバーからの応答を処理します。

session.process(result)

パラメーター:

次の値を返します。

以来

  • 2.5.0



1023
1024
1025
1026
1027
1028
1029
1030
1031
1032
1033
1034
1035
1036
1037
1038
1039
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は1023行

デフォルト プロセス(結果)
  ただし、 implicit?
    set_operation_time(結果)
    場合 cluster_time_doc = 結果.cluster_time
      advanced_cluster_time(cluster_time_doc)
    end
  end
  @server_session.set_last_use!

  場合 doc = 結果.応答 & & 結果.応答.ドキュメント.最初に
    場合 doc[:recoveryToken]
      自己.リカバリ_トークン = doc[:recoveryToken]
    end
  end

  結果
end

再試行_読み取りの回数 =ブール値

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

このセッションで実行された読み取りを、最新の 再試行可能な読み取りの仕様 に従って再試行できるかどうか。

このメソッドが true を返す場合、最新の再試行可能な読み取りはアプリケーションによってリクエストされています。 読み取り操作に選択されたサーバーが最新の再試行可能な読み取りをサポートしている場合は、その特定の操作にそれらが使用されます。 読み取り操作に選択されたサーバーが最新の再試行可能な読み取りをサポートしていない場合、読み取りは再試行されません。

このメソッドが false を返す場合、アプリケーションによってレガシーの再試行可能な読み取りがリクエストされています。 クライアントが接続しているサーバーのサーバー バージョンに関係なく、レガシーの再試行可能な読み取りロジックが使用されます。 読み取り再試行の回数は、 :max_read_retry クライアント オプションによって指定されます。このオプションはデフォルトで1であり、レガシー読み取り再試行を無効にするには0に設定できます。

次の値を返します。

  • （ブール値）

以来

  • 2.5.0



174
175
176
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は174行

デフォルト retry_reads?
  クライアント.options[:retry_reads] != false
end

retry_writes? = true 、 false

注：

再試行可能な書込みは、サーバー バージョンが3.6以上で、かつシャーディングされたクラスター、レプリカセット、または負荷分散されたトポロジーを持つ場合にのみ使用できます。

このセッションで実行された書き込みが再試行されます。

例:

書き込みが再試行されます。

session.retry_writes?

次の値を返します。

  • （ true 、 false ） —

    書込みが再試行される場合。

以来

  • 2.5.0



189
190
191
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は189行

デフォルト retry_writes?
  !!クライアント.options[:retry_writes] & & (クラスター.replica_set? || クラスター.シャーディングされたかどうか || クラスター.load_Balanced?)
end

#session_id ⇒ BSON::Document

セッションが終了されていない場合は、このセッションのサーバー セッション ID を取得します。 セッションが終了した場合、 は Error::SessionEned を発生させます。

次の値を返します。

  • （ BSON::Document ） —

    サーバー セッション ID

次の値が発生します。

以来

  • 2.5.0



231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は231行

デフォルト Session_id
  場合 終了しました
    発生 エラー::SessionEned
  end

  #明示的なセッションには常にsession_idが付与されます。これは実行中であるためです。
  サーバー セッションの構築を提供する必要があります。 暗黙的なセッション
  は具体化されるまでセッション_idを持たないため、 は
  #session_id は失敗する可能性があります。 アプリケーションに機会があってはなりません
  暗黙的なセッションは次ではないとして、この失敗が発生します:
  アプリケーションがアクセスできるのは、アプリケーションの有効期間が次のように制限されているためです。
  これはドライバーによって完全に実行されます。
  ただし、 マテリアライズド？
    発生 エラー::SessionNot マテリアライズド
  end

  @server_session.Session_id
end

#スナップショット = true | false

セッションがスナップショット読み取り用に構成されているかどうかを返します。

次の値を返します。

  • （ true | false ） —

    セッションがスナップショット読み取り用に構成されているかどうか。

以来

  • 2.5.0



117
118
119
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は117行

デフォルト スナップショット
  !!options[:snapshot]
end

# start_transaction (options = nil) =オブジェクト

このセッションの後続の操作を新しいトランザクションに配置します。

start_transaction が呼び出された後に操作が実行されるまで、サーバー上でトランザクションは開始されないことに注意してください。

例:

新しいトランザクションを開始する

session.start_transaction(options)

パラメーター:

  • options （ハッシュ） （デフォルトはnil ） —

    開始されるトランザクションのオプション。

オプション ハッシュ（ options ）:

  • :max_commit_time_ms （整数） —

    1 つの commitTransaction コマンドの実行を許可する最大時間（ミリ秒単位）です。

  • :read_concern （ハッシュ） —

    読み取り保証 (read concern) オプション ハッシュと、次の任意キーが含まれます。

    • : レベル- シンボルとしての読み込み設定（read preference）レベル。有効な値

      are *:local*, *:majority*, and *:snapshot*
  • :write_concern （ハッシュ） —

    書込み保証（write concern） オプション。 :w => Integer|String、 :fsync => ブール値、 :j => ブール値 にすることができます。

  • :read （ハッシュ） —

    読み込み設定（read preference）オプション。 ハッシュには以下の項目が含まれる場合があります。

    • : モード- シンボルとして指定された読み込み設定（read preference）。有効な値は:primaryのみです。

次の値が発生します。

  • （ Error::InvalidTransactionOperation ） —

    トランザクションがすでに進行中である場合、または書込み保証 (write concern)が未確認の場合。

以来

  • 2.6.0



540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は540行

デフォルト start_transaction(options = nil)
  場合 options
    Lint.validate_read_concern_option(options[:read_concern])

=begin
    # ここで無効な読み込み設定（read preference）を検出すると便利ですが、
    一部の仕様テストでは、無効な読み込み設定（read preference）を後で検出する必要があります。
    # int モードがオンの場合にこれを実行できる可能性があります。
    モード =[:read] &=option[:read][:mode].to_s
    モードとモードが .= 'プライマリ' 場合
      Mongo::Error::InvalidTransactionOperation.new(
        "トランザクション内の読み込み設定 (read preference) はプライマリである必要があります（リクエスト: #{モード}）"
      )
    end
=end
  end

  場合 スナップショット
    発生 mongo::エラー::SnapshotSessionTransactionProvided
  end

  checkpoint_if_endd.

  場合 Within(STARTING_TRANSACTION_STATE, TRANSACTION_IN_PROGESS_STATE)
    発生 mongo::エラー::InvalidTransactionOperation.新着情報(
      mongo::エラー::InvalidTransactionOperation::TRANSACTION_ALREADI_IN_PROGESS)
  end

  unpin

  next_txn_num
  @txn_options = (@options[:default_transaction_options] || {}).merge(options || {})

  場合 txn_write_concern & & !WriteConcern.得る(txn_write_concern).確認済み?
    発生 mongo::エラー::InvalidTransactionOperation.新着情報(
      mongo::エラー::InvalidTransactionOperation::Unacknowledged_WRITE_CONCERN)
  end

  @ State = STARTING_TRANSACTION_STATE
  @already_commited = false

  # このメソッドには明示的な戻り値はありません。
  #ここで nil を返すことができますが、true はユーザーに
  # 操作が成功しました。 これは対話型の使用を目的としています。
  戻り値は文書化されていないことに注意してください。
  true
end

開始_トランザクション=ブール値

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

次の値を返します。

  • （ブール値）

以来

  • 2.5.0



727
728
729
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は727行

デフォルト start_transaction?
  Within(STARTING_TRANSACTION_STATE)
end

次を使用して、_read_write_concernを使用します。 （コマンド） =ハッシュ、 BSON::Document

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

該当しない場合は、コマンドから読み取り保証や書込み保証を削除します。

例:

session.suppress_read_write_concern!(cmd)

次の値を返します。

  • （ハッシュ、 BSON ::Document ） —

    コマンド ドキュメント。

以来

  • 2.6.0



948
949
950
951
952
953
954
955
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は948行

デフォルト sink_read_write_concern を使用します。(コマンド)
  コマンド.タップ 行う |c|
    次へ ただし、 in_transaction?

    c.削除(:readConcern) ただし、 start_transaction?
    c.削除(:writeConcern) ただし、 c[:commitTransaction] || c[:abortTransaction]
  end
end

#txn_num ⇒ Integer

現在のトランザクション番号を取得します。

例:

現在のトランザクション番号を取得します。

session.txn_num

次の値を返します。

  • (整数) —

    現在のトランザクション番号。

以来

  • 2.6.0



1111
1112
1113
1114
1115
1116
1117
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は1111行

デフォルト txn_num
  場合 終了しました
    発生 エラー::SessionEned
  end

  @server_session.txn_num
end

#txn_options ⇒ Hash

このセッションでは。

次の値を返します。

  • （ハッシュ） —

    現在実行中のトランザクションのオプション

以来

  • 2.6.0



130
131
132
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は130行

デフォルト txn_options
  @txn_options or 発生 ArgumentError, "アクティブなトランザクションがありません"
end

# txn_read_preference =ハッシュ

現在アクティブなトランザクションでセッションが使用する読み込み設定 (read preference) を取得します。

これはアンダースコア キーを持つドライバー スタイルのハッシュです。

例:

トランザクションの読み込み設定 (read preference) を取得する

session.txn_read_preference

次の値を返します。

  • （ハッシュ） —

    トランザクションの読み込み設定（read preference）。

以来

  • 2.6.0



204
205
206
207
208
209
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は204行

デフォルト txn_read_preference
  rp = txn_options[:read] ||
    @client.read_preference
  mongo::Lint.validate_userscore_read_preference(rp)
  rp
end

#解除（接続 = nil） =オブジェクト

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

セッションが固定されている場合は、固定されたサーバーまたは接続からこのセッションの固定を解除します。

パラメーター:

  • 接続 （接続 | nil ） （デフォルトはnil ） —

    接続の固定を解除します。

以来

  • 2.5.0



795
796
797
798
799
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は795行

デフォルト unpin(接続 = nil)
  @finned_server = nil
  @finned_ connection_ global_id = nil
  接続.unpin ただし、 接続.nil?
end

#unping_maybe (error, connection = nil) = nil) =オブジェクト

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

セッションが固定され、指定された例外インスタンスとセッションのトランザクション状態で固定を解除する必要がある場合は、このセッションを固定されたサーバーまたは接続から固定を解除します。

例外インスタンスには、すでにすべてのラベルが設定されている必要があります（クライアントとサーバー側で生成されたラベルの両方）。

パラメーター:

  • エラー （エラー） —

    処理する例外インスタンス。

  • 接続 （接続 | nil ） （デフォルトはnil ） —

    接続の固定を解除します。

以来

  • 2.5.0



812
813
814
815
816
817
818
819
820
821
822
823
824
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は812行

デフォルト unping_maybe(エラー, 接続 = nil)
  場合 !Within(セッション::NO_TRANSACTION_STATE) & &
    エラー.ラベル('TransientTransactionError')
  次に
    unpin(接続)
  end

  場合 commit_transaction? & &
    エラー.ラベル(「 UnknownTransactionCommitResult 」)
  次に
    unpin(接続)
  end
end

#update_state! ⇒ Object

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

（コミット以外と中止以外の）操作が実行されているため、セッションの状態を更新します。

以来

  • 2.6.0



984
985
986
987
988
989
990
991
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は984行

デフォルト update_state!
  ケース @ State
  次の場合: STARTING_TRANSACTION_STATE
    @ State = TRANSACTION_IN_PROGESS_STATE
  次の場合: TRACTION_COMMITED_STATE, TRANSACTION_ABORTED_STATE
    @ State = NO_TRANSACTION_STATE
  end
end

#validate!(client) ⇒ Session

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

指定されたクライアントが使用するセッションを検証します。

セッションは終了してはならず、セッションが使用されるクライアントと同じクラスターを持つクライアントによって作成された必要があります。

パラメーター:

  • クライアント （クライアント） —

    セッションが使用されるクライアント。

次の値を返します。

次の値が発生します。

以来

  • 2.5.0



1006
1007
1008
1009
1010
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は1006行

デフォルト validate!(クライアント)
  checkpoint_matching_cluster.(クライアント)
  checkpoint_if_endd.
  自己
end

# validate_read_preference (コマンド) =オブジェクト

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

コマンド プライマリ の 読み込み設定（read preference） を確認します。

例:

session.validate_read_preference!(command)

次の値が発生します。

以来

  • 2.6.0



967
968
969
970
971
972
973
974
975
976
977
978
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は967行

デフォルト validate_read_preference!(コマンド)
  return ただし、 in_transaction?
  return ただし、 コマンド[' $readPreference ']

  モード = コマンド[' $readPreference ']['mode'] || コマンド[' $readPreference '][: モード]

  場合 モード & & モード != 'プライマリ'
    発生 mongo::エラー::InvalidTransactionOperation.新着情報(
      "トランザクション内の読み込み設定 (read preference) はプライマリである必要があります（リクエスト: #{モード} ） ]
    )
  end
end

# with_transaction （オプション = nil） =オブジェクト

注：

with_transaction にはループが含まれているため、with_transaction 自体がループに配置されている場合、そのブロックは外側のループを制御するために次の または ブレークを呼び出してはなりません。これは代わりに with_transaction のループに影響するためです。 ドライバーは、この状況を検出すると、トランザクションを警告して中止します。

トランザクションで指定されたブロックを実行し、必要に応じて再試行します。

ブロックの戻り値を返します。

再試行の正確な回数と実行されるタイミングは、ドライバーの詳細な実装です。提供されたブロックは冪等である必要があり、複数回呼び出されるように準備されている必要があります。 ドライバーは、発生したエラーに応じて、アクティブなトランザクション内でコミット コマンドを再試行するか、トランザクションを繰り返してブロックを再度呼び出す場合があります。 また、再試行は異なるサーバーに対して実行される可能性があることにも注意してください。

トランザクションはネストできません。セッションにすでにアクティブなトランザクションがあるときにこのメソッドが呼び出されると、 InvalidTransactionOperation が発生します。

Mongo::Error から派生していない例外は、処理を停止し、トランザクションを中止し、with_transaction から伝播されます。 Mongo::Error から派生した例外は with_transaction によって処理され、 プロセスが再試行される可能性があります。

現在、with_transaction は、with_transaction の実行を開始してから少なくとも120秒が経過するまで、コミットを再試行し、呼び出しをブロックします。 このタイムアウトは設定できず、将来のドライバー バージョンで変更される可能性があります。

例:

トランザクション内でのステートメントの実行

session.with_transaction(write_concern: {w: :majority}) do
  collection.update_one({ id: 3 }, { '$set' => { status: 'Inactive'} },
                        session: session)

end

トランザクション内でステートメントを実行し、消費される合計時間を制限します

Timeout.timeout(5) do
  session.with_transaction(write_concern: {w: :majority}) do
    collection.update_one({ id: 3 }, { '$set' => { status: 'Inactive'} },
                          session: session)

  end
end

パラメーター:

  • options （ハッシュ） （デフォルトはnil ） —

    開始されるトランザクションのオプション。 これらは、 start_transaction が受け入れるオプションと同じオプションです。

次の値が発生します。

  • （ Error::InvalidTransactionOperation ） —

    トランザクションがすでに進行中である場合、または書込み保証 (write concern)が未確認の場合。

以来

  • 2.7.0



424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
 
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/session.rb' の場合は424行

デフォルト with_transaction(options=nil)
  # 操作全体で構成されていない120秒のタイムアウト
  deadline = Utils.MongoDB_time + 120
  transaction_in_progress = false
  ループ 行う
    commit_options = {}
    場合 options
      commit_options[:write_concern] = options[:write_concern]
    end
    start_transaction(options)
    transaction_in_progress = true
    begin
      rv = ノードの数 自己
    ヘルプ 例外 => e
      場合 Within(STARTING_TRANSACTION_STATE, TRANSACTION_IN_PROGESS_STATE)
        log_警告(「 $ { e . クラス } : #{ e } によりトランザクションを中止し ます 」)
        abort_transaction
        transaction_in_progress = false
      end

      場合 Utils.MongoDB_time >= deadline
        transaction_in_progress = false
        発生
      end

      場合 e.is_a?(mongo::エラー) & & e.ラベル('TransientTransactionError')
        次へ
      end

      発生
    else
      場合 Within(TRANSACTION_ABORTED_STATE, NO_TRANSACTION_STATE, TRACTION_COMMITED_STATE)
        transaction_in_progress = false
        return rv
      end

      begin
        commit_transaction(commit_options)
        transaction_in_progress = false
        return rv
      ヘルプ mongo::エラー => e
        場合 e.ラベル(「 UnknownTransactionCommitResult 」)
          場合 Utils.MongoDB_time >= deadline ||
            e.is_a?(エラー::OperationFailure) & & e.max_time_ms_expired?
          次に
            transaction_in_progress = false
            発生
          end
          wc_options = ケース v = commit_options[:write_concern]
            次の場合: WriteConcern::Base
              v.options
            次の場合: nil
              {}
            else
              v
            end
          commit_options[:write_concern] = wc_options.merge(w: :majority)
          RETRY
        elsif e.ラベル('TransientTransactionError')
          場合 Utils.MongoDB_time >= deadline
            transaction_in_progress = false
            発生
          end
          @ State = NO_TRANSACTION_STATE
          次へ
        else
          transaction_in_progress = false
          発生
        end
      ヘルプ エラー::AuthError
        transaction_in_progress = false
        発生
      end
    end
  end

  #正規の戻り値ではありませんが、true を返すため、対話型では
  成功したことを示す メソッドを使用します。
  true
保証する
  場合 transaction_in_progress
    log_警告(' with_transaction コールバックで with_transaction ループが発生し、トランザクションが中止されました')
    begin
      abort_transaction
    ヘルプ エラー::OperationFailure, エラー::InvalidTransactionOperation
    end
  end
end