transaction.hxx

#ifndef PQXX_H_TRANSACTION
#define PQXX_H_TRANSACTION

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

#include "pqxx/dbtransaction.hxx"


/* Methods tested in eg. self-test program test1 are marked with "//[t01]"
 */


namespace pqxx
{

namespace internal
{
class PQXX_LIBEXPORT basic_transaction : public dbtransaction
{
protected:
  basic_transaction(                                                    //[t01]
        connection_base &C,
        const std::string &IsolationLevel,
        readwrite_policy);

private:
  virtual void do_commit() override;                                    //[t01]
};
} // namespace internal




template<
        isolation_level ISOLATIONLEVEL=read_committed,
        readwrite_policy READWRITE=read_write>
class transaction : public internal::basic_transaction
{
public:
  using isolation_tag = isolation_traits<ISOLATIONLEVEL>;


  explicit transaction(connection_base &C, const std::string &TName):   //[t01]
    namedclass(fullname("transaction", isolation_tag::name()), TName),
    internal::basic_transaction(C, isolation_tag::name(), READWRITE)
        { Begin(); }

  explicit transaction(connection_base &C) :                            //[t01]
    transaction(C, "") {}

  virtual ~transaction() noexcept
        { End(); }
};


using work = transaction<>;

using read_transaction = transaction<read_committed, read_only>;


}

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

#endif