diff --git a/mittest/simple_server/test_ob_black_list_service.cpp b/mittest/simple_server/test_ob_black_list_service.cpp index 0e9eb6c807..e43bc51c89 100644 --- a/mittest/simple_server/test_ob_black_list_service.cpp +++ b/mittest/simple_server/test_ob_black_list_service.cpp @@ -47,12 +47,12 @@ TEST_F(TestObBlackListService, black_list_inner_func) // sql ASSERT_EQ(OB_SUCCESS, get_curr_simple_server().init_sql_proxy2("sys", "oceanbase")); ObSqlString sql; - sql.assign_fmt(BLACK_LIST_SELECT_LS_INFO_STMT); + ASSERT_EQ(OB_SUCCESS, sql.assign_fmt(BLACK_LIST_SELECT_LS_INFO_STMT)); ASSERT_EQ(OB_SUCCESS, ret); SMART_VAR(ObISQLClient::ReadResult, res) { // do sql query - ObMySQLProxy &sql_proxy = get_curr_simple_server().get_sql_proxy2(); - ASSERT_EQ(OB_SUCCESS, sql_proxy.read(res, sql.ptr())); + ObMySQLProxy &sql_proxy = *GCTX.sql_proxy_; + ASSERT_EQ(OB_SUCCESS, sql_proxy.read(res, OB_SYS_TENANT_ID, sql.ptr(), nullptr, INNER_SQL_QUERY_TIMEOUT)); sqlclient::ObMySQLResult *result = res.get_result(); ASSERT_NE(nullptr, result); @@ -73,7 +73,7 @@ TEST_F(TestObBlackListService, black_list_inner_func) ASSERT_EQ(false, check); // query again - ASSERT_EQ(OB_SUCCESS, sql_proxy.read(res, sql.ptr())); + ASSERT_EQ(OB_SUCCESS, sql_proxy.read(res, OB_SYS_TENANT_ID, sql.ptr(), nullptr, INNER_SQL_QUERY_TIMEOUT)); result = res.get_result(); ASSERT_NE(nullptr, result);