diff --git a/source/common/database.cpp b/source/common/database.cpp
index 8369701..866676c 100644
--- a/source/common/database.cpp
+++ b/source/common/database.cpp
@@ -271,7 +271,7 @@ void Query::AddQueryAsync(int32 queryID, Database* db, QUERY_TYPE type, const ch
 	va_end(args);
 	query = string(buffer);
 
-	Query* asyncQuery = new Query(this, queryID);
+	Query* asyncQuery = new Query(this, queryID, query);
 
 	safe_delete_array(buffer);
 
diff --git a/source/common/database.h b/source/common/database.h
index 52115e2..c5aa88f 100644
--- a/source/common/database.h
+++ b/source/common/database.h
@@ -109,7 +109,7 @@ public:
 		memset(errbuf, 0, sizeof(errbuf));
 		queryID = 0;
 	}
-	Query(Query* queryPtr, int32 in_id) {
+	Query(Query* queryPtr, int32 in_id, std::string in_query) {
 		result = 0;
 		affected_rows = 0;
 		last_insert_id = 0;
@@ -121,7 +121,7 @@ public:
 		escaped_data1 = 0;
 		multiple_results = 0;
 		memset(errbuf, 0, sizeof(errbuf));
-		query = string(queryPtr->GetQuery());
+		query = std::move(in_query);
 		in_type = queryPtr->GetQueryType();
 		queryID = in_id;
 	}