From 3c1d15e3bfc2788cd7f6c9f826eafc1a8abc77c1 Mon Sep 17 00:00:00 2001 From: Dan Goodliffe Date: Fri, 23 Jul 2021 00:52:03 +0100 Subject: First cut replicating row deletes --- lib/output/pq/updateDatabase.h | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'lib/output/pq/updateDatabase.h') diff --git a/lib/output/pq/updateDatabase.h b/lib/output/pq/updateDatabase.h index e56852b..7641ada 100644 --- a/lib/output/pq/updateDatabase.h +++ b/lib/output/pq/updateDatabase.h @@ -27,7 +27,7 @@ namespace MyGrate::Output::Pq { std::vector columns; std::size_t keys; - DbPrepStmtPtr update; + DbPrepStmtPtr update, deleteFrom; }; using TableDefPtr = std::unique_ptr; @@ -53,6 +53,7 @@ namespace MyGrate::Output::Pq { // Replication events void updateRow(MariaDB_Event_Ptr) override; + void deleteRow(MariaDB_Event_Ptr) override; void tableMap(MariaDB_Event_Ptr) override; const uint64_t source; -- cgit v1.2.3