diff options
| author | Dan Goodliffe <dan@randomdan.homeip.net> | 2021-07-04 19:27:32 +0100 |
|---|---|---|
| committer | Dan Goodliffe <dan@randomdan.homeip.net> | 2021-07-04 19:27:32 +0100 |
| commit | df70cd1da9537e0af3e8f62062a01d1ba9bd7160 (patch) | |
| tree | 495ec810d799f40e0ab68458a3f9a1887f9976e7 /lib/output/pq/pqConn.h | |
| parent | Get columns and values from cursors (diff) | |
| download | mygrate-df70cd1da9537e0af3e8f62062a01d1ba9bd7160.tar.bz2 mygrate-df70cd1da9537e0af3e8f62062a01d1ba9bd7160.tar.xz mygrate-df70cd1da9537e0af3e8f62062a01d1ba9bd7160.zip | |
Support bulk upload to PQ
Diffstat (limited to 'lib/output/pq/pqConn.h')
| -rw-r--r-- | lib/output/pq/pqConn.h | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/lib/output/pq/pqConn.h b/lib/output/pq/pqConn.h index 3b27f97..6ee6dc0 100644 --- a/lib/output/pq/pqConn.h +++ b/lib/output/pq/pqConn.h @@ -2,6 +2,7 @@ #define MYGRATE_OUTPUT_PQ_PQCONN_H #include <cstddef> +#include <cstdio> #include <dbConn.h> #include <functional> #include <initializer_list> @@ -36,6 +37,9 @@ namespace MyGrate::Output::Pq { void commitTx() override; void rollbackTx() override; + FILE * beginBulkUpload(const char * schema, const char * table); + void endBulkUpload(const char * errormsg); + const std::string connstr; private: |