Seskupení více operací v transakcích ve službě Azure Cosmos DB pro virtuální jádro MongoDB

PLATÍ PRO: Virtuální jádro MongoDB

Je běžné, že chcete seskupit více operací do jedné transakce, aby bylo možné potvrdit nebo vrátit zpět dohromady. V databázových principech transakce obvykle implementují čtyři klíčové principy ACID . ACID znamená:

• Atomicita: Transakce jsou zcela dokončeny nebo vůbec.
• Konzistence: Databáze přecházejí z jednoho konzistentního stavu na jiný.
• Izolace: Jednotlivé transakce jsou stíněny před souběžnými transakcemi.
• Stálost: Dokončené transakce jsou trvalé a zajišťují, aby data zůstala konzistentní, i když došlo k selhání systému.

Principy ACID při správě databází zajišťují spolehlivé zpracování transakcí. Azure Cosmos DB pro mongoDB vCore implementuje tyto principy a umožňuje vytvářet transakce pro více operací.

Požadavky

• Existující cluster azure Cosmos DB pro virtuální jádra MongoDB
  • Pokud nemáte předplatné Azure, vytvořte si účet zdarma.
  • Pokud máte existující předplatné Azure, vytvořte nový cluster azure Cosmos DB pro virtuální jádra MongoDB.

Vytvoření transakce

Vytvořte novou transakci pomocí vhodných metod z jazyka pro vývojáře podle vašeho výběru. Tyto metody obvykle zahrnují určitý balicí mechanismus seskupit více transakcí dohromady a metodu potvrzení transakce.

JavaScript

Poznámka:

Ukázky v této části předpokládají, že máte proměnnou kolekce s názvem collection.

1. Slouží startSession() k vytvoření relace klienta pro operaci transakce.

   const transactionSession = client.startSession();
   

2. Vytvořte transakci pomocí withTransaction() a umístěte všechny relevantní transakce do zpětného volání.

   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);
   });
   

3. Potvrzení transakce pomocí commitTransaction().

   transactionSession.commitTransaction();
   

4. Slouží endSession() k ukončení relace transakce.

   transactionSession.endSession();
   

Java

Poznámka:

Ukázky v této části předpokládají, že máte proměnnou kolekce s názvem databaseCollection.

1. Slouží startSession() k vytvoření relace klienta pro operaci transakce v rámci try bloku.

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

2. Vytvoření transakce pomocí startTransaction().

   session.startTransaction();
   

3. Zahrnout všechny relevantní transakce operace.

   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));
   

4. Potvrzení transakce pomocí commitTransaction().

   clientSession.commitTransaction();
   

Python

Poznámka:

Ukázky v této části předpokládají, že máte proměnnou kolekce s názvem coll.

1. Slouží start_session() k vytvoření relace klienta pro operaci transakce.

   with client.start_session() as ts:
   

2. V rámci bloku relace vytvořte transakci pomocí start_transaction().

   ts.start_transaction()
   

3. Zahrnout všechny relevantní transakce operace.

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

4. Potvrzení transakce pomocí commit_transaction().

   ts.commit_transaction()
   

Vrácení transakce zpět

Někdy může být nutné vrátit transakci zpět před potvrzením.

JavaScript

1. Pomocí existující relace transakce přerušte transakci s abortTransaction().

   transactionSession.abortTransaction();
   

2. Ukončete relaci transakce.

   transactionSession.endSession();
   

Java

1. Pomocí existující relace transakce přerušte transakci s ().

   clientSession.abortTransaction();
   

Python

1. Pomocí existující relace transakce přerušte transakci s abort_transaction().

   ts.abort_transaction()
   

Další krok

Vytvoření webové aplikace Node.js