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

[FEAT MERGE] transaction pdml support optimization

Browse Source 
Co-authored-by: SanmuWangZJU <sanmuwang.ws@gmail.com>
This commit is contained in:
chinaxing
2024-02-07 23:02:56 +00:00
committed by ob-robot
parent 58aad015d5
commit 8d63652331
169 changed files with 8960 additions and 3921 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/sql/ob_sql_trans_control.cpp
View File

@ -1136,9 +1136,10 @@ int ObSqlTransControl::create_anonymous_savepoint(ObExecContext &exec_ctx, trans
ObSQLSessionInfo *session = GET_MY_SESSION(exec_ctx);
CK (OB_NOT_NULL(session));
OZ (get_tx_service(session, txs));
CK (OB_NOT_NULL(session->get_tx_desc()));
ObTxParam tx_param;
OZ (build_tx_param_(session, tx_param));
OZ (txs->create_implicit_savepoint(*session->get_tx_desc(), tx_param, savepoint), *session->get_tx_desc());
const int16_t branch_id = DAS_CTX(exec_ctx).get_write_branch_id();
OZ (txs->create_branch_savepoint(*session->get_tx_desc(), branch_id, savepoint), *session->get_tx_desc());
return ret;
}
@ -1496,5 +1497,16 @@ int ObSqlTransControl::check_free_route_tx_alive(ObSQLSessionInfo &session, tran
return ret;
}
int ObSqlTransControl::alloc_branch_id(ObExecContext &exec_ctx, const int64_t count, int16_t &branch_id)
{
int ret = OB_SUCCESS;
ObSQLSessionInfo *session = GET_MY_SESSION(exec_ctx);
transaction::ObTxDesc *tx_desc = NULL;
CK (OB_NOT_NULL(session));
CK (OB_NOT_NULL(tx_desc = session->get_tx_desc()));
OZ (tx_desc->alloc_branch_id(count, branch_id));
return ret;
}
}/* ns sql*/
}/* ns oceanbase */