ClickHouse/base/mysqlxx/Transaction.h
Ivan b7ef5a699c
Move FastMemcpy to contribs ()
* Get rid of non-existent vectorclass
* Move FastMemcpy to contribs
* Restore comments
* Disable FastMemcpy on non-Linux
* Fix cmake file
* Don't build FastMemcpy for ARM64
* Replace FastMemcpy submodule with its contents
* Fix cmake file
* Move widechar_width to contrib/
* Move sumbur to contrib/
* Move consistent-hashing to contrib/
* Fix UBSan tests
2020-03-13 01:26:16 +03:00

54 lines
969 B
C++

#pragma once
#include <boost/noncopyable.hpp>
#include <mysqlxx/Connection.h>
namespace mysqlxx
{
/** RAII для транзакции. При инициализации, транзакция стартует.
* При уничтожении, если не был вызван метод commit(), будет произведёт rollback.
*/
class Transaction : private boost::noncopyable
{
public:
Transaction(Connection & conn_)
: conn(conn_), finished(false)
{
conn.query("START TRANSACTION").execute();
}
virtual ~Transaction()
{
try
{
if (!finished)
rollback();
}
catch (...)
{
}
}
void commit()
{
conn.query("COMMIT").execute();
finished = true;
}
void rollback()
{
conn.query("ROLLBACK").execute();
finished = true;
}
private:
Connection & conn;
bool finished;
};
}