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

[CP] improve processlist in fetch

Browse Source
This commit is contained in:
LiuYoung00
2023-06-06 09:18:21 +00:00
committed by ob-robot
parent 5c8789da2f
commit 1968d98d68
3 changed files with 5 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/observer/mysql/obmp_stmt_fetch.cpp
View File

@ -680,17 +680,9 @@ int ObMPStmtFetch::process_fetch_stmt(ObSQLSessionInfo &session)
{ {
int tmp_ret = OB_SUCCESS; int tmp_ret = OB_SUCCESS;
//清空WARNING BUFFER //清空WARNING BUFFER
pl::ObPLCursorInfo *cursor = session.get_cursor(cursor_id_); ObSqlCtx sql_ctx; // sql_ctx do nothing in do_after_process
if (NULL != cursor tmp_ret = do_after_process(session, sql_ctx, false/*no asyn response*/);
&& cursor->is_streaming() UNUSED(tmp_ret);
&& NULL != cursor->get_cursor_handler()
&& NULL != cursor->get_cursor_handler()->get_result_set()) {
ObSqlCtx *sql_ctx
= cursor->get_cursor_handler()->get_result_set()->get_exec_context().get_sql_ctx();
if (NULL != sql_ctx) {
tmp_ret = do_after_process(session, *sql_ctx, false/*no asyn response*/);
}
}
} }
return ret; return ret;
} }

1
src/observer/mysql/obmp_stmt_fetch.h
View File

@ -70,7 +70,6 @@ public:
void set_close_cursor() { need_close_cursor_ = true; } void set_close_cursor() { need_close_cursor_ = true; }
void reset_close_cursor() { need_close_cursor_ = false; } void reset_close_cursor() { need_close_cursor_ = false; }
protected: protected:
virtual int deserialize() { return common::OB_SUCCESS; } virtual int deserialize() { return common::OB_SUCCESS; }
virtual int process(); virtual int process();

3
src/observer/virtual_table/ob_show_processlist.cpp
View File

@ -308,7 +308,8 @@ bool ObShowProcesslist::FillScanner::operator()(sql::ObSQLSessionMgr::Key key, O
if (obmysql::COM_QUERY == sess_info->get_mysql_cmd() || if (obmysql::COM_QUERY == sess_info->get_mysql_cmd() ||
obmysql::COM_STMT_EXECUTE == sess_info->get_mysql_cmd() || obmysql::COM_STMT_EXECUTE == sess_info->get_mysql_cmd() ||
obmysql::COM_STMT_PREPARE == sess_info->get_mysql_cmd() || obmysql::COM_STMT_PREPARE == sess_info->get_mysql_cmd() ||
obmysql::COM_STMT_PREXECUTE == sess_info->get_mysql_cmd()) { obmysql::COM_STMT_PREXECUTE == sess_info->get_mysql_cmd() ||
obmysql::COM_STMT_FETCH == sess_info->get_mysql_cmd()) {
int len = sess_info->get_current_trace_id().to_string(trace_id_, sizeof(trace_id_)); int len = sess_info->get_current_trace_id().to_string(trace_id_, sizeof(trace_id_));
cur_row_->cells_[cell_idx].set_varchar(trace_id_, len); cur_row_->cells_[cell_idx].set_varchar(trace_id_, len);
cur_row_->cells_[cell_idx].set_collation_type(default_collation); cur_row_->cells_[cell_idx].set_collation_type(default_collation);