將多個作業分組到 Azure Cosmos DB for MongoDB 虛擬核心中的交易

使用 startSession() 建立交易作業的用戶端工作階段。

const transactionSession = client.startSession();

使用 withTransaction() 建立交易，並將所有相關的交易作業放在回呼內。

await transactionSession.withTransaction(async () => {
    await collection.insertOne({ name: "Coolarn shirt", price: 38.00 }, transactionSession);
    await collection.insertOne({ name: "Coolarn shirt button", price: 1.50 }, transactionSession);
});

使用 commitTransaction() 認可交易。

transactionSession.commitTransaction();

使用 endSession() 結束交易工作階段。

transactionSession.endSession();

使用 startSession() 為 try 區塊內的交易作業建立用戶端工作階段。

try (ClientSession session = client.startSession()) {
}

使用 startTransaction() 建立交易。

session.startTransaction();

包含所有相關的交易作業。

collection.insertOne(session, new Document().append("name", "Coolarn shirt").append("price", 38.00));
collection.insertOne(session, new Document().append("name", "Coolarn shirt button").append("price", 1.50));

使用 commitTransaction() 認可交易。

clientSession.commitTransaction();

使用 start_session() 建立交易作業的用戶端工作階段。

with client.start_session() as ts:

在工作階段區塊內，使用 start_transaction() 建立交易。

ts.start_transaction()

包含所有相關的交易作業。

coll.insert_one({ 'name': 'Coolarn shirt', 'price': 38.00 }, session=ts)
coll.insert_one({ 'name': 'Coolarn shirt button', 'price': 1.50 }, session=ts)

使用 commit_transaction() 認可交易。

ts.commit_transaction()

使用現有的交易工作階段，透過 abortTransaction() 中止交易。

transactionSession.abortTransaction();

結束交易工作階段。

transactionSession.endSession();

使用現有的交易工作階段，透過 () 中止交易。

clientSession.abortTransaction();

使用現有的交易工作階段，透過 abort_transaction() 中止交易。

ts.abort_transaction()