tour 04 transactions lite

%23%20%2F%2F%2F%20script%0A%23%20requires-python%20%3D%20%22%3E%3D3.12%22%0A%23%20dependencies%20%3D%20%5B%22marimo%22%5D%0A%23%20%2F%2F%2F%0A%22%22%22SQLer%20Lite%20Tour%3A%20Transactions%20-%20Works%20in%20Pyodide%2FWASM!%22%22%22%0A%0Aimport%20marimo%0A%0A__generated_with%20%3D%20%220.20.4%22%0Aapp%20%3D%20marimo.App(width%3D%22medium%22)%0A%0A%0A%40app.cell%0Adef%20_()%3A%0A%20%20%20%20%23%20---%20marimo%20scaffolding%20(please%20ignore)%20---%0A%20%20%20%20import%20marimo%20as%20mo%0A%0A%20%20%20%20return%20(mo%2C)%0A%0A%0A%40app.cell%0Aasync%20def%20_()%3A%0A%20%20%20%20%23%20---%20WASM%20scaffolding%20(please%20ignore)%20---%0A%20%20%20%20%23%20Loads%20sqlite3%20%2B%20sqler%20in%20Pyodide%2Fbrowser%20environments.%0A%20%20%20%20%23%20Not%20needed%20when%20running%20locally%20with%20%60marimo%20edit%60.%0A%20%20%20%20import%20sys%0A%0A%20%20%20%20pyodide_sqlite3_ready%20%3D%20True%0A%20%20%20%20sqler_ready%20%3D%20True%0A%20%20%20%20if%20sys.platform%20%3D%3D%20%22emscripten%22%3A%0A%20%20%20%20%20%20%20%20pyodide_sqlite3_ready%20%3D%20False%0A%20%20%20%20%20%20%20%20sqler_ready%20%3D%20False%0A%20%20%20%20%20%20%20%20try%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20import%20pyodide%0A%0A%20%20%20%20%20%20%20%20%20%20%20%20await%20pyodide.loadPackage(%22sqlite3%22)%0A%20%20%20%20%20%20%20%20%20%20%20%20pyodide_sqlite3_ready%20%3D%20True%0A%20%20%20%20%20%20%20%20except%20Exception%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20try%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20import%20js%0A%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20await%20js.pyodide.loadPackage(%22sqlite3%22)%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20pyodide_sqlite3_ready%20%3D%20True%0A%20%20%20%20%20%20%20%20%20%20%20%20except%20Exception%20as%20exc%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20print(%22Failed%20to%20load%20sqlite3%20in%20Pyodide%3A%22%2C%20exc)%0A%0A%20%20%20%20%20%20%20%20import%20importlib.util%20as%20importlib_util%0A%0A%20%20%20%20%20%20%20%20if%20importlib_util.find_spec(%22sqler%22)%20is%20not%20None%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20sqler_ready%20%3D%20True%0A%20%20%20%20%20%20%20%20else%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20try%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20import%20micropip%0A%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20await%20micropip.install(%22sqler%22)%0A%20%20%20%20%20%20%20%20%20%20%20%20except%20Exception%20as%20exc%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20print(%22Failed%20to%20install%20sqler%20in%20Pyodide%3A%22%2C%20exc)%0A%20%20%20%20%20%20%20%20%20%20%20%20else%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20if%20importlib_util.find_spec(%22sqler%22)%20is%20not%20None%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20sqler_ready%20%3D%20True%0A%20%20%20%20return%20pyodide_sqlite3_ready%2C%20sqler_ready%0A%0A%0A%40app.cell%0Adef%20_(mo)%3A%0A%20%20%20%20mo.md(r%22%22%22%0A%20%20%20%20%23%20SQLer%20Lite%20Tour%3A%20Transactions%0A%0A%20%20%20%20This%20notebook%20covers%20database%20transactions%20in%20SQLer%20-%20how%20to%20group%0A%20%20%20%20multiple%20operations%20into%20atomic%20units%20that%20either%20all%20succeed%20or%20all%20fail.%0A%20%20%20%20Works%20in%20Pyodide%2FWASM!%0A%0A%20%20%20%20You'll%20learn%3A%0A%0A%20%20%20%201.%20Why%20transactions%20matter%0A%20%20%20%202.%20Using%20the%20%60db.transaction()%60%20context%20manager%0A%20%20%20%203.%20Automatic%20rollback%20on%20errors%0A%20%20%20%204.%20Transaction-aware%20model%20saves%0A%0A%20%20%20%20Let's%20get%20started!%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(mo)%3A%0A%20%20%20%20mo.md(r%22%22%22%0A%20%20%20%20%23%23%201.%20Why%20Transactions%20Matter%0A%0A%20%20%20%20Imagine%20transferring%20money%20between%20accounts%3A%0A%0A%20%20%20%201.%20Deduct%20%24100%20from%20Account%20A%0A%20%20%20%202.%20Add%20%24100%20to%20Account%20B%0A%0A%20%20%20%20What%20if%20step%202%20fails%20after%20step%201%20succeeds%3F%20You've%20lost%20%24100!%0A%0A%20%20%20%20Transactions%20ensure%20**atomicity**%3A%20either%20ALL%20operations%20succeed%2C%0A%20%20%20%20or%20NONE%20of%20them%20do.%20If%20anything%20fails%2C%20everything%20is%20rolled%20back.%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(mo)%3A%0A%20%20%20%20mo.md(r%22%22%22%0A%20%20%20%20%23%23%202.%20Setting%20Up%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(pyodide_sqlite3_ready%2C%20sqler_ready)%3A%0A%20%20%20%20if%20not%20pyodide_sqlite3_ready%3A%0A%20%20%20%20%20%20%20%20raise%20RuntimeError(%0A%20%20%20%20%20%20%20%20%20%20%20%20%22sqlite3%20is%20required%20in%20Pyodide%3B%20failed%20to%20load%20package%20'sqlite3'.%22%0A%20%20%20%20%20%20%20%20)%0A%20%20%20%20if%20not%20sqler_ready%3A%0A%20%20%20%20%20%20%20%20raise%20RuntimeError(%0A%20%20%20%20%20%20%20%20%20%20%20%20%22sqler%20is%20required%20in%20Pyodide%3B%20failed%20to%20install%20sqler%20wheel.%22%0A%20%20%20%20%20%20%20%20)%0A%0A%20%20%20%20import%20importlib%0A%20%20%20%20from%20dataclasses%20import%20dataclass%0A%0A%20%20%20%20_sqler%20%3D%20importlib.import_module(%22sqler%22)%0A%20%20%20%20F%20%3D%20_sqler.F%0A%20%20%20%20SQLerDB%20%3D%20_sqler.SQLerDB%0A%20%20%20%20SQLerLiteModel%20%3D%20_sqler.SQLerLiteModel%0A%0A%20%20%20%20db%20%3D%20SQLerDB.in_memory()%0A%20%20%20%20print(%22Database%20connected!%22)%0A%20%20%20%20return%20F%2C%20SQLerLiteModel%2C%20dataclass%2C%20db%0A%0A%0A%40app.cell%0Adef%20_(SQLerLiteModel%2C%20dataclass%2C%20db)%3A%0A%20%20%20%20%40dataclass%0A%20%20%20%20class%20Account(SQLerLiteModel)%3A%0A%20%20%20%20%20%20%20%20__tablename__%20%3D%20%22accounts%22%0A%20%20%20%20%20%20%20%20name%3A%20str%0A%20%20%20%20%20%20%20%20balance%3A%20int%0A%0A%20%20%20%20Account.set_db(db)%0A%0A%20%20%20%20%23%20Create%20initial%20accounts%0A%20%20%20%20_alice%20%3D%20Account(name%3D%22Alice%22%2C%20balance%3D1000)%0A%20%20%20%20_alice.save()%0A%20%20%20%20_bob%20%3D%20Account(name%3D%22Bob%22%2C%20balance%3D500)%0A%20%20%20%20_bob.save()%0A%20%20%20%20print(f%22Created%3A%20Alice%20(%7B_alice.balance%7D)%2C%20Bob%20(%7B_bob.balance%7D)%22)%0A%20%20%20%20return%20(Account%2C)%0A%0A%0A%40app.cell%0Adef%20_(mo)%3A%0A%20%20%20%20mo.md(r%22%22%22%0A%20%20%20%20%23%23%203.%20Basic%20Transaction%20Usage%0A%0A%20%20%20%20Use%20%60db.transaction()%60%20as%20a%20context%20manager.%20All%20operations%20inside%0A%20%20%20%20the%20block%20are%20part%20of%20the%20transaction%3A%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(Account%2C%20db)%3A%0A%20%20%20%20%23%20Successful%20transaction%0A%20%20%20%20with%20db.transaction()%3A%0A%20%20%20%20%20%20%20%20%23%20Transfer%20200%20from%20Alice%20to%20Bob%0A%20%20%20%20%20%20%20%20_a%20%3D%20Account.from_id(1)%0A%20%20%20%20%20%20%20%20_b%20%3D%20Account.from_id(2)%0A%0A%20%20%20%20%20%20%20%20_a.balance%20-%3D%20200%0A%20%20%20%20%20%20%20%20_a.save()%0A%0A%20%20%20%20%20%20%20%20_b.balance%20%2B%3D%20200%0A%20%20%20%20%20%20%20%20_b.save()%0A%0A%20%20%20%20%23%20Verify%20the%20transfer%0A%20%20%20%20_alice_after%20%3D%20Account.from_id(1)%0A%20%20%20%20_bob_after%20%3D%20Account.from_id(2)%0A%20%20%20%20print(f%22After%20transfer%3A%20Alice%20(%7B_alice_after.balance%7D)%2C%20Bob%20(%7B_bob_after.balance%7D)%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(mo)%3A%0A%20%20%20%20mo.md(r%22%22%22%0A%20%20%20%20%23%23%204.%20Automatic%20Rollback%20on%20Error%0A%0A%20%20%20%20If%20an%20exception%20occurs%20inside%20a%20transaction%2C%20all%20changes%20are%20rolled%20back%3A%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(Account%2C%20db)%3A%0A%20%20%20%20%23%20Check%20balances%20before%0A%20%20%20%20_before_alice%20%3D%20Account.from_id(1)%0A%20%20%20%20_before_bob%20%3D%20Account.from_id(2)%0A%20%20%20%20print(f%22Before%3A%20Alice%20(%7B_before_alice.balance%7D)%2C%20Bob%20(%7B_before_bob.balance%7D)%22)%0A%0A%20%20%20%20try%3A%0A%20%20%20%20%20%20%20%20with%20db.transaction()%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20_a%20%3D%20Account.from_id(1)%0A%20%20%20%20%20%20%20%20%20%20%20%20_b%20%3D%20Account.from_id(2)%0A%0A%20%20%20%20%20%20%20%20%20%20%20%20%23%20Deduct%20from%20Alice%0A%20%20%20%20%20%20%20%20%20%20%20%20_a.balance%20-%3D%20300%0A%20%20%20%20%20%20%20%20%20%20%20%20_a.save()%0A%20%20%20%20%20%20%20%20%20%20%20%20print(f%22%20%20Deducted%20from%20Alice%3A%20%7B_a.balance%7D%22)%0A%0A%20%20%20%20%20%20%20%20%20%20%20%20%23%20Simulate%20an%20error%20before%20crediting%20Bob%0A%20%20%20%20%20%20%20%20%20%20%20%20raise%20ValueError(%22Network%20error!%20Transaction%20failed!%22)%0A%0A%20%20%20%20%20%20%20%20%20%20%20%20%23%20This%20line%20never%20executes%0A%20%20%20%20%20%20%20%20%20%20%20%20_b.balance%20%2B%3D%20300%0A%20%20%20%20%20%20%20%20%20%20%20%20_b.save()%0A%0A%20%20%20%20except%20ValueError%20as%20_e%3A%0A%20%20%20%20%20%20%20%20print(f%22%20%20Error%20caught%3A%20%7B_e%7D%22)%0A%0A%20%20%20%20%23%20Verify%20rollback%20-%20balances%20should%20be%20unchanged%0A%20%20%20%20_after_alice%20%3D%20Account.from_id(1)%0A%20%20%20%20_after_bob%20%3D%20Account.from_id(2)%0A%20%20%20%20print(f%22After%3A%20Alice%20(%7B_after_alice.balance%7D)%2C%20Bob%20(%7B_after_bob.balance%7D)%22)%0A%20%20%20%20print(%22Transaction%20was%20rolled%20back%20-%20no%20money%20lost!%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(mo)%3A%0A%20%20%20%20mo.md(r%22%22%22%0A%20%20%20%20%23%23%205.%20Transaction-Aware%20Saves%0A%0A%20%20%20%20%60model.save()%60%20respects%20active%20transactions.%20Saves%20are%20deferred%20until%0A%20%20%20%20the%20transaction%20commits%2C%20enabling%20proper%20rollback%3A%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(Account%2C%20db)%3A%0A%20%20%20%20%23%20Create%20a%20new%20account%20inside%20a%20failed%20transaction%0A%20%20%20%20_initial_count%20%3D%20Account.count()%0A%20%20%20%20print(f%22Initial%20account%20count%3A%20%7B_initial_count%7D%22)%0A%0A%20%20%20%20try%3A%0A%20%20%20%20%20%20%20%20with%20db.transaction()%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20%23%20Create%20new%20account%0A%20%20%20%20%20%20%20%20%20%20%20%20_charlie%20%3D%20Account(name%3D%22Charlie%22%2C%20balance%3D750)%0A%20%20%20%20%20%20%20%20%20%20%20%20_charlie.save()%0A%20%20%20%20%20%20%20%20%20%20%20%20print(%22%20%20Created%20Charlie%20inside%20transaction%22)%0A%0A%20%20%20%20%20%20%20%20%20%20%20%20raise%20RuntimeError(%22Oops!%20Abort%20everything!%22)%0A%0A%20%20%20%20except%20RuntimeError%3A%0A%20%20%20%20%20%20%20%20print(%22%20%20Transaction%20aborted!%22)%0A%0A%20%20%20%20%23%20Charlie%20should%20NOT%20exist%20-%20the%20transaction%20was%20rolled%20back%0A%20%20%20%20_final_count%20%3D%20Account.count()%0A%20%20%20%20print(f%22Final%20account%20count%3A%20%7B_final_count%7D%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(mo)%3A%0A%20%20%20%20mo.md(r%22%22%22%0A%20%20%20%20%23%23%206.%20Multiple%20Operations%20in%20a%20Transaction%0A%0A%20%20%20%20Batch%20multiple%20creates%2C%20updates%2C%20and%20deletes%20in%20one%20atomic%20operation%3A%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(Account%2C%20F%2C%20db)%3A%0A%20%20%20%20print(%22Before%20batch%20operation%3A%22)%0A%20%20%20%20for%20_acc%20in%20Account.all()%3A%0A%20%20%20%20%20%20%20%20print(f%22%20%20%7B_acc.name%7D%3A%20%7B_acc.balance%7D%22)%0A%0A%20%20%20%20with%20db.transaction()%3A%0A%20%20%20%20%20%20%20%20%23%20Create%20new%20accounts%0A%20%20%20%20%20%20%20%20Account(name%3D%22Diana%22%2C%20balance%3D300).save()%0A%20%20%20%20%20%20%20%20Account(name%3D%22Eve%22%2C%20balance%3D450).save()%0A%0A%20%20%20%20%20%20%20%20%23%20Update%20existing%0A%20%20%20%20%20%20%20%20_alice%20%3D%20Account.filter(F(%22name%22)%20%3D%3D%20%22Alice%22).first()%0A%20%20%20%20%20%20%20%20_alice.balance%20%2B%3D%20100%0A%20%20%20%20%20%20%20%20_alice.save()%0A%0A%20%20%20%20%20%20%20%20%23%20All%20committed%20together%0A%0A%20%20%20%20print(%22%5CnAfter%20batch%20operation%3A%22)%0A%20%20%20%20for%20_acc%20in%20Account.all()%3A%0A%20%20%20%20%20%20%20%20print(f%22%20%20%7B_acc.name%7D%3A%20%7B_acc.balance%7D%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(mo)%3A%0A%20%20%20%20mo.md(r%22%22%22%0A%20%20%20%20%23%23%207.%20Checking%20Transaction%20State%0A%0A%20%20%20%20You%20can%20check%20if%20a%20transaction%20is%20active%3A%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(db)%3A%0A%20%20%20%20print(f%22Outside%20transaction%20-%20in_transaction%3A%20%7Bdb.adapter.in_transaction%7D%22)%0A%0A%20%20%20%20with%20db.transaction()%3A%0A%20%20%20%20%20%20%20%20print(f%22Inside%20transaction%20-%20in_transaction%3A%20%7Bdb.adapter.in_transaction%7D%22)%0A%0A%20%20%20%20print(f%22After%20transaction%20-%20in_transaction%3A%20%7Bdb.adapter.in_transaction%7D%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(mo)%3A%0A%20%20%20%20mo.md(r%22%22%22%0A%20%20%20%20%23%23%20Summary%0A%0A%20%20%20%20Transactions%20ensure%20data%20integrity%20for%20multi-step%20operations%3A%0A%0A%20%20%20%20%7C%20Feature%20%7C%20Description%20%7C%0A%20%20%20%20%7C---------%7C-------------%7C%0A%20%20%20%20%7C%20%60with%20db.transaction()%3A%60%20%7C%20Context%20manager%20for%20atomic%20operations%20%7C%0A%20%20%20%20%7C%20Automatic%20rollback%20%7C%20On%20any%20exception%2C%20all%20changes%20are%20undone%20%7C%0A%20%20%20%20%7C%20Transaction-aware%20saves%20%7C%20%60model.save()%60%20respects%20active%20transactions%20%7C%0A%20%20%20%20%7C%20%60db.adapter.in_transaction%60%20%7C%20Check%20if%20transaction%20is%20active%20%7C%0A%0A%20%20%20%20**Best%20Practices%3A**%0A%20%20%20%20-%20Use%20transactions%20for%20any%20multi-step%20data%20modifications%0A%20%20%20%20-%20Keep%20transactions%20short%20to%20avoid%20blocking%0A%20%20%20%20-%20Handle%20exceptions%20and%20let%20rollback%20happen%20automatically%0A%0A%20%20%20%20**Key%20difference%20from%20Pydantic%20version%3A**%0A%20%20%20%20-%20Use%20%60%40dataclass%60%20decorator%20on%20your%20model%20classes%0A%20%20%20%20-%20Inherit%20from%20%60SQLerLiteModel%60%20instead%20of%20%60SQLerModel%60%0A%20%20%20%20-%20Transaction%20behavior%20is%20identical!%0A%0A%20%20%20%20**Congratulations!**%20You've%20completed%20the%20SQLer%20Lite%20core%20tours!%0A%20%20%20%20These%20notebooks%20work%20in%20Pyodide%2FWASM%20browser%20environments.%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(db)%3A%0A%20%20%20%20db.close()%0A%20%20%20%20print(%22Database%20closed!%22)%0A%20%20%20%20return%0A%0A%0Aif%20__name__%20%3D%3D%20%22__main__%22%3A%0A%20%20%20%20app.run()%0A