summaryrefslogtreecommitdiff
path: root/lib/output/pq/updateDatabase.h
diff options
context:
space:
mode:
authorDan Goodliffe <dan@randomdan.homeip.net>2021-08-05 23:30:09 +0100
committerDan Goodliffe <dan@randomdan.homeip.net>2021-08-05 23:30:09 +0100
commitfdc6de263a58480519d683e67bb3dfa262d9b230 (patch)
tree1b2a5dbe54a02bacd008e38f2ef965ce40c9c8da /lib/output/pq/updateDatabase.h
parentAdd base handlers for gtid/xid events (diff)
downloadmygrate-fdc6de263a58480519d683e67bb3dfa262d9b230.tar.bz2
mygrate-fdc6de263a58480519d683e67bb3dfa262d9b230.tar.xz
mygrate-fdc6de263a58480519d683e67bb3dfa262d9b230.zip
Handle gtid and xid transaction events
Diffstat (limited to 'lib/output/pq/updateDatabase.h')
-rw-r--r--lib/output/pq/updateDatabase.h3
1 files changed, 3 insertions, 0 deletions
diff --git a/lib/output/pq/updateDatabase.h b/lib/output/pq/updateDatabase.h
index d2b4872..716d7f6 100644
--- a/lib/output/pq/updateDatabase.h
+++ b/lib/output/pq/updateDatabase.h
@@ -59,6 +59,8 @@ namespace MyGrate::Output::Pq {
void insertRow(MariaDB_Event_Ptr) override;
void tableMap(MariaDB_Event_Ptr) override;
void rotate(MariaDB_Event_Ptr) override;
+ void gtid(MariaDB_Event_Ptr) override;
+ void xid(MariaDB_Event_Ptr) override;
const uint64_t source;
const std::string schema;
@@ -81,6 +83,7 @@ namespace MyGrate::Output::Pq {
Tables tables;
Tables::const_iterator selected;
MariaDB_Event_Ptr table_map;
+ bool intx {false};
};
}