Connection.h

Go to the documentation of this file.

#ifndef LINTEL_CONNECTION_H
#define LINTEL_CONNECTION_H
 
#include <memory>
 
#include "lintel/core/configuration/DatabaseConnectionEntry.h"
#include "lintel/core/persistence/postgresql/Connection.h"
#include "lintel/core/persistence/sqlite3/Connection.h"
 
namespace lintel {
namespace db {
 
  class Transaction;
 
  class Statement;
 
  class PreparedStatement;
 
  class Notify;
 
  class Connection
  {
  private:
    std::shared_ptr<postgresql::Connection> m_conn = nullptr;
    std::shared_ptr<sqlite::Connection> m_connSQLite = nullptr;
 
    ConnectionType m_connectionType;
 
    friend class Transaction;
 
    friend class Statement;
 
    friend class PreparedStatement;
 
    friend class Notify;
 
    friend class Cursor;
 
  public:
    explicit Connection(ConnectionType connectionType, const std::string &connectionInfo);
 
    explicit Connection(const std::shared_ptr<DatabaseConnectionEntry> &connectionEntry);
 
    explicit Connection(Connection &connection) = delete;
 
    [[nodiscard]] bool isHealthy() const;
  };
}// namespace db
 
}// namespace lintel
#endif// LINTEL_CONNECTION_H