Skip to content

Combine involved user and group identity link checks into a single EXISTS #4310

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
filiphr merged 2 commits into from
Oct 16, 2026
+681 −253
Merged

Combine involved user and group identity link checks into a single EXISTS #4310

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
b44be7d
Combine involved user and group identity link checks into a single EX…
filiphr Oct 15, 2026
e969897
Add an index on GROUP_ID_ of ACT_HI_IDENTITYLINK
filiphr Oct 15, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion ...able-app-engine/src/main/resources/org/flowable/app/db/create/flowable.db2.create.app.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -15,4 +15,4 @@ CREATE INDEX ACT_IDX_APP_DEF_DPLY ON ACT_APP_APPDEF(DEPLOYMENT_ID_);
CREATE UNIQUE INDEX ACT_IDX_APP_DEF_UNIQ ON ACT_APP_APPDEF(KEY_, VERSION_, TENANT_ID_);

insert into ACT_GE_PROPERTY
values ('app.schema.version', '8.1.0.2', 1);
values ('app.schema.version', '8.1.0.3', 1);
2 changes: 1 addition & 1 deletion ...wable-app-engine/src/main/resources/org/flowable/app/db/create/flowable.h2.create.app.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -15,4 +15,4 @@ CREATE INDEX ACT_IDX_APP_DEF_DPLY ON ACT_APP_APPDEF(DEPLOYMENT_ID_);
CREATE UNIQUE INDEX ACT_IDX_APP_DEF_UNIQ ON ACT_APP_APPDEF(KEY_, VERSION_, TENANT_ID_);

insert into ACT_GE_PROPERTY
values ('app.schema.version', '8.1.0.2', 1);
values ('app.schema.version', '8.1.0.3', 1);
2 changes: 1 addition & 1 deletion ...le-app-engine/src/main/resources/org/flowable/app/db/create/flowable.mssql.create.app.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -15,4 +15,4 @@ CREATE NONCLUSTERED INDEX ACT_IDX_APP_DEF_DPLY ON ACT_APP_APPDEF(DEPLOYMENT_ID_)
CREATE UNIQUE NONCLUSTERED INDEX ACT_IDX_APP_DEF_UNIQ ON ACT_APP_APPDEF(KEY_, VERSION_, TENANT_ID_);

insert into ACT_GE_PROPERTY
values ('app.schema.version', '8.1.0.2', 1);
values ('app.schema.version', '8.1.0.3', 1);
2 changes: 1 addition & 1 deletion ...le-app-engine/src/main/resources/org/flowable/app/db/create/flowable.mysql.create.app.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -17,4 +17,4 @@ ALTER TABLE ACT_APP_DEPLOYMENT MODIFY DEPLOY_TIME_ datetime(3);
CREATE UNIQUE INDEX ACT_IDX_APP_DEF_UNIQ ON ACT_APP_APPDEF(KEY_, VERSION_, TENANT_ID_);

insert into ACT_GE_PROPERTY
values ('app.schema.version', '8.1.0.2', 1);
values ('app.schema.version', '8.1.0.3', 1);
2 changes: 1 addition & 1 deletion ...e-app-engine/src/main/resources/org/flowable/app/db/create/flowable.oracle.create.app.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -15,4 +15,4 @@ CREATE INDEX ACT_IDX_APP_DEF_DPLY ON ACT_APP_APPDEF(DEPLOYMENT_ID_);
CREATE UNIQUE INDEX ACT_IDX_APP_DEF_UNIQ ON ACT_APP_APPDEF(KEY_, VERSION_, TENANT_ID_);

insert into ACT_GE_PROPERTY
values ('app.schema.version', '8.1.0.2', 1);
values ('app.schema.version', '8.1.0.3', 1);
2 changes: 1 addition & 1 deletion ...app-engine/src/main/resources/org/flowable/app/db/create/flowable.postgres.create.app.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -15,4 +15,4 @@ CREATE INDEX ACT_IDX_APP_DEF_DPLY ON ACT_APP_APPDEF(DEPLOYMENT_ID_);
CREATE UNIQUE INDEX ACT_IDX_APP_DEF_UNIQ ON ACT_APP_APPDEF(KEY_, VERSION_, TENANT_ID_);

