Skip to content

Commit de25e0c

Browse files
committed
add required param note
1 parent 4a53704 commit de25e0c

File tree

2 files changed

+7
-2
lines changed

2 files changed

+7
-2
lines changed

source/fundamentals/transactions.txt

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -49,6 +49,11 @@ instantiating a new client each time.
4949
``ClientSession`` with a different ``MongoClient`` results in operation
5050
errors.
5151

52+
.. important::
53+
54+
You must include the ``session`` as a parameter for any operations that you
55+
want to include in a transaction.
56+
5257
Methods
5358
-------
5459

source/includes/fundamentals/code-snippets/Transaction.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,14 +17,14 @@ public static void main(String[] args) {
1717
MongoDatabase database = mongoClient.getDatabase("transaction_db");
1818
MongoCollection<Document> collection = database.getCollection("books");
1919

20-
// Set transaction options
20+
// Sets transaction options
2121
TransactionOptions txnOptions = TransactionOptions.builder()
2222
.writeConcern(WriteConcern.MAJORITY)
2323
.build();
2424

2525
try (ClientSession session = mongoClient.startSession()) {
2626

27-
// Use withTransaction and lambda for transaction operations
27+
// Uses withTransaction and lambda for transaction operations
2828
session.withTransaction(() -> {
2929
collection.insertMany(session, Arrays.asList(
3030
new Document("title", "The Bluest Eye").append("author", "Toni Morrison"),

0 commit comments

Comments
 (0)