lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

DataNativeSqlParser

Browse Source
This commit is contained in:
redkale
2023-08-10 00:08:09 +08:00
parent 302259e30d
commit e5d31344b9
3 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/org/redkale/source/AbstractDataSqlSource.java
View File

@@ -642,11 +642,11 @@ public abstract class AbstractDataSqlSource extends AbstractDataSource implement
return getSQLAttrValue(info, attr, val); 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) { if (nativeSqlParser == null) {
throw new SourceException("not found DataNativeSqlParser instance"); 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 @Override

4
src/main/java/org/redkale/source/DataJdbcSource.java
View File

@@ -2537,7 +2537,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
@Override @Override
public int nativeUpdate(String sql, Map<String, Object> params) { 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(); final long s = System.currentTimeMillis();
SourceConnection conn = writePool.pollConnection(); SourceConnection conn = writePool.pollConnection();
try { try {
@@ -2612,7 +2612,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
@Override @Override
public <V> V nativeQuery(String sql, BiConsumer<Object, Object> consumer, Function<DataResultSet, V> handler, Map<String, Object> params) { 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 long s = System.currentTimeMillis();
final SourceConnection conn = readPool.pollConnection(); final SourceConnection conn = readPool.pollConnection();
try { try {

2
src/main/java/org/redkale/source/DataNativeSqlParser.java
View File

@@ -19,7 +19,7 @@ import org.redkale.convert.json.JsonConvert;
*/ */
public interface DataNativeSqlParser { 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 { public static class NativeSqlInfo {