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

http://jira.mfd.msk:8088/browse/CLS-427 реализация методов в transactional Imdg

Browse source
This commit is contained in:
ialbert 2023-07-17 18:20:01 +03:00
parent 658810cc85
commit 07293ff3eb
1 changed files with 23 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -91,6 +91,29 @@ public class ImdgTransactionalHazelcast<T extends SpcexObjectBase> implements Im
} }
} }
@Override
public T getFirstObjectBySQL(String paramString) {
SqlPredicate sqlPredicate = new SqlPredicate(paramString);
Set<Long> found = map.keySet(sqlPredicate);
Iterator<Long> allFoundByCondition = found.iterator();
if (allFoundByCondition.hasNext()) {
return map.get(allFoundByCondition.next());
} else return null;
}
@Override
public T getSingleObjectBySQL(String paramString) {
SqlPredicate sqlPredicate = new SqlPredicate(paramString);
Set<Long> found = map.keySet(sqlPredicate);
if (found.size() > 1) {
throw new RuntimeException("More than one element found by predicate " + paramString + " - " + found.size());
}
Iterator<Long> allFoundByCondition = found.iterator();
if (allFoundByCondition.hasNext()) {
return map.get(allFoundByCondition.next());
} else return null;
}
@Override @Override
public Collection<T> getCollectionObjectsBySQL(String paramString) { public Collection<T> getCollectionObjectsBySQL(String paramString) {
SqlPredicate sqlPredicate = new SqlPredicate(paramString); SqlPredicate sqlPredicate = new SqlPredicate(paramString);