Connection.h

Go to the documentation of this file.

#ifndef LINTEL_POSTGRES_CONNECTION_H
#define LINTEL_POSTGRES_CONNECTION_H
 
#include <libpq-fe.h>
 
#include <memory>
#include <string>
#include <vector>
 
#include "lintel/core/configuration/DatabaseConnectionEntry.h"
#include "lintel/core/exceptions/SQLException.h"
#include "lintel/core/persistence/Parameter.h"
#include "lintel/core/persistence/postgresql/Result.h"
 
namespace lintel {
namespace postgresql {
  class Transaction;
 
  class Statement;
 
  class PreparedStatement;
 
  class Notify;
 
  class Cursor;
 
  class Connection
  {
  private:
    PGconn *m_conn;
    std::string m_connInfo;
 
    friend class Transaction;
 
    friend class Statement;
 
    friend class PreparedStatement;
 
    friend class Notify;
 
    friend class Cursor;
 
    std::shared_ptr<Result> execute(const std::string &statement) const;
 
    [[nodiscard]] std::shared_ptr<Result> executeParameters(const std::string &statement,
      const db::Parameters &parameters) const;
 
    [[nodiscard]] std::shared_ptr<Result>
      prepareStatement(const std::string &statementName, const std::string &query, int32_t nParams) const;
 
    [[nodiscard]] std::shared_ptr<Result> executePreparedStatement(const std::string &statementName,
      int32_t nParams,
      const db::Parameters &parameters) const;
 
    [[nodiscard]] std::string getErrorMessage() const;
 
    [[nodiscard]] static std::string buildConnInfo(const std::shared_ptr<DatabaseConnectionEntry> &connectionEntry);
 
  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 postgresql
 
}// namespace lintel
#endif// LINTEL_POSTGRES_CONNECTION_H