diff --git a/cpp/dbpool.cc b/cpp/dbpool.cc index 8e5aafe..afaaae1 100644 --- a/cpp/dbpool.cc +++ b/cpp/dbpool.cc @@ -373,6 +373,9 @@ namespace f8 if (!request) { return; } + if (DBPool::Instance()->on_dberror) { + DBPool::Instance()->on_dberror(request->param, errcode, errmsg); + } if (request->on_error) { request->on_error(request->param, errcode, errmsg); } diff --git a/cpp/dbpool.h b/cpp/dbpool.h index 8a415c9..2d61b26 100644 --- a/cpp/dbpool.h +++ b/cpp/dbpool.h @@ -13,6 +13,9 @@ namespace f8 DBPool() {}; friend class a8::Singleton; + public: + AsyncDBOnErrorFunc on_dberror = nullptr; + public: void Init(); void UnInit();