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

[CP] [to #55892808]fix bug dblink transaction in nested sql

Browse Source
This commit is contained in:
seuwebber 2024-05-30 09:26:27 +00:00 committed by ob-robot
parent f857cd2956
commit e4b2343022
1 changed files with 13 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
src/pl/ob_pl.cpp
View File

@ -844,15 +844,20 @@ void ObPLContext::destory(
} else if (session_info.associated_xa()) {
IS_DBLINK_TRANS;
if (is_dblink) {
transaction::ObTransID tx_id;
const bool force_disconnect = false;
int rl_ret = OB_SUCCESS;
if (OB_SUCCESS != (rl_ret = ObTMService::tm_rollback(ctx, tx_id))) {
LOG_WARN("failed to rollback for dblink trans", K(ret), K(rl_ret), K(tx_id), K(xid), K(global_tx_type));
} else if (OB_SUCCESS != (rl_ret = session_info.get_dblink_context().clean_dblink_conn(force_disconnect))) {
LOG_WARN("dblink trans failed to release dblink connections", K(ret), K(rl_ret), K(tx_id), K(xid));
if (in_nested_sql_ctrl()) {
// rollback or commit by the top sql.
} else {
transaction::ObTransID tx_id;
const bool force_disconnect = false;
int rl_ret = OB_SUCCESS;
if (OB_SUCCESS != (rl_ret = ObTMService::tm_rollback(ctx, tx_id))) {
LOG_WARN("failed to rollback for dblink trans", K(ret), K(rl_ret), K(tx_id), K(xid), K(global_tx_type));
} else if (OB_SUCCESS != (rl_ret =
session_info.get_dblink_context().clean_dblink_conn(force_disconnect))) {
LOG_WARN("dblink trans failed to release dblink connections", K(ret), K(rl_ret), K(tx_id), K(xid));
}
ret = OB_SUCCESS == ret ? rl_ret : ret;
}
ret = OB_SUCCESS == ret ? rl_ret : ret;
} else if (OB_TRANS_XA_BRANCH_FAIL != ret) {
tmp_ret = ObDbmsXA::xa_rollback_savepoint(ctx);
if (OB_SUCCESS != tmp_ret) {