#ifndef PQ_COMMAND_H #define PQ_COMMAND_H #include "command.h" #include "pq-connection.h" #include #include #include #pragma GCC diagnostic push #pragma GCC diagnostic ignored "-Wold-style-cast" #pragma GCC diagnostic ignored "-Wsign-conversion" #ifndef __clang__ # pragma GCC diagnostic ignored "-Wuseless-cast" #endif #include #pragma GCC diagnostic pop #include "command_fwd.h" #include #include #include #include #include namespace DB { class Blob; } namespace PQ { class DLL_PUBLIC CommandOptions : public DB::CommandOptions { public: CommandOptions(std::size_t, const DB::CommandOptionsMap &); explicit CommandOptions( std::size_t hash, unsigned int fetchTuples = 35, bool useCursor = true, bool fetchBinary = false); unsigned int fetchTuples; bool useCursor; bool fetchBinary; }; using CommandOptionsPtr = std::shared_ptr; using CommandOptionsCPtr = std::shared_ptr; class Command : public virtual DB::Command { public: Command(Connection *, const std::string & sql, const DB::CommandOptionsCPtr &); void bindParamI(unsigned int, int) override; void bindParamI(unsigned int, long int) override; void bindParamI(unsigned int, long long int) override; void bindParamI(unsigned int, unsigned int) override; void bindParamI(unsigned int, long unsigned int) override; void bindParamI(unsigned int, long long unsigned int) override; void bindParamB(unsigned int, bool) override; void bindParamF(unsigned int, double) override; void bindParamF(unsigned int, float) override; void bindParamS(unsigned int, const Glib::ustring &) override; void bindParamS(unsigned int, const std::string_view) override; void bindParamT(unsigned int, const boost::posix_time::time_duration) override; void bindParamT(unsigned int, const boost::posix_time::ptime) override; void bindParamBLOB(unsigned int, const DB::Blob &) override; void bindNull(unsigned int) override; protected: void prepareSql(std::stringstream & psql, const std::string & sql) const; Connection::StatementHash hash; const std::string stmntName; Connection * const c; void paramsAtLeast(unsigned int); template void paramSet(unsigned int, T &&... t); void paramSet(unsigned int, const std::string_view); std::vector values; std::vector lengths; std::vector formats; std::vector> bufs; }; } #endif