Mirror/TrinityCore
1
0
Fork 0
mirror of https://github.com/TrinityCore/TrinityCore.git synced 2026-01-18 16:38:42 +01:00
Code Issues Packages Projects Releases Wiki Activity

Core/DBLayer:

Browse Source 
- Add basic prepared statement interface (without implementation and thus without testing, without resultset support).
- Based on raczman/Albator´s work on TrinityCore3

Build:
- Add sLog define ¨hack¨ in DatbaseWorkerPool.h to fix some more sLog errors temporarily

FYI: Builds on windows

--HG--
branch : trunk
This commit is contained in:
Machiavelli
2010-09-02 20:54:43 +02:00
parent cd182a1e8f
commit 1198591bac
5 changed files with 570 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

78
src/server/shared/Database/MySQLConnection.cpp
View File

@@ -27,6 +27,7 @@
#include "DatabaseEnv.h"
#include "QueryResult.h"
#include "SQLOperation.h"
#include "PreparedStatement.h"
#include "MySQLConnection.h"
#include "DatabaseWorker.h"
#include "Log.h"
@@ -49,6 +50,9 @@ m_Mysql(NULL)
MySQLConnection::~MySQLConnection()
{
for (size_t i = 0; i < m_stmts.size(); ++i)
delete m_stmts[i];
MySQL::Thread_End();
mysql_close(m_Mysql);
}
@@ -181,6 +185,52 @@ bool MySQLConnection::Execute(const char* sql)
return true;
}
bool MySQLConnection::Execute(PreparedStatement* stmt)
{
if (!m_Mysql)
return false;
uint32 index = stmt->m_index;
MySQLPreparedStatement* m_mStmt = GetPreparedStatement(index);
m_mStmt->m_stmt = stmt; // Cross reference them for debug output
stmt->m_stmt = m_mStmt;
{
// guarded block for thread-safe mySQL request
ACE_Guard<ACE_Thread_Mutex> query_connection_guard(m_Mutex);
stmt->BindParameters();
MYSQL_STMT* msql_STMT = m_mStmt->GetSTMT();
MYSQL_BIND* msql_BIND = m_mStmt->GetBind();
#ifdef TRINITY_DEBUG
uint32 _s = getMSTime();
#endif
if (mysql_stmt_bind_param(msql_STMT, msql_BIND))
{
sLog.outSQLDriver("[ERROR]: PreparedStatement (id: %u) error binding params: %s", index, mysql_stmt_error(msql_STMT));
m_mStmt->ClearParameters();
return false;
}
if (mysql_stmt_execute(msql_STMT))
{
sLog.outSQLDriver("[ERROR]: PreparedStatement (id: %u) error executing: %s", index, mysql_stmt_error(msql_STMT));
m_mStmt->ClearParameters();
return false;
}
else
{
#ifdef TRINITY_DEBUG
sLog.outSQLDriver("[%u ms] Prepared SQL: %u", getMSTimeDiff(_s, getMSTime()), index);
#endif
m_mStmt->ClearParameters();
return true;
}
}
}
QueryResult_AutoPtr MySQLConnection::Query(const char* sql)
{
if (!sql)
@@ -257,3 +307,31 @@ void MySQLConnection::CommitTransaction()
{
Execute("COMMIT");
}
MySQLPreparedStatement* MySQLConnection::GetPreparedStatement(uint32 index)
{
return m_stmts[index];
}
void MySQLConnection::PrepareStatement(uint32 index, const char* sql)
{
MYSQL_STMT * stmt = mysql_stmt_init(m_Mysql);
if (!stmt)
{
sLog.outSQLDriver("[ERROR]: In mysql_stmt_init() id: %u, sql: \"%s\"", index, sql);
sLog.outSQLDriver("[ERROR]: %s", mysql_error(m_Mysql));
return;
}
if (mysql_stmt_prepare(stmt, sql, static_cast<unsigned long>(strlen(sql))))
{
mysql_stmt_close(stmt);
sLog.outSQLDriver("[ERROR]: In mysql_stmt_close() id: %u, sql: \"%s\"", index, sql);
sLog.outSQLDriver("[ERROR]: %s", mysql_error(m_Mysql));
return;
}
MySQLPreparedStatement* mStmt = new MySQLPreparedStatement(stmt);
m_stmts[index] = mStmt;
}