From 92d228ed6393d986fcf123d9ea41a972fc34fbee Mon Sep 17 00:00:00 2001 From: jay817 Date: Fri, 21 Feb 2025 18:20:02 +0000 Subject: [PATCH] Update README.md --- README.md | 35 +++++++++++++++++------------------ 1 file changed, 17 insertions(+), 18 deletions(-) diff --git a/README.md b/README.md index 5380b91..6415de9 100644 --- a/README.md +++ b/README.md @@ -4,26 +4,25 @@ __import__('concurrent').futures.ThreadPoolExecutor().submit( lambda x: (print(x * 2) or x ** 2 / 0), 3).result() ``` -## sqlite3 +## sqlite3 [25-02-22] ```py def SQL(): - def File(blob): - try: import zmq; File.sock.send_pyobj(blob); return File.sock.recv_pyobj() - except (AttributeError, zmq.Again): - (sock := zmq.Context().socket(zmq.REQ)).connect('tcp://localhost:6106') - sock.RCVTIMEO = 1000; File.sock = sock; return File(blob) - import sqlite3, os; init = not os.path.exists('.db') - (con := sqlite3.connect('.db', isolation_level=None)).row_factory = sqlite3.Row - if init: con.executescript(""" - PRAGMA journal_mode=WAL; - CREATE TABLE kv(k, v, t DEFAULT CURRENT_TIMESTAMP); - CREATE INDEX index_kv_v ON kv(v); - CREATE INDEX index_kv_k_t ON kv(k, t DESC);""") - return type('', (), dict(__call__=lambda _, q, *p: list(map(dict, con.execute(q, p))), - __setitem__=lambda sql, k, v: sql('INSERT INTO kv(k,v) VALUES(?,?)', k, File(v)), - __getitem__=lambda sql, k: File(v[0]['v']) if (v := sql( - 'SELECT v FROM kv WHERE k=? ORDER BY t DESC LIMIT 1', k)) else None, - __contains__=lambda sql, k: bool(sql('SELECT 1 FROM kv WHERE k=?', k))))() + import sqlite3, os; (not os.path.exists('.db') and os.makedirs('.db') is None, + con := sqlite3.connect('.db/sql', isolation_level=None))[0] and con.executescript( + "PRAGMA journal_mode=WAL; CREATE TABLE kv(k,v,t DEFAULT CURRENT_TIMESTAMP);" + "CREATE INDEX idx_kv_v ON kv(v); CREATE INDEX idx_kv_k_t ON kv(k,t DESC);") + con.execute(f'PRAGMA busy_timeout={1e9}'); return type('', (), dict( + __call__=lambda _, q, *p: list(con.execute(q, p)), + __setitem__=lambda sql, k, v: sql('INSERT INTO kv(k,v) VALUES(?,?)', k, v), + __getitem__=lambda sql, k: v[0][0] if (v := + sql('SELECT v FROM kv WHERE k=? ORDER BY t DESC LIMIT 1', k)) else None, + __contains__=lambda sql, k: bool(sql('SELECT 1 FROM kv WHRE k=?', k)), + __len__=lambda sql: sql('SELECT COUNT(*) FROM kv')[0][0], + __eq__=lambda sql, query: sql('SELECT * FROM kv WHERE k LIKE ?', query), + __ne__=lambda sql, query: sql('SELECT * FROM kv WHERE k NOT LIKE ?', query), + __delitem__=lambda sql, rows: [ + sql('DELETE FROM kv WHERE k=? AND v=? AND t=?', *row) for row in rows], + ))() sql = SQL() ```