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

Fix incorrect compatibility mode

Browse Source
This commit is contained in:
obdev
2023-05-31 14:17:30 +00:00
committed by ob-robot
parent da5d0b04d1
commit de8fcb7674
3 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/observer/mysql/obmp_stmt_execute.cpp
View File

@ -1776,6 +1776,8 @@ int ObMPStmtExecute::process()
int64_t tenant_version = 0;
int64_t sys_version = 0;
THIS_WORKER.set_session(sess);
lib::CompatModeGuard g(sess->get_compatibility_mode() == ORACLE_MODE ?
lib::Worker::CompatMode::ORACLE : lib::Worker::CompatMode::MYSQL);
ObSQLSessionInfo::LockGuard lock_guard(session.get_query_lock());
session.set_current_trace_id(ObCurTraceId::get_trace_id());
session.get_raw_audit_record().request_memory_used_ = 0;

2
src/observer/mysql/obmp_stmt_prepare.cpp
View File

@ -176,6 +176,8 @@ int ObMPStmtPrepare::process()
} else {
ObSQLSessionInfo &session = *sess;
THIS_WORKER.set_session(sess);
lib::CompatModeGuard g(sess->get_compatibility_mode() == ORACLE_MODE ?
lib::Worker::CompatMode::ORACLE : lib::Worker::CompatMode::MYSQL);
ObSQLSessionInfo::LockGuard lock_guard(session.get_query_lock());
session.set_current_trace_id(ObCurTraceId::get_trace_id());
session.get_raw_audit_record().request_memory_used_ = 0;

2
src/observer/mysql/obmp_stmt_prexecute.cpp
View File

@ -146,6 +146,8 @@ int ObMPStmtPrexecute::before_process()
ret = OB_ERR_UNEXPECTED;
LOG_WARN("session is NULL or invalid", K(ret), K(session));
} else {
lib::CompatModeGuard g(session->get_compatibility_mode() == ORACLE_MODE ?
lib::Worker::CompatMode::ORACLE : lib::Worker::CompatMode::MYSQL);
uint32_t ps_stmt_checksum = DEFAULT_ITERATION_COUNT;
ObSQLSessionInfo::LockGuard lock_guard(session->get_query_lock());
session->set_current_trace_id(ObCurTraceId::get_trace_id());