transaction.hxx

/* Definition of the pqxx::transaction class.
 * pqxx::transaction represents a standard database transaction.
 *
 * DO NOT INCLUDE THIS FILE DIRECTLY; include pqxx/transaction instead.
 *
 * Copyright (c) 2000-2020, Jeroen T. Vermeulen.
 *
 * See COPYING for copyright license.  If you did not receive a file called
 * COPYING with this source code, please notify the distributor of this
 * mistake, or contact the author.
 */
#ifndef PQXX_H_TRANSACTION
#define PQXX_H_TRANSACTION

#include "pqxx/compiler-public.hxx"
#include "pqxx/internal/compiler-internal-pre.hxx"

#include "pqxx/dbtransaction.hxx"

namespace pqxx::internal
{
class PQXX_LIBEXPORT basic_transaction : public dbtransaction
{
protected:
  basic_transaction(connection &c, char const begin_command[]);

private:
  virtual void do_commit() override;
  virtual void do_abort() override;
};
} // namespace pqxx::internal


namespace pqxx
{


template<
  isolation_level ISOLATION = isolation_level::read_committed,
  write_policy READWRITE = write_policy::read_write>
class transaction final : public internal::basic_transaction
{
public:

  explicit transaction(connection &c, std::string const &tname) :
          namedclass{"transaction", tname},
          internal::basic_transaction(
            c, internal::begin_cmd<ISOLATION, READWRITE>.c_str())
  {}

  explicit transaction(connection &c) : transaction(c, "") {}

  virtual ~transaction() noexcept override { close(); }
};


using work = transaction<>;

using read_transaction =
  transaction<isolation_level::read_committed, write_policy::read_only>;

} // namespace pqxx

#include "pqxx/internal/compiler-internal-post.hxx"
#endif