postgres.hxx

#pragma once
 
#include <StormByte/database/database.hxx>
#include <StormByte/database/postgres/prepared_stmt.hxx>
 
#include <filesystem>
#include <memory>
 
struct pg_conn; 
 
namespace StormByte::Database::Postgres {
    class STORMBYTE_DATABASE_PUBLIC Postgres: public Database {
        public:
            Postgres(const Postgres& db)                            = delete;
 
            Postgres(Postgres&& db) noexcept                        = default;
 
            Postgres& operator=(const Postgres& db)                 = delete;
 
            Postgres& operator=(Postgres&& db) noexcept             = default;
 
            virtual ~Postgres() noexcept;
 
            ExpectedRows                                            Query(const std::string& query) noexcept override;
 
            bool                                                    SilentQuery(const std::string& query) noexcept override;
 
        protected:
            Postgres(const std::string& host, const std::string& user, const std::string& password, const std::string& db_name, std::shared_ptr<Logger::Log> logger);
 
            Postgres(std::string&& host, std::string&& user, std::string&& password, std::string&& db_name, std::shared_ptr<Logger::Log> logger);
 
        private:
            std::string m_host;                                     
            std::string m_user;                                     
            std::string m_password;                                 
            std::string m_dbname;                                   
            struct pg_conn* m_conn;                                 
 
            bool                                                    DoConnect() noexcept override;
 
            void                                                    DoPreDisconnect() noexcept override;
 
            void                                                    DoDisconnect() noexcept override;
 
            std::unique_ptr<StormByte::Database::PreparedSTMT>      CreatePreparedSTMT(std::string&& name, std::string&& query) noexcept override;
    };
}