クラス: Mongo::Session

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


、lib/mongo/session/セッション_プール.rb、lib/mongo/session/server_session.rb、lib/mongo/session/server_session/dirtyable.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_timeout_ms （整数） —

    セッションで実行される次の操作の timeoutMS 値。

    • commitTransaction

    • abortTransaction

    • withTransaction

    • endSession

  • :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



83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
 
# ファイル 'lib/mongo/session.rb', 行 83

デフォルト 初期化(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
  @with_transaction_readline = nil
end

インスタンス属性の詳細

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

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

次の値を返します。

  • （クライアント） —

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

以来

  • 2.5.1



116
117
118
 
# ファイル 'lib/mongo/session.rb', 行 116

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

# operation_time = BSON::Timestamp (readonly)

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

次の値を返します。

  • （ BSON::Timestamp ） —

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

以来

  • 2.5.0



131
132
133
 
# ファイル 'lib/mongo/session.rb', 行 131

デフォルト operation_time
  @operation_time
end

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

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

次の値を返します。

  • （ハッシュ） —

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

以来

  • 2.5.0



111
112
113
 
# ファイル 'lib/mongo/session.rb', 行 111

デフォルト options
  @options
end

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

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

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

次の値を返します。

  • (Integer | nil) —

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

以来

  • 2.5.0



284
285
286
 
# ファイル 'lib/mongo/session.rb', 行 284

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

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

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

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

次の値を返します。

  • (Server | nil) —

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

以来

  • 2.5.0



278
279
280
 
# ファイル 'lib/mongo/session.rb', 行 278

デフォルト completed_server
  @finned_server
end

#recovery_token ⇒ BSON::Document | nil

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

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

次の値を返します。

  • (BSON::Document | nil) —

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

以来

  • 2.5.0



290
291
292
 
# ファイル 'lib/mongo/session.rb', 行 290

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

# snapshot_timestamp =オブジェクト

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

以来

  • 2.5.0



1192
1193
1194
 
# ファイル 'lib/mongo/session.rb', 行 1192

デフォルト snapshot_timestamp
  @snapshot_timestamp
end

# with_transaction_deedline = オブジェクト（読み取り専用）

以来

  • 2.5.0



1194
1195
1196
 
# ファイル 'lib/mongo/session.rb', 行 1194

デフォルト with_transaction_readline
  @with_transaction_readline
end

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

abort_transaction (options = nil) = オブジェクト

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

例:

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

session.abort_transaction

パラメーター:

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

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

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

  • :timeout_ms （整数） —

    操作のタイムアウト（ミリ秒単位）。 負でない整数である必要があります。 0 の明示的な値は無限を意味します。 デフォルト値が設定されていない場合、値はクライアントから継承されることを意味します。

次の値が発生します。

以来

  • 2.6.0



730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
 
# ファイル 'lib/mongo/session.rb', 行 730

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

  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

  options ||= {}

  begin
    ただし、 start_transaction?
      @aboring_transaction = true
      context = 操作::Context.新着情報(
        クライアント: @client,
        セッション: 自己,
        operation_timeouts: operation_timeouts(options)
      )
      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



819
820
821
 
# ファイル 'lib/mongo/session.rb', 行 819

デフォルト aborting_transaction
  !!@aboring_transaction
end

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

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

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

例:

session.add_autocommit!(cmd)

次の値を返します。

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

    コマンド ドキュメント。

以来

  • 2.6.0



899
900
901
902
903
 
# ファイル 'lib/mongo/session.rb', 行 899

デフォルト 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



914
915
916
917
918
919
920
 
# ファイル 'lib/mongo/session.rb', 行 914

デフォルト 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



931
932
933
934
935
 
# ファイル 'lib/mongo/session.rb', 行 931

デフォルト 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



946
947
948
949
950
951
952
953
954
955
956
957
958
959
960
961
962
963
964
965
966
967
968
969
970
971
972
973
974
975
976
977
978
979
980
981
982
983
984
985
986
987
988
989
990
991
992
993
994
995
996
997
998
999
1000
1001
1002
1003
1004
1005
1006
1007
1008
1009
 
# ファイル 'lib/mongo/session.rb', 行 946

デフォルト add_txn_opts。(コマンド, 読み取り, context)
  コマンド.タップ 行う |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

    # Ignore wtimeout if csot
    場合 context&.csot?
      c[:writeConcern]&.削除(:wtimeout)
    end

    空の（サーバーのデフォルト）書込み保証（書込み保証 (write concern)）は送信されません。
    c.削除(:writeConcern) 場合 c[:writeConcern]&.空の場合
  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



1123
1124
1125
1126
1127
1128
1129
 
# ファイル 'lib/mongo/session.rb', 行 1123

デフォルト 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



118
119
120
 
# ファイル 'lib/mongo/session.rb', 行 118

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

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

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

例:

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

session.commit_transaction

パラメーター:

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

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

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

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

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

  • :timeout_ms （整数） —

    操作のタイムアウト（ミリ秒単位）。 負でない整数である必要があります。 0 の明示的な値は無限を意味します。 デフォルト値が設定されていない場合、値はクライアントから継承されることを意味します。

次の値が発生します。

以来

  • 2.6.0



648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
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
 
# ファイル 'lib/mongo/session.rb', 行 648

デフォルト 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,
        セッション: 自己,
        operation_timeouts: operation_timeouts(options)
      )
      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



811
812
813
 
# ファイル 'lib/mongo/session.rb', 行 811

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

# ダーティ 。 (マーク = true) = オブジェクト

基礎となるサーバーセッションの指定された値にダーティ状態を設定します。 サーバーセッションがない場合、これは何も行いません。

パラメーター:

  • マーク （ true | false ） （デフォルトはtrue ） —

    サーバーセッションをダーティとしてマークするかどうか。

以来

  • 2.5.0



138
139
140
 
# ファイル 'lib/mongo/session.rb', 行 138

デフォルト dirty!(マーク = true)
  @server_session&.dirty!(マーク)
end

# ダーティー= true | false | nil

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

基礎となるサーバーセッションがダーティであるかどうかを返します。 このセッションのサーバーセッションが存在しない場合、 は nil を返します。

次の値を返します。

  • （ true | false | nil ） —

    基礎となるサーバーセッションがダーティであるかどうか。 このセッションのサーバーセッションが存在しない場合、 は nil を返します。

以来

  • 2.5.0



146
147
148
 
# ファイル 'lib/mongo/session.rb', 行 146

デフォルト dirty?
  @server_session&.dirty?
end

#end_session ⇒ nil

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

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

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

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

例:

session.end_session

次の値を返します。

  • (nil) —

    常に nil です。

以来

  • 2.5.0



377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
 
# ファイル 'lib/mongo/session.rb', 行 377

デフォルト 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



243
244
245
 
# ファイル 'lib/mongo/session.rb', 行 243

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

明示的かどうか = true 、 false

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

例:

セッションは明示的か?

session.explicit?

次の値を返します。

  • （ true 、 false ） —

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

以来

  • 2.5.2



178
179
180
 
# ファイル 'lib/mongo/session.rb', 行 178

デフォルト explicit?
  !implicit?
end

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

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

例:

セッションは暗黙的か？

session.implicit?

次の値を返します。

  • （ true 、 false ） —

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

以来

  • 2.5.1



166
167
168
 
# ファイル 'lib/mongo/session.rb', 行 166

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

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

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

例:

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

session.in_transaction?

次の値を返します。

  • （ true | false ） —

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

以来

  • 2.6.0



803
804
805
 
# ファイル 'lib/mongo/session.rb', 行 803

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

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

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

例:

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

session.inspect

次の値を返します。

  • ( string ) —

    セッション検査。

以来

  • 2.5.0



355
356
357
 
# ファイル 'lib/mongo/session.rb', 行 355

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

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

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

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

次の値を返します。

以来

  • 2.5.0



1137
1138
1139
1140
1141
1142
1143
1144
1145
1146
1147
 
# ファイル 'lib/mongo/session.rb', 行 1137

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

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

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

  自己
end

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

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

次の値を返します。

  • （ブール値）

以来

  • 2.5.0



1150
1151
1152
1153
1154
1155
1156
 
# ファイル 'lib/mongo/session.rb', 行 1150

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

  !@server_session.nil?
end

# next_txn_num =整数

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

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

例:

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

session.next_txn_num

次の値を返します。

  • (整数) —

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

以来

  • 2.5.0



1167
1168
1169
1170
1171
1172
1173
 
# ファイル 'lib/mongo/session.rb', 行 1167

デフォルト 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



846
847
848
849
850
851
 
# ファイル 'lib/mongo/session.rb', 行 846

デフォルト 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



828
829
830
831
832
833
834
835
836
837
838
 
# ファイル 'lib/mongo/session.rb', 行 828

デフォルト 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



1095
1096
1097
1098
1099
1100
1101
1102
1103
1104
1105
1106
1107
1108
1109
1110
1111
 
# ファイル 'lib/mongo/session.rb', 行 1095

デフォルト プロセス(結果)
  ただし、 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



198
199
200
 
# ファイル 'lib/mongo/session.rb', 行 198

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

retry_writes? = true 、 false

注：

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

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

例:

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

session.retry_writes?

次の値を返します。

  • （ true 、 false ） —

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

以来

  • 2.5.0



213
214
215
 
# ファイル 'lib/mongo/session.rb', 行 213

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

#session_id ⇒ BSON::Document

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

次の値を返します。

  • （ BSON::Document ） —

    サーバー セッション ID

次の値が発生します。

以来

  • 2.5.0



255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
 
# ファイル 'lib/mongo/session.rb', 行 255

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

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

  @server_session.Session_id
end

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

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

次の値を返します。

  • （ true | false ） —

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

以来

  • 2.5.0



124
125
126
 
# ファイル 'lib/mongo/session.rb', 行 124

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

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

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

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

例:

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

session.start_transaction(options)

パラメーター:

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

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

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

  • :max_commit_time_ms （整数） —

    1 つの commitTransaction コマンドの実行を許可する最大時間（ミリ秒単位）です。 このオプションは非推奨です。代わりに :timeout_ms を使用してください。

  • :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のみです。

  • :timeout_ms （整数） —

    操作のタイムアウト（ミリ秒単位）。 負でない整数である必要があります。 0 の明示的な値は無限を意味します。 デフォルト値が設定されていない場合、値はクライアントから継承されることを意味します。

次の値が発生します。

  • （ Error::InvalidTransactionOperation ） —

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

以来

  • 2.6.0



583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
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
 
# ファイル 'lib/mongo/session.rb', 行 583

デフォルト start_transaction(options = nil)
  checkpoint_transactions_supported.

  場合 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



791
792
793
 
# ファイル 'lib/mongo/session.rb', 行 791

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

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

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

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

例:

session.suppress_read_write_concern!(cmd)

次の値を返します。

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

    コマンド ドキュメント。

以来

  • 2.6.0



1020
1021
1022
1023
1024
1025
1026
1027
 
# ファイル 'lib/mongo/session.rb', 行 1020

デフォルト 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



1183
1184
1185
1186
1187
1188
1189
 
# ファイル 'lib/mongo/session.rb', 行 1183

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

  @server_session.txn_num
end

#txn_options ⇒ Hash

このセッションでは。

次の値を返します。

  • （ハッシュ） —

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

以来

  • 2.6.0



154
155
156
 
# ファイル 'lib/mongo/session.rb', 行 154

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

# txn_read_preference =ハッシュ

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

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

例:

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

session.txn_read_preference

次の値を返します。

  • （ハッシュ） —

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

以来

  • 2.6.0



228
229
230
231
232
233
 
# ファイル 'lib/mongo/session.rb', 行 228

デフォルト 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



859
860
861
862
863
 
# ファイル 'lib/mongo/session.rb', 行 859

デフォルト 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



876
877
878
879
880
881
882
883
884
885
886
887
888
 
# ファイル 'lib/mongo/session.rb', 行 876

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

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

#update_state! ⇒ Object

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

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

以来

  • 2.6.0



1056
1057
1058
1059
1060
1061
1062
1063
 
# ファイル 'lib/mongo/session.rb', 行 1056

デフォルト 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



1078
1079
1080
1081
1082
 
# ファイル 'lib/mongo/session.rb', 行 1078

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

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

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

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

例:

session.validate_read_preference!(command)

次の値が発生します。

以来

  • 2.6.0



1039
1040
1041
1042
1043
1044
1045
1046
1047
1048
1049
1050
 
# ファイル 'lib/mongo/session.rb', 行 1039

デフォルト 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



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
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
 
# ファイル 'lib/mongo/session.rb', 行 448

デフォルト with_transaction(options = nil)
  場合 timeout_ms = (options || {})[:timeout_ms]
    timeout_second = timeout_ms / 1_000.0
    deadline = Utils.MongoDB_time + timeout_second
    @with_transaction_readline = deadline
  elsif default_timeout_ms = @options[:default_timeout_ms]
    timeout_second = default_timeout_ms / 1_000.0
    deadline = Utils.MongoDB_time + timeout_second
    @with_transaction_readline = deadline
  elsif @client.timeout_second
    deadline = Utils.MongoDB_time + @client.timeout_second
    @with_transaction_readline = deadline
  else
    deadline = Utils.MongoDB_time + 120
  end
  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 } によりトランザクションを中止し ます 」)
        @with_transaction_readline = nil
        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
  @with_transaction_readline = nil
end