aboutsummaryrefslogtreecommitdiff
path: root/src/server/shared/Database/SQLOperation.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/server/shared/Database/SQLOperation.cpp')
-rw-r--r--src/server/shared/Database/SQLOperation.cpp49
1 files changed, 1 insertions, 48 deletions
diff --git a/src/server/shared/Database/SQLOperation.cpp b/src/server/shared/Database/SQLOperation.cpp
index 1cd45a4c0b6..a3eda4b7239 100644
--- a/src/server/shared/Database/SQLOperation.cpp
+++ b/src/server/shared/Database/SQLOperation.cpp
@@ -16,9 +16,9 @@
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*/
-#include "DatabaseEnv.h"
#include "SQLOperation.h"
#include "MySQLConnection.h"
+#include "Log.h"
/*! Basic, ad-hoc queries. */
BasicStatementTask::BasicStatementTask(const char* sql) :
@@ -53,53 +53,6 @@ bool BasicStatementTask::Execute()
return m_conn->Execute(m_sql);
}
-/*! Transactions. */
-TransactionTask::TransactionTask()
-{
-}
-
-TransactionTask::~TransactionTask()
-{
-
-}
-
-void TransactionTask::ForcefulDelete()
-{
- while (!m_queries.empty())
- {
- free((void*)const_cast<char*>(m_queries.front()));
- m_queries.pop();
- }
-}
-
-bool TransactionTask::Execute()
-{
- if (m_queries.empty())
- return false;
-
- const char* sql;
-
- m_conn->BeginTransaction();
- while (!m_queries.empty())
- {
- sql = m_queries.front();
- if (!m_conn->Execute(sql))
- {
- free((void*)const_cast<char*>(sql));
- m_queries.pop();
- m_conn->RollbackTransaction();
- ForcefulDelete();
- return false;
- }
-
- free((void*)const_cast<char*>(sql));
- m_queries.pop();
- }
-
- m_conn->CommitTransaction();
- return true;
-}
-
bool SQLQueryHolder::SetQuery(size_t index, const char *sql)
{
if (m_queries.size() <= index)