robusttransaction.hxx

/* Definition of the pqxx::robusttransaction class.
 *
 * pqxx::robusttransaction is a slower but safer transaction class.
 *
 * DO NOT INCLUDE THIS FILE DIRECTLY; include pqxx/robusttransaction 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_ROBUSTTRANSACTION
#define PQXX_H_ROBUSTTRANSACTION

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

#include "pqxx/dbtransaction.hxx"

namespace pqxx::internal
{
class PQXX_LIBEXPORT PQXX_NOVTABLE basic_robusttransaction
        : public dbtransaction
{
public:
  virtual ~basic_robusttransaction() override = 0;

protected:
  basic_robusttransaction(connection &c, char const begin_command[]);

private:
  using IDType = unsigned long;

  std::string m_conn_string;
  std::string m_xid;
  int m_backendpid = -1;

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


namespace pqxx
{

template<isolation_level ISOLATION = read_committed>
class robusttransaction final : public internal::basic_robusttransaction
{
public:
  explicit robusttransaction(
    connection &c, std::string_view name = std::string_view{}) :
          namedclass{"robusttransaction", name},
          internal::basic_robusttransaction{
            c,
            pqxx::internal::begin_cmd<ISOLATION, write_policy::read_write>.c_str()}
  {}

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

} // namespace pqxx

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