insert into ACT_GE_PROPERTY
values ('app.schema.version', '8.1.0.2', 1);
values ('app.schema.version', '8.1.0.3', 1);
1 change: 1 addition & 0 deletions .../main/resources/org/flowable/app/db/upgrade/flowable.all.upgradestep.8102.to.8103.app.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
update ACT_GE_PROPERTY set VALUE_ = '8.1.0.3' where NAME_ = 'app.schema.version';
3 changes: 2 additions & 1 deletion ...owable-app-rest/src/test/java/org/flowable/test/persistence/SqlUpgradeValidationTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,8 @@ class SqlUpgradeValidationTest {
"7.1.0.2",
"7.2.0.1",
"7.2.0.2",
"8.1.0.2"
"8.1.0.2",
"8.1.0.3"
);

@ParameterizedTest
Expand Down
2 changes: 1 addition & 1 deletion ...e-cmmn-engine/src/main/resources/org/flowable/cmmn/db/create/flowable.db2.create.cmmn.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -268,4 +268,4 @@ CREATE TABLE ACT_CMMN_HI_PLAN_ITEM_INST
CREATE INDEX ACT_IDX_HI_PLAN_ITEM_INST_CASE ON ACT_CMMN_HI_PLAN_ITEM_INST (CASE_INST_ID_);

insert into ACT_GE_PROPERTY
values ('cmmn.schema.version', '8.1.0.2', 1);
values ('cmmn.schema.version', '8.1.0.3', 1);
2 changes: 1 addition & 1 deletion ...le-cmmn-engine/src/main/resources/org/flowable/cmmn/db/create/flowable.h2.create.cmmn.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -268,4 +268,4 @@ CREATE TABLE ACT_CMMN_HI_PLAN_ITEM_INST
CREATE INDEX ACT_IDX_HI_PLAN_ITEM_INST_CASE ON ACT_CMMN_HI_PLAN_ITEM_INST (CASE_INST_ID_);

insert into ACT_GE_PROPERTY
values ('cmmn.schema.version', '8.1.0.2', 1);
values ('cmmn.schema.version', '8.1.0.3', 1);
2 changes: 1 addition & 1 deletion ...-cmmn-engine/src/main/resources/org/flowable/cmmn/db/create/flowable.hsql.create.cmmn.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -268,4 +268,4 @@ CREATE TABLE ACT_CMMN_HI_PLAN_ITEM_INST
CREATE INDEX ACT_IDX_HI_PLAN_ITEM_INST_CASE ON ACT_CMMN_HI_PLAN_ITEM_INST (CASE_INST_ID_);

insert into ACT_GE_PROPERTY
values ('cmmn.schema.version', '8.1.0.2', 1);
values ('cmmn.schema.version', '8.1.0.3', 1);
2 changes: 1 addition & 1 deletion ...cmmn-engine/src/main/resources/org/flowable/cmmn/db/create/flowable.mssql.create.cmmn.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -268,4 +268,4 @@ CREATE TABLE ACT_CMMN_HI_PLAN_ITEM_INST
CREATE NONCLUSTERED INDEX ACT_IDX_HI_PLAN_ITEM_INST_CASE ON ACT_CMMN_HI_PLAN_ITEM_INST(CASE_INST_ID_);

insert into ACT_GE_PROPERTY
values ('cmmn.schema.version', '8.1.0.2', 1);
values ('cmmn.schema.version', '8.1.0.3', 1);
2 changes: 1 addition & 1 deletion ...cmmn-engine/src/main/resources/org/flowable/cmmn/db/create/flowable.mysql.create.cmmn.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -268,4 +268,4 @@ CREATE TABLE ACT_CMMN_HI_PLAN_ITEM_INST
CREATE INDEX ACT_IDX_HI_PLAN_ITEM_INST_CASE ON ACT_CMMN_HI_PLAN_ITEM_INST (CASE_INST_ID_);

