Skip to content

Commit 949fbbb

Browse files
amporsimamporsim
committed
Add .listIds() to support fetching ids only
1 parent 55cdec3 commit 949fbbb

File tree

299 files changed

+1671
-30
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

299 files changed

+1671
-30
lines changed

‎modules/flowable-app-engine/src/main/java/org/flowable/app/engine/impl/persistence/entity/AppDefinitionEntityManager.java

+2
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,8 @@ public interface AppDefinitionEntityManager extends EntityManager<AppDefinitionE
3939

4040
List<AppDefinition> findAppDefinitionsByQueryCriteria(AppDefinitionQuery appDefinitionQuery);
4141

42+
List<String> findAppDefinitionIdsByQueryCriteria(AppDefinitionQuery appDefinitionQuery);
43+
4244
long findAppDefinitionCountByQueryCriteria(AppDefinitionQuery appDefinitionQuery);
4345

4446
}

‎modules/flowable-app-engine/src/main/java/org/flowable/app/engine/impl/persistence/entity/AppDefinitionEntityManagerImpl.java

+5
Original file line numberDiff line numberDiff line change
@@ -79,6 +79,11 @@ public List<AppDefinition> findAppDefinitionsByQueryCriteria(AppDefinitionQuery
7979
return dataManager.findAppDefinitionsByQueryCriteria((AppDefinitionQueryImpl) appDefinitionQuery);
8080
}
8181

