From 7a5dbf29c6401d57fdc1a925bf698933a41b45c2 Mon Sep 17 00:00:00 2001 From: hemny Date: Thu, 2 Dec 2021 13:27:37 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=97=A5=E5=BF=97=E6=9C=AA?= =?UTF-8?q?=E8=AE=B0=E5=BD=95SQL=E8=AF=AD=E5=8F=A5=E7=9A=84=E6=8C=81?= =?UTF-8?q?=E7=BB=AD=E6=97=B6=E9=97=B4=E7=9A=84bug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/gausskernel/process/tcop/postgres.cpp | 24 +++++++++---------- .../runtime/executor/lightProxy.cpp | 4 ++-- src/gausskernel/runtime/opfusion/opfusion.cpp | 4 ++-- 3 files changed, 16 insertions(+), 16 deletions(-) diff --git a/src/gausskernel/process/tcop/postgres.cpp b/src/gausskernel/process/tcop/postgres.cpp index 2a2f16c53..843eb15a0 100755 --- a/src/gausskernel/process/tcop/postgres.cpp +++ b/src/gausskernel/process/tcop/postgres.cpp @@ -1651,10 +1651,10 @@ void exec_simple_plan(PlannedStmt* plan) */ switch (check_log_duration(msec_str, was_logged)) { case 1: - ereport(DEBUG1, (errmsg("duration: %s ms, debugid %ld, unique id %lu", msec_str, u_sess->debug_query_id, u_sess->slow_query_cxt.slow_query.unique_sql_id), errhidestmt(true))); + ereport(LOG, (errmsg("duration: %s ms, debugid %ld, unique id %lu", msec_str, u_sess->debug_query_id, u_sess->slow_query_cxt.slow_query.unique_sql_id), errhidestmt(true))); break; case 2: - ereport(DEBUG1, + ereport(LOG, (errmsg("duration: %s ms, debug id %ld unique id %lu statement: %s", msec_str, u_sess->debug_query_id, u_sess->slow_query_cxt.slow_query.unique_sql_id, "TODO: deparse plan"), // vam query_string), errhidestmt(true) // vam errdetail_execute(parsetree_list) @@ -2756,13 +2756,13 @@ static void exec_simple_query(const char* query_string, MessageType messageType, */ switch (check_log_duration(msec_str, was_logged)) { case 1: - ereport(DEBUG1, (errmsg("duration: %s ms, queryid %ld, unique id %lu", msec_str, u_sess->debug_query_id, u_sess->slow_query_cxt.slow_query.unique_sql_id), errhidestmt(true))); + ereport(LOG, (errmsg("duration: %s ms, queryid %ld, unique id %lu", msec_str, u_sess->debug_query_id, u_sess->slow_query_cxt.slow_query.unique_sql_id), errhidestmt(true))); break; case 2: { char* mask_string = NULL; MASK_PASSWORD_START(mask_string, query_string); - ereport(DEBUG1, + ereport(LOG, (errmsg("duration: %s ms queryid %ld unique id %ld statement: %s", msec_str, u_sess->debug_query_id, u_sess->slow_query_cxt.slow_query.unique_sql_id,mask_string), errhidestmt(true), errdetail_execute(parsetree_list))); @@ -3582,13 +3582,13 @@ pass_parsing: */ switch (check_log_duration(msec_str, false)) { case 1: - ereport(DEBUG1, (errmsg("duration: %s ms, queryid %ld unique id %ld", msec_str, u_sess->debug_query_id, u_sess->slow_query_cxt.slow_query.unique_sql_id), errhidestmt(true))); + ereport(LOG, (errmsg("duration: %s ms, queryid %ld unique id %ld", msec_str, u_sess->debug_query_id, u_sess->slow_query_cxt.slow_query.unique_sql_id), errhidestmt(true))); break; case 2: { char* cur_mask_string = NULL; MASK_PASSWORD_START(cur_mask_string, query_string); - ereport(DEBUG1, (errmsg( + ereport(LOG, (errmsg( "duration: %s ms queryid %ld unique id %ld parse %s: %s", msec_str, u_sess->debug_query_id, u_sess->slow_query_cxt.slow_query.unique_sql_id, *stmt_name ? stmt_name : "", cur_mask_string), errhidestmt(true))); MASK_PASSWORD_END(cur_mask_string, query_string); @@ -4711,13 +4711,13 @@ static void exec_bind_message(StringInfo input_message) */ switch (check_log_duration(msec_str, false)) { case 1: - ereport(DEBUG1, (errmsg("duration: %s ms, queryid %ld, unique id %ld", msec_str, u_sess->debug_query_id, u_sess->slow_query_cxt.slow_query.unique_sql_id), errhidestmt(true))); + ereport(LOG, (errmsg("duration: %s ms, queryid %ld, unique id %ld", msec_str, u_sess->debug_query_id, u_sess->slow_query_cxt.slow_query.unique_sql_id), errhidestmt(true))); break; case 2: { char* mask_string = NULL; MASK_PASSWORD_START(mask_string, psrc->query_string); - ereport(DEBUG1, + ereport(LOG, (errmsg("duration: %s ms queryid %ld unique id %ld bind %s%s%s: %s", msec_str, u_sess->debug_query_id, @@ -4976,13 +4976,13 @@ static void exec_execute_message(const char* portal_name, long max_rows) */ switch (check_log_duration(msec_str, was_logged)) { case 1: - ereport(DEBUG1, (errmsg("duration: %s ms queryid %ld unique id %ld", msec_str, u_sess->debug_query_id, u_sess->slow_query_cxt.slow_query.unique_sql_id), errhidestmt(true))); + ereport(LOG, (errmsg("duration: %s ms queryid %ld unique id %ld", msec_str, u_sess->debug_query_id, u_sess->slow_query_cxt.slow_query.unique_sql_id), errhidestmt(true))); break; case 2: { char* mask_string = NULL; MASK_PASSWORD_START(mask_string, sourceText); - ereport(DEBUG1, + ereport(LOG, (errmsg("duration: %s ms queryid %ld unique id %ld %s %s%s%s: %s", msec_str, u_sess->debug_query_id, @@ -11344,13 +11344,13 @@ static void exec_batch_bind_execute(StringInfo input_message) */ switch (check_log_duration(msec_str, false)) { case 1: - ereport(DEBUG1, (errmsg("duration: %s ms, queryid %ld unique id %ld", msec_str, u_sess->debug_query_id, u_sess->slow_query_cxt.slow_query.unique_sql_id), errhidestmt(true))); + ereport(LOG, (errmsg("duration: %s ms, queryid %ld unique id %ld", msec_str, u_sess->debug_query_id, u_sess->slow_query_cxt.slow_query.unique_sql_id), errhidestmt(true))); break; case 2: { char* mask_string = NULL; MASK_PASSWORD_START(mask_string, psrc->query_string); - ereport(DEBUG1, + ereport(LOG, (errmsg("duration: %s ms queryid %ld unique id %ld batch bind-execute %s%s%s: %s", msec_str, u_sess->debug_query_id, diff --git a/src/gausskernel/runtime/executor/lightProxy.cpp b/src/gausskernel/runtime/executor/lightProxy.cpp index ca8931b5b..5ed562c82 100644 --- a/src/gausskernel/runtime/executor/lightProxy.cpp +++ b/src/gausskernel/runtime/executor/lightProxy.cpp @@ -879,10 +879,10 @@ bool lightProxy::processMsg(int msgType, StringInfo msg) char msec_str[32]; switch (check_log_duration(msec_str, false)) { case 1: - ereport(DEBUG1, (errmsg("duration: %s ms, queryid %ld, unique id %lu", msec_str, u_sess->debug_query_id, u_sess->slow_query_cxt.slow_query.unique_sql_id), errhidestmt(true))); + ereport(LOG, (errmsg("duration: %s ms, queryid %ld, unique id %lu", msec_str, u_sess->debug_query_id, u_sess->slow_query_cxt.slow_query.unique_sql_id), errhidestmt(true))); break; case 2: { - ereport(DEBUG1, + ereport(LOG, (errmsg("duration: %s ms queryid %ld unique id %ld", msec_str, u_sess->debug_query_id, u_sess->slow_query_cxt.slow_query.unique_sql_id), errhidestmt(true))); break; diff --git a/src/gausskernel/runtime/opfusion/opfusion.cpp b/src/gausskernel/runtime/opfusion/opfusion.cpp index 17984aece..46a1bc4a7 100644 --- a/src/gausskernel/runtime/opfusion/opfusion.cpp +++ b/src/gausskernel/runtime/opfusion/opfusion.cpp @@ -483,12 +483,12 @@ bool OpFusion::process(int op, StringInfo msg, char *completionTag, bool isTopLe char msec_str[32]; switch (check_log_duration(msec_str, false)) { case 1: - ereport(DEBUG1, (errmsg("duration: %s ms, queryid %lu, unique id %lu", msec_str, u_sess->debug_query_id, + ereport(LOG, (errmsg("duration: %s ms, queryid %lu, unique id %lu", msec_str, u_sess->debug_query_id, u_sess->slow_query_cxt.slow_query.unique_sql_id), errhidestmt(true))); break; case 2: { - ereport(DEBUG1, (errmsg("duration: %s ms queryid %lu unique id %lu", msec_str, u_sess->debug_query_id, + ereport(LOG, (errmsg("duration: %s ms queryid %lu unique id %lu", msec_str, u_sess->debug_query_id, u_sess->slow_query_cxt.slow_query.unique_sql_id), errhidestmt(true))); break;