Mnohofázové transakce: implementace operací odolných vůči selhání v DBMS

Implementace odolných transakcí: praktický přístup s idempotentními operacemi

Vícefázové transakce zajišťují integritu dat při výpadcích pomocí idempotentních operací a stavového deníku. Tato metoda je vhodná pro jakýkoli databázový systém, včetně MongoDB, a zabraňuje ztrátě dat při výpadcích napájení nebo chybách systému.

Princip činnosti vícefázové transakce

Transakce je rozdělena na postupná stádia, z nichž každé je zaznamenáno v samostatné tabulce TRANSACTIONS. Klíčové stavy:

• blocking — blokování účtů k vyloučení paralelních operací.
• save_balance — uložení původních zůstatků do deníku.
• main — provedení hlavní operace převodu prostředků.
• unlock — odblokování účtů po dokončení.
• finished — finální stav úspěšné transakce.

Idempotence operací zaručuje, že opakované provedení stádia po výpadku nezkreslí data. Například operace A := B + 1 je idempotentní, zatímco A := A + 1 — není, ale lze ji rozložit na dvě idempotentní.

Etapy implementace s příklady kódu

Uvažujme převod 250 tenge z účtu „Assange“ na účet „Agent Y“. Výchozí data v tabulce ACCOUNTS:

| ID | Jméno | Zůstatek, ₸ | TR_ID |

|----|---------|-------------|-------|

| 34 | Assange | 300 | null |

| 78 | Agent Y | 7 | null |

1. Blokování účtů (STATUS='blocking')

Nejprve se vytvoří záznam v TRANSACTIONS:

| ID | FROM_ID | TO_ID | AMOUNT, ₸ | FROM_BALANCE | TO_BALANCE | STATUS |

|----|---------|-------|-----------|--------------|------------|----------|

| 172| 34 | 78 | 250 | null | null | blocking |

Blokování se provádí atomickými příkazy, například v MongoDB:

db.accounts.updateOne(
  { ID: 34, TR_ID: null },
  { $set: { TR_ID: 172 } }
);

Pokud příkaz nezmění záznam, blokování se nepodařilo — je nutný opakování nebo zrušení. Pro zabránění vzájemných blokování se identifikátory třídí před zpracováním.

2. Uložení zůstatků (STATUS='save_balance')

Po blokování se zkopírují výchozí zůstatky do TRANSACTIONS — toto je idempotentní operace:

db.transactions.updateOne(
  { ID: 172 },
  { $set: { FROM_BALANCE: 300, TO_BALANCE: 7, STATUS: 'save_balance' } }
);

3. Provedení převodu (STATUS='main')

Hlavní operace používá uložené zůstatky pro idempotenci:

db.accounts.updateOne(
  { ID: 34, TR_ID: 172 },
  { $set: { BALANCE: 50 } } // 300 - 250
);

db.accounts.updateOne(
  { ID: 78, TR_ID: 172 },
  { $set: { BALANCE: 257 } } // 7 + 250
);

Stav se aktualizuje na 'unlock' až po úspěšném použití změn.

4. Odblokování a dokončení (STATUS='unlock')

Účty se odblokují s kontrolou TR_ID:

db.accounts.updateOne(
  { ID: 34, TR_ID: 172 },
  { $set: { TR_ID: null } }
);

Po odblokování obou účtů se stav změní na 'finished'.

Výhody a omezení přístupu

Co je důležité:

• Odolnost: systém se obnoví po jakýchkoli výpadcích bez ztráty dat.
• Idempotence: operace lze bezpečně opakovat, což je klíčové pro distribuované systémy.
• Univerzálnost: metoda je použitelná pro různé databázové systémy, nejen pro MongoDB.
• Konzistence: je zaručena integrita dat na všech etapách transakce.
• Výkonnost: vyžaduje dodatečné záznamy do deníku, což může zpomalit operace.

Omezení zahrnují zvýšenou složitost implementace a režijní náklady na vedení deníku TRANSACTIONS. Nicméně pro finanční systémy nebo kritické aplikace jsou tyto kompromisy oprávněné.

Doporučení pro vývojáře

• Používejte atomické operace databázového systému pro blokování a aktualizace.
• Implementujte mechanismus opakování při neúspěšných blokováních.
• Testujte scénáře s výpadky, včetně náhlých zastavení procesů.
• Optimalizujte třídění identifikátorů pro minimalizaci deadlocků.

Tento přístup zajišťuje spolehlivost srovnatelnou s klasickými dvoufázovými commity, ale s větší flexibilitou pro NoSQL-systémy.

— Editorial Team