本文整理了Java中org.camunda.bpm.engine.RepositoryService.createProcessDefinitionQuery
方法的一些代码示例,展示了RepositoryService.createProcessDefinitionQuery
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RepositoryService.createProcessDefinitionQuery
方法的具体详情如下:
包路径:org.camunda.bpm.engine.RepositoryService
类名称:RepositoryService
方法名:createProcessDefinitionQuery
[英]Query process definitions.
[中]查询进程定义。
代码示例来源:origin: camunda/camunda-bpm-platform
public void testQueryNoTenantIdSet() {
ProcessDefinitionQuery query = repositoryService
.createProcessDefinitionQuery();
assertThat(query.count(), is(3L));
}
代码示例来源:origin: camunda/camunda-bpm-platform
public void testFailQueryByTenantIdNull() {
try {
repositoryService.createProcessDefinitionQuery()
.tenantIdIn((String) null);
fail("expected exception");
} catch (NullValueException e) {
}
}
代码示例来源:origin: camunda/camunda-bpm-platform
public void testQueryByInvalidDeploymentId() {
ProcessDefinitionQuery query = repositoryService.createProcessDefinitionQuery().deploymentId("invalid");
verifyQueryResults(query, 0);
try {
repositoryService.createProcessDefinitionQuery().deploymentId(null);
fail();
} catch (ProcessEngineException e) {
// Expected Exception
}
}
代码示例来源:origin: camunda/camunda-bpm-platform
public void testQueryByInvalidKey() {
ProcessDefinitionQuery query = repositoryService.createProcessDefinitionQuery().processDefinitionKey("invalid");
verifyQueryResults(query, 0);
try {
repositoryService.createProcessDefinitionQuery().processDefinitionKey(null);
fail();
} catch (ProcessEngineException e) {
// Expected Exception
}
}
代码示例来源:origin: camunda/camunda-bpm-platform
public void testQueryByVersion() {
ProcessDefinitionQuery query = repositoryService.createProcessDefinitionQuery().processDefinitionVersion(2);
verifyQueryResults(query, 1);
query = repositoryService.createProcessDefinitionQuery().processDefinitionVersion(1);
verifyQueryResults(query, 3);
}
代码示例来源:origin: camunda/camunda-bpm-platform
public void testQueryByDefinitionsWithoutTenantId() {
ProcessDefinitionQuery query = repositoryService
.createProcessDefinitionQuery()
.withoutTenantId();
assertThat(query.count(), is(1L));
}
代码示例来源:origin: camunda/camunda-bpm-platform
public void testQueryByLatest() {
ProcessDefinitionQuery query = repositoryService.createProcessDefinitionQuery().latestVersion();
verifyQueryResults(query, 3);
query = repositoryService.createProcessDefinitionQuery().processDefinitionKey("one").latestVersion();
verifyQueryResults(query, 1);
query = repositoryService.createProcessDefinitionQuery().processDefinitionKey("two").latestVersion();
verifyQueryResults(query, 1);
}
代码示例来源:origin: camunda/camunda-bpm-platform
public void testQuerySortingAsc() {
// exclude definitions without tenant id because of database-specific ordering
List<ProcessDefinition> processDefinitions = repositoryService
.createProcessDefinitionQuery()
.tenantIdIn(TENANT_ONE, TENANT_TWO)
.orderByTenantId()
.asc()
.list();
assertThat(processDefinitions.size(), is(2));
assertThat(processDefinitions.get(0).getTenantId(), is(TENANT_ONE));
assertThat(processDefinitions.get(1).getTenantId(), is(TENANT_TWO));
}
代码示例来源:origin: camunda/camunda-bpm-platform
@Deployment
public void testParseProcessDefinitionStringTtl() {
List<ProcessDefinition> processDefinitions = repositoryService.createProcessDefinitionQuery().list();
assertNotNull(processDefinitions);
assertEquals(1, processDefinitions.size());
Integer timeToLive = processDefinitions.get(0).getHistoryTimeToLive();
assertNotNull(timeToLive);
assertEquals(5, timeToLive.intValue());
}
代码示例来源:origin: camunda/camunda-bpm-platform
@Test
public void testDeleteProcessDefinition() {
// given deployment with two process definitions in one xml model file
deployment = repositoryService.createDeployment()
.addClasspathResource("org/camunda/bpm/engine/test/repository/twoProcesses.bpmn20.xml")
.deploy();
List<ProcessDefinition> processDefinitions = repositoryService.createProcessDefinitionQuery().list();
//when a process definition is been deleted
repositoryService.deleteProcessDefinition(processDefinitions.get(0).getId());
//then only one process definition should remain
assertEquals(1, repositoryService.createProcessDefinitionQuery().count());
}
代码示例来源:origin: camunda/camunda-bpm-platform
@Deployment(resources = { "org/camunda/bpm/engine/test/api/oneTaskProcess.bpmn20.xml" })
public void testDeleteDeploymentCascadeWithRunningInstances() {
List<ProcessDefinition> processDefinitions = repositoryService.createProcessDefinitionQuery().list();
assertEquals(1, processDefinitions.size());
ProcessDefinition processDefinition = processDefinitions.get(0);
runtimeService.startProcessInstanceById(processDefinition.getId());
// Try to delete the deployment, no exception should be thrown
repositoryService.deleteDeployment(processDefinition.getDeploymentId(), true);
}
代码示例来源:origin: camunda/camunda-bpm-platform
public void testQueryByNameLike() {
ProcessDefinitionQuery query = repositoryService.createProcessDefinitionQuery().processDefinitionNameLike("%w%");
verifyQueryResults(query, 1);
query = query.processDefinitionNameLike("%z\\_%");
verifyQueryResults(query, 1);
}
代码示例来源:origin: camunda/camunda-bpm-platform
public void testQueryAuthenticatedTenants() {
identityService.setAuthentication("user", null, Arrays.asList(TENANT_ONE, TENANT_TWO));
ProcessDefinitionQuery query = repositoryService.createProcessDefinitionQuery();
assertThat(query.count(), is(3L));
assertThat(query.tenantIdIn(TENANT_ONE).count(), is(1L));
assertThat(query.tenantIdIn(TENANT_TWO).count(), is(1L));
assertThat(query.withoutTenantId().count(), is(1L));
}
代码示例来源:origin: camunda/camunda-bpm-platform
@Deployment(resources={"org/camunda/bpm/engine/test/api/repository/processOne.bpmn20.xml"})
public void testParsingNullVersionTag() {
ProcessDefinition process = repositoryService
.createProcessDefinitionQuery()
.orderByProcessDefinitionId()
.asc()
.singleResult();
assertEquals(null, process.getVersionTag());
}
代码示例来源:origin: camunda/camunda-bpm-platform
@Deployment(resources = {"org/camunda/bpm/engine/test/api/mgmt/JobDefinitionQueryTest.testBase.bpmn"})
public void testQueryByProcessDefinitionKey() {
ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().singleResult();
JobDefinitionQuery query = managementService.createJobDefinitionQuery().processDefinitionKey(processDefinition.getKey());
verifyQueryResults(query, 4);
}
代码示例来源:origin: camunda/camunda-bpm-platform
public ProcessInstance startAndDeleteProcessInstance(String tenantId, BpmnModelInstance modelInstance) {
String deploymentId = deploymentForTenant(TENANT_ONE, PROCESS);
ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().deploymentId(deploymentId).singleResult();
ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefinition.getId());
runtimeService.deleteProcessInstance(processInstance.getId(), "test");
return processInstance;
}
代码示例来源:origin: camunda/camunda-bpm-platform
public void testPropagateTenantIdToProcessDefinition() {
deploymentForTenant(TENANT_ID, Bpmn.createExecutableProcess(PROCESS_DEFINITION_KEY).done());
ProcessDefinition processDefinition = repositoryService
.createProcessDefinitionQuery()
.singleResult();
assertNotNull(processDefinition);
// inherit the tenant id from deployment
assertEquals(TENANT_ID, processDefinition.getTenantId());
}
代码示例来源:origin: camunda/camunda-bpm-platform
@Deployment(resources = {"org/camunda/bpm/engine/test/api/oneTaskProcess.bpmn20.xml"})
public void testSubmitTaskFormFailAfterProcessInstanceSuspendByProcessDefinitionId() {
ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().singleResult();
ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefinition.getId());
runtimeService.suspendProcessInstanceByProcessDefinitionId(processDefinition.getId());
try {
formService.submitTaskFormData(taskService.createTaskQuery().processInstanceId(processInstance.getId()).singleResult().getId(), new HashMap<String, String>());
fail();
} catch(SuspendedEntityInteractionException e) {
// This is expected
}
}
代码示例来源:origin: camunda/camunda-bpm-platform
@Test
@Deployment(resources = {"org/camunda/bpm/engine/test/api/variables/scope/TargetVariableScopeTest.testExecutionWithoutProperTargetScope.bpmn","org/camunda/bpm/engine/test/api/variables/scope/doer.bpmn"})
public void testExecutionWithoutProperTargetScope () {
VariableMap variables = Variables.createVariables().putValue("orderIds", Arrays.asList(new int[]{1, 2, 3}));
//fails due to inappropriate variable scope target
thrown.expect(ScriptEvaluationException.class);
ProcessDefinition processDefinition = engineRule.getRepositoryService().createProcessDefinitionQuery().processDefinitionKey("Process_MultiInstanceCallAcitivity").singleResult();
thrown.expectMessage(startsWith("Unable to evaluate script while executing activity 'CallActivity_1' in the process definition with id '" + processDefinition.getId() + "': org.camunda.bpm.engine.ProcessEngineException: ENGINE-20011 Scope with specified activity Id NOT_EXISTING and execution"));
engineRule.getRuntimeService().startProcessInstanceByKey("Process_MultiInstanceCallAcitivity",variables);
}
代码示例来源:origin: camunda/camunda-bpm-platform
@Deployment(resources = {"org/camunda/bpm/engine/test/api/repository/ProcessDefinitionSuspensionTest.testSuspendStartTimerOnProcessDefinitionSuspension.bpmn20.xml"})
public void testSuspendStartTimerOnProcessDefinitionSuspensionById() {
ProcessDefinition pd = repositoryService.createProcessDefinitionQuery().singleResult();
Job startTimer = managementService.createJobQuery().timers().singleResult();
assertFalse(startTimer.isSuspended());
// when
repositoryService.suspendProcessDefinitionById(pd.getId());
// then
// refresh job
startTimer = managementService.createJobQuery().timers().singleResult();
assertTrue(startTimer.isSuspended());
}
内容来源于网络,如有侵权,请联系作者删除!