Connection.h

Go to the documentation of this file.

#ifndef LINTEL_SQLITE_CONNECTION_H
#define LINTEL_SQLITE_CONNECTION_H
 
#include <sqlite3.h>
 
#include <map>
#include <memory>
#include <string>
 
#include "lintel/core/configuration/DatabaseConnectionEntry.h"
#include "lintel/core/persistence/Parameter.h"
#include "lintel/core/persistence/sqlite3/Result.h"
 
namespace lintel {
namespace sqlite {
  class Transaction;
 
  class Statement;
 
  class PreparedStatement;
 
  class Notify;
 
  class Cursor;
 
  class Connection
  {
  private:
    sqlite3 *m_db;
 
    friend class Transaction;
 
    friend class Statement;
 
    friend class PreparedStatement;
 
    friend class Notify;
 
    friend class Cursor;
 
    std::map<std::string, sqlite3_stmt *> m_preparedStatements;
 
  private:
    [[nodiscard]] std::shared_ptr<Result> execute(const std::string &statement) const;
 
    [[nodiscard]] std::shared_ptr<Result> executeParameters(const std::string &statement,
      const db::Parameters &parameters);
 
    void applyPragmas(const std::string &connectionInfo);
 
    std::shared_ptr<Result> prepareStatement(const std::string &queryName, const std::string &query);
 
    [[nodiscard]] std::shared_ptr<Result> executePreparedStatement(const std::string &queryName,
      const db::Parameters &parameters);
 
    void finalizePreparedStatement(const std::string &queryName);
 
    static int callBack(void *funcPtr, int argc, char **argv, char **column);
 
    [[nodiscard]] std::string getErrorMessage() const;
 
  public:
    explicit Connection(const std::string &connectionInfo);
 
    explicit Connection(const std::shared_ptr<DatabaseConnectionEntry> &connectionEntry);
 
    Connection(Connection &connection) = delete;
 
    [[nodiscard]] bool isHealthy() const;
 
    ~Connection();
  };
}// namespace sqlite
 
}// namespace lintel
#endif// LINTEL_SQLITE_CONNECTION_H