Connection.hpp

Go to the documentation of this file.

// ANNA - Anna is Not Nothingness Anymore                                                         //
//                                                                                                //
// (c) Copyright 2005-2015 Eduardo Ramos Testillano & Francisco Ruiz Rayo                         //
//                                                                                                //
// See project site at http://redmine.teslayout.com/projects/anna-suite                           //
// See accompanying file LICENSE or copy at http://www.teslayout.com/projects/public/anna.LICENSE //


#ifndef anna_dbms_Connection_hpp
#define anna_dbms_Connection_hpp

#include <anna/comm/Resource.hpp>

#include <anna/dbms/DatabaseException.hpp>
#include <anna/dbms/ResultCode.hpp>

namespace anna {

namespace xml {
class Node;
}

namespace dbms {

class Database;
class Statement;

class Connection : public comm::Resource {
public:
  Database& getDatabase() const { return a_database; }

  const std::string& getUser() const { return a_user; }

  const std::string& getPassword() const { return a_password; }

  void setPassword(const char* password) { a_password = password; }

  int setMaxCommitPending(const int maxCommitPending) {
    const int result = a_maxCommitPending;
    a_maxCommitPending = maxCommitPending;
    return result;
  }

  void resetRollbackPending() { a_rollbackPending =  false; }

  void activateRollbackPending() { a_rollbackPending = true; }

  ResultCode execute(Statement* statement) noexcept(false);

  virtual std::string asString() const ;

  virtual xml::Node* asXML(xml::Node* parent) const ;

protected:
  Database& a_database;
  std::string a_user; 
  std::string a_password; 
  Connection(Database& database, const std::string& name, const char* user, const char* password) :
    comm::Resource(name),
    a_database(database),
    a_user(user),
    a_password(password),
    a_lockingCounter(0),
    a_commitPending(0),
    a_rollbackPending(false),
    a_maxCommitPending(0) {}

  void commit() noexcept(false);

  void rollback() ;

  virtual void open() noexcept(false) = 0;

  virtual void close()  = 0;

private:
  int a_commitPending; // Numero de sentencias a las que no se han fijado cambios.
  bool a_rollbackPending;
  int a_maxCommitPending;
  int a_lockingCounter;

  Connection(const Connection&);

  void initialize() noexcept(false);
  void lock() noexcept(false);
  void unlock() ;

  virtual bool do_beginTransaction() noexcept(false) { return false;}
  virtual void do_commit() noexcept(false) = 0;
  virtual void do_rollback()  = 0;

  friend class Database;
};

}
}

#endif