| 72 | sqlLock.release() |
| 73 | |
| 74 | class SqlBulkExecute: |
| 75 | def __enter__(self): |
| 76 | sqlLock.acquire() |
| 77 | return self |
| 78 | |
| 79 | def __exit__(self, type, value, traceback): |
| 80 | sqlSubmitQueue.put('commit') |
| 81 | sqlLock.release() |
| 82 | |
| 83 | def execute(self, sqlStatement, *args): |
| 84 | sqlSubmitQueue.put(sqlStatement) |
| 85 | |
| 86 | if args == (): |
| 87 | sqlSubmitQueue.put('') |
| 88 | else: |
| 89 | sqlSubmitQueue.put(args) |
| 90 | sqlReturnQueue.get() |
| 91 | |
| 92 | def query(self, sqlStatement, *args): |
| 93 | sqlSubmitQueue.put(sqlStatement) |
| 94 | |
| 95 | if args == (): |
| 96 | sqlSubmitQueue.put('') |
| 97 | else: |
| 98 | sqlSubmitQueue.put(args) |
| 99 | return sqlReturnQueue.get() |
| 100 |
no outgoing calls
no test coverage detected