rendered paste body#ifdef _SQL_TRANSACTIONbool MySQLDatabase::StartTransaction(){ const char* QueryString = "BEGIN"; if(mQueryThread == 0) { // No query thread. // Assume we're dealing with a normal query. mSearchMutex.acquire(); uint32 Connection = GetConnection(); mSearchMutex.release(); strcpy(QueryBuffer[Connection], QueryString); bool Result = SendQuery(Connection, QueryBuffer[Connection], false); InUseMarkers[Connection].release(); return Result; } DelayedQueryBufferMutex.acquire(); strcpy(QueryBuffer[Connection], QueryString); mQueryThread->AddQuery(DelayedQueryBuffer); DelayedQueryBufferMutex.release(); return true;} bool MySQLDatabase::EndTransaction(){ const char* QueryString = "COMMIT"; if(mQueryThread == 0) { // No query thread. // Assume we're dealing with a normal query. mSearchMutex.acquire(); uint32 Connection = GetConnection(); mSearchMutex.release(); strcpy(QueryBuffer[Connection], QueryString); bool Result = SendQuery(Connection, QueryBuffer[Connection], false); InUseMarkers[Connection].release(); return Result; } DelayedQueryBufferMutex.acquire(); strcpy(QueryBuffer[Connection], QueryString); mQueryThread->AddQuery(DelayedQueryBuffer); DelayedQueryBufferMutex.release(); return true;}#endif //_SQL_TRANSACTION