-
Notifications
You must be signed in to change notification settings - Fork 10
DOCSP-41763 Add transaction page #47
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Merged
stephmarie17
merged 10 commits into
mongodb:master
from
stephmarie17:docsp-41763-addTransactionPage
Sep 27, 2024
Merged
Changes from 5 commits
Commits
Show all changes
10 commits
Select commit
Hold shift + click to select a range
7809afb
add new page and code example
stephmarie17 7380add
edits
stephmarie17 2272a23
update example section
stephmarie17 ba73ae2
update example
stephmarie17 d57a4cf
implement RR feedback
stephmarie17 f0b50af
update example references
stephmarie17 fe1c19f
typo
stephmarie17 a81cae4
RR feedback
stephmarie17 49666ab
implement technical feedback
stephmarie17 6d14900
update imports in example
stephmarie17 File filter
Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
There are no files selected for viewing
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,58 @@ | ||
import com.mongodb.* | ||
import com.mongodb.client.ClientSession | ||
import com.mongodb.client.MongoClients | ||
import org.bson.Document | ||
|
||
// start-data-class | ||
data class Restaurant(val name: String, val cuisine: String) | ||
// end-data-class | ||
|
||
fun main() { | ||
// start-transaction | ||
// Creates a new MongoClient with a connection string | ||
val client = MongoClients.create("<connection string>") | ||
stephmarie17 marked this conversation as resolved.
Show resolved
Hide resolved
stephmarie17 marked this conversation as resolved.
Show resolved
Hide resolved
|
||
|
||
// Gets the database and collection | ||
val database = client.getDatabase("sample_restaurants") | ||
val collection = database.getCollection<Restaurant>("restaurants") | ||
|
||
// Defines options and inserts restaurants into the collection | ||
fun insertRestaurantsInTransaction(session: ClientSession) { | ||
// Sets options for the collection operation within the transaction | ||
val restaurantsCollectionWithOptions = collection | ||
.withWriteConcern(WriteConcern("majority")) | ||
.withReadConcern(ReadConcern.LOCAL) | ||
stephmarie17 marked this conversation as resolved.
Show resolved
Hide resolved
|
||
|
||
// Inserts restaurants within the transaction | ||
restaurantsCollectionWithOptions.insertOne( | ||
session, | ||
Restaurant("name", "Kotlin Sync Pizza").append("cuisine", "Pizza") | ||
stephmarie17 marked this conversation as resolved.
Show resolved
Hide resolved
|
||
) | ||
restaurantsCollectionWithOptions.insertOne( | ||
session, | ||
Restaurant("name", "Kotlin Sync Burger").append("cuisine", "Burger") | ||
) | ||
} | ||
|
||
// Starts a client session | ||
client.startSession().use { session -> | ||
try { | ||
stephmarie17 marked this conversation as resolved.
Show resolved
Hide resolved
|
||
val txnOptions = TransactionOptions.builder() | ||
.readConcern(ReadConcern.LOCAL) | ||
.writeConcern(WriteConcern.MAJORITY) | ||
.build() | ||
|
||
// Uses the withTransaction method to start a transaction and run the given function | ||
session.withTransaction({ | ||
insertRestaurantsInTransaction(session) | ||
println("Transaction succeeded") | ||
}, txnOptions) | ||
} catch (e: Exception) { | ||
println("Transaction failed: ${e.message}") | ||
} | ||
} | ||
|
||
// Closes the MongoClient | ||
client.close() | ||
// end-transaction | ||
} |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,164 @@ | ||
.. _kotlin-sync-write-transactions: | ||
|
||
============ | ||
Transactions | ||
============ | ||
|
||
.. contents:: On this page | ||
:local: | ||
:backlinks: none | ||
:depth: 2 | ||
:class: singlecol | ||
|
||
.. facet:: | ||
:name: genre | ||
:values: reference | ||
|
||
.. meta:: | ||
:keywords: ACID, write, consistency, code example | ||
|
||
Overview | ||
-------- | ||
|
||
In this guide, you can learn how to use the {+driver-short+} to perform | ||
**transactions**. Transactions allow you to run a series of operations that do | ||
not change any data until the transaction is committed. If any operation in | ||
the transaction returns an error, the driver cancels the transaction and discards | ||
all data changes before they ever become visible. | ||
|
||
In MongoDB, transactions run within logical **sessions**. A | ||
session is a grouping of related read or write operations that you intend to run | ||
sequentially. Sessions enable **causal consistency** for a | ||
group of operations and allow you to run operations in an | ||
**ACID-compliant transaction**, which is a transaction that meets an expectation | ||
of atomicity, consistency, isolation, and durability. MongoDB guarantees that the | ||
data involved in your transaction operations remains consistent, even if the | ||
operations encounter unexpected errors. | ||
|
||
When using the {+driver-short+}, you can create a new session from a | ||
``MongoClient`` instance as a ``ClientSession`` type. We recommend that you reuse | ||
your ``MongoClient`` for multiple sessions and transactions instead of | ||
creating a new client each time. | ||
|
||
.. warning:: | ||
|
||
Use a ``ClientSession`` only with the ``MongoClient`` (or associated | ||
``MongoDatabase`` or ``MongoCollection``) that created it. Using a | ||
``ClientSession`` with a different ``MongoClient`` results in operation | ||
errors. | ||
|
||
Sample Data | ||
~~~~~~~~~~~ | ||
|
||
The examples in this guide use the ``sample_restaurants.restaurants`` collection | ||
from the :atlas:`Atlas sample datasets </sample-data>`. To learn how to create a | ||
free MongoDB Atlas cluster and load the sample datasets, see the | ||
:atlas:`Get Started with Atlas </getting-started>` guide. | ||
|
||
The documents in this collection are modeled by the following {+language+} data class: | ||
|
||
.. literalinclude:: /includes/write/transaction.kt | ||
:start-after: start-data-class | ||
:end-before: end-data-class | ||
:language: kotlin | ||
:copyable: | ||
:dedent: | ||
|
||
Methods | ||
------- | ||
|
||
Create a ``ClientSession`` by using the ``startSession()`` method on your ``MongoClient`` | ||
instance. You can then modify the session state by using the methods provided by | ||
the ``ClientSession``. The following table describes the methods you can use to | ||
manage your transaction: | ||
|
||
.. list-table:: | ||
:widths: 25 75 | ||
:header-rows: 1 | ||
|
||
* - Method | ||
- Description | ||
|
||
* - ``startTransaction()`` | ||
- | Starts a new transaction, configured with the given options, on | ||
this session. Returns an error if there is already | ||
a transaction in progress for the session. To learn more about | ||
this method, see the :manual:`startTransaction() page | ||
</reference/method/Session.startTransaction/>` in the Server manual. | ||
| | ||
| **Parameter**: ``TransactionOptions`` | ||
|
||
* - ``abortTransaction()`` | ||
- | Ends the active transaction for this session. Returns an | ||
error if there is no active transaction for the session or the | ||
transaction has been committed or ended. To learn more about | ||
this method, see the :manual:`abortTransaction() page | ||
</reference/method/Session.abortTransaction/>` in the Server manual. | ||
| | ||
|
||
* - ``commitTransaction()`` | ||
- | Commits the active transaction for this session. Returns an | ||
error if there is no active transaction for the session or if the | ||
transaction was ended. To learn more about | ||
this method, see the :manual:`commitTransaction() page | ||
</reference/method/Session.commitTransaction/>` in the Server manual. | ||
|
||
* - ``withTransaction()`` | ||
- | Starts a transaction on this session and runs the given function within | ||
a transaction. | ||
| | ||
| **Parameters**: transaction body function, ``TransactionOptions`` | ||
|
||
Example | ||
------- | ||
|
||
The following example demonstrates how to create a session, create a | ||
transaction, and insert documents into a collection in one transaction | ||
through the following steps: | ||
|
||
1. Create a session from the client by using the ``startSession()`` method. | ||
#. Use the ``withTransaction()`` method to start a transaction. | ||
#. Insert multiple documents into the ``restaurants`` collection. The | ||
``withTransaction()`` method runs the insert operation and commits the | ||
transaction. If any operation results in errors, ``withTransaction()`` | ||
cancels the transaction. | ||
stephmarie17 marked this conversation as resolved.
Show resolved
Hide resolved
|
||
#. Close the connection to the server by using the ``client.close()`` method. | ||
stephmarie17 marked this conversation as resolved.
Show resolved
Hide resolved
|
||
|
||
.. literalinclude:: /includes/write/transaction.kt | ||
:start-after: start-transaction | ||
:end-before: end-transaction | ||
:language: kotlin | ||
:copyable: | ||
:dedent: | ||
|
||
If you require more control over your transactions, you can use the ``startTransaction()`` | ||
method. You can use this method with the ``commitTransaction()`` and ``abortTransaction()`` | ||
methods described in the preceding section to manually manage the transaction lifecycle. | ||
|
||
Additional Information | ||
---------------------- | ||
|
||
To learn more about the concepts mentioned in this guide, see the following pages in | ||
the Server manual: | ||
|
||
- :manual:`Transactions </core/transactions/>` | ||
- :manual:`Server Sessions </reference/server-sessions>` | ||
- :manual:`Read Isolation, Consistency, and Recency </core/read-isolation-consistency-recency/#causal-consistency>` | ||
|
||
To learn more about ACID compliance, see the :website:`What are ACID | ||
Properties in Database Management Systems? </basics/acid-transactions>` | ||
article on the MongoDB website. | ||
|
||
.. _api-docs-transaction: | ||
stephmarie17 marked this conversation as resolved.
Show resolved
Hide resolved
|
||
|
||
API Documentation | ||
~~~~~~~~~~~~~~~~~ | ||
|
||
To learn more about any of the types or methods discussed in this | ||
guide, see the following API documentation: | ||
|
||
- `ClientSession <{+api+}/com.mongodb.kotlin.client/-client-session/index.html>`_ | ||
- `abortTransaction() <{+api+}/com.mongodb.kotlin.client/-client-session/abort-transaction.html>`_ | ||
- `commitTransaction() <{+api+}/com.mongodb.kotlin.client/-client-session/commit-transaction.html>`_ | ||
- `startTransaction() <{+api+}/com.mongodb.kotlin.client/-client-session/start-transaction.html>`_ | ||
- `withTransaction() <{+api+}/com.mongodb.kotlin.client/-client-session/with-transaction.html>`_ |
Oops, something went wrong.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Uh oh!
There was an error while loading. Please reload this page.