insert into ACT_GE_PROPERTY
values ('cmmn.schema.version', '8.1.0.2', 1);
values ('cmmn.schema.version', '8.1.0.3', 1);
2 changes: 1 addition & 1 deletion ...mmn-engine/src/main/resources/org/flowable/cmmn/db/create/flowable.oracle.create.cmmn.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -268,4 +268,4 @@ CREATE TABLE ACT_CMMN_HI_PLAN_ITEM_INST
CREATE INDEX ACT_IDX_HI_PLAN_ITEM_INST_CASE ON ACT_CMMN_HI_PLAN_ITEM_INST (CASE_INST_ID_);

insert into ACT_GE_PROPERTY
values ('cmmn.schema.version', '8.1.0.2', 1);
values ('cmmn.schema.version', '8.1.0.3', 1);
2 changes: 1 addition & 1 deletion ...n-engine/src/main/resources/org/flowable/cmmn/db/create/flowable.postgres.create.cmmn.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -268,4 +268,4 @@ CREATE TABLE ACT_CMMN_HI_PLAN_ITEM_INST
CREATE INDEX ACT_IDX_HI_PLAN_ITEM_INST_CASE ON ACT_CMMN_HI_PLAN_ITEM_INST (CASE_INST_ID_);

insert into ACT_GE_PROPERTY
values ('cmmn.schema.version', '8.1.0.2', 1);
values ('cmmn.schema.version', '8.1.0.3', 1);
38 changes: 18 additions & 20 deletions ...ble-cmmn-engine/src/main/resources/org/flowable/cmmn/db/mapping/entity/CaseDefinition.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -276,29 +276,27 @@
and (RES.TENANT_ID_ = '' or RES.TENANT_ID_ is null)
</if>
<if test="includeAuthorization">
AND
<!-- The user and groups are combined in a single EXISTS, so databases can turn it into a semi-join -->
AND exists (select ID_ from ${prefix}ACT_RU_IDENTITYLINK IDN where IDN.SCOPE_DEFINITION_ID_ = RES.ID_ and IDN.SCOPE_TYPE_ = 'cmmn' and
<trim prefix="(" prefixOverrides="OR" suffix=")">
<if test="authorizationUserId != null">
exists (select ID_ from ${prefix}ACT_RU_IDENTITYLINK IDN where IDN.SCOPE_DEFINITION_ID_ = RES.ID_ and IDN.SCOPE_TYPE_ = 'cmmn' and IDN.USER_ID_ = #{authorizationUserId, jdbcType=NVARCHAR})
</if>
<if test="authorizationGroups != null &amp;&amp; !authorizationGroups.empty">
OR exists (select ID_ from ${prefix}ACT_RU_IDENTITYLINK IDN where IDN.SCOPE_DEFINITION_ID_ = RES.ID_ and IDN.SCOPE_TYPE_ = 'cmmn' and
(
<foreach item="authorizationGroupListItem" index="groupIndex" collection="safeAuthorizationGroups">
<if test="groupIndex &gt; 0">
or
</if>
IDN.GROUP_ID_ IN
<foreach item="authorizationGroup" index="index" collection="authorizationGroupListItem"
open="(" separator="," close=")">
#{authorizationGroup, jdbcType=NVARCHAR}
</foreach>
</foreach>
)
)
<if test="authorizationUserId != null">
IDN.USER_ID_ = #{authorizationUserId, jdbcType=NVARCHAR}
</if>
<if test="safeAuthorizationGroups != null &amp;&amp; !safeAuthorizationGroups.empty">
OR
<foreach item="authorizationGroupListItem" index="groupIndex" collection="safeAuthorizationGroups">
<if test="groupIndex &gt; 0">
or
</if>
IDN.GROUP_ID_ IN
<foreach item="authorizationGroup" index="index" collection="authorizationGroupListItem"
open="(" separator="," close=")">
#{authorizationGroup, jdbcType=NVARCHAR}
</foreach>
</foreach>
</if>

</trim>
)
</if>
</where>
</sql>
Expand Down
45 changes: 21 additions & 24 deletions ...wable-cmmn-engine/src/main/resources/org/flowable/cmmn/db/mapping/entity/CaseInstance.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -909,35 +909,32 @@
</foreach>
and P.STATE_ = 'active')
</if>
<if test="orQueryObject.involvedUser != null">
or EXISTS(select ID_ from ${prefix}ACT_RU_IDENTITYLINK I where I.SCOPE_ID_ = RES.ID_ and I.SCOPE_TYPE_ = 'cmmn' and I.USER_ID_ =
#{orQueryObject.involvedUser, jdbcType=NVARCHAR})
</if>
<if test="orQueryObject.involvedUserIdentityLink != null">
or EXISTS(select ID_ from ${prefix}ACT_RU_IDENTITYLINK I where I.SCOPE_ID_ = RES.ID_ and I.SCOPE_TYPE_ = 'cmmn' and
I.USER_ID_ = #{orQueryObject.involvedUserIdentityLink.userId, jdbcType=NVARCHAR} and I.TYPE_ = #{orQueryObject.involvedUserIdentityLink.type, jdbcType=NVARCHAR})
</if>
<if test="orQueryObject.involvedGroups != null">
<!-- The involvement checks are combined in a single EXISTS, so databases can turn it into a semi-join when the OR has no other criteria -->
<if test="orQueryObject.involvedUser != null || orQueryObject.involvedUserIdentityLink != null || orQueryObject.involvedGroups != null || orQueryObject.involvedGroupIdentityLink != null">
or EXISTS(
select ID_ from ${prefix}ACT_RU_IDENTITYLINK I where I.SCOPE_ID_ = RES.ID_ and I.SCOPE_TYPE_ = 'cmmn' and
(
<foreach item="involvedGroupListItem" index="groupIndex" collection="orQueryObject.safeInvolvedGroups">
<if test="groupIndex &gt; 0">
or
<trim prefix="(" prefixOverrides="OR" suffix=")">
<if test="orQueryObject.involvedUser != null">
or I.USER_ID_ = #{orQueryObject.involvedUser, jdbcType=NVARCHAR}
</if>
I.GROUP_ID_ IN
<foreach item="involvedGroup" index="index" collection="involvedGroupListItem"
open="(" separator="," close=")">
#{involvedGroup, jdbcType=NVARCHAR}
</foreach>
</foreach>
)
<if test="orQueryObject.involvedUserIdentityLink != null">
or (I.USER_ID_ = #{orQueryObject.involvedUserIdentityLink.userId, jdbcType=NVARCHAR} and I.TYPE_ = #{orQueryObject.involvedUserIdentityLink.type, jdbcType=NVARCHAR})
</if>
<if test="orQueryObject.involvedGroups != null">
<foreach item="involvedGroupListItem" index="groupIndex" collection="orQueryObject.safeInvolvedGroups">
or I.GROUP_ID_ IN
<foreach item="involvedGroup" index="index" collection="involvedGroupListItem"
open="(" separator="," close=")">
#{involvedGroup, jdbcType=NVARCHAR}
</foreach>
</foreach>
</if>
<if test="orQueryObject.involvedGroupIdentityLink != null">
or (I.GROUP_ID_ = #{orQueryObject.involvedGroupIdentityLink.groupId, jdbcType=NVARCHAR} and I.TYPE_ = #{orQueryObject.involvedGroupIdentityLink.type, jdbcType=NVARCHAR})
</if>
</trim>
)
</if>
<if test="orQueryObject.involvedGroupIdentityLink != null">
or EXISTS(select ID_ from ${prefix}ACT_RU_IDENTITYLINK I where I.SCOPE_ID_ = RES.ID_ and I.SCOPE_TYPE_ = 'cmmn' and
I.GROUP_ID_ = #{orQueryObject.involvedGroupIdentityLink.groupId, jdbcType=NVARCHAR} and I.TYPE_ = #{orQueryObject.involvedGroupIdentityLink.type, jdbcType=NVARCHAR})
</if>
<if test="orQueryObject.parentScopeId != null">
or EXISTS(select 1 from ${prefix}ACT_RU_ENTITYLINK LINK where
LINK.SCOPE_ID_ = #{orQueryObject.parentScopeId, jdbcType=NVARCHAR}
Expand Down
47 changes: 22 additions & 25 deletions ...mn-engine/src/main/resources/org/flowable/cmmn/db/mapping/entity/HistoricCaseInstance.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1056,35 +1056,32 @@
</foreach>
and P.STATE_ = 'active')
</if>
<if test="orQueryObject.involvedUser != null">
or EXISTS(select ID_ from ${prefix}ACT_HI_IDENTITYLINK I where I.SCOPE_ID_ = ${queryTablePrefix}ID_ and I.SCOPE_TYPE_ = 'cmmn' and I.USER_ID_ =
#{orQueryObject.involvedUser, jdbcType=NVARCHAR})
</if>
<if test="orQueryObject.involvedUserIdentityLink != null">
or EXISTS(select ID_ from ${prefix}ACT_HI_IDENTITYLINK I where I.SCOPE_ID_ = ${queryTablePrefix}ID_ and I.SCOPE_TYPE_ = 'cmmn' and
I.USER_ID_ = #{orQueryObject.involvedUserIdentityLink.userId, jdbcType=NVARCHAR} and I.TYPE_ = #{orQueryObject.involvedUserIdentityLink.type, jdbcType=NVARCHAR})
</if>
<if test="orQueryObject.involvedGroups != null">
<!-- The involvement checks are combined in a single EXISTS, so databases can turn it into a semi-join when the OR has no other criteria -->
<if test="orQueryObject.involvedUser != null || orQueryObject.involvedUserIdentityLink != null || orQueryObject.involvedGroups != null || orQueryObject.involvedGroupIdentityLink != null">
or EXISTS(
select ID_ from ${prefix}ACT_HI_IDENTITYLINK I where I.SCOPE_ID_ = ${queryTablePrefix}ID_ and I.SCOPE_TYPE_ = 'cmmn' and
(
<foreach item="involvedGroupListItem" index="groupIndex" collection="orQueryObject.safeInvolvedGroups">
<if test="groupIndex &gt; 0">
or
select ID_ from ${prefix}ACT_HI_IDENTITYLINK I where I.SCOPE_ID_ = ${queryTablePrefix}ID_ and I.SCOPE_TYPE_ = 'cmmn' and
<trim prefix="(" prefixOverrides="OR" suffix=")">
<if test="orQueryObject.involvedUser != null">
or I.USER_ID_ = #{orQueryObject.involvedUser, jdbcType=NVARCHAR}
</if>
I.GROUP_ID_ IN
<foreach item="involvedGroup" index="index" collection="involvedGroupListItem"
open="(" separator="," close=")">
#{involvedGroup, jdbcType=NVARCHAR}
</foreach>
</foreach>
)
<if test="orQueryObject.involvedUserIdentityLink != null">
or (I.USER_ID_ = #{orQueryObject.involvedUserIdentityLink.userId, jdbcType=NVARCHAR} and I.TYPE_ = #{orQueryObject.involvedUserIdentityLink.type, jdbcType=NVARCHAR})
</if>
<if test="orQueryObject.involvedGroups != null">
<foreach item="involvedGroupListItem" index="groupIndex" collection="orQueryObject.safeInvolvedGroups">
or I.GROUP_ID_ IN
<foreach item="involvedGroup" index="index" collection="involvedGroupListItem"
open="(" separator="," close=")">
#{involvedGroup, jdbcType=NVARCHAR}
</foreach>
</foreach>
</if>
<if test="orQueryObject.involvedGroupIdentityLink != null">
or (I.GROUP_ID_ = #{orQueryObject.involvedGroupIdentityLink.groupId, jdbcType=NVARCHAR} and I.TYPE_ = #{orQueryObject.involvedGroupIdentityLink.type, jdbcType=NVARCHAR})
</if>
</trim>
)
</if>
<if test="orQueryObject.involvedGroupIdentityLink != null">
or EXISTS(select ID_ from ${prefix}ACT_HI_IDENTITYLINK I where I.SCOPE_ID_ = ${queryTablePrefix}ID_ and I.SCOPE_TYPE_ = 'cmmn' and
I.GROUP_ID_ = #{orQueryObject.involvedGroupIdentityLink.groupId, jdbcType=NVARCHAR} and I.TYPE_ = #{orQueryObject.involvedGroupIdentityLink.type, jdbcType=NVARCHAR})
</if>
<if test="orQueryObject.parentScopeId != null">
or EXISTS(select 1 from ${prefix}ACT_HI_ENTITYLINK LINK where
LINK.SCOPE_ID_ = #{orQueryObject.parentScopeId, jdbcType=NVARCHAR}
Expand Down
1 change: 1 addition & 0 deletions ...ain/resources/org/flowable/cmmn/db/upgrade/flowable.all.upgradestep.8102.to.8103.cmmn.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
update ACT_GE_PROPERTY set VALUE_ = '8.1.0.3' where NAME_ = 'cmmn.schema.version';
55 changes: 55 additions & 0 deletions ...ngine/src/test/java/org/flowable/cmmn/test/history/HistoricCaseInstanceQueryImplTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1738,6 +1738,61 @@ public void getCaseInstanceByInvolvedGroupIdentityLink() {
}
}

@Test
public void getCaseInstanceByOrInvolvedUsersAndGroupsWithIdentityLinkTypes() {
CaseInstance userTypeInstance = startOneTaskCase();
cmmnRuntimeService.addUserIdentityLink(userTypeInstance.getId(), "kermit", "specialLink");
CaseInstance userOtherTypeInstance = startOneTaskCase();
cmmnRuntimeService.addUserIdentityLink(userOtherTypeInstance.getId(), "kermit", "otherLink");
CaseInstance groupTypeInstance = startOneTaskCase();
cmmnRuntimeService.addGroupIdentityLink(groupTypeInstance.getId(), "sales", "specialLink");
CaseInstance groupOtherTypeInstance = startOneTaskCase();
cmmnRuntimeService.addGroupIdentityLink(groupOtherTypeInstance.getId(), "sales", "otherLink");
CaseInstance groupsInstance = startOneTaskCase();
cmmnRuntimeService.addGroupIdentityLink(groupsInstance.getId(), "testGroup", "otherLink");

if (CmmnHistoryTestHelper.isHistoryLevelAtLeast(HistoryLevel.ACTIVITY, cmmnEngineConfiguration)) {
assertThat(cmmnHistoryService.createHistoricCaseInstanceQuery()
.or().involvedUser("kermit", "specialLink").involvedGroup("sales", "specialLink").endOr()
.list())
.extracting(HistoricCaseInstance::getId)
.containsExactlyInAnyOrder(userTypeInstance.getId(), groupTypeInstance.getId());

assertThat(cmmnHistoryService.createHistoricCaseInstanceQuery()
.or().involvedUser("kermit", "specialLink").involvedGroups(Set.of("testGroup")).endOr()
.list())
.extracting(HistoricCaseInstance::getId)
.containsExactlyInAnyOrder(userTypeInstance.getId(), groupsInstance.getId());

assertThat(cmmnHistoryService.createHistoricCaseInstanceQuery()
.or().involvedUser("kermit").involvedGroup("sales", "specialLink").involvedGroups(Set.of("testGroup")).endOr()
.list())
.extracting(HistoricCaseInstance::getId)
.containsExactlyInAnyOrder(userTypeInstance.getId(), userOtherTypeInstance.getId(), groupTypeInstance.getId(), groupsInstance.getId());

assertThat(cmmnHistoryService.createHistoricCaseInstanceQuery()
.or()
.involvedUser("kermit", "specialLink")
.involvedGroup("sales", "specialLink")
.involvedGroups(Set.of("testGroup"))
.caseInstanceId(groupOtherTypeInstance.getId())
.endOr()
.count())
.isEqualTo(4);

assertThat(cmmnHistoryService.createHistoricCaseInstanceQuery()
.or().involvedUser("kermit", "wrongType").involvedGroup("sales", "wrongType").endOr()
.count())
.isZero();
}
}

protected CaseInstance startOneTaskCase() {
return cmmnRuntimeService.createCaseInstanceBuilder()
.caseDefinitionKey("oneTaskCase")
.start();
}

@Test
public void getCaseInstanceByInvolvedGroupOrUser() {
CaseInstance caseInstance = cmmnRuntimeService.createCaseInstanceBuilder()
Expand Down
Loading
Loading