Transaction.h

Go to the documentation of this file.

/*
* This file is part of Project SkyFire https://www.projectskyfire.org.
* See LICENSE.md file for Copyright information
*/
 
#ifndef _TRANSACTION_H
#define _TRANSACTION_H
 
#include "Platform/Threading.h"
#include "SQLOperation.h"
 
//- Forward declare (don't include header to prevent circular includes)
class PreparedStatement;

class Transaction
{
    friend class TransactionTask;
    friend class MySQLConnection;
 
    template <typename T>
    friend class DatabaseWorkerPool;
 
public:
    Transaction() : _cleanedUp(false) { }
    ~Transaction() { Cleanup(); }
 
    void Append(PreparedStatement* statement);
    void Append(const char* sql);
    void PAppend(const char* sql, ...);
 
    size_t GetSize() const { return m_queries.size(); }
 
protected:
    void Cleanup();
    std::list<SQLElementData> m_queries;
 
private:
    bool _cleanedUp;
};
 
typedef Skyfire::AutoPtr<Transaction, Skyfire::Mutex> SQLTransaction;

class TransactionTask : public SQLOperation
{
    template <class T> friend class DatabaseWorkerPool;
    friend class DatabaseWorker;
 
public:
    TransactionTask(SQLTransaction trans) : m_trans(trans) { };
    ~TransactionTask() { };
 
protected:
    bool Execute();
 
    SQLTransaction m_trans;
};
 
#endif