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/>.
*/
#pragma once
#include <functional>
 
#include "sql/sqlException.hpp"
#include "sql/resultSet.hpp"
#include "sql/preparedStatement.hpp"
 
 
namespace anch::sql {

  struct SqlConnectionConfiguration {
    std::string driver = "";

    std::string database;

    std::string hostname;

    int port;

    std::string user;

    std::string password;

    std::string application = "AnCH";
  };

  class Connection {
 
    // Attributes +
  protected:
    bool _valid;

    bool _transaction;

    std::map<std::string, PreparedStatement*> _stmts;

    bool _errors;
    // Attributes -
 
    // Constructors +
  public:
    Connection();

    Connection(const Connection&) = delete;
    // Constructors -
 
    // Destructor +
  public:
    virtual ~Connection() noexcept;
    // Destructor -
 
    // Methods +
  public:
    void startTransaction();

    void begin();

    void commit();

    void rollback();

    void release() noexcept;

    PreparedStatement& prepareStatement(const std::string& query);

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

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

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

    template<typename T, typename... Q>
    ResultSet* query(const std::string& query, const T& value, const Q&... values);

    template<typename T, typename... Q>
    void queryMapRow(const std::string& query, std::function<void(ResultSet&)> rowMapper, const T& value, const Q&... values);

    template<typename T, typename... Q>
    void queryExtract(const std::string& query, std::function<void(ResultSet&)> resExtractor, const T& value, const Q&... values);

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

    template<typename T, typename... Q>
    uint64_t update(const std::string& query, const T& value, const Q&... values);

    template<typename T, typename Iterable>
    uint64_t batchUpdate(const std::string& query, std::function<void(PreparedStatement&, const T&)> mapper, const Iterable& values);
 
  protected:
    virtual ResultSet* executeQuery(const std::string& query) = 0;

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

    virtual void sendStartTransaction() = 0;

    virtual void sendCommit() = 0;

    virtual void sendRollback() = 0;

    virtual PreparedStatement* makePrepared(const std::string& query) = 0;
 
  private:
    static void extract(ResultSet* res, std::function<void(ResultSet&)> resExtractor);

    static void mapRow(ResultSet* res, std::function<void(ResultSet&)> rowMapper);

    template<typename T, typename... Q>
    static void bindParameters(PreparedStatement& stmt, std::size_t& idx, const T& value, const Q&... values);

    template<typename T>
    static void bindParameters(PreparedStatement& stmt, std::size_t& idx, const T& value);
    // Methods -
 
    // Accessors +
  public:
    bool isValid() const noexcept;
 
  protected:
    void setValid(bool valid) noexcept;
    // Accessors -
 
  };
 
}
 
#include "sql/impl/connection.hpp"