From 5f0e260cfbdd43556c5f867861216cba3692d8e4 Mon Sep 17 00:00:00 2001
From: Dan Goodliffe <dan@randomdan.homeip.net>
Date: Fri, 23 Jul 2021 01:13:47 +0100
Subject: First cut replicating row inserts

---
 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 7641ada..89d9916 100644
--- a/lib/output/pq/updateDatabase.h
+++ b/lib/output/pq/updateDatabase.h
@@ -27,7 +27,7 @@ namespace MyGrate::Output::Pq {
 
 		std::vector<ColumnDefPtr> columns;
 		std::size_t keys;
-		DbPrepStmtPtr update, deleteFrom;
+		DbPrepStmtPtr update, deleteFrom, insertInto;
 	};
 	using TableDefPtr = std::unique_ptr<TableOutput>;
 
@@ -54,6 +54,7 @@ namespace MyGrate::Output::Pq {
 		// Replication events
 		void updateRow(MariaDB_Event_Ptr) override;
 		void deleteRow(MariaDB_Event_Ptr) override;
+		void insertRow(MariaDB_Event_Ptr) override;
 		void tableMap(MariaDB_Event_Ptr) override;
 
 		const uint64_t source;
-- 
cgit v1.2.3