treshenkov/clearing
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Imdg.insert return id

Browse source
This commit is contained in:
AKurakin 2023-04-05 13:23:52 +03:00
parent 316e2fe042
commit c8306a1f7f
3 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
platform-parent/platform-imdg-api-hazelcast-impl/src/main/java/ru/spcex/platform/imdg/iml/hazelcast/adapter/ImdgHazelcast.java
View file

@ -40,11 +40,12 @@ public class ImdgHazelcast<T extends SpcexObjectBase> implements Imdg<T> {
} }
@Override @Override
public void insert(T paramT) { public Long insert(T paramT) {
if (paramT.getId() == null) { if (paramT.getId() == null) {
paramT.setId(idGenerator.newId()); paramT.setId(idGenerator.newId());
} }
map.put(paramT.getId(), paramT); map.put(paramT.getId(), paramT);
return paramT.getId();
} }
@Override @Override

3
platform-parent/platform-imdg-api-hazelcast-impl/src/main/java/ru/spcex/platform/imdg/iml/hazelcast/adapter/ImdgTransactionalHazelcast.java
View file

@ -25,11 +25,12 @@ public class ImdgTransactionalHazelcast<T extends SpcexObjectBase> implements Im
private HazelcastInstance hzInstance; private HazelcastInstance hzInstance;
@Override @Override
public void insert(T paramT) { public Long insert(T paramT) {
if (paramT.getId() == null) { if (paramT.getId() == null) {
paramT.setId(idGenerator.newId()); paramT.setId(idGenerator.newId());
} }
map.put(paramT.getId(), paramT); map.put(paramT.getId(), paramT);
return paramT.getId();
} }
@Override @Override

2
platform-parent/platform-imdg-api/src/main/java/ru/spcex/platform/imdg/api/Imdg.java
View file

@ -12,7 +12,7 @@ public interface Imdg<T extends SpcexObjectBase> {
throw new UnsupportedOperationException("not implemented name"); throw new UnsupportedOperationException("not implemented name");
} }
default void insert(T paramT) { default Long insert(T paramT) {
throw new UnsupportedOperationException("not implemented insert"); throw new UnsupportedOperationException("not implemented insert");
} }