dbtransaction.hxx

#ifndef PQXX_H_DBTRANSACTION
#define PQXX_H_DBTRANSACTION

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

#include "pqxx/transaction_base.hxx"

namespace pqxx
{

enum readwrite_policy
{
  read_only,
  read_write
};



class PQXX_LIBEXPORT PQXX_NOVTABLE dbtransaction : public transaction_base
{
public:
  virtual ~dbtransaction();

protected:
  dbtransaction(
        connection_base &,
        const std::string &IsolationString,
        readwrite_policy rw=read_write);

  explicit dbtransaction(
        connection_base &,
        bool direct=true,
        readwrite_policy rw=read_write);


  void start_backend_transaction();

  virtual void do_begin() override;                                     //[t01]
  virtual result do_exec(const char Query[]) override;
  virtual void do_commit() override =0;

  virtual void do_abort() override;                             //[t13]

  static std::string fullname(const std::string &ttype,
        const std::string &isolation);

private:
  std::string m_start_cmd;
};

} // namespace pqxx

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

#endif