diff --git a/src/observer/mysql/obmp_stmt_execute.cpp b/src/observer/mysql/obmp_stmt_execute.cpp
index c050944e6f..231854e7aa 100644
--- a/src/observer/mysql/obmp_stmt_execute.cpp
+++ b/src/observer/mysql/obmp_stmt_execute.cpp
@@ -1445,8 +1445,8 @@ int ObMPStmtExecute::do_process(ObSQLSessionInfo &session,
       audit_record.is_executor_rpc_ = false;
       audit_record.is_inner_sql_ = false;
       audit_record.is_hit_plan_cache_ = result.get_is_from_plan_cache();
-      audit_record.sql_ = const_cast<char *>(ctx_.cur_sql_.ptr());
-      audit_record.sql_len_ = min(ctx_.cur_sql_.length(), OB_MAX_SQL_LENGTH);
+      audit_record.sql_ = const_cast<char *>(ctx_.raw_sql_.ptr());
+      audit_record.sql_len_ = min(ctx_.raw_sql_.length(), OB_MAX_SQL_LENGTH);
       audit_record.sql_cs_type_ = session.get_local_collation_connection();
       audit_record.ps_stmt_id_ = stmt_id_;
       audit_record.ps_inner_stmt_id_ = inner_stmt_id;
diff --git a/src/sql/ob_sql.cpp b/src/sql/ob_sql.cpp
index 9b6a78e9e8..f43bae9c40 100644
--- a/src/sql/ob_sql.cpp
+++ b/src/sql/ob_sql.cpp
@@ -2388,6 +2388,7 @@ int ObSql::handle_ps_execute(const ObPsStmtId client_stmt_id,
     } else {
       const ObString &sql = !ps_info->get_no_param_sql().empty() ? ps_info->get_no_param_sql() : ps_info->get_ps_sql();
       context.cur_sql_ = sql;
+      context.raw_sql_ = ps_info->get_ps_sql();
 #ifndef NDEBUG
       LOG_INFO("Begin to handle execute statement", "sess_id", session.get_sessid(),
                "proxy_sess_id", session.get_proxy_sessid(), K(sql));
diff --git a/src/sql/ob_sql_context.h b/src/sql/ob_sql_context.h
index 52e11e38c1..3f9e7ed213 100644
--- a/src/sql/ob_sql_context.h
+++ b/src/sql/ob_sql_context.h
@@ -732,6 +732,7 @@ public:
       uint32_t reserved_ : 29;
     };
   };
+  common::ObString raw_sql_;
   TO_STRING_KV(K(stmt_type_));
 private:
   share::ObFeedbackRerouteInfo *reroute_info_;