pgsql_connect.hpp

浏览该文件的文档.

#ifndef NEFORCE_DATABASE_PGSQL_CONNECT_HPP__
#define NEFORCE_DATABASE_PGSQL_CONNECT_HPP__

 
#ifdef NEFORCE_SUPPORT_POSTGRESQL
#    include <libpq-fe.h>
#    include "NeForce/db/db_interface.hpp"
NEFORCE_BEGIN_NAMESPACE__



class NEFORCE_API pgsql_connect final : public idb_tb_connect {
private:
    ::PGconn* link_ = nullptr;        
    mutable string last_error_{};     
    mutable uint32_t last_errno_ = 0; 
 
public:
    pgsql_connect() = default;

    ~pgsql_connect() override { close(); }
 
    pgsql_connect(const pgsql_connect&) = delete;
    pgsql_connect& operator=(const pgsql_connect&) = delete;

    NEFORCE_NODISCARD bool connect(const db_config& config) override;

    bool reconnect(const db_config& config) override;

    void close() override;

    bool set_character_set(const string& encoding) const override;

    NEFORCE_NODISCARD string_view get_character_set() const override;

    NEFORCE_NODISCARD string_view get_error() const override { return last_error_.view(); }

    NEFORCE_NODISCARD uint32_t get_errno() const override { return last_errno_; }

    bool update(const string& sql) const override;

    unique_ptr<idb_tb_result> query(const string& sql) const override;

    unique_ptr<idb_prepared_statement> prepare_statement(const string& sql) const override;

    NEFORCE_NODISCARD bool connected() const override;

    NEFORCE_NODISCARD bool is_valid() const override { return connected(); }
};

class NEFORCE_API pgsql_factory final : public idb_factory {
public:
    explicit pgsql_factory(db_config config) :
    idb_factory(_NEFORCE move(config)) {}

    ~pgsql_factory() override = default;

    idb_connect* create_connect() override;

    idb_result* create_result(void* native_result) override;
};
 // PostgreSQL
 // Database
 
NEFORCE_END_NAMESPACE__
#endif
#endif // NEFORCE_DATABASE_PGSQL_CONNECT_HPP__