mirror of
https://github.com/pocoproject/poco.git
synced 2024-12-18 04:10:33 +01:00
122 lines
1.9 KiB
C++
122 lines
1.9 KiB
C++
//
|
|
// Transaction.cpp
|
|
//
|
|
// $Id: //poco/Main/Data/src/Transaction.cpp#1 $
|
|
//
|
|
// Library: Data
|
|
// Package: DataCore
|
|
// Module: Transaction
|
|
//
|
|
// Copyright (c) 2006, Applied Informatics Software Engineering GmbH.
|
|
// and Contributors.
|
|
//
|
|
// SPDX-License-Identifier: BSL-1.0
|
|
//
|
|
|
|
|
|
#include "Poco/Data/Transaction.h"
|
|
#include "Poco/Exception.h"
|
|
|
|
|
|
namespace Poco {
|
|
namespace Data {
|
|
|
|
|
|
Transaction::Transaction(Poco::Data::Session& rSession, Poco::Logger* pLogger):
|
|
_rSession(rSession),
|
|
_pLogger(pLogger)
|
|
{
|
|
begin();
|
|
}
|
|
|
|
|
|
Transaction::Transaction(Poco::Data::Session& rSession, bool start):
|
|
_rSession(rSession),
|
|
_pLogger(0)
|
|
{
|
|
if (start) begin();
|
|
}
|
|
|
|
|
|
Transaction::~Transaction()
|
|
{
|
|
try
|
|
{
|
|
if (_rSession.isTransaction())
|
|
{
|
|
try
|
|
{
|
|
if (_pLogger)
|
|
_pLogger->debug("Rolling back transaction.");
|
|
|
|
_rSession.rollback();
|
|
}
|
|
catch (...)
|
|
{
|
|
if (_pLogger)
|
|
_pLogger->error("Error while rolling back database transaction.");
|
|
}
|
|
}
|
|
}
|
|
catch (...)
|
|
{
|
|
poco_unexpected();
|
|
}
|
|
}
|
|
|
|
|
|
void Transaction::begin()
|
|
{
|
|
if (!_rSession.isTransaction())
|
|
_rSession.begin();
|
|
else
|
|
throw InvalidAccessException("Transaction in progress.");
|
|
}
|
|
|
|
|
|
void Transaction::execute(const std::string& sql, bool doCommit)
|
|
{
|
|
if (!_rSession.isTransaction()) _rSession.begin();
|
|
_rSession << sql, Keywords::now;
|
|
if (doCommit) commit();
|
|
}
|
|
|
|
|
|
void Transaction::execute(const std::vector<std::string>& sql)
|
|
{
|
|
try
|
|
{
|
|
std::vector<std::string>::const_iterator it = sql.begin();
|
|
std::vector<std::string>::const_iterator end = sql.end();
|
|
for (; it != end; ++it) execute(*it, it + 1 == end ? true : false);
|
|
return;
|
|
}
|
|
catch (Exception& ex)
|
|
{
|
|
if (_pLogger) _pLogger->error(ex.displayText());
|
|
}
|
|
|
|
rollback();
|
|
}
|
|
|
|
|
|
void Transaction::commit()
|
|
{
|
|
if (_pLogger)
|
|
_pLogger->debug("Committing transaction.");
|
|
|
|
_rSession.commit();
|
|
}
|
|
|
|
|
|
void Transaction::rollback()
|
|
{
|
|
if (_pLogger)
|
|
_pLogger->debug("Rolling back transaction.");
|
|
|
|
_rSession.rollback();
|
|
}
|
|
|
|
|
|
} } // namespace Poco::Data
|