diff options
author | Dan Goodliffe <dan@randomdan.homeip.net> | 2021-08-05 23:30:09 +0100 |
---|---|---|
committer | Dan Goodliffe <dan@randomdan.homeip.net> | 2021-08-05 23:30:09 +0100 |
commit | fdc6de263a58480519d683e67bb3dfa262d9b230 (patch) | |
tree | 1b2a5dbe54a02bacd008e38f2ef965ce40c9c8da /lib/output/pq/updateDatabase.h | |
parent | Add base handlers for gtid/xid events (diff) | |
download | mygrate-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.h | 3 |
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}; }; } |