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

Browse Source
This commit is contained in:
Redkale
2018-05-06 18:23:38 +08:00
parent 78df572bec
commit 20940e82de
1 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/org/redkale/source/DataSqlSource.java
View File

@@ -243,8 +243,13 @@ public abstract class DataSqlSource<DBChannel> extends AbstractService implement
@Override @Override
public <T> int insert(@RpcCall(DataCallArrayAttribute.class) T... values) { public <T> int insert(@RpcCall(DataCallArrayAttribute.class) T... values) {
if (values.length == 0) return 0; if (values.length == 0) return 0;
final EntityInfo<T> info = loadEntityInfo((Class<T>) values[0].getClass());
checkEntity("insert", false, values); checkEntity("insert", false, values);
final EntityInfo<T> info = loadEntityInfo((Class<T>) values[0].getClass());
if (info.autouuid) {
for (T value : values) {
info.createPrimaryValue(value);
}
}
if (info.isVirtualEntity()) return insertCache(info, values); if (info.isVirtualEntity()) return insertCache(info, values);
return insertDB(info, values).whenComplete((rs, t) -> { return insertDB(info, values).whenComplete((rs, t) -> {
if (t != null) { if (t != null) {
@@ -261,6 +266,11 @@ public abstract class DataSqlSource<DBChannel> extends AbstractService implement
CompletableFuture future = checkEntity("insert", true, values); CompletableFuture future = checkEntity("insert", true, values);
if (future != null) return future; if (future != null) return future;
final EntityInfo<T> info = loadEntityInfo((Class<T>) values[0].getClass()); final EntityInfo<T> info = loadEntityInfo((Class<T>) values[0].getClass());
if (info.autouuid) {
for (T value : values) {
info.createPrimaryValue(value);
}
}
if (info.isVirtualEntity()) { if (info.isVirtualEntity()) {
return CompletableFuture.supplyAsync(() -> insertCache(info, values), getExecutor()); return CompletableFuture.supplyAsync(() -> insertCache(info, values), getExecutor());
} }