summaryrefslogtreecommitdiff
path: root/lib/output
diff options
context:
space:
mode:
authorDan Goodliffe <dan@randomdan.homeip.net>2021-07-24 14:21:11 +0100
committerDan Goodliffe <dan@randomdan.homeip.net>2021-07-24 14:21:11 +0100
commit1a8117e9de2101e24c7b1ab9d0b794f71dec4c77 (patch)
treef8fcd10842788ad315036664f3462888120b6c41 /lib/output
parentFix up insert/delete SQL generation (diff)
downloadmygrate-1a8117e9de2101e24c7b1ab9d0b794f71dec4c77.tar.bz2
mygrate-1a8117e9de2101e24c7b1ab9d0b794f71dec4c77.tar.xz
mygrate-1a8117e9de2101e24c7b1ab9d0b794f71dec4c77.zip
Remove any default implementation for EventHandlerBase
Diffstat (limited to 'lib/output')
-rw-r--r--lib/output/dumpToConsole.cpp2
-rw-r--r--lib/output/dumpToConsole.h5
2 files changed, 6 insertions, 1 deletions
diff --git a/lib/output/dumpToConsole.cpp b/lib/output/dumpToConsole.cpp
index 949c16f..656063b 100644
--- a/lib/output/dumpToConsole.cpp
+++ b/lib/output/dumpToConsole.cpp
@@ -17,7 +17,7 @@ namespace MyGrate::Output {
{
const auto & tm = event->event.table_map;
scprintf<"Table map %?.%? -> %?\n">(std::cout, tm.database, tm.table, tm.table_id);
- EventHandlerBase::tableMap(std::move(event));
+ tableMaps.insert_or_assign(event->event.table_map.table_id, std::move(event));
}
void
diff --git a/lib/output/dumpToConsole.h b/lib/output/dumpToConsole.h
index e3d51b6..bbbac44 100644
--- a/lib/output/dumpToConsole.h
+++ b/lib/output/dumpToConsole.h
@@ -16,8 +16,13 @@ namespace MyGrate::Output {
void deleteRow(MyGrate::MariaDB_Event_Ptr event) override;
private:
+ using TableId = decltype(st_mariadb_rpl_table_map_event::table_id);
+ using TableMaps = std::map<TableId, MyGrate::MariaDB_Event_Ptr>;
+
void dumpRowData(const st_mariadb_rpl_rows_event & row) const;
void dumpRowPairData(const st_mariadb_rpl_rows_event & row) const;
+
+ TableMaps tableMaps;
};
}