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

Use recursive thread mutex for SQL transaction queue

Browse Source 
--HG--
branch : trunk
This commit is contained in:
thenecromancer
2010-02-01 10:23:18 +01:00
parent adfce8fec4
commit fd5f1e554d
2 changed files with 9 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/shared/Database/SqlOperations.cpp
View File

@@ -33,22 +33,17 @@ void SqlStatement::Execute(Database *db)
void SqlTransaction::Execute(Database *db)
{
if(m_queue.empty())
return;
const char *sql;
db->DirectExecute("START TRANSACTION");
while(!m_queue.empty())
while(m_queue.next(sql))
{
char const *sql = m_queue.front();
m_queue.pop();
if(!db->DirectExecute(sql))
{
free((void*)const_cast<char*>(sql));
db->DirectExecute("ROLLBACK");
while(!m_queue.empty())
while(m_queue.next(sql))
{
free((void*)const_cast<char*>(m_queue.front()));
m_queue.pop();
free((void*)const_cast<char*>(sql));
}
return;
}

7
src/shared/Database/SqlOperations.h
View File

@@ -24,6 +24,7 @@
#include "Common.h"
#include "ace/Thread_Mutex.h"
#include "ace/Recursive_Thread_Mutex.h"
#include "LockedQueue.h"
#include <queue>
#include "Utilities/Callback.h"
@@ -56,11 +57,13 @@ class SqlStatement : public SqlOperation
class SqlTransaction : public SqlOperation
{
typedef ACE_Based::LockedQueue<const char *, ACE_Recursive_Thread_Mutex> LockedQueue;
private:
std::queue<const char *> m_queue;
LockedQueue m_queue;
public:
SqlTransaction() {}
void DelayExecute(const char *sql) { m_queue.push(strdup(sql)); }
void DelayExecute(const char *sql) { m_queue.add(strdup(sql)); }
void Execute(Database *db);
};