Skip to content
Snippets Groups Projects
Verified Commit 366b9696 authored by Timm Fitschen's avatar Timm Fitschen
Browse files

fix count result

parent aa2568f9
No related branches found
No related tags found
2 merge requests!44Release 0.6,!43Merge f-GRPC-main to dev
Pipeline #11566 canceled
......@@ -235,8 +235,8 @@ public class EntityTransactionServiceImpl extends EntityTransactionServiceImplBa
final Retrieve transaction = new Retrieve(container);
transaction.execute();
if (container.getFlags().containsKey("_isCount")) {
final int count = Integer.parseInt(container.getFlags().get("_isCount"));
if (container.getFlags().containsKey("query_count_result")) {
final int count = Integer.parseInt(container.getFlags().get("query_count_result"));
builder
.addResponsesBuilder()
.setRetrieveResponse(RetrieveResponse.newBuilder().setCountResult(count));
......
......
......@@ -54,7 +54,9 @@ public class ExecuteQuery extends FlagJob {
}
getContainer().addMessage(queryInstance);
if (queryInstance.getQuery().getType() == Type.COUNT) {
getContainer().getFlags().put("count", Integer.toString(queryInstance.getCount()));
getContainer()
.getFlags()
.put("query_count_result", Integer.toString(queryInstance.getCount()));
}
for (final EntityInterface entity : getContainer()) {
getTransaction().getSchedule().addAll(loadJobs(entity, getTransaction()));
......
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment