Method TransactionHandler

libraries/lib-sqlite-helpers/sqlite/Connection.cpp:205–251

}

Error Connection::TransactionHandler(
   Connection& connection, Transaction::TransactionOperation operation,
   Transaction& transaction)
{
   std::string sql;

   const auto& name = transaction.mName;

   switch (operation)
   {
   case Transaction::TransactionOperation::BeginOp:
      sql = std::string("SAVEPOINT ") + name;
      break;
   case Transaction::TransactionOperation::CommitOp:
      sql = std::string("RELEASE SAVEPOINT ") + name;
      break;
   case Transaction::TransactionOperation::RollbackOp:
      sql = std::string("ROLLBACK TO SAVEPOINT ") + name +
            std::string("; RELEASE SAVEPOINT ") + name;
      break;
   }

   auto error = Error(sqlite3_exec(
      connection.mConnection, sql.c_str(), nullptr, nullptr, nullptr));

   if (operation != Transaction::TransactionOperation::BeginOp)
   {
      transaction.mCommitted = true;

      connection.mPendingTransactions.erase(
         std::remove_if(
            connection.mPendingTransactions.begin(),
            connection.mPendingTransactions.end(),
            [tx = &transaction](auto lhs) { return lhs == tx; }),
         connection.mPendingTransactions.end());
   }

   if (error.IsError())
      return error;

   if (operation == Transaction::TransactionOperation::BeginOp)
   {
      connection.mPendingTransactions.push_back(&transaction);
   }

   return {};
}

Result<Statement> Connection::CreateStatement(std::string_view sql) const
{