diff --git a/src/helper_sql.py b/src/helper_sql.py
new file mode 100644
index 00000000..f32a31d4
--- /dev/null
+++ b/src/helper_sql.py
@@ -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()