ScopedConnection.h

Go to the documentation of this file.

#ifndef LINTEL_SCOPEDCONNECTION_H
#define LINTEL_SCOPEDCONNECTION_H
 
#include <memory>
#include <string>
 
#include "lintel/core/configuration/DatabaseConnectionEntry.h"
#include "lintel/core/persistence/Connection.h"
#include "lintel/core/persistence/ConnectionPool.h"
#include "lintel/core/persistence/ConnectionPoolRegistry.h"
 
namespace lintel {
namespace db {
  class ScopedConnection
  {
  public:
    explicit ScopedConnection(std::shared_ptr<DatabaseConnectionEntry> connectionEntry);
    ~ScopedConnection();
 
    ScopedConnection(const ScopedConnection &) = delete;
    ScopedConnection &operator=(const ScopedConnection &) = delete;
    ScopedConnection(ScopedConnection &&other) noexcept;
    ScopedConnection &operator=(ScopedConnection &&other) noexcept;
 
    [[nodiscard]] Connection &connection() const;
 
    [[nodiscard]] bool valid() const;
    [[nodiscard]] bool isPooled() const;
 
  private:
    void reset();
 
    std::shared_ptr<DatabaseConnectionEntry> m_connectionEntry;
    bool m_isPooled = false;
    ConnectionPool::Lease m_lease;
    std::unique_ptr<Connection> m_directConnection;
  };
}// namespace db
 
}// namespace lintel
#endif// LINTEL_SCOPEDCONNECTION_H