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-01-15 23:11:16 +08:00
parent 19c8ffb79d
commit f5d79c7035
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -2535,10 +2535,10 @@ public abstract class DataSqlSource extends AbstractDataSource implements Functi
return CompletableFuture.completedFuture(rs); return CompletableFuture.completedFuture(rs);
} }
} }
return findsComposeAsync(info, selects, pks); return findsDBAsync(info, selects, pks);
} }
protected <T> CompletableFuture<T[]> findsComposeAsync(final EntityInfo<T> info, final SelectColumn selects, Serializable... pks) { protected <T> CompletableFuture<T[]> findsDBAsync(final EntityInfo<T> info, final SelectColumn selects, Serializable... pks) {
final Attribute<T, Serializable> primary = info.getPrimary(); final Attribute<T, Serializable> primary = info.getPrimary();
return queryListAsync(info.getType(), selects, null, FilterNode.create(info.getPrimarySQLColumn(), FilterExpress.IN, pks)).thenApply(list -> { return queryListAsync(info.getType(), selects, null, FilterNode.create(info.getPrimarySQLColumn(), FilterExpress.IN, pks)).thenApply(list -> {
T[] rs = info.getArrayer().apply(pks.length); T[] rs = info.getArrayer().apply(pks.length);