org.camunda.bpm.engine.RepositoryService.createProcessDefinitionQuery()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(9.7k)|赞(0)|评价(0)|浏览(286)

本文整理了Java中org.camunda.bpm.engine.RepositoryService.createProcessDefinitionQuery方法的一些代码示例,展示了RepositoryService.createProcessDefinitionQuery的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RepositoryService.createProcessDefinitionQuery方法的具体详情如下:
包路径:org.camunda.bpm.engine.RepositoryService
类名称:RepositoryService
方法名:createProcessDefinitionQuery

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());
}

相关文章

微信公众号

最新文章

更多

RepositoryService类方法