提交 b990a438 编写于 作者: T TyphoonTai

modified: src/obproxy/proxy/mysql/ob_mysql_transact.cpp

上级 94c958da
...@@ -6154,7 +6154,7 @@ int ObMysqlTransact::ObTransState::get_config_item(const ObString& cluster_name, ...@@ -6154,7 +6154,7 @@ int ObMysqlTransact::ObTransState::get_config_item(const ObString& cluster_name,
} }
} }
} }
bool is_request_follower = false; bool is_request_follower = true;
if (is_weak_read_user){ if (is_weak_read_user){
is_request_follower = (RequestFollower == 1); is_request_follower = (RequestFollower == 1);
} else{ } else{
...@@ -6166,6 +6166,7 @@ int ObMysqlTransact::ObTransState::get_config_item(const ObString& cluster_name, ...@@ -6166,6 +6166,7 @@ int ObMysqlTransact::ObTransState::get_config_item(const ObString& cluster_name,
is_request_follower = (RequestFollower == int_item.get_value()); is_request_follower = (RequestFollower == int_item.get_value());
} }
} }
if (OB_SUCC(ret)) {
bool is_sys_var_update = (session_info.is_request_follower_user() != is_request_follower); bool is_sys_var_update = (session_info.is_request_follower_user() != is_request_follower);
session_info.set_is_request_follower_user(is_request_follower); session_info.set_is_request_follower_user(is_request_follower);
if (is_sys_var_update) { if (is_sys_var_update) {
...@@ -6184,6 +6185,7 @@ int ObMysqlTransact::ObTransState::get_config_item(const ObString& cluster_name, ...@@ -6184,6 +6185,7 @@ int ObMysqlTransact::ObTransState::get_config_item(const ObString& cluster_name,
} }
} }
} }
}
if (OB_SUCC(ret)) { if (OB_SUCC(ret)) {
ObConfigBoolItem bool_item; ObConfigBoolItem bool_item;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册