diff options
| author | Dan Goodliffe <dan@randomdan.homeip.net> | 2021-07-24 14:54:38 +0100 |
|---|---|---|
| committer | Dan Goodliffe <dan@randomdan.homeip.net> | 2021-07-24 14:54:38 +0100 |
| commit | b1d6a387b2d0255c6e209c2afc2eb7b11ead2a67 (patch) | |
| tree | b8a51d01cf63349939ae94e50509854d8d369690 /lib/output/pq/updateDatabase.h | |
| parent | Remove any default implementation for EventHandlerBase (diff) | |
| download | mygrate-b1d6a387b2d0255c6e209c2afc2eb7b11ead2a67.tar.bz2 mygrate-b1d6a387b2d0255c6e209c2afc2eb7b11ead2a67.tar.xz mygrate-b1d6a387b2d0255c6e209c2afc2eb7b11ead2a67.zip | |
Dedupe a bit
Diffstat (limited to 'lib/output/pq/updateDatabase.h')
| -rw-r--r-- | lib/output/pq/updateDatabase.h | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/lib/output/pq/updateDatabase.h b/lib/output/pq/updateDatabase.h index 89d9916..970c6d5 100644 --- a/lib/output/pq/updateDatabase.h +++ b/lib/output/pq/updateDatabase.h @@ -6,6 +6,7 @@ #include <cstdint> #include <eventHandlerBase.h> #include <eventSourceBase.h> +#include <row.h> namespace MyGrate::Input { class MySQLConn; @@ -65,6 +66,10 @@ namespace MyGrate::Output::Pq { UpdateDatabase(PqConn &&, uint64_t source); UpdateDatabase(PqConn &&, uint64_t source, RecordSetPtr cfg); + static void verifyRow(const MariaDB_Event_Ptr & e, const TableDefPtr &); + static void copyAll(const Row & r, std::back_insert_iterator<std::vector<DbValue>> &&); + static void copyKeys(const Row & r, const TableDefPtr &, std::back_insert_iterator<std::vector<DbValue>> &&); + using Tables = std::map<std::string, TableDefPtr, std::less<>>; Tables tables; Tables::const_iterator selected; |