summaryrefslogtreecommitdiff
path: root/lib/input/replStream.cpp
diff options
context:
space:
mode:
authorDan Goodliffe <dan@randomdan.homeip.net>2021-06-12 20:26:01 +0100
committerDan Goodliffe <dan@randomdan.homeip.net>2021-06-12 20:26:01 +0100
commit231bc3fc8d1902bb19b6fce39ffd72cce4b4f2c3 (patch)
treee074ea9bf53400600831215822a848fe27bfac55 /lib/input/replStream.cpp
parentHave verify return its expression, might be useful (diff)
downloadmygrate-231bc3fc8d1902bb19b6fce39ffd72cce4b4f2c3.tar.bz2
mygrate-231bc3fc8d1902bb19b6fce39ffd72cce4b4f2c3.tar.xz
mygrate-231bc3fc8d1902bb19b6fce39ffd72cce4b4f2c3.zip
Avoid direct use of runtime_error in MySQL stuff
Adds proper exception which extends it and gets the MySQL error message.
Diffstat (limited to 'lib/input/replStream.cpp')
-rw-r--r--lib/input/replStream.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/lib/input/replStream.cpp b/lib/input/replStream.cpp
index 1ec696a..90f26d6 100644
--- a/lib/input/replStream.cpp
+++ b/lib/input/replStream.cpp
@@ -30,7 +30,7 @@ namespace MyGrate::Input {
mariadb_rpl_optionsv(rpl.get(), MARIADB_RPL_START, position);
mariadb_rpl_optionsv(rpl.get(), MARIADB_RPL_FLAGS, MARIADB_RPL_BINLOG_SEND_ANNOTATE_ROWS);
- verify<std::runtime_error>(!mariadb_rpl_open(rpl.get()), "Failed to mariadb_rpl_open");
+ verify<MySQLErr>(!mariadb_rpl_open(rpl.get()), "Failed to mariadb_rpl_open", this);
while (MyGrate::MariaDB_Event_Ptr event {mariadb_rpl_fetch(rpl.get(), nullptr), &mariadb_free_rpl_event}) {
position = event->next_event_pos;