tour 10 db operations

%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%22sqler%22%2C%20%22marimo%22%5D%0A%23%20%2F%2F%2F%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%0Adef%20_(mo)%3A%0A%20%20%20%20mo.md(r%22%22%22%0A%20%20%20%20%23%20SQLer%20Tour%3A%20Database%20Operations%0A%0A%20%20%20%20This%20notebook%20covers%20SQLer's%20database%20operations%20for%20production%20use%0A%20%20%20%20including%20health%20checks%2C%20statistics%2C%20and%20maintenance.%0A%0A%20%20%20%20You'll%20learn%3A%0A%0A%20%20%20%201.%20Health%20checks%20for%20monitoring%0A%20%20%20%202.%20Database%20statistics%0A%20%20%20%203.%20Vacuum%20(reclaim%20space)%0A%20%20%20%204.%20Checkpoint%20(WAL%20mode)%0A%20%20%20%205.%20Registry%20and%20table%20management%0A%0A%20%20%20%20Let's%20explore!%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.%20Setting%20Up%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_()%3A%0A%20%20%20%20from%20sqler%20import%20SQLerDB%2C%20SQLerModel%0A%20%20%20%20from%20sqler.ops%20import%20(%0A%20%20%20%20%20%20%20%20get_stats%2C%0A%20%20%20%20%20%20%20%20health_check%2C%0A%20%20%20%20%20%20%20%20is_healthy%2C%0A%20%20%20%20%20%20%20%20vacuum%2C%0A%20%20%20%20)%0A%0A%20%20%20%20db%20%3D%20SQLerDB.in_memory()%0A%20%20%20%20print(%22Database%20connected!%22)%0A%20%20%20%20print(%22%5CnOperations%20available%3A%22)%0A%20%20%20%20print(%22%20%20-%20health_check()%3A%20Detailed%20health%20status%22)%0A%20%20%20%20print(%22%20%20-%20is_healthy()%3A%20Quick%20boolean%20check%22)%0A%20%20%20%20print(%22%20%20-%20get_stats()%3A%20Database%20statistics%22)%0A%20%20%20%20print(%22%20%20-%20vacuum()%3A%20Reclaim%20disk%20space%22)%0A%20%20%20%20print(%22%20%20-%20checkpoint()%3A%20WAL%20checkpoint%22)%0A%20%20%20%20return%20SQLerModel%2C%20db%2C%20get_stats%2C%20health_check%2C%20is_healthy%2C%20vacuum%0A%0A%0A%40app.cell%0Adef%20_(SQLerModel%2C%20db)%3A%0A%20%20%20%20class%20User(SQLerModel)%3A%0A%20%20%20%20%20%20%20%20_table%20%3D%20%22users%22%0A%20%20%20%20%20%20%20%20name%3A%20str%0A%20%20%20%20%20%20%20%20email%3A%20str%0A%0A%20%20%20%20User.set_db(db)%0A%0A%20%20%20%20%23%20Create%20some%20data%0A%20%20%20%20for%20_i%20in%20range(10)%3A%0A%20%20%20%20%20%20%20%20User(name%3Df%22User%7B_i%7D%22%2C%20email%3Df%22user%7B_i%7D%40example.com%22).save()%0A%0A%20%20%20%20print(f%22Created%20%7BUser.query().count()%7D%20users%22)%0A%20%20%20%20return%20(User%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%202.%20Health%20Checks%0A%0A%20%20%20%20Use%20health%20checks%20for%20monitoring%20and%20liveness%20probes%3A%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(db%2C%20health_check)%3A%0A%20%20%20%20%23%20Detailed%20health%20check%0A%20%20%20%20_status%20%3D%20health_check(db)%0A%0A%20%20%20%20print(%22Health%20Check%20Result%3A%22)%0A%20%20%20%20print(f%22%20%20Healthy%3A%20%7B_status.healthy%7D%22)%0A%20%20%20%20print(f%22%20%20Latency%3A%20%7B_status.latency_ms%3A.2f%7Dms%22)%0A%20%20%20%20print(f%22%20%20Message%3A%20%7B_status.message%7D%22)%0A%20%20%20%20print(f%22%20%20Timestamp%3A%20%7B_status.timestamp%7D%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(db%2C%20is_healthy)%3A%0A%20%20%20%20%23%20Quick%20boolean%20check%20for%20liveness%20probes%0A%20%20%20%20_healthy%20%3D%20is_healthy(db)%0A%20%20%20%20print(f%22is_healthy(db)%20%3D%20%7B_healthy%7D%22)%0A%0A%20%20%20%20%23%20Use%20in%20health%20endpoints%3A%0A%20%20%20%20%23%20if%20not%20is_healthy(db)%3A%0A%20%20%20%20%23%20%20%20%20%20return%20%7B%22status%22%3A%20%22unhealthy%22%7D%2C%20503%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%203.%20Database%20Statistics%0A%0A%20%20%20%20Get%20detailed%20statistics%20about%20your%20database%3A%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(db%2C%20get_stats)%3A%0A%20%20%20%20_stats%20%3D%20get_stats(db)%0A%0A%20%20%20%20print(%22Database%20Statistics%3A%22)%0A%20%20%20%20print(f%22%20%20Page%20count%3A%20%7B_stats.page_count%7D%22)%0A%20%20%20%20print(f%22%20%20Page%20size%3A%20%7B_stats.page_size%7D%20bytes%22)%0A%20%20%20%20print(f%22%20%20Size%3A%20%7B_stats.size_bytes%7D%20bytes%22)%0A%20%20%20%20print(f%22%20%20WAL%20size%3A%20%7B_stats.wal_size_bytes%7D%20bytes%22)%0A%20%20%20%20print(f%22%20%20Freelist%3A%20%7B_stats.freelist_count%7D%20pages%22)%0A%20%20%20%20print(f%22%20%20Tables%3A%20%7B_stats.table_count%7D%22)%0A%20%20%20%20print(f%22%20%20Indexes%3A%20%7B_stats.index_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%204.%20Registry%0A%0A%20%20%20%20SQLer%20maintains%20a%20registry%20of%20all%20models%20bound%20to%20tables%3A%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_()%3A%0A%20%20%20%20from%20sqler%20import%20resolve%2C%20tables%0A%0A%20%20%20%20%23%20List%20all%20registered%20tables%20(returns%20dict%5Bstr%2C%20type%5D)%0A%20%20%20%20_registry%20%3D%20tables()%0A%20%20%20%20print(f%22Registered%20tables%3A%20%7Blist(_registry.keys())%7D%22)%0A%0A%20%20%20%20%23%20Resolve%20a%20model%20by%20table%20name%0A%20%20%20%20for%20_table%2C%20_cls%20in%20_registry.items()%3A%0A%20%20%20%20%20%20%20%20print(f%22%20%20%7B_table%7D%20-%3E%20%7B_cls.__name__%7D%22)%0A%0A%20%20%20%20%23%20You%20can%20also%20resolve%20by%20name%0A%20%20%20%20_user_cls%20%3D%20resolve(%22users%22)%0A%20%20%20%20print(f%22%5Cnresolve('users')%20%3D%20%7B_user_cls%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.%20Vacuum%20(Reclaim%20Space)%0A%0A%20%20%20%20After%20deleting%20records%2C%20use%20vacuum%20to%20reclaim%20disk%20space%3A%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(User%2C%20db%2C%20get_stats%2C%20vacuum)%3A%0A%20%20%20%20%23%20Check%20initial%20size%0A%20%20%20%20_before%20%3D%20get_stats(db)%0A%20%20%20%20print(f%22Before%3A%20%7B_before.size_bytes%7D%20bytes%2C%20%7B_before.freelist_count%7D%20free%20pages%22)%0A%0A%20%20%20%20%23%20Delete%20some%20records%0A%20%20%20%20for%20_i%20in%20range(5)%3A%0A%20%20%20%20%20%20%20%20_user%20%3D%20User.from_id(_i%20%2B%201)%0A%20%20%20%20%20%20%20%20if%20_user%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20_user.delete()%0A%0A%20%20%20%20print(f%22Deleted%205%20users%2C%20now%20have%20%7BUser.query().count()%7D%20users%22)%0A%0A%20%20%20%20%23%20Vacuum%20to%20reclaim%20space%0A%20%20%20%20_duration%20%3D%20vacuum(db)%0A%20%20%20%20print(f%22Vacuumed%20database%20in%20%7B_duration%3A.2f%7Dms%22)%0A%0A%20%20%20%20_after%20%3D%20get_stats(db)%0A%20%20%20%20print(f%22After%3A%20%7B_after.size_bytes%7D%20bytes%2C%20%7B_after.freelist_count%7D%20free%20pages%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.%20Pagination%0A%0A%20%20%20%20For%20large%20datasets%2C%20use%20pagination%3A%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(SQLerModel%2C%20db)%3A%0A%20%20%20%20class%20Product(SQLerModel)%3A%0A%20%20%20%20%20%20%20%20_table%20%3D%20%22products%22%0A%20%20%20%20%20%20%20%20name%3A%20str%0A%20%20%20%20%20%20%20%20price%3A%20float%0A%0A%20%20%20%20Product.set_db(db)%0A%0A%20%20%20%20%23%20Create%20many%20products%0A%20%20%20%20for%20_i%20in%20range(25)%3A%0A%20%20%20%20%20%20%20%20Product(name%3Df%22Product%20%7B_i%7D%22%2C%20price%3D_i%20*%2010.0).save()%0A%0A%20%20%20%20print(f%22Created%20%7BProduct.query().count()%7D%20products%22)%0A%20%20%20%20return%20(Product%2C)%0A%0A%0A%40app.cell%0Adef%20_(Product)%3A%0A%20%20%20%20%23%20Manual%20pagination%20with%20limit%2Foffset%0A%20%20%20%20_page_size%20%3D%205%0A%0A%20%20%20%20print(%22Manual%20pagination%20(limit%2Foffset)%3A%22)%0A%20%20%20%20for%20_page%20in%20range(3)%3A%0A%20%20%20%20%20%20%20%20_offset%20%3D%20_page%20*%20_page_size%0A%20%20%20%20%20%20%20%20_results%20%3D%20Product.query().limit(_page_size).offset(_offset).all()%0A%20%20%20%20%20%20%20%20print(f%22%20%20Page%20%7B_page%20%2B%201%7D%3A%20%7B%5Bp.name%20for%20p%20in%20_results%5D%7D%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(Product)%3A%0A%20%20%20%20%23%20Using%20paginate()%20for%20convenience%20(returns%20dicts)%0A%20%20%20%20_page%20%3D%20Product.query().paginate(page%3D1%2C%20per_page%3D5)%0A%0A%20%20%20%20print(%22%5CnUsing%20paginate()%3A%22)%0A%20%20%20%20print(f%22%20%20Total%20items%3A%20%7B_page.total%7D%22)%0A%20%20%20%20print(f%22%20%20Total%20pages%3A%20%7B_page.total_pages%7D%22)%0A%20%20%20%20print(f%22%20%20Current%20page%3A%20%7B_page.page%7D%22)%0A%20%20%20%20print(f%22%20%20Has%20next%3A%20%7B_page.has_next%7D%22)%0A%20%20%20%20print(f%22%20%20Items%3A%20%7B%5Bp%5B'name'%5D%20for%20p%20in%20_page.items%5D%7D%22)%0A%0A%20%20%20%20%23%20Get%20next%20page%0A%20%20%20%20if%20_page.has_next%3A%0A%20%20%20%20%20%20%20%20_page2%20%3D%20Product.query().paginate(page%3D2%2C%20per_page%3D5)%0A%20%20%20%20%20%20%20%20print(f%22%5CnPage%202%3A%20%7B%5Bp%5B'name'%5D%20for%20p%20in%20_page2.items%5D%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.%20Logging%20Queries%0A%0A%20%20%20%20Enable%20query%20logging%20for%20debugging%3A%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(Product)%3A%0A%20%20%20%20from%20sqler.logging%20import%20query_logger%0A%20%20%20%20from%20sqler.query%20import%20SQLerField%20as%20F%0A%0A%20%20%20%20%23%20Enable%20the%20global%20query%20logger%20(used%20by%20adapters)%0A%20%20%20%20query_logger.enable()%0A%20%20%20%20query_logger.clear()%20%20%23%20Clear%20any%20previous%20logs%0A%0A%20%20%20%20%23%20Run%20some%20queries%20-%20these%20get%20logged%20automatically%0A%20%20%20%20Product.query().filter(F(%22price%22)%20%3E%20100).all()%0A%20%20%20%20Product.query().count()%0A%0A%20%20%20%20%23%20Get%20logged%20queries%0A%20%20%20%20print(%22Recent%20queries%3A%22)%0A%20%20%20%20for%20_log%20in%20query_logger.logs%5B-5%3A%5D%3A%0A%20%20%20%20%20%20%20%20_sql_preview%20%3D%20_log.sql%5B%3A60%5D%20if%20len(_log.sql)%20%3E%2060%20else%20_log.sql%0A%20%20%20%20%20%20%20%20print(f%22%20%20%7B_sql_preview%7D...%20(%7B_log.duration_ms%3A.2f%7Dms)%22)%0A%0A%20%20%20%20%23%20Get%20statistics%0A%20%20%20%20_stats%20%3D%20query_logger.get_stats()%0A%20%20%20%20print(f%22%5CnStats%3A%20%7B_stats%5B'count'%5D%7D%20queries%2C%20avg%20%7B_stats%5B'avg_time_ms'%5D%3A.2f%7Dms%22)%0A%0A%20%20%20%20query_logger.disable()%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%20SQLer%20database%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%60health_check(db)%60%20%7C%20Detailed%20health%20status%20%7C%0A%20%20%20%20%7C%20%60is_healthy(db)%60%20%7C%20Quick%20boolean%20check%20%7C%0A%20%20%20%20%7C%20%60get_stats(db)%60%20%7C%20Database%20statistics%20%7C%0A%20%20%20%20%7C%20%60vacuum(db)%60%20%7C%20Reclaim%20disk%20space%20%7C%0A%20%20%20%20%7C%20%60checkpoint(db)%60%20%7C%20WAL%20checkpoint%20%7C%0A%20%20%20%20%7C%20%60backup(db%2C%20path)%60%20%7C%20Online%20backup%20%7C%0A%20%20%20%20%7C%20%60restore(path)%60%20%7C%20Restore%20from%20backup%20%7C%0A%20%20%20%20%7C%20%60tables()%60%20%7C%20List%20registered%20tables%20%7C%0A%20%20%20%20%7C%20%60resolve(table)%60%20%7C%20Get%20model%20for%20table%20%7C%0A%20%20%20%20%7C%20%60.paginate(page%2C%20size)%60%20%7C%20Pagination%20helper%20%7C%0A%20%20%20%20%7C%20%60QueryLogger%60%20%7C%20Query%20debugging%20%7C%0A%0A%20%20%20%20**For%20production%3A**%0A%20%20%20%20-%20Use%20%60is_healthy()%60%20for%20Kubernetes%20liveness%20probes%0A%20%20%20%20-%20Schedule%20regular%20%60vacuum()%60%20for%20disk%20cleanup%0A%20%20%20%20-%20Monitor%20with%20%60get_stats()%60%20for%20growth%20tracking%0A%20%20%20%20-%20Enable%20%60QueryLogger%60%20for%20debugging%20slow%20queries%0A%0A%20%20%20%20**Next%20up%3A**%20Tour%2011%20covers%20Metrics%20%26%20Caching!%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