diff options
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; |