Move duplicated sql code into helper

This commit is contained in:
Grant T. Olson 2013-08-26 20:00:30 -04:00 committed by Grant T. Olson
parent 61c9251183
commit edf9101eae
1 changed files with 33 additions and 0 deletions

33
src/helper_sql.py Normal file
View File

@ -0,0 +1,33 @@
import shared
def sqlQuery(sqlStatement, *args):
shared.sqlLock.acquire()
shared.sqlSubmitQueue.put(sqlStatement)
if args == ():
shared.sqlSubmitQueue.put('')
else:
shared.sqlSubmitQueue.put(args)
queryreturn = shared.sqlReturnQueue.get()
shared.sqlLock.release()
return queryreturn
def sqlExecute(sqlStatement, *args):
shared.sqlLock.acquire()
shared.sqlSubmitQueue.put(sqlStatement)
if args == ():
shared.sqlSubmitQueue.put('')
else:
shared.sqlSubmitQueue.put(args)
shared.sqlReturnQueue.get()
shared.sqlSubmitQueue.put('commit')
shared.sqlLock.release()
def sqlStoredProcedure(procName):
shared.sqlLock.acquire()
shared.sqlSubmitQueue.put(procName)
shared.sqlLock.release()