(sqlStatement, *args)
| 6 | sqlLock = threading.Lock() |
| 7 | |
| 8 | def sqlQuery(sqlStatement, *args): |
| 9 | sqlLock.acquire() |
| 10 | sqlSubmitQueue.put(sqlStatement) |
| 11 | |
| 12 | if args == (): |
| 13 | sqlSubmitQueue.put('') |
| 14 | elif type(args[0]) in [list, tuple]: |
| 15 | sqlSubmitQueue.put(args[0]) |
| 16 | else: |
| 17 | sqlSubmitQueue.put(args) |
| 18 | |
| 19 | queryreturn, rowcount = sqlReturnQueue.get() |
| 20 | sqlLock.release() |
| 21 | |
| 22 | return queryreturn |
| 23 | |
| 24 | |
| 25 | def sqlExecuteChunked(sqlStatement, idCount, *args): |
no test coverage detected