This is an automated email from the ASF dual-hosted git repository.
fjtiradosarti pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-kie-kogito-apps.git
The following commit(s) were added to refs/heads/main by this push:
new 631dbad75 [Fix #2197] Adding count for jobs and process definitions
(#2200)
631dbad75 is described below
commit 631dbad750f43cb5e9862b32087f769f7d7ff2ee
Author: Francisco Javier Tirado Sarti
<[email protected]>
AuthorDate: Fri Feb 28 14:31:22 2025 +0100
[Fix #2197] Adding count for jobs and process definitions (#2200)
---
.../src/main/resources/count.schema.graphqls | 2 ++
.../index/jpa/query/AbstractJobEntityQueryIT.java | 18 ++++++++++++++++++
.../query/AbstractProcessDefinitionEntityQueryIT.java | 16 ++++++++++++++++
3 files changed, 36 insertions(+)
diff --git
a/data-index/data-index-graphql/src/main/resources/count.schema.graphqls
b/data-index/data-index-graphql/src/main/resources/count.schema.graphqls
index 180ed7d0d..2e029bbc2 100644
--- a/data-index/data-index-graphql/src/main/resources/count.schema.graphqls
+++ b/data-index/data-index-graphql/src/main/resources/count.schema.graphqls
@@ -1,4 +1,6 @@
extend type Query {
CountProcessInstances(where: ProcessInstanceArgument): Int
CountUserTaskInstances(where: UserTaskInstanceArgument): Int
+ CountJobs(where: JobArgument): Int
+ CountProcessDefinitions(where: ProcessDefinitionArgument): Int
}
\ No newline at end of file
diff --git
a/data-index/data-index-storage/data-index-storage-jpa-common/src/test/java/org/kie/kogito/index/jpa/query/AbstractJobEntityQueryIT.java
b/data-index/data-index-storage/data-index-storage-jpa-common/src/test/java/org/kie/kogito/index/jpa/query/AbstractJobEntityQueryIT.java
index f07b11b5d..1550092f8 100644
---
a/data-index/data-index-storage/data-index-storage-jpa-common/src/test/java/org/kie/kogito/index/jpa/query/AbstractJobEntityQueryIT.java
+++
b/data-index/data-index-storage/data-index-storage-jpa-common/src/test/java/org/kie/kogito/index/jpa/query/AbstractJobEntityQueryIT.java
@@ -18,13 +18,22 @@
*/
package org.kie.kogito.index.jpa.query;
+import java.util.List;
+import java.util.UUID;
+
+import org.apache.commons.lang3.RandomStringUtils;
+import org.junit.jupiter.api.Test;
import org.kie.kogito.index.jpa.storage.JobEntityStorage;
import org.kie.kogito.index.model.Job;
+import org.kie.kogito.index.test.TestUtils;
import org.kie.kogito.index.test.query.AbstractJobQueryIT;
import org.kie.kogito.persistence.api.Storage;
import jakarta.inject.Inject;
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.kie.kogito.persistence.api.query.QueryFilterFactory.equalTo;
+
public abstract class AbstractJobEntityQueryIT extends AbstractJobQueryIT {
@Inject
@@ -35,4 +44,13 @@ public abstract class AbstractJobEntityQueryIT extends
AbstractJobQueryIT {
return storage;
}
+ @Test
+ void testCount() {
+ String jobId = UUID.randomUUID().toString();
+ storage.put(jobId, TestUtils
+ .createJob(jobId, UUID.randomUUID().toString(),
RandomStringUtils.randomAlphabetic(5), UUID.randomUUID().toString(),
+ RandomStringUtils.randomAlphabetic(10), "EXPECTED",
0L));
+ assertThat(storage.query().count()).isNotZero();
+ assertThat(storage.query().filter(List.of(equalTo("status",
"UNEXPECTED"))).count()).isZero();
+ }
}
diff --git
a/data-index/data-index-storage/data-index-storage-jpa-common/src/test/java/org/kie/kogito/index/jpa/query/AbstractProcessDefinitionEntityQueryIT.java
b/data-index/data-index-storage/data-index-storage-jpa-common/src/test/java/org/kie/kogito/index/jpa/query/AbstractProcessDefinitionEntityQueryIT.java
index 1c9a84d66..6bd9af585 100644
---
a/data-index/data-index-storage/data-index-storage-jpa-common/src/test/java/org/kie/kogito/index/jpa/query/AbstractProcessDefinitionEntityQueryIT.java
+++
b/data-index/data-index-storage/data-index-storage-jpa-common/src/test/java/org/kie/kogito/index/jpa/query/AbstractProcessDefinitionEntityQueryIT.java
@@ -18,14 +18,22 @@
*/
package org.kie.kogito.index.jpa.query;
+import java.util.List;
+import java.util.Set;
+
+import org.junit.jupiter.api.Test;
import org.kie.kogito.index.jpa.storage.ProcessDefinitionEntityStorage;
import org.kie.kogito.index.model.ProcessDefinition;
import org.kie.kogito.index.model.ProcessDefinitionKey;
+import org.kie.kogito.index.test.TestUtils;
import org.kie.kogito.index.test.query.AbstractProcessDefinitionQueryIT;
import org.kie.kogito.persistence.api.Storage;
import jakarta.inject.Inject;
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.kie.kogito.persistence.api.query.QueryFilterFactory.equalTo;
+
public abstract class AbstractProcessDefinitionEntityQueryIT extends
AbstractProcessDefinitionQueryIT {
@Inject
@@ -36,4 +44,12 @@ public abstract class AbstractProcessDefinitionEntityQueryIT
extends AbstractPro
return storage;
}
+ @Test
+ void testCount() {
+ ProcessDefinition pdv1 = TestUtils.createProcessDefinition("items",
"1.0", Set.of("admin", "kogito"));
+ storage.put(new ProcessDefinitionKey(pdv1.getId(), pdv1.getVersion()),
pdv1);
+ assertThat(storage.query().count()).isNotZero();
+ assertThat(storage.query().filter(List.of(equalTo("version",
"60.0"))).count()).isZero();
+ }
+
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
