Loading...
Searching...
No Matches
connection-pipeline.hxx
#include "pqxx/internal/libpq-forward.hxx"
#include <pqxx/internal/callgate.hxx>
#include "pqxx/pipeline.hxx"
namespace pqxx::internal::gate
{
class PQXX_PRIVATE connection_pipeline : callgate<connection>
{
friend class pqxx::pipeline;
connection_pipeline(reference x) : super(x) {}
void start_exec(char const query[]) { home().start_exec(query); }
pqxx::internal::pq::PGresult *get_result() { return home().get_result(); }
void cancel_query() { home().cancel_query(); }
bool consume_input() noexcept { return home().consume_input(); }
bool is_busy() const noexcept { return home().is_busy(); }
int encoding_id() { return home().encoding_id(); }
auto get_notice_waiters() const { return home().m_notice_waiters; }
};
} // namespace pqxx::internal::gate
pqxx::connection
Connection to a database.
Definition connection.hxx:279
pqxx::internal::callgate
Base class for call gates.
Definition callgate.hxx:55
pqxx::internal::gate::connection_pipeline
Definition connection-pipeline.hxx:9
pqxx::pipeline
Processes several queries in FIFO manner, optimized for high throughput.
Definition pipeline.hxx:51