connection.hpp

/*
  ANCH Framework: ANother C++ Hack is a C++ framework based on C++11 standard
  Copyright (C) 2012 Vincent Lachenal

  This file is part of ANCH Framework.

  ANCH Framework is free software: you can redistribute it and/or modify
  it under the terms of the GNU Lesser General Public License as published by
  the Free Software Foundation, either version 3 of the License, or
  (at your option) any later version.

  ANCH 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 Lesser General Public License for more details.

  You should have received a copy of the GNU Lesser General Public License
  along with ANCH Framework.  If not, see <http://www.gnu.org/licenses/>.
*/
#ifndef _ANCH_SQL_CON_H_
#define _ANCH_SQL_CON_H_

#include <functional>

#include "sql/sqlException.hpp"
#include "sql/resultSet.hpp"


namespace anch {
  namespace sql {

    struct SqlConnectionConfiguration {
      std::string driver;

      std::string database;

      std::string hostname;

      int port;

      std::string user;

      std::string password;

      std::string application;
    };

    class Connection {

      // Attributes +
    protected:
      bool _autoCommit;

      bool _valid;
      // Attributes -

      // Constructors +
    public:
      Connection() throw(SqlException);

      Connection(const Connection&) = delete;
      // Constructors -

      // Destructor +
    public:
      virtual ~Connection();
      // Destructor -

      // Methods +
    public:
      void commit() throw(SqlException);

      void rollback() throw(SqlException);

      void setAutoCommit(bool autoCommit) throw(SqlException);

      ResultSet* query(const std::string& query) throw(SqlException);

      void queryMapRow(const std::string& sqlQuery, std::function<void(ResultSet&)> rowMapper) throw(SqlException);

      void queryExtract(const std::string& sqlQuery, std::function<void(ResultSet&)> resExtractor) throw(SqlException);

      uint64_t update(const std::string& query) throw(SqlException);

    protected:
      virtual ResultSet* executeQuery(const std::string& query) throw(SqlException) = 0;

      virtual uint64_t executeUpdate(const std::string& query) throw(SqlException) = 0;

      virtual void sendCommit() throw(SqlException) = 0;

      virtual void sendRollback() throw(SqlException) = 0;

      virtual void toggleAutoCommit(bool autoCommit) throw(SqlException) = 0;
      // Methods -

      // Accessors +
    public:
      inline bool isAutoCommit() const {
        return _autoCommit;
      }

      inline bool isValid() const {
        return _valid;
      }

    protected:
      inline void setValid(bool valid) {
        _valid = valid;
      }
      // Accessors -

    };

  }
}

#endif // _ANCH_SQL_CON_H_