PostgresClient.hpp

Go to the documentation of this file.

#pragma once
#include <string>
#include <memory>
#include <functional>
#include <libpq-fe.h>
#include <orbit/network/Proactor.hpp>
#include <orbit/database/ResultSet.hpp>
 
namespace database {
 
class PostgresClient : public std::enable_shared_from_this<PostgresClient> {
public:
    PostgresClient(network::Proactor* proactor, const std::string& conninfo);
    ~PostgresClient();
 
    void connect(std::function<void(bool success)> callback);
 
    void query(const std::string& sql, std::function<void(const ResultSet& res)> callback);
 
private:
    void handle_connect(std::function<void(bool)> callback);
    void handle_query(std::function<void(const ResultSet&)> callback);
 
    network::Proactor* proactor_;
    std::string conninfo_;
    PGconn* conn_{nullptr};
    bool connected_{false};
};
 
} // namespace database