mirror of
https://github.com/VCMP-SqMod/SqMod.git
synced 2025-02-12 07:47:12 +01:00
4a6bfc086c
Switched to POCO library for unified platform/library interface. Deprecated the external module API. It was creating more problems than solving. Removed most built-in libraries in favor of system libraries for easier maintenance. Cleaned and secured code with help from static analyzers.
125 lines
2.0 KiB
C++
125 lines
2.0 KiB
C++
//
|
|
// Transaction.cpp
|
|
//
|
|
// 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 (Poco::Exception& exc)
|
|
{
|
|
if (_pLogger)
|
|
_pLogger->error("Error while rolling back database transaction: %s", exc.displayText());
|
|
}
|
|
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->log(ex);
|
|
}
|
|
|
|
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
|