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

[to #33186370] fix cursor for loop & tcl retry logic

Browse Source
This commit is contained in:
obdev
2023-01-28 16:57:28 +08:00
committed by ob-robot
parent 038fe6a4dd
commit da8c498599
2 changed files with 4 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/sql/ob_spi.cpp
View File

@ -1467,6 +1467,7 @@ int ObSPIService::spi_inner_execute(ObPLExecCtx *ctx,
//自动提交,禁掉PL整体重试
if (OB_SUCC(ret)
&& (ObStmt::is_ddl_stmt(stmt_type, true)
|| ObStmt::is_tcl_stmt(stmt_type)
|| (lib::is_mysql_mode() && session->get_local_autocommit()))) {
OX (session->set_pl_can_retry(false));
}
@ -1687,6 +1688,7 @@ int ObSPIService::dbms_cursor_execute(ObPLExecCtx *ctx,
//自动提交,禁掉PL整体重试
if (OB_SUCC(ret)
&& (ObStmt::is_ddl_stmt(stmt_type, true)
|| ObStmt::is_tcl_stmt(stmt_type)
|| (lib::is_mysql_mode() && session->get_local_autocommit()))) {
OX (session->set_pl_can_retry(false));
}
@ -2598,6 +2600,7 @@ int ObSPIService::spi_execute_immediate(ObPLExecCtx *ctx,
//自动提交,禁掉PL整体重试
if (OB_SUCC(ret)
&& (ObStmt::is_ddl_stmt(stmt_type, true)
|| ObStmt::is_tcl_stmt(stmt_type)
|| (lib::is_mysql_mode() && session->get_local_autocommit()))) {
OX (session->set_pl_can_retry(false));
}