hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

fix test_ob_black_list_service bug

Browse Source
This commit is contained in:
dimstars
2023-12-25 09:43:07 +00:00
committed by ob-robot
parent 14421b2ab1
commit b9c4e8cc69
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
mittest/simple_server/test_ob_black_list_service.cpp
View File

@ -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);