diff --git a/dbcon/mysql/ha_mcs.cpp b/dbcon/mysql/ha_mcs.cpp index 0253b059a..50b14dd26 100644 --- a/dbcon/mysql/ha_mcs.cpp +++ b/dbcon/mysql/ha_mcs.cpp @@ -1156,6 +1156,20 @@ void ha_mcs::cond_pop() DBUG_VOID_RETURN; } +int ha_mcs::reset() +{ + DBUG_ENTER("ha_mcs::reset"); + + if (!condStack.empty()) + { + condStack.clear(); + } + + DBUG_RETURN(0); +} + + + int ha_mcs::repair(THD* thd, HA_CHECK_OPT* check_opt) { DBUG_ENTER("ha_mcs::repair"); diff --git a/dbcon/mysql/ha_mcs.h b/dbcon/mysql/ha_mcs.h index fde032a22..04db8d6c0 100644 --- a/dbcon/mysql/ha_mcs.h +++ b/dbcon/mysql/ha_mcs.h @@ -215,6 +215,7 @@ public: int rnd_end(); int rnd_next(uchar* buf); ///< required int rnd_pos(uchar* buf, uchar* pos); ///< required + int reset() override; void position(const uchar* record); ///< required int info(uint32_t); ///< required int extra(enum ha_extra_function operation);