tour 03 safe models 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%20Safe%20Models%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%20Safe%20Models%20(Optimistic%20Locking)%0A%0A%20%20%20%20This%20notebook%20covers%20Safe%20Models%20-%20SQLer's%20solution%20for%20handling%20concurrent%0A%20%20%20%20updates%20without%20data%20loss.%20Works%20in%20Pyodide%2FWASM!%0A%0A%20%20%20%20You'll%20learn%3A%0A%0A%20%20%20%201.%20What%20optimistic%20locking%20is%20and%20why%20you%20need%20it%0A%20%20%20%202.%20Using%20%60SQLerLiteSafeModel%60%20for%20version%20tracking%0A%20%20%20%203.%20Handling%20%60StaleVersionError%60%20conflicts%0A%20%20%20%204.%20The%20%60refresh()%60%20pattern%20for%20conflict%20recovery%0A%0A%20%20%20%20Let's%20dive%20in!%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.%20The%20Problem%3A%20Lost%20Updates%0A%0A%20%20%20%20Imagine%20two%20users%20editing%20the%20same%20record%20simultaneously%3A%0A%0A%20%20%20%201.%20User%20A%20reads%20%60balance%20%3D%20100%60%0A%20%20%20%202.%20User%20B%20reads%20%60balance%20%3D%20100%60%0A%20%20%20%203.%20User%20A%20sets%20%60balance%20%3D%20150%60%20and%20saves%0A%20%20%20%204.%20User%20B%20sets%20%60balance%20%3D%2080%60%20and%20saves%20(overwrites%20A's%20change!)%0A%0A%20%20%20%20User%20A's%20update%20is%20**lost**.%20This%20is%20the%20%22lost%20update%22%20problem.%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.%20The%20Solution%3A%20Optimistic%20Locking%0A%0A%20%20%20%20Safe%20models%20track%20a%20%60_version%60%20number%20that%20increments%20on%20every%20save.%0A%20%20%20%20When%20saving%2C%20SQLer%20checks%20if%20the%20version%20matches%20what%20you%20read.%0A%20%20%20%20If%20someone%20else%20modified%20the%20record%2C%20you%20get%20a%20%60StaleVersionError%60.%0A%0A%20%20%20%20Let's%20set%20up%20our%20database%20and%20create%20a%20safe%20model%3A%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%20SQLerLiteSafeModel%20%3D%20_sqler.SQLerLiteSafeModel%0A%20%20%20%20StaleVersionError%20%3D%20_sqler.StaleVersionError%0A%0A%20%20%20%20db%20%3D%20SQLerDB.in_memory()%0A%20%20%20%20print(%22Database%20connected!%22)%0A%20%20%20%20return%20SQLerLiteSafeModel%2C%20StaleVersionError%2C%20dataclass%2C%20db%0A%0A%0A%40app.cell%0Adef%20_(SQLerLiteSafeModel%2C%20dataclass%2C%20db)%3A%0A%20%20%20%20%40dataclass%0A%20%20%20%20class%20Account(SQLerLiteSafeModel)%3A%0A%20%20%20%20%20%20%20%20__tablename__%20%3D%20%22accounts%22%0A%20%20%20%20%20%20%20%20owner%3A%20str%0A%20%20%20%20%20%20%20%20balance%3A%20int%0A%0A%20%20%20%20Account.set_db(db)%0A%20%20%20%20print(%22Account%20model%20registered!%22)%0A%20%20%20%20print(%22Note%3A%20SQLerLiteSafeModel%20automatically%20tracks%20_version%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.%20Version%20Tracking%20in%20Action%0A%0A%20%20%20%20Each%20save%20increments%20the%20%60_version%60.%20Let's%20see%20it%20work%3A%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(Account)%3A%0A%20%20%20%20%23%20Create%20a%20new%20account%0A%20%20%20%20acc%20%3D%20Account(owner%3D%22Alice%22%2C%20balance%3D100)%0A%20%20%20%20print(f%22Before%20save%3A%20_version%20%3D%20%7Bacc._version%7D%22)%0A%0A%20%20%20%20acc.save()%0A%20%20%20%20print(f%22After%20first%20save%3A%20_version%20%3D%20%7Bacc._version%7D%22)%0A%0A%20%20%20%20acc.balance%20%3D%20150%0A%20%20%20%20acc.save()%0A%20%20%20%20print(f%22After%20second%20save%3A%20_version%20%3D%20%7Bacc._version%7D%22)%0A%0A%20%20%20%20acc.balance%20%3D%20200%0A%20%20%20%20acc.save()%0A%20%20%20%20print(f%22After%20third%20save%3A%20_version%20%3D%20%7Bacc._version%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.%20Detecting%20Conflicts%0A%0A%20%20%20%20When%20two%20%22users%22%20have%20stale%20versions%2C%20the%20second%20save%20fails.%0A%20%20%20%20Let's%20simulate%20this%3A%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(Account%2C%20StaleVersionError)%3A%0A%20%20%20%20%23%20Create%20a%20fresh%20account%0A%20%20%20%20original%20%3D%20Account(owner%3D%22Bob%22%2C%20balance%3D500)%0A%20%20%20%20original.save()%0A%20%20%20%20print(f%22Created%20account%3A%20balance%3D%7Boriginal.balance%7D%2C%20version%3D%7Boriginal._version%7D%22)%0A%0A%20%20%20%20%23%20Simulate%20two%20users%20loading%20the%20same%20record%0A%20%20%20%20user_a%20%3D%20Account.from_id(original._id)%0A%20%20%20%20user_b%20%3D%20Account.from_id(original._id)%0A%0A%20%20%20%20print(f%22%5CnUser%20A%20loaded%3A%20balance%3D%7Buser_a.balance%7D%2C%20version%3D%7Buser_a._version%7D%22)%0A%20%20%20%20print(f%22User%20B%20loaded%3A%20balance%3D%7Buser_b.balance%7D%2C%20version%3D%7Buser_b._version%7D%22)%0A%0A%20%20%20%20%23%20User%20A%20makes%20a%20change%20and%20saves%20successfully%0A%20%20%20%20user_a.balance%20%3D%20600%0A%20%20%20%20user_a.save()%0A%20%20%20%20print(f%22%5CnUser%20A%20saved%3A%20balance%3D%7Buser_a.balance%7D%2C%20version%3D%7Buser_a._version%7D%22)%0A%0A%20%20%20%20%23%20User%20B%20tries%20to%20save%20with%20stale%20version%0A%20%20%20%20user_b.balance%20%3D%20400%0A%20%20%20%20try%3A%0A%20%20%20%20%20%20%20%20user_b.save()%0A%20%20%20%20%20%20%20%20print(%22User%20B%20saved%20successfully%20(unexpected!)%22)%0A%20%20%20%20except%20StaleVersionError%20as%20_e%3A%0A%20%20%20%20%20%20%20%20print(%22%5CnUser%20B%20got%20StaleVersionError!%22)%0A%20%20%20%20%20%20%20%20print(f%22%20%20Message%3A%20%7B_e%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%205.%20Handling%20Conflicts%3A%20The%20Refresh%20Pattern%0A%0A%20%20%20%20When%20you%20get%20a%20%60StaleVersionError%60%2C%20the%20recommended%20pattern%20is%3A%0A%20%20%20%201.%20Call%20%60.refresh()%60%20to%20get%20the%20latest%20data%0A%20%20%20%202.%20Re-apply%20your%20business%20logic%0A%20%20%20%203.%20Try%20saving%20again%0A%0A%20%20%20%20Let's%20see%20this%20pattern%3A%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(Account%2C%20StaleVersionError)%3A%0A%20%20%20%20%23%20Create%20account%0A%20%20%20%20account%20%3D%20Account(owner%3D%22Charlie%22%2C%20balance%3D1000)%0A%20%20%20%20account.save()%0A%0A%20%20%20%20%23%20Two%20concurrent%20%22sessions%22%0A%20%20%20%20session1%20%3D%20Account.from_id(account._id)%0A%20%20%20%20session2%20%3D%20Account.from_id(account._id)%0A%0A%20%20%20%20%23%20Session%201%20adds%20100%0A%20%20%20%20session1.balance%20%2B%3D%20100%0A%20%20%20%20session1.save()%0A%20%20%20%20print(f%22Session%201%3A%20Added%20100%2C%20new%20balance%20%3D%20%7Bsession1.balance%7D%22)%0A%0A%20%20%20%20%23%20Session%202%20tries%20to%20add%2050%20(has%20stale%20data)%0A%20%20%20%20session2.balance%20%2B%3D%2050%0A%20%20%20%20try%3A%0A%20%20%20%20%20%20%20%20session2.save()%0A%20%20%20%20except%20StaleVersionError%3A%0A%20%20%20%20%20%20%20%20print(f%22%5CnSession%202%3A%20Conflict!%20My%20balance%20was%20%7Bsession2.balance%20-%2050%7D%22)%0A%0A%20%20%20%20%20%20%20%20%23%20Refresh%20and%20re-apply%20the%20logic%0A%20%20%20%20%20%20%20%20session2.refresh()%0A%20%20%20%20%20%20%20%20print(f%22Session%202%3A%20After%20refresh%2C%20balance%20%3D%20%7Bsession2.balance%7D%22)%0A%0A%20%20%20%20%20%20%20%20session2.balance%20%2B%3D%2050%20%20%23%20Re-apply%20our%20change%0A%20%20%20%20%20%20%20%20session2.save()%0A%20%20%20%20%20%20%20%20print(f%22Session%202%3A%20Now%20added%2050%2C%20new%20balance%20%3D%20%7Bsession2.balance%7D%22)%0A%0A%20%20%20%20%23%20Final%20result%3A%20both%20changes%20were%20applied!%0A%20%20%20%20final_account%20%3D%20Account.from_id(account._id)%0A%20%20%20%20print(f%22%5CnFinal%20balance%3A%20%7Bfinal_account.balance%7D%20(started%20at%201000%2C%20added%20100%20%2B%2050)%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.%20Checking%20Version%20Before%20Save%0A%0A%20%20%20%20You%20can%20check%20if%20your%20model%20is%20stale%20before%20attempting%20to%20save%3A%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(Account)%3A%0A%20%20%20%20%23%20Create%20and%20load%0A%20%20%20%20check_acc%20%3D%20Account(owner%3D%22Eve%22%2C%20balance%3D500)%0A%20%20%20%20check_acc.save()%0A%20%20%20%20loaded%20%3D%20Account.from_id(check_acc._id)%0A%0A%20%20%20%20%23%20Someone%20else%20modifies%20it%0A%20%20%20%20check_acc.balance%20%3D%20600%0A%20%20%20%20check_acc.save()%0A%0A%20%20%20%20%23%20Check%20the%20version%0A%20%20%20%20print(f%22Loaded%20version%3A%20%7Bloaded._version%7D%22)%0A%20%20%20%20print(f%22Current%20DB%20version%3A%20%7BAccount.from_id(loaded._id)._version%7D%22)%0A%0A%20%20%20%20%23%20You%20can%20compare%20before%20saving%0A%20%20%20%20current%20%3D%20Account.from_id(loaded._id)%0A%20%20%20%20if%20loaded._version%20!%3D%20current._version%3A%0A%20%20%20%20%20%20%20%20print(%22Warning%3A%20Record%20has%20been%20modified%20since%20you%20loaded%20it!%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.%20Why%20Use%20Safe%20Models%3F%0A%0A%20%20%20%20Use%20%60SQLerLiteSafeModel%60%20when%3A%0A%0A%20%20%20%20-%20Multiple%20users%2Fprocesses%20might%20edit%20the%20same%20record%0A%20%20%20%20-%20You%20need%20audit%20trails%20of%20changes%0A%20%20%20%20-%20Data%20integrity%20is%20critical%0A%20%20%20%20-%20You're%20building%20collaborative%20features%0A%0A%20%20%20%20Use%20regular%20%60SQLerLiteModel%60%20when%3A%0A%0A%20%20%20%20-%20Records%20are%20only%20edited%20by%20one%20user%20at%20a%20time%0A%20%20%20%20-%20You%20don't%20need%20version%20tracking%0A%20%20%20%20-%20Simplicity%20is%20more%20important%20than%20conflict%20detection%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%20Summary%0A%0A%20%20%20%20Safe%20Models%20provide%20optimistic%20locking%20for%20concurrent%20access%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%60SQLerLiteSafeModel%60%20%7C%20Base%20class%20with%20%60_version%60%20tracking%20%7C%0A%20%20%20%20%7C%20%60StaleVersionError%60%20%7C%20Raised%20when%20saving%20with%20outdated%20version%20%7C%0A%20%20%20%20%7C%20%60.refresh()%60%20%7C%20Reload%20latest%20data%20from%20database%20%7C%0A%0A%20%20%20%20**Best%20Practices%3A**%0A%20%20%20%20-%20Use%20safe%20models%20for%20data%20that%20might%20be%20edited%20concurrently%0A%20%20%20%20-%20Catch%20%60StaleVersionError%60%20and%20implement%20retry%20logic%0A%20%20%20%20-%20Keep%20the%20refresh-modify-save%20cycle%20short%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%60SQLerLiteSafeModel%60%20instead%20of%20%60SQLerSafeModel%60%0A%20%20%20%20-%20Works%20identically%20otherwise!%0A%0A%20%20%20%20**Next%20up%3A**%20Tour%2004%20covers%20Transactions!%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