summaryrefslogtreecommitdiff
path: root/lib/row.h
diff options
context:
space:
mode:
authorDan Goodliffe <dan@randomdan.homeip.net>2021-08-02 21:13:43 +0100
committerDan Goodliffe <dan@randomdan.homeip.net>2021-08-02 21:13:43 +0100
commit25e2428754a3ac6c02650812564c857d1e25df55 (patch)
treee5175651650126f77c46a9030853dafeac13c4f7 /lib/row.h
parentAssert DbValue is copyable and moveable (diff)
downloadmygrate-25e2428754a3ac6c02650812564c857d1e25df55.tar.bz2
mygrate-25e2428754a3ac6c02650812564c857d1e25df55.tar.xz
mygrate-25e2428754a3ac6c02650812564c857d1e25df55.zip
Handle Rows events with more than one row
Diffstat (limited to 'lib/row.h')
-rw-r--r--lib/row.h17
1 files changed, 3 insertions, 14 deletions
diff --git a/lib/row.h b/lib/row.h
index 35d8bcd..908a52f 100644
--- a/lib/row.h
+++ b/lib/row.h
@@ -13,24 +13,13 @@ struct st_mariadb_rpl_table_map_event;
namespace MyGrate {
class Row : public std::vector<DbValue> {
public:
- Row(const st_mariadb_rpl_rows_event &, const st_mariadb_rpl_table_map_event &);
+ using Rows = std::vector<Row>;
+ static Rows fromRowsEvent(const st_mariadb_rpl_rows_event &, const st_mariadb_rpl_table_map_event &);
- private:
- friend class RowPair;
- Row(const st_mariadb_rpl_rows_event &, const st_mariadb_rpl_table_map_event &, MyGrate::RawDataReader && md,
- MyGrate::RawDataReader && data);
+ using std::vector<DbValue>::vector;
Row(const st_mariadb_rpl_rows_event &, const st_mariadb_rpl_table_map_event &, MyGrate::RawDataReader & md,
MyGrate::RawDataReader & data);
};
-
- class RowPair : public std::pair<Row, Row> {
- public:
- RowPair(const st_mariadb_rpl_rows_event &, const st_mariadb_rpl_table_map_event &);
-
- private:
- RowPair(const st_mariadb_rpl_rows_event &, const st_mariadb_rpl_table_map_event &,
- MyGrate::RawDataReader && md1, MyGrate::RawDataReader && md2, MyGrate::RawDataReader && data);
- };
}
#endif