diff --git a/src/server/shared/Database/DatabaseWorkerPool.h b/src/server/shared/Database/DatabaseWorkerPool.h
index e15d50f00e..9b912dd385 100755
--- a/src/server/shared/Database/DatabaseWorkerPool.h
+++ b/src/server/shared/Database/DatabaseWorkerPool.h
@@ -279,6 +279,13 @@ class DatabaseWorkerPool
             PreparedStatementTask* task = new PreparedStatementTask(stmt);
             Enqueue(task);
         }
+		
+        void DirectExecute(PreparedStatement* stmt)
+        {
+            T* t = GetFreeConnection();
+            t->Execute(stmt);
+            t->Unlock();
+        }
 
         void escape_string(std::string& str)
         {