_rSession(rSession),

_pLogger(pLogger)

{

begin();

_rSession(rSession),

_pLogger(0)

{

if (start) begin();

{

if (!_rSession.isTransaction())

_rSession.begin();

else

throw InvalidAccessException("Transaction in progress.");

{

if (!_rSession.isTransaction()) _rSession.begin();

_rSession << sql, Keywords::now;

if (doCommit) commit();

{

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();

{

if (_pLogger)

_pLogger->debug("Committing transaction.");

_rSession.commit();

{

if (_pLogger)

_pLogger->debug("Rolling back transaction.");

_rSession.rollback();