/**
 * @file
 * $Id$
 * $Revision$
 * $Author$
 * $Date$
 *
 * This file is part of The iWear Framework.
 * In particular this file is part of the iWear Database Access Library.
 *
 * The iWear Framework is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by the
 * Free Software Foundation as in version 2 of the License.

 * 
 * The iWear Framework is distributed in the hope that it will be useful, but
 * WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
 * or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License for
 * more details.
 * 
 * You should have received a copy of the GNU General Public License along with
 * The iWear Framework; if not, write to the Free Software Foundation, Inc., 59
 * Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */

#ifndef __DBCLASSES_IWPGDB_H
#define __DBCLASSES_IWPGDB_H

#ifndef __DBCLASSES_IWDB_H
#include <dbclasses/iwdb.h>
#endif

#ifndef HAVE_IWPGDB
#error HAVE_IWPGDB is not defined in config.h at installation time. Rebuild the library.
#endif

#include <pqxx/connection>
#include <pqxx/nontransaction>
#include <pqxx/transaction>

#include <list>
using namespace std;

namespace iwear {
    namespace db {

class PGRecordSet;
class IWPgDB : public IWDB 
{
public:
    friend class PGRecordSet;
    IWPgDB( );
    virtual ~IWPgDB( );
private:
    IWPgDB( const IWPgDB& ) : IWDB() {}

    pqxx::connection* Conn;
    pqxx::nontransaction* NonTrans;

   /**
    * A list of transactions for multiple transaction level nesting
    */
    list<pqxx::transaction<>*> Transactions;

   /**
    * The actual active transaction
    * @warn This can be NULL 
    */
    pqxx::transaction<pqxx::serializable>* ActualTrans;

    void remove_actual_transaction(void);


    virtual int32_t do_connect( const string& dbh, const string& dbn, const string& dbu, const string& dbpw, const string& dbpar);
    virtual int32_t do_disconnect( void );
    virtual int32_t do_query( const string& cmd);
    virtual int32_t do_query( const string& cmd, RecordSet*& RS);
   /**
    * This will create a new transaction and puts it to this list
    */
    virtual int32_t do_transact(void);
    virtual int32_t do_commit(void);
    virtual int32_t do_rollback(void);
    virtual int32_t do_set_encoding( const string& );
   /**
    * We override this function, since the libpqxx can better detect database
    * backend disconnection issues, so we use their native functions.
    */
    virtual bool is_connected( void );
};
} // namespace iwear
}
#endif