importpysqlite2.dbapi2assqliteimportQueue,time,thread,osfromthreadingimportThread_threadex=thread.allocate_lock()qthreads=0sqlqueue=Queue.Queue()ConnectCmd="connect"SqlCmd="SQL"StopCmd="stop"classDbCmd:def__init__(self,cmd,params=[]):self.cmd=cmdself.params=paramsclassDbWrapper(Thread):def__init__(self,path,nr):Thread.__init__(self)self.path=pathself.nr=nrdefrun(self):globalqthreadscon=sqlite.connect(self.path)cur=con.cursor()whileTrue:s=sqlqueue.get()print"Conn%d ->%s ->%s"%(self.nr,s.cmd,s.params)ifs.cmd==SqlCmd:commitneeded=Falseres=[]#               s.params is a list to bundle statements into a "transaction"forsqlins.params:cur.execute(sql[0],sql[1])ifnotsql[0].upper().startswith("SELECT"):commitneeded=Trueforrowincur.fetchall():res.append(row)ifcommitneeded:con.commit()s.resultqueue.put(res)else:_threadex.acquire()qthreads-=1_threadex.release()#               allow other threads to stopsqlqueue.put(s)s.resultqueue.put(None)breakdefexecSQL(s):ifs.cmd==ConnectCmd:globalqthreads_threadex.acquire()qthreads+=1_threadex.release()wrap=DbWrapper(s.params,qthreads)wrap.start()elifs.cmd==StopCmd:s.resultqueue=Queue.Queue()sqlqueue.put(s)#       sleep until all threads are stoppedwhileqthreads>0:time.sleep(0.1)else:s.resultqueue=Queue.Queue()sqlqueue.put(s)returns.resultqueue.get()if__name__=="__main__":dbname="test.db"execSQL(DbCmd(ConnectCmd,dbname))execSQL(DbCmd(SqlCmd,[("create table people (name_last, age integer);",())]))#   don't add connections before creating tableexecSQL(DbCmd(ConnectCmd,dbname))#   insert one rowexecSQL(DbCmd(SqlCmd,[("insert into people (name_last, age) values (?, ?);",('Smith',80))]))#   insert two rows in one transactionexecSQL(DbCmd(SqlCmd,[("insert into people (name_last, age) values (?, ?);",('Jones',55)),("insert into people (name_last, age) values (?, ?);",('Gruns',25))]))forpinexecSQL(DbCmd(SqlCmd,[("select * from people",())])):printpexecSQL(DbCmd(StopCmd))os.remove(dbname)