82+
@Override
83+
public List<String> findAppDefinitionIdsByQueryCriteria(AppDefinitionQuery appDefinitionQuery) {
84+
return dataManager.findAppDefinitionIdsByQueryCriteria((AppDefinitionQueryImpl) appDefinitionQuery);
85+
}
86+
8287
@Override
8388
public long findAppDefinitionCountByQueryCriteria(AppDefinitionQuery appDefinitionQuery) {
8489
return dataManager.findAppDefinitionCountByQueryCriteria((AppDefinitionQueryImpl) appDefinitionQuery);

‎modules/flowable-app-engine/src/main/java/org/flowable/app/engine/impl/persistence/entity/AppDeploymentEntityManager.java

+2
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,8 @@ public interface AppDeploymentEntityManager extends EntityManager<AppDeploymentE
3232
AppDeploymentQuery createDeploymentQuery();
3333

3434
List<AppDeployment> findDeploymentsByQueryCriteria(AppDeploymentQuery deploymentQuery);
35+
36+
List<String> findDeploymentIdsByQueryCriteria(AppDeploymentQuery deploymentQuery);
3537

3638
long findDeploymentCountByQueryCriteria(AppDeploymentQuery deploymentQuery);
3739

‎modules/flowable-app-engine/src/main/java/org/flowable/app/engine/impl/persistence/entity/AppDeploymentEntityManagerImpl.java

+5
Original file line numberDiff line numberDiff line change
@@ -79,6 +79,11 @@ public AppDeploymentQuery createDeploymentQuery() {
7979
public List<AppDeployment> findDeploymentsByQueryCriteria(AppDeploymentQuery deploymentQuery) {
8080
return dataManager.findDeploymentsByQueryCriteria((AppDeploymentQueryImpl) deploymentQuery);
8181
}
82+
83+
@Override
84+
public List<String> findDeploymentIdsByQueryCriteria(AppDeploymentQuery deploymentQuery) {
85+
return dataManager.findDeploymentIdsByQueryCriteria((AppDeploymentQueryImpl) deploymentQuery);
86+
}
8287

8388
@Override
8489
public long findDeploymentCountByQueryCriteria(AppDeploymentQuery deploymentQuery) {

‎modules/flowable-app-engine/src/main/java/org/flowable/app/engine/impl/persistence/entity/data/AppDefinitionDataManager.java

+2
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,8 @@ public interface AppDefinitionDataManager extends DataManager<AppDefinitionEntit
4242

4343
List<AppDefinition> findAppDefinitionsByQueryCriteria(AppDefinitionQueryImpl appDefinitionQuery);
4444

45+
List<String> findAppDefinitionIdsByQueryCriteria(AppDefinitionQueryImpl appDefinitionQuery);
46+
4547
long findAppDefinitionCountByQueryCriteria(AppDefinitionQueryImpl appDefinitionQuery);
4648

4749
}

‎modules/flowable-app-engine/src/main/java/org/flowable/app/engine/impl/persistence/entity/data/AppDeploymentDataManager.java

+2
Original file line numberDiff line numberDiff line change
@@ -32,4 +32,6 @@ public interface AppDeploymentDataManager extends DataManager<AppDeploymentEntit
3232

3333
List<AppDeployment> findDeploymentsByQueryCriteria(AppDeploymentQueryImpl deploymentQuery);
3434

35+
List<String> findDeploymentIdsByQueryCriteria(AppDeploymentQueryImpl deploymentQuery);
36+
3537
}

‎modules/flowable-app-engine/src/main/java/org/flowable/app/engine/impl/persistence/entity/data/impl/MybatisAppDefinitionDataManager.java

+6
Original file line numberDiff line numberDiff line change
@@ -123,6 +123,12 @@ public List<AppDefinition> findAppDefinitionsByQueryCriteria(AppDefinitionQueryI
123123
return getDbSqlSession().selectList("selectAppDefinitionsByQueryCriteria", appDefinitionQuery);
124124
}
125125

126+
@Override
127+
@SuppressWarnings("unchecked")
128+
public List<String> findAppDefinitionIdsByQueryCriteria(AppDefinitionQueryImpl appDefinitionQuery) {
129+
return getDbSqlSession().selectList("selectAppDefinitionIdsByQueryCriteria", appDefinitionQuery);
130+
}
131+
126132
@Override
127133
public long findAppDefinitionCountByQueryCriteria(AppDefinitionQueryImpl appDefinitionQuery) {
128134
return (Long) getDbSqlSession().selectOne("selectAppDefinitionCountByQueryCriteria", appDefinitionQuery);

‎modules/flowable-app-engine/src/main/java/org/flowable/app/engine/impl/persistence/entity/data/impl/MybatisAppDeploymentDataManager.java

+6-1
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,12 @@ public List<String> getDeploymentResourceNames(String deploymentId) {
6060
public List<AppDeployment> findDeploymentsByQueryCriteria(AppDeploymentQueryImpl deploymentQuery) {
6161
return getDbSqlSession().selectList("selectAppDeploymentsByQueryCriteria", deploymentQuery);
6262
}
63-
63+
64+
@Override
65+
public List<String> findDeploymentIdsByQueryCriteria(AppDeploymentQueryImpl deploymentQuery) {
66+
return getDbSqlSession().selectList("selectAppDeploymentIdsByQueryCriteria", deploymentQuery);
67+
}
68+
6469
@Override
6570
public long findDeploymentCountByQueryCriteria(AppDeploymentQueryImpl deploymentQuery) {
6671
return (Long) getDbSqlSession().selectOne("selectAppDeploymentCountByQueryCriteria", deploymentQuery);

‎modules/flowable-app-engine/src/main/java/org/flowable/app/engine/impl/repository/AppDefinitionQueryImpl.java

+5
Original file line numberDiff line numberDiff line change
@@ -303,6 +303,11 @@ public List<AppDefinition> executeList(CommandContext commandContext) {
303303
return CommandContextUtil.getAppDefinitionEntityManager(commandContext).findAppDefinitionsByQueryCriteria(this);
304304
}
305305

306+
@Override
307+
public List<String> executeListIds(CommandContext commandContext) {
308+
return CommandContextUtil.getAppDefinitionEntityManager(commandContext).findAppDefinitionIdsByQueryCriteria(this);
309+
}
310+
306311
// getters ////////////////////////////////////////////
307312

308313
public String getDeploymentId() {

‎modules/flowable-app-engine/src/main/java/org/flowable/app/engine/impl/repository/AppDeploymentQueryImpl.java

+5
Original file line numberDiff line numberDiff line change
@@ -185,6 +185,11 @@ public List<AppDeployment> executeList(CommandContext commandContext) {
185185
return CommandContextUtil.getAppDeploymentEntityManager(commandContext).findDeploymentsByQueryCriteria(this);
186186
}
187187

188+
@Override
189+
public List<String> executeListIds(CommandContext commandContext) {
190+
return CommandContextUtil.getAppDeploymentEntityManager(commandContext).findDeploymentIdsByQueryCriteria(this);
191+
}
192+
188193
// getters ////////////////////////////////////////////////////////
189194

190195
public String getDeploymentId() {

‎modules/flowable-app-engine/src/main/resources/org/flowable/app/db/mapping/entity/AppDefinition.xml

+8
Original file line numberDiff line numberDiff line change
@@ -144,6 +144,14 @@
144144
<if test="needsPaging">${limitAfter}</if>
145145
</select>
146146

147+
<select id="selectAppDefinitionIdsByQueryCriteria" parameterType="org.flowable.app.engine.impl.repository.AppDefinitionQueryImpl" resultType="string">
148+
<if test="needsPaging">${limitBefore}</if>
149+
SELECT RES.ID_ <if test="needsPaging">${limitBetween}</if>
150+
<include refid="selectAppDefinitionsByQueryCriteriaSql"/>
151+
${orderBy}
152+
<if test="needsPaging">${limitAfter}</if>
153+
</select>
154+
147155
<select id="selectAppDefinitionCountByQueryCriteria" parameterType="org.flowable.app.engine.impl.repository.AppDefinitionQueryImpl" resultType="long">
148156
select count(RES.ID_)
149157
<include refid="selectAppDefinitionsByQueryCriteriaSql"/>

‎modules/flowable-app-engine/src/main/resources/org/flowable/app/db/mapping/entity/AppDeployment.xml

+8
Original file line numberDiff line numberDiff line change
@@ -102,6 +102,14 @@
102102
<if test="needsPaging">${limitAfter}</if>
103103
</select>
104104

105+
<select id="selectAppDeploymentIdsByQueryCriteria" parameterType="org.flowable.app.engine.impl.repository.AppDeploymentQueryImpl" resultType="string">
106+
<if test="needsPaging">${limitBefore}</if>
107+
SELECT RES.ID_ <if test="needsPaging">${limitBetween}</if>
108+
<include refid="selectAppDeploymentsByQueryCriteriaSql"/>
109+
${orderBy}
110+
<if test="needsPaging">${limitAfter}</if>
111+
</select>
112+
105113
<select id="selectAppDeploymentCountByQueryCriteria" parameterType="org.flowable.app.engine.impl.repository.AppDeploymentQueryImpl" resultType="long">
106114
select count(RES.ID_)
107115
<include refid="selectAppDeploymentsByQueryCriteriaSql"/>

‎modules/flowable-app-engine/src/test/java/org/flowable/app/engine/test/repository/AppDefinitionQueryTest.java

+7
Original file line numberDiff line numberDiff line change
@@ -89,21 +89,26 @@ public void testQueryNoParams() {
8989
@Test
9090
public void testQueryByDeploymentId() {
9191
assertThat(appRepositoryService.createAppDefinitionQuery().deploymentId(deploymentId1).list()).hasSize(1);
92+
assertThat(appRepositoryService.createAppDefinitionQuery().deploymentId(deploymentId1).listIds()).hasSize(1);
9293
assertThat(appRepositoryService.createAppDefinitionQuery().deploymentId(deploymentId1).count()).isEqualTo(1);
9394

9495
assertThat(appRepositoryService.createAppDefinitionQuery().deploymentId(deploymentId2).list()).hasSize(1);
96+
assertThat(appRepositoryService.createAppDefinitionQuery().deploymentId(deploymentId2).listIds()).hasSize(1);
9597
assertThat(appRepositoryService.createAppDefinitionQuery().deploymentId(deploymentId2).count()).isEqualTo(1);
9698

9799
assertThat(appRepositoryService.createAppDefinitionQuery().deploymentId(deploymentId3).list()).hasSize(1);
100+
assertThat(appRepositoryService.createAppDefinitionQuery().deploymentId(deploymentId3).listIds()).hasSize(1);
98101
assertThat(appRepositoryService.createAppDefinitionQuery().deploymentId(deploymentId3).count()).isEqualTo(1);
99102

100103
assertThat(appRepositoryService.createAppDefinitionQuery().deploymentId(deploymentId4).list()).hasSize(1);
104+
assertThat(appRepositoryService.createAppDefinitionQuery().deploymentId(deploymentId4).listIds()).hasSize(1);
101105
assertThat(appRepositoryService.createAppDefinitionQuery().deploymentId(deploymentId4).count()).isEqualTo(1);
102106
}
103107

104108
@Test
105109
public void testQueryByInvalidDeploymentId() {
106110
assertThat(appRepositoryService.createAppDefinitionQuery().deploymentId("invalid").list()).isEmpty();
111+
assertThat(appRepositoryService.createAppDefinitionQuery().deploymentId("invalid").listIds()).isEmpty();
107112
assertThat(appRepositoryService.createAppDefinitionQuery().deploymentId("invalid").count()).isZero();
108113
}
109114

@@ -222,9 +227,11 @@ public void testQueryByAppDefinitionCategoryNotEquals() {
222227
@Test
223228
public void testQueryByAppDefinitionName() {
224229
assertThat(appRepositoryService.createAppDefinitionQuery().appDefinitionName("Test app").list()).hasSize(3);
230+
assertThat(appRepositoryService.createAppDefinitionQuery().appDefinitionName("Test app").listIds()).hasSize(3);
225231
assertThat(appRepositoryService.createAppDefinitionQuery().appDefinitionName("Test app").count()).isEqualTo(3);
226232

227233
assertThat(appRepositoryService.createAppDefinitionQuery().appDefinitionName("Full info app").list()).hasSize(1);
234+
assertThat(appRepositoryService.createAppDefinitionQuery().appDefinitionName("Full info app").listIds()).hasSize(1);
228235
assertThat(appRepositoryService.createAppDefinitionQuery().appDefinitionName("Full info app").count()).isEqualTo(1);
229236

230237
assertThat(appRepositoryService.createAppDefinitionQuery().appDefinitionName("Full info app").singleResult().getDeploymentId())

‎modules/flowable-app-engine/src/test/java/org/flowable/app/engine/test/repository/DeploymentQueryTest.java

+11
Original file line numberDiff line numberDiff line change
@@ -59,42 +59,51 @@ public void deleteTestDeployments() {
5959
@Test
6060
public void testQueryNoParams() {
6161
assertThat(appRepositoryService.createDeploymentQuery().list()).hasSize(2);
62+
assertThat(appRepositoryService.createDeploymentQuery().listIds()).hasSize(2);
6263
assertThat(appRepositoryService.createDeploymentQuery().count()).isEqualTo(2);
6364

6465
assertThat(appRepositoryService.createDeploymentQuery().list())
6566
.extracting(AppDeployment::getId)
6667
.containsExactlyInAnyOrder(deploymentId1, deploymentId2);
68+
69+
assertThat(appRepositoryService.createDeploymentQuery().listIds())
70+
.containsExactlyInAnyOrder(deploymentId1, deploymentId2);
6771
}
6872

6973
@Test
7074
public void testQueryByDeploymentId() {
7175
assertThat(appRepositoryService.createDeploymentQuery().deploymentId(deploymentId1).singleResult()).isNotNull();
7276
assertThat(appRepositoryService.createDeploymentQuery().deploymentId(deploymentId1).singleResult().getId()).isEqualTo(deploymentId1);
7377
assertThat(appRepositoryService.createDeploymentQuery().deploymentId(deploymentId1).list()).hasSize(1);
78+
assertThat(appRepositoryService.createDeploymentQuery().deploymentId(deploymentId1).listIds()).hasSize(1);
7479
assertThat(appRepositoryService.createDeploymentQuery().deploymentId(deploymentId1).count()).isEqualTo(1);
7580

7681
assertThat(appRepositoryService.createDeploymentQuery().deploymentId(deploymentId2).singleResult()).isNotNull();
7782
assertThat(appRepositoryService.createDeploymentQuery().deploymentId(deploymentId2).list()).hasSize(1);
83+
assertThat(appRepositoryService.createDeploymentQuery().deploymentId(deploymentId2).listIds()).hasSize(1);
7884
assertThat(appRepositoryService.createDeploymentQuery().deploymentId(deploymentId2).count()).isEqualTo(1);
7985
}
8086

8187
@Test
8288
public void testQueryByInvalidDeploymentId() {
8389
assertThat(appRepositoryService.createDeploymentQuery().deploymentId("invalid").singleResult()).isNull();
8490
assertThat(appRepositoryService.createDeploymentQuery().deploymentId("invalid").list()).isEmpty();
91+
assertThat(appRepositoryService.createDeploymentQuery().deploymentId("invalid").listIds()).isEmpty();
8592
assertThat(appRepositoryService.createDeploymentQuery().deploymentId("invalid").count()).isZero();
8693
}
8794

8895
@Test
8996
public void testQueryByDeploymentIds() {
9097
assertThat(appRepositoryService.createDeploymentQuery().deploymentIds(Arrays.asList(deploymentId1, deploymentId2, "dummy")).list()).hasSize(2);
98+
assertThat(appRepositoryService.createDeploymentQuery().deploymentIds(Arrays.asList(deploymentId1, deploymentId2, "dummy")).listIds()).hasSize(2);
9199
assertThat(appRepositoryService.createDeploymentQuery().deploymentIds(Arrays.asList(deploymentId2, "dummy")).singleResult()).isNotNull();
92100
}
93101

94102
@Test
95103
public void testQueryByInvalidDeploymentIds() {
96104
assertThat(appRepositoryService.createDeploymentQuery().deploymentIds(Collections.singletonList("invalid")).singleResult()).isNull();
97105
assertThat(appRepositoryService.createDeploymentQuery().deploymentIds(Collections.singletonList("invalid")).list()).isEmpty();
106+
assertThat(appRepositoryService.createDeploymentQuery().deploymentIds(Collections.singletonList("invalid")).listIds()).isEmpty();
98107
assertThat(appRepositoryService.createDeploymentQuery().deploymentIds(Collections.singletonList("invalid")).count()).isZero();
99108
assertThatThrownBy(() -> appRepositoryService.createDeploymentQuery().deploymentIds(null))
100109
.isInstanceOf(FlowableIllegalArgumentException.class)
@@ -121,10 +130,12 @@ public void testQueryByDeploymentNameLike() {
121130
assertThat(appRepositoryService.createDeploymentQuery().deploymentNameLike("test%").singleResult()).isNotNull();
122131
assertThat(appRepositoryService.createDeploymentQuery().deploymentNameLike("test%").singleResult().getId()).isEqualTo(deploymentId2);
123132
assertThat(appRepositoryService.createDeploymentQuery().deploymentNameLike("test%").list()).hasSize(1);
133+
assertThat(appRepositoryService.createDeploymentQuery().deploymentNameLike("test%").listIds()).hasSize(1);
124134
assertThat(appRepositoryService.createDeploymentQuery().deploymentNameLike("test%").count()).isEqualTo(1);
125135

126136
assertThat(appRepositoryService.createDeploymentQuery().deploymentNameLike("inval%").singleResult()).isNull();
127137
assertThat(appRepositoryService.createDeploymentQuery().deploymentNameLike("inval%").list()).isEmpty();
138+
assertThat(appRepositoryService.createDeploymentQuery().deploymentNameLike("inval%").listIds()).isEmpty();
128139
assertThat(appRepositoryService.createDeploymentQuery().deploymentNameLike("inval%").count()).isZero();
129140
}
130141

‎modules/flowable-batch-service/src/main/java/org/flowable/batch/service/impl/BatchPartQueryImpl.java

+5
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,11 @@ public List<BatchPart> executeList(CommandContext commandContext) {
6161
return batchServiceConfiguration.getBatchPartEntityManager().findBatchPartsByQueryCriteria(this);
6262
}
6363

64+
@Override
65+
public List<String> executeListIds(CommandContext commandContext) {
66+
return batchServiceConfiguration.getBatchPartEntityManager().findBatchPartIdsByQueryCriteria(this);
67+
}
68+
6469
@Override
6570
public BatchPartQuery id(String id) {
6671
if (id == null) {

‎modules/flowable-batch-service/src/main/java/org/flowable/batch/service/impl/BatchQueryImpl.java

+5
Original file line numberDiff line numberDiff line change
@@ -205,6 +205,11 @@ public List<Batch> executeList(CommandContext commandContext) {
205205
return batchServiceConfiguration.getBatchEntityManager().findBatchesByQueryCriteria(this);
206206
}
207207

208+
@Override
209+
public List<String> executeListIds(CommandContext commandContext) {
210+
return batchServiceConfiguration.getBatchEntityManager().findBatchIdsByQueryCriteria(this);
211+
}
212+
208213
@Override
209214
public void delete() {
210215
if (commandExecutor != null) {

‎modules/flowable-batch-service/src/main/java/org/flowable/batch/service/impl/persistence/entity/BatchEntityManager.java

+2
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,8 @@ public interface BatchEntityManager extends EntityManager<BatchEntity> {
2626
List<Batch> findAllBatches();
2727

2828
List<Batch> findBatchesByQueryCriteria(BatchQueryImpl batchQuery);
29+
30+
List<String> findBatchIdsByQueryCriteria(BatchQueryImpl batchQuery);
2931

3032
long findBatchCountByQueryCriteria(BatchQueryImpl batchQuery);
3133

‎modules/flowable-batch-service/src/main/java/org/flowable/batch/service/impl/persistence/entity/BatchEntityManagerImpl.java

+5
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,11 @@ public List<Batch> findBatchesByQueryCriteria(BatchQueryImpl batchQuery) {
4747
return dataManager.findBatchesByQueryCriteria(batchQuery);
4848
}
4949

50+
@Override
51+
public List<String> findBatchIdsByQueryCriteria(BatchQueryImpl batchQuery) {
52+
return dataManager.findBatchIdsByQueryCriteria(batchQuery);
53+
}
54+
5055
@Override
5156
public long findBatchCountByQueryCriteria(BatchQueryImpl batchQuery) {
5257
return dataManager.findBatchCountByQueryCriteria(batchQuery);

‎modules/flowable-batch-service/src/main/java/org/flowable/batch/service/impl/persistence/entity/BatchPartEntityManager.java

+2
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,8 @@ public interface BatchPartEntityManager extends EntityManager<BatchPartEntity> {
2828

2929
List<BatchPart> findBatchPartsByQueryCriteria(BatchPartQuery batchPartQuery);
3030

31+
List<String> findBatchPartIdsByQueryCriteria(BatchPartQuery batchPartQuery);
32+
3133
long findBatchPartCountByQueryCriteria(BatchPartQuery batchPartQuery);
3234

3335
BatchPartEntity createBatchPart(BatchEntity parentBatch, String status, String scopeId, String subScopeId, String scopeType);

‎modules/flowable-batch-service/src/main/java/org/flowable/batch/service/impl/persistence/entity/BatchPartEntityManagerImpl.java

+5
Original file line numberDiff line numberDiff line change
@@ -51,6 +51,11 @@ public List<BatchPart> findBatchPartsByQueryCriteria(BatchPartQuery batchPartQue
5151
return dataManager.findBatchPartsByQueryCriteria((BatchPartQueryImpl) batchPartQuery);
5252
}
5353

54+
@Override
55+
public List<String> findBatchPartIdsByQueryCriteria(BatchPartQuery batchPartQuery) {
56+
return dataManager.findBatchPartIdsByQueryCriteria((BatchPartQueryImpl) batchPartQuery);
57+
}
58+
5459
@Override
5560
public long findBatchPartCountByQueryCriteria(BatchPartQuery batchPartQuery) {
5661
return dataManager.findBatchPartCountByQueryCriteria((BatchPartQueryImpl) batchPartQuery);

‎modules/flowable-batch-service/src/main/java/org/flowable/batch/service/impl/persistence/entity/data/BatchDataManager.java

+2
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,8 @@ public interface BatchDataManager extends DataManager<BatchEntity> {
2626
List<Batch> findAllBatches();
2727

2828
List<Batch> findBatchesByQueryCriteria(BatchQueryImpl batchQuery);
29+
30+
List<String> findBatchIdsByQueryCriteria(BatchQueryImpl batchQuery);
2931

3032
long findBatchCountByQueryCriteria(BatchQueryImpl batchQuery);
3133

‎modules/flowable-batch-service/src/main/java/org/flowable/batch/service/impl/persistence/entity/data/BatchPartDataManager.java

+2
Original file line numberDiff line numberDiff line change
@@ -29,5 +29,7 @@ public interface BatchPartDataManager extends DataManager<BatchPartEntity> {
2929

3030
List<BatchPart> findBatchPartsByQueryCriteria(BatchPartQueryImpl batchPartQuery);
3131

32+
List<String> findBatchPartIdsByQueryCriteria(BatchPartQueryImpl batchPartQuery);
33+
3234
long findBatchPartCountByQueryCriteria(BatchPartQueryImpl batchPartQuery);
3335
}

‎modules/flowable-batch-service/src/main/java/org/flowable/batch/service/impl/persistence/entity/data/impl/MybatisBatchDataManager.java

+6
Original file line numberDiff line numberDiff line change
@@ -64,6 +64,12 @@ public List<Batch> findBatchesByQueryCriteria(BatchQueryImpl batchQuery) {
6464
return getDbSqlSession().selectList("selectBatchByQueryCriteria", batchQuery, getManagedEntityClass());
6565
}
6666

67+
@Override
68+
@SuppressWarnings("unchecked")
69+
public List<String> findBatchIdsByQueryCriteria(BatchQueryImpl batchQuery) {
70+
return getDbSqlSession().selectList("selectBatchIdsByQueryCriteria", batchQuery, getManagedEntityClass());
71+
}
72+
6773
@Override
6874
public long findBatchCountByQueryCriteria(BatchQueryImpl batchQuery) {
6975
return (Long) getDbSqlSession().selectOne("selectBatchCountByQueryCriteria", batchQuery);

‎modules/flowable-batch-service/src/main/java/org/flowable/batch/service/impl/persistence/entity/data/impl/MybatisBatchPartDataManager.java

+6
Original file line numberDiff line numberDiff line change
@@ -77,6 +77,12 @@ public List<BatchPart> findBatchPartsByQueryCriteria(BatchPartQueryImpl batchPar
7777
return getDbSqlSession().selectList("selectBatchPartsByQueryCriteria", batchPartQuery, getManagedEntityClass());
7878
}
7979

80+
@Override
81+
@SuppressWarnings("unchecked")
82+
public List<String> findBatchPartIdsByQueryCriteria(BatchPartQueryImpl batchPartQuery) {
83+
return getDbSqlSession().selectList("selectBatchPartIdsByQueryCriteria", batchPartQuery, getManagedEntityClass());
84+
}
85+
8086
@Override
8187
public long findBatchPartCountByQueryCriteria(BatchPartQueryImpl batchPartQuery) {
8288
return (Long) getDbSqlSession().selectOne("selectBatchPartCountByQueryCriteria", batchPartQuery);

‎modules/flowable-batch-service/src/main/resources/org/flowable/batch/service/db/mapping/entity/Batch.xml

+8
Original file line numberDiff line numberDiff line change
@@ -154,6 +154,14 @@
154154
<if test="needsPaging">${limitAfter}</if>
155155
</select>
156156

157+
<select id="selectBatchIdsByQueryCriteria" parameterType="org.flowable.batch.service.impl.BatchQueryImpl" resultType="string">
158+
<if test="needsPaging">${limitBefore}</if>
159+
SELECT RES.ID_ <if test="needsPaging">${limitBetween}</if>
160+
<include refid="selectBatchByQueryCriteriaSql" />
161+
${orderBy}
162+
<if test="needsPaging">${limitAfter}</if>
163+
</select>
164+
157165
<select id="selectBatchCountByQueryCriteria" parameterType="org.flowable.batch.service.impl.BatchQueryImpl" resultType="long">
158166
select count(RES.ID_)
159167
<include refid="selectBatchByQueryCriteriaSql" />

0 commit comments

Comments
 (0)