From e5d31344b953449a1d13fccbb4c660303abc0394 Mon Sep 17 00:00:00 2001
From: redkale <redkale@qq.com>
Date: Thu, 10 Aug 2023 00:08:09 +0800
Subject: [PATCH] DataNativeSqlParser

---
 src/main/java/org/redkale/source/AbstractDataSqlSource.java | 4 ++--
 src/main/java/org/redkale/source/DataJdbcSource.java        | 4 ++--
 src/main/java/org/redkale/source/DataNativeSqlParser.java   | 2 +-
 3 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/src/main/java/org/redkale/source/AbstractDataSqlSource.java b/src/main/java/org/redkale/source/AbstractDataSqlSource.java
index c27964cdc..79a6ed9cc 100644
--- a/src/main/java/org/redkale/source/AbstractDataSqlSource.java
+++ b/src/main/java/org/redkale/source/AbstractDataSqlSource.java
@@ -642,11 +642,11 @@ public abstract class AbstractDataSqlSource extends AbstractDataSource implement
         return getSQLAttrValue(info, attr, val);
     }
 
-    protected DataNativeSqlParser.NativeSqlInfo nativeParse(String nativeSql, Map<String, Object> params) {
+    protected DataNativeSqlParser.NativeSqlInfo nativeParse(String prepareSign, String nativeSql, Map<String, Object> params) {
         if (nativeSqlParser == null) {
             throw new SourceException("not found DataNativeSqlParser instance");
         }
-        return nativeSqlParser.parse(nativeSql, params == null ? Collections.emptyMap() : params);
+        return nativeSqlParser.parse(prepareSign, nativeSql, params == null ? Collections.emptyMap() : params);
     }
 
     @Override
diff --git a/src/main/java/org/redkale/source/DataJdbcSource.java b/src/main/java/org/redkale/source/DataJdbcSource.java
index ba10cdad1..b69b32b19 100644
--- a/src/main/java/org/redkale/source/DataJdbcSource.java
+++ b/src/main/java/org/redkale/source/DataJdbcSource.java
@@ -2537,7 +2537,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
 
     @Override
     public int nativeUpdate(String sql, Map<String, Object> params) {
-        NativeSqlInfo sinfo = super.nativeParse(sql, params);
+        NativeSqlInfo sinfo = super.nativeParse("?", sql, params);
         final long s = System.currentTimeMillis();
         SourceConnection conn = writePool.pollConnection();
         try {
@@ -2612,7 +2612,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
 
     @Override
     public <V> V nativeQuery(String sql, BiConsumer<Object, Object> consumer, Function<DataResultSet, V> handler, Map<String, Object> params) {
-        NativeSqlInfo sinfo = super.nativeParse(sql, params);
+        NativeSqlInfo sinfo = super.nativeParse("?", sql, params);
         final long s = System.currentTimeMillis();
         final SourceConnection conn = readPool.pollConnection();
         try {
diff --git a/src/main/java/org/redkale/source/DataNativeSqlParser.java b/src/main/java/org/redkale/source/DataNativeSqlParser.java
index 80e6212c8..52a8a5ef4 100644
--- a/src/main/java/org/redkale/source/DataNativeSqlParser.java
+++ b/src/main/java/org/redkale/source/DataNativeSqlParser.java
@@ -19,7 +19,7 @@ import org.redkale.convert.json.JsonConvert;
  */
 public interface DataNativeSqlParser {
 
-    NativeSqlInfo parse(String nativeSql, Map<String, Object> params);
+    NativeSqlInfo parse(String prepareSign, String nativeSql, Map<String, Object> params);
 
     public static class NativeSqlInfo {