txn code examples

Author: rustagir

source/connection/specify-connection-options/csot.txt

@@ -164,7 +164,7 @@ You can specify a ``timeoutMS`` option at a lower level to override the
 client-level configuration. This allows you to customize timeouts based
 on the needs of individual operations.
 
-The following example demonstrates how an collection-level timeout
+The following example demonstrates how a collection-level timeout
 configuration can override a client-level timeout configuration:
 
 .. literalinclude:: /includes/connect/CSOT.java
@@ -191,13 +191,28 @@ the following methods:
 - `withTransaction() <{+api+}/apidocs/mongodb-driver-sync/com/mongodb/client/ClientSession.html#withTransaction(com.mongodb.client.TransactionBody)>`__
 - `close() <{+api+}/apidocs/mongodb-driver-core/com/mongodb/session/ClientSession.html#close()>`__
 
+The following code demonstrates how to set the ``defaultTimeout`` when
+instantiating a ``ClientSession``:
+
+.. literalinclude:: /includes/connect/CSOT.java
+   :language: java
+   :start-after: start-session-timeout
+   :end-before: end-session-timeout
+   :dedent:
+
 If you do not specify the ``defaultTimeout``, the driver uses the timeout
 value set on the parent ``MongoClient``.
 
 You can also set a transaction-level timeout by using the ``timeout()``
 method when building a ``TransactionOptions`` instance. Setting this
 option applies a timeout to all operations performed in the scope of the
-transaction.
+transaction:
+
+.. literalinclude:: /includes/connect/CSOT.java
+   :language: java
+   :start-after: start-txn-timeout
+   :end-before: end-txn-timeout
+   :dedent:
 
 To learn more about transactions, see the :ref:`java-fundamentals-transactions` guide.
 

source/includes/connect/CSOT.java

@@ -4,11 +4,14 @@
 import static com.mongodb.client.model.Filters.gte;
 import static java.util.concurrent.TimeUnit.SECONDS;
 
+import com.mongodb.ClientSessionOptions;
 import com.mongodb.ConnectionString;
 import com.mongodb.MongoClientSettings;
+import com.mongodb.TransactionOptions;
 import com.mongodb.client.*;
 import com.mongodb.client.cursor.TimeoutMode;
 import com.mongodb.client.model.InsertOneOptions;
+import com.mongodb.client.model.bulk.ClientBulkWriteOptions;
 import com.mongodb.client.result.InsertOneResult;
 import org.bson.Document;
 
@@ -75,6 +78,34 @@ private void overrideTimeout(){
         // end-override
     }
 
+    private void txnTimeout(){
+        MongoClientSettings settings = MongoClientSettings.builder()
+                .applyConnectionString(new ConnectionString("<connection string>"))
+                .build();
+
+        try (MongoClient mongoClient = MongoClients.create(settings)) {
+            MongoCollection<Document> collection = mongoClient
+                    .getDatabase("db")
+                    .getCollection("people");
+
+            // start-session-timeout
+            ClientSessionOptions opts = ClientSessionOptions.builder()
+                    .defaultTimeout(5L, SECONDS)
+                    .build();
+
+            ClientSession session = mongoClient.startSession(opts);
+            // ... perform operations on ClientSession
+            // end-session-timeout
+
+            // start-txn-timeout
+            TransactionOptions txnOptions = TransactionOptions.builder()
+                    .timeout(5L, SECONDS)
+                    .build();
+            // end-txn-timeout
+        }
+
+    }
+
     private void cursorTimeout(){
         MongoClientSettings settings = MongoClientSettings.builder()
                 .applyConnectionString(new ConnectionString("<connection string>"))