A thread safe queue worker that executes SQL for multi-threaded applications.
Project description
Sqlite3 Execution Queue
A thread safe queue worker that executes SQL for multi-threaded applications.
Hierarchy
sqlqueue
'---- SqlQueue()
|---- sql()
|---- _sql()
|---- commit()
'---- stop()
Example
python
from sqlq import *
# specify the db file, relative or absolute path
sqlqueue = SqlQueue(r"db.db")
# run benchmark
# this example shows how sqlq is used
# SQL should not be executed frequently
# see next example for sqlq usage
r = (1, 5, 10, 50, 100, 200)
r = (50,)
for l in r:
tw = ThreadWrapper(threading.Semaphore(l))
starttime = time.time()
for i in range(l):
def job(i):
sqlqueue._sql(threading.get_ident(), "INSERT INTO test VALUES (?);", (str(i),))
tw.add(job, args=args(i))
tw.wait()
p(l, (time.time()-starttime)/l, time.time()-starttime)
# p(sql.sql("SELECT * FROM test;"))
tw = ThreadWrapper(threading.Semaphore(l))
starttime = time.time()
for i in range(l):
def job(i):
sqlqueue._sql(threading.get_ident(), f"DELETE FROM test WHERE a = ?;", (str(i),))
tw.add(job, args=args(i))
tw.wait()
p(l, (time.time()-starttime)/l, time.time()-starttime)
starttime = time.time()
for i in range(l):
sqlqueue.sql("INSERT INTO test VALUES (?);", (str(i),))
p(l, (time.time()-starttime)/l, time.time()-starttime)
# p(sql.sql("SELECT * FROM test;"))
starttime = time.time()
for i in range(l):
sqlqueue.sql(f"DELETE FROM test WHERE a = ?;", (str(i),))
p(l, (time.time()-starttime)/l, time.time()-starttime)
p()
sqlqueue.commit()
# SQL execution modes
SqlQueue().sql("SELECT * FROM table;")
SqlQueue().sql("INSERT INTO table VALUES (?);", (0,))
SqlQueue().sql("INSERT INTO table VALUES (?);", ((0,),(0,)))
SqlQueue().sql('''
CREATE TABLE "tablea" ("a" TEXT);
DELETE TABLE "table";
''')
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
sqlq-0.0.3.tar.gz
(3.8 kB
view hashes)
Built Distribution
sqlq-0.0.3-py3-none-any.whl
(15.9 kB
view hashes)