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

DataSqlSource方法名优化

Browse Source
This commit is contained in:
redkale
2023-04-20 21:47:01 +08:00
parent 82fa56d66c
commit bec1c0c2d8
4 changed files with 28 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -668,15 +668,15 @@ public abstract class AbstractDataSqlSource extends AbstractDataSource implement
@Local @Local
@Override @Override
public abstract int directExecute(String sql); public abstract int nativeExecute(String sql);
@Local @Local
@Override @Override
public abstract int[] directExecute(String... sqls); public abstract int[] nativeExecute(String... sqls);
@Local @Local
@Override @Override
public abstract <V> V directQuery(String sql, Function<DataResultSet, V> handler); public abstract <V> V nativeQuery(String sql, Function<DataResultSet, V> handler);
//是否异步 //是否异步
protected abstract boolean isAsync(); protected abstract boolean isAsync();

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

@@ -2466,8 +2466,8 @@ public class DataJdbcSource extends AbstractDataSqlSource {
*/ */
@Local @Local
@Override @Override
public int directExecute(String sql) { public int nativeExecute(String sql) {
return directExecute(new String[]{sql})[0]; return nativeExecute(new String[]{sql})[0];
} }
/** /**
@@ -2480,7 +2480,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
*/ */
@Local @Local
@Override @Override
public int[] directExecute(String... sqls) { public int[] nativeExecute(String... sqls) {
if (sqls.length == 0) { if (sqls.length == 0) {
return new int[0]; return new int[0];
} }
@@ -2523,7 +2523,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
*/ */
@Local @Local
@Override @Override
public <V> V directQuery(String sql, Function<DataResultSet, V> handler) { public <V> V nativeQuery(String sql, Function<DataResultSet, V> handler) {
final long s = System.currentTimeMillis(); final long s = System.currentTimeMillis();
final Connection conn = readPool.pollConnection(); final Connection conn = readPool.pollConnection();
try { try {

6
src/main/java/org/redkale/source/DataMemorySource.java
View File

@@ -94,17 +94,17 @@ public class DataMemorySource extends AbstractDataSqlSource implements SearchSou
} }
@Override @Override
public int directExecute(String sql) { public int nativeExecute(String sql) {
throw new UnsupportedOperationException("Not supported yet."); throw new UnsupportedOperationException("Not supported yet.");
} }
@Override @Override
public int[] directExecute(String... sqls) { public int[] nativeExecute(String... sqls) {
throw new UnsupportedOperationException("Not supported yet."); throw new UnsupportedOperationException("Not supported yet.");
} }
@Override @Override
public <V> V directQuery(String sql, Function<DataResultSet, V> handler) { public <V> V nativeQuery(String sql, Function<DataResultSet, V> handler) {
throw new UnsupportedOperationException("Not supported yet."); throw new UnsupportedOperationException("Not supported yet.");
} }

21
src/main/java/org/redkale/source/DataSqlSource.java
View File

@@ -17,9 +17,24 @@ import java.util.function.Function;
*/ */
public interface DataSqlSource extends DataSource { public interface DataSqlSource extends DataSource {
public int directExecute(String sql); public int nativeExecute(String sql);
public int[] directExecute(String... sqls); public int[] nativeExecute(String... sqls);
public <V> V directQuery(String sql, Function<DataResultSet, V> handler); public <V> V nativeQuery(String sql, Function<DataResultSet, V> handler);
@Deprecated
default int directExecute(String sql) {
return nativeExecute(sql);
}
@Deprecated
default int[] directExecute(String... sqls) {
return nativeExecute(sqls);
}
@Deprecated
default <V> V directQuery(String sql, Function<DataResultSet, V> handler) {
return nativeQuery(sql, handler);
}
} }