1 files changed, 10 insertions, 1 deletions
diff --git a/src/server/shared/Database/MySQLConnection.cpp b/src/server/shared/Database/MySQLConnection.cpp
index 00777d29ac8..47eeea3646a 100644
--- a/src/server/shared/Database/MySQLConnection.cpp
+++ b/src/server/shared/Database/MySQLConnection.cpp
@@ -335,4 +335,13 @@ void MySQLConnection::PrepareStatement(uint32 index, const char* sql)
     MySQLPreparedStatement* mStmt = new MySQLPreparedStatement(stmt);
     m_stmts[index] = mStmt;
 }
-    
-\ No newline at end of file
+
+PreparedResultSet* MySQLConnection::Query(PreparedStatement* stmt)
+{
+    this->Execute(stmt);
+    if (mysql_more_results(m_Mysql))
+    {
+        mysql_next_result(m_Mysql);
+    }
+    return new PreparedResultSet(stmt->m_stmt->GetSTMT());
+}
+\ No newline at end of file