robusttransaction.hxx

Go to the documentation of this file.

/*-------------------------------------------------------------------------
 *
 *   FILE
 *      pqxx/robusttransaction.hxx
 *
 *   DESCRIPTION
 *      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) 2002-2004, Jeroen T. Vermeulen <jtv@xs4all.nl>
 *
 * 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.
 *
 *-------------------------------------------------------------------------
 */
#include "pqxx/dbtransaction"


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


namespace pqxx
{

class PQXX_LIBEXPORT basic_robusttransaction : public dbtransaction
{
public:
  typedef isolation_traits<read_committed> isolation_tag;

  virtual ~basic_robusttransaction() =0;                                //[t16]

protected:

  explicit basic_robusttransaction(connection_base &C,
                                   const PGSTD::string &IsolationLevel,
                                   const PGSTD::string &Name);          //[t16]

private:
  typedef unsigned long IDType;
  IDType m_ID;
  PGSTD::string m_LogTable;
  int m_backendpid;

  virtual void do_begin();                                              //[t18]
  virtual void do_commit();                                             //[t16]
  virtual void do_abort();                                              //[t18]

  void CreateLogTable();
  void CreateTransactionRecord();
  void DeleteTransactionRecord(IDType ID) throw ();
  bool CheckTransactionRecord(IDType ID);
};




template<isolation_level ISOLATIONLEVEL=read_committed>
class robusttransaction : public basic_robusttransaction
{
public:
  typedef isolation_traits<ISOLATIONLEVEL> isolation_tag;

  explicit robusttransaction(connection_base &C, const PGSTD::string &TName) :
    basic_robusttransaction(C, isolation_tag::name(), TName)
        { Begin(); }

  explicit robusttransaction(connection_base &C) :
    basic_robusttransaction(C, isolation_tag::name(), PGSTD::string())
        { Begin(); }

  virtual ~robusttransaction() throw () { End(); }
};

} // namespace pqxx

---