[jbpm-commits] JBoss JBPM SVN: r5211 - in jbpm4/trunk/modules: integration/console/src/main/java/org/jbpm/integration/console and 7 other directories.

Author: tom.baeyens(a)jboss.com Date: 2009-07-03 05:47:17 -0400 (Fri, 03 Jul 2009) New Revision: 5211 Added: jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/query/TaskQueryImpl.java Removed: jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/task/TaskQueryImpl.java Modified: jbpm4/trunk/modules/api/src/main/java/org/jbpm/api/ProcessDefinitionQuery.java jbpm4/trunk/modules/integration/console/src/main/java/org/jbpm/integration/console/ProcessManagementImpl.java jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/cmd/CreateTaskQueryCmd.java jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/hibernate/DbSessionImpl.java jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/query/ProcessDefinitionQueryImpl.java jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/session/DbSession.java jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/svc/TaskServiceImpl.java jbpm4/trunk/modules/test-db/src/test/java/org/jbpm/test/deploy/SuspendDeploymentTest.java Log: JBPM-2383 made process definition query consistent wrt notSuspended() suspended() and updated the console integration query to only show the notSuspended process definitions Modified: jbpm4/trunk/modules/api/src/main/java/org/jbpm/api/ProcessDefinitionQuery.java =================================================================== --- jbpm4/trunk/modules/api/src/main/java/org/jbpm/api/ProcessDefinitionQuery.java 2009-07-03 09:32:54 UTC (rev 5210) +++ jbpm4/trunk/modules/api/src/main/java/org/jbpm/api/ProcessDefinitionQuery.java 2009-07-03 09:47:17 UTC (rev 5211) @@ -39,7 +39,9 @@ ProcessDefinitionQuery processDefinitionNameLike(String name); ProcessDefinitionQuery processDefinitionName(String name); ProcessDefinitionQuery deploymentId(String deploymentId); + ProcessDefinitionQuery suspended(); + ProcessDefinitionQuery notSuspended(); ProcessDefinitionQuery orderAsc(String property); ProcessDefinitionQuery orderDesc(String property); Modified: jbpm4/trunk/modules/integration/console/src/main/java/org/jbpm/integration/console/ProcessManagementImpl.java =================================================================== --- jbpm4/trunk/modules/integration/console/src/main/java/org/jbpm/integration/console/ProcessManagementImpl.java 2009-07-03 09:32:54 UTC (rev 5210) +++ jbpm4/trunk/modules/integration/console/src/main/java/org/jbpm/integration/console/ProcessManagementImpl.java 2009-07-03 09:47:17 UTC (rev 5211) @@ -59,6 +59,7 @@ // active processes List<ProcessDefinition> activePds = repositoryService.createProcessDefinitionQuery() + .notSuspended() .orderAsc(ProcessDefinitionQuery.PROPERTY_NAME) .list(); Modified: jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/cmd/CreateTaskQueryCmd.java =================================================================== --- jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/cmd/CreateTaskQueryCmd.java 2009-07-03 09:32:54 UTC (rev 5210) +++ jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/cmd/CreateTaskQueryCmd.java 2009-07-03 09:47:17 UTC (rev 5211) @@ -22,8 +22,8 @@ package org.jbpm.pvm.internal.cmd; import org.jbpm.pvm.internal.env.Environment; +import org.jbpm.pvm.internal.query.TaskQueryImpl; import org.jbpm.pvm.internal.session.DbSession; -import org.jbpm.pvm.internal.task.TaskQueryImpl; /** Modified: jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/hibernate/DbSessionImpl.java =================================================================== --- jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/hibernate/DbSessionImpl.java 2009-07-03 09:32:54 UTC (rev 5210) +++ jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/hibernate/DbSessionImpl.java 2009-07-03 09:47:17 UTC (rev 5211) @@ -46,9 +46,9 @@ import org.jbpm.pvm.internal.query.HistoryProcessInstanceQueryImpl; import org.jbpm.pvm.internal.query.JobQueryImpl; import org.jbpm.pvm.internal.query.ProcessInstanceQueryImpl; +import org.jbpm.pvm.internal.query.TaskQueryImpl; import org.jbpm.pvm.internal.session.DbSession; import org.jbpm.pvm.internal.task.TaskImpl; -import org.jbpm.pvm.internal.task.TaskQueryImpl; import org.jbpm.pvm.internal.util.Clock; /** Modified: jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/query/ProcessDefinitionQueryImpl.java =================================================================== --- jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/query/ProcessDefinitionQueryImpl.java 2009-07-03 09:32:54 UTC (rev 5210) +++ jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/query/ProcessDefinitionQueryImpl.java 2009-07-03 09:47:17 UTC (rev 5211) @@ -58,7 +58,7 @@ protected String key; protected String nameLike; protected String name; - protected boolean suspended; + protected Boolean suspended; protected String deploymentId; public Object execute(Session session) { @@ -90,10 +90,12 @@ hql.append(DeploymentProperty.class.getName()); hql.append(" as versionProperty "); - if (suspended) { - appendWhereClause("deployment.state = '"+Deployment.STATE_SUSPENDED+"'", hql); - } else { - appendWhereClause("deployment.state != '"+Deployment.STATE_SUSPENDED+"'", hql); + if (suspended!=null) { + if (suspended) { + appendWhereClause("deployment.state = '"+Deployment.STATE_SUSPENDED+"'", hql); + } else { + appendWhereClause("deployment.state != '"+Deployment.STATE_SUSPENDED+"'", hql); + } } appendWhereClause("idProperty.key = '"+DeploymentImpl.KEY_PROCESS_DEFINITION_ID+"'", hql); @@ -158,6 +160,11 @@ return this; } + public ProcessDefinitionQuery notSuspended() { + this.suspended = false; + return this; + } + public ProcessDefinitionQuery processDefinitionNameLike(String name) { this.nameLike = name; return this; Copied: jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/query/TaskQueryImpl.java (from rev 5192, jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/task/TaskQueryImpl.java) =================================================================== --- jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/query/TaskQueryImpl.java (rev 0) +++ jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/query/TaskQueryImpl.java 2009-07-03 09:47:17 UTC (rev 5211) @@ -0,0 +1,210 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2005, JBoss Inc., and individual contributors as indicated + * by the @authors tag. See the copyright.txt in the distribution for a + * full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.jbpm.pvm.internal.query; + +import java.util.ArrayList; +import java.util.List; + +import org.hibernate.Query; +import org.jbpm.api.JbpmException; +import org.jbpm.api.TaskQuery; +import org.jbpm.api.identity.Group; +import org.jbpm.api.task.Task; +import org.jbpm.internal.log.Log; +import org.jbpm.pvm.internal.env.Environment; +import org.jbpm.pvm.internal.identity.spi.IdentitySession; +import org.jbpm.pvm.internal.model.ExecutionImpl; +import org.jbpm.pvm.internal.task.ParticipationImpl; +import org.jbpm.pvm.internal.task.TaskImpl; + +/** + * @author Tom Baeyens + * @author Heiko Braun <heiko.braun(a)jboss.com&gt; + */ +public class TaskQueryImpl extends AbstractQuery implements TaskQuery { + + private static final long serialVersionUID = 1L; + + private static Log log = Log.getLog(TaskQueryImpl.class.getName()); + + protected boolean unassigned = false; + protected String assignee = null; + protected String candidate = null; + protected Boolean suspended = null; + protected String processInstanceId = null; + protected String processDefinitionId = null; + protected String activityName = null; + + /* groupIds transports the groupIds from the hql to the applyParameters */ + protected List<String> groupIds; + + public TaskQuery assignee(String assignee) { + if (candidate!=null) { + throw new JbpmException("assignee(...) cannot be combined with candidate(...) in one query"); + } + this.assignee = assignee; + return this; + } + + public TaskQuery candidate(String userId) { + this.candidate = userId; + unassigned(); + return this; + } + + public TaskQuery processInstanceId(String processInstanceId) { + this.processInstanceId = processInstanceId; + return this; + } + + public TaskQuery processDefinitionId(String processDefinitionId) { + this.processDefinitionId = processDefinitionId; + return this; + } + + public TaskQuery activityName(String activityName) { + this.activityName = activityName; + return this; + } + + public TaskQuery unassigned() { + this.assignee = null; + this.unassigned = true; + return this; + } + + public TaskQuery suspended() { + this.suspended = true; + return this; + } + + public TaskQuery notSuspended() { + this.suspended = false; + return this; + } + + public TaskQuery orderAsc(String property) { + orderByClause = "task." + property + " asc "; + return this; + } + + public TaskQuery orderDesc(String property) { + orderByClause = "task." + property + " desc "; + return this; + } + + public TaskQuery page(int firstResult, int maxResults) { + page = new Page(firstResult, maxResults); + return this; + } + + protected void applyParameters(Query query) { + if (assignee!=null) { + log.debug("setting parameter assignee: "+assignee); + query.setString("assignee", assignee); + } + + if (candidate!=null) { + log.debug("setting parameter candidateUserId: "+candidate); + query.setString("candidateUserId", candidate); + + if (groupIds!=null) { + log.debug("setting parameter candidateGroupIds: "+groupIds); + query.setParameterList("candidateGroupIds", groupIds); + } + } + } + + public String hql() { + StringBuilder hql = new StringBuilder(); + hql.append("select task "); + hql.append("from "); + hql.append(TaskImpl.class.getName()); + hql.append(" as task "); + + // participations + if (candidate!=null) { + hql.append(", "); + hql.append(ParticipationImpl.class.getName()); + hql.append(" as participant "); + + appendWhereClause("participant.task = task ", hql); + appendWhereClause("participant.type = 'candidate' ", hql); + + IdentitySession identitySession = Environment.getFromCurrent(IdentitySession.class); + List<Group> groups = identitySession.findGroupsByUser(candidate); + if (groups.isEmpty()) { + groupIds = null; + appendWhereClause("participant.userId = :candidateUserId ", hql); + + } else { + groupIds = new ArrayList<String>(); + for (Group group: groups) { + groupIds.add(group.getId()); + } + appendWhereClause("((participant.userId = :candidateUserId) or (participant.groupId in (:candidateGroupIds)))", hql); + } + } + + if (suspended!=null) { + if (suspended) { + appendWhereClause("task.state = '"+ExecutionImpl.STATE_SUSPENDED+"' ", hql); + } else { + appendWhereClause("task.state != '"+ExecutionImpl.STATE_SUSPENDED+"' ", hql); + } + } + + if (processInstanceId!=null) { + appendWhereClause("task.processInstance.id = '"+processInstanceId+"' ", hql); + } + + if (activityName!=null) { + appendWhereClause("task.execution.activityName = '"+activityName+"' ", hql); + } + + if (processDefinitionId!=null) { + appendWhereClause("task.processInstance.processDefinitionId = '"+processDefinitionId+"' ", hql); + } + + if (assignee!=null) { + appendWhereClause("task.assignee = :assignee ", hql); + } else if (unassigned) { + appendWhereClause("task.assignee is null ", hql); + } + + appendOrderByClause(hql); + + String hqlQuery = hql.toString(); + + log.debug(hqlQuery); + + return hqlQuery; + } + + public List<Task> list() { + return (List<Task>) commandService.execute(this); + } + + public Task uniqueResult() { + return (Task)untypedUniqueResult(); + } +} Property changes on: jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/query/TaskQueryImpl.java ___________________________________________________________________ Name: svn:keywords + Id Revision Name: svn:mergeinfo + Name: svn:eol-style + LF Modified: jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/session/DbSession.java =================================================================== --- jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/session/DbSession.java 2009-07-03 09:32:54 UTC (rev 5210) +++ jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/session/DbSession.java 2009-07-03 09:47:17 UTC (rev 5211) @@ -34,7 +34,7 @@ import org.jbpm.pvm.internal.query.HistoryProcessInstanceQueryImpl; import org.jbpm.pvm.internal.query.JobQueryImpl; import org.jbpm.pvm.internal.query.ProcessInstanceQueryImpl; -import org.jbpm.pvm.internal.task.TaskQueryImpl; +import org.jbpm.pvm.internal.query.TaskQueryImpl; /** Modified: jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/svc/TaskServiceImpl.java =================================================================== --- jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/svc/TaskServiceImpl.java 2009-07-03 09:32:54 UTC (rev 5210) +++ jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/svc/TaskServiceImpl.java 2009-07-03 09:47:17 UTC (rev 5211) @@ -50,8 +50,8 @@ import org.jbpm.pvm.internal.cmd.RemoveParticipantCmd; import org.jbpm.pvm.internal.cmd.SaveTaskCmd; import org.jbpm.pvm.internal.cmd.SetTaskVariablesCmd; +import org.jbpm.pvm.internal.query.TaskQueryImpl; import org.jbpm.pvm.internal.task.TaskImpl; -import org.jbpm.pvm.internal.task.TaskQueryImpl; /** * @author Alejandro Guizar, Tom Baeyens Deleted: jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/task/TaskQueryImpl.java =================================================================== --- jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/task/TaskQueryImpl.java 2009-07-03 09:32:54 UTC (rev 5210) +++ jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/task/TaskQueryImpl.java 2009-07-03 09:47:17 UTC (rev 5211) @@ -1,210 +0,0 @@ -/* - * JBoss, Home of Professional Open Source - * Copyright 2005, JBoss Inc., and individual contributors as indicated - * by the @authors tag. See the copyright.txt in the distribution for a - * full listing of individual contributors. - * - * This is free software; you can redistribute it and/or modify it - * under the terms of the GNU Lesser General Public License as - * published by the Free Software Foundation; either version 2.1 of - * the License, or (at your option) any later version. - * - * This software is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this software; if not, write to the Free - * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA - * 02110-1301 USA, or see the FSF site: http://www.fsf.org. - */ -package org.jbpm.pvm.internal.task; - -import java.util.ArrayList; -import java.util.List; - -import org.hibernate.Query; -import org.jbpm.api.JbpmException; -import org.jbpm.api.TaskQuery; -import org.jbpm.api.identity.Group; -import org.jbpm.api.task.Task; -import org.jbpm.internal.log.Log; -import org.jbpm.pvm.internal.env.Environment; -import org.jbpm.pvm.internal.identity.spi.IdentitySession; -import org.jbpm.pvm.internal.model.ExecutionImpl; -import org.jbpm.pvm.internal.query.AbstractQuery; -import org.jbpm.pvm.internal.query.Page; - -/** - * @author Tom Baeyens - * @author Heiko Braun <heiko.braun(a)jboss.com&gt; - */ -public class TaskQueryImpl extends AbstractQuery implements TaskQuery { - - private static final long serialVersionUID = 1L; - - private static Log log = Log.getLog(TaskQueryImpl.class.getName()); - - protected boolean unassigned = false; - protected String assignee = null; - protected String candidate = null; - protected Boolean suspended = null; - protected String processInstanceId = null; - protected String processDefinitionId = null; - protected String activityName = null; - - /* groupIds transports the groupIds from the hql to the applyParameters */ - protected List<String> groupIds; - - public TaskQuery assignee(String assignee) { - if (candidate!=null) { - throw new JbpmException("assignee(...) cannot be combined with candidate(...) in one query"); - } - this.assignee = assignee; - return this; - } - - public TaskQuery candidate(String userId) { - this.candidate = userId; - unassigned(); - return this; - } - - public TaskQuery processInstanceId(String processInstanceId) { - this.processInstanceId = processInstanceId; - return this; - } - - public TaskQuery processDefinitionId(String processDefinitionId) { - this.processDefinitionId = processDefinitionId; - return this; - } - - public TaskQuery activityName(String activityName) { - this.activityName = activityName; - return this; - } - - public TaskQuery unassigned() { - this.assignee = null; - this.unassigned = true; - return this; - } - - public TaskQuery suspended() { - this.suspended = true; - return this; - } - - public TaskQuery notSuspended() { - this.suspended = false; - return this; - } - - public TaskQuery orderAsc(String property) { - orderByClause = "task." + property + " asc "; - return this; - } - - public TaskQuery orderDesc(String property) { - orderByClause = "task." + property + " desc "; - return this; - } - - public TaskQuery page(int firstResult, int maxResults) { - page = new Page(firstResult, maxResults); - return this; - } - - protected void applyParameters(Query query) { - if (assignee!=null) { - log.debug("setting parameter assignee: "+assignee); - query.setString("assignee", assignee); - } - - if (candidate!=null) { - log.debug("setting parameter candidateUserId: "+candidate); - query.setString("candidateUserId", candidate); - - if (groupIds!=null) { - log.debug("setting parameter candidateGroupIds: "+groupIds); - query.setParameterList("candidateGroupIds", groupIds); - } - } - } - - public String hql() { - StringBuilder hql = new StringBuilder(); - hql.append("select task "); - hql.append("from "); - hql.append(TaskImpl.class.getName()); - hql.append(" as task "); - - // participations - if (candidate!=null) { - hql.append(", "); - hql.append(ParticipationImpl.class.getName()); - hql.append(" as participant "); - - appendWhereClause("participant.task = task ", hql); - appendWhereClause("participant.type = 'candidate' ", hql); - - IdentitySession identitySession = Environment.getFromCurrent(IdentitySession.class); - List<Group> groups = identitySession.findGroupsByUser(candidate); - if (groups.isEmpty()) { - groupIds = null; - appendWhereClause("participant.userId = :candidateUserId ", hql); - - } else { - groupIds = new ArrayList<String>(); - for (Group group: groups) { - groupIds.add(group.getId()); - } - appendWhereClause("((participant.userId = :candidateUserId) or (participant.groupId in (:candidateGroupIds)))", hql); - } - } - - if (suspended!=null) { - if (suspended) { - appendWhereClause("task.state = '"+ExecutionImpl.STATE_SUSPENDED+"' ", hql); - } else { - appendWhereClause("task.state != '"+ExecutionImpl.STATE_SUSPENDED+"' ", hql); - } - } - - if (processInstanceId!=null) { - appendWhereClause("task.processInstance.id = '"+processInstanceId+"' ", hql); - } - - if (activityName!=null) { - appendWhereClause("task.execution.activityName = '"+activityName+"' ", hql); - } - - if (processDefinitionId!=null) { - appendWhereClause("task.processInstance.processDefinitionId = '"+processDefinitionId+"' ", hql); - } - - if (assignee!=null) { - appendWhereClause("task.assignee = :assignee ", hql); - } else if (unassigned) { - appendWhereClause("task.assignee is null ", hql); - } - - appendOrderByClause(hql); - - String hqlQuery = hql.toString(); - - log.debug(hqlQuery); - - return hqlQuery; - } - - public List<Task> list() { - return (List<Task>) commandService.execute(this); - } - - public Task uniqueResult() { - return (Task)untypedUniqueResult(); - } -} Modified: jbpm4/trunk/modules/test-db/src/test/java/org/jbpm/test/deploy/SuspendDeploymentTest.java =================================================================== --- jbpm4/trunk/modules/test-db/src/test/java/org/jbpm/test/deploy/SuspendDeploymentTest.java 2009-07-03 09:32:54 UTC (rev 5210) +++ jbpm4/trunk/modules/test-db/src/test/java/org/jbpm/test/deploy/SuspendDeploymentTest.java 2009-07-03 09:47:17 UTC (rev 5211) @@ -96,8 +96,6 @@ repositoryService.suspendDeployment(deploymentHireId); - - expectedProcessNames.remove("hire"); processDefinitions = repositoryService .createProcessDefinitionQuery() @@ -177,6 +175,48 @@ assertEquals(expectedProcessNames, getProcessDefinitionNames(processDefinitions)); } + public void testQueryNonSuspendProcessDefinitions() { + deployJpdlXmlString( + "<process name='claim'>" + + " <start>" + + " <transition to='c' />" + + " </start>" + + " <state name='c' />" + + "</process>" + ); + + String deploymentHireId = deployJpdlXmlString( + "<process name='hire'>" + + " <start>" + + " <transition to='h' />" + + " </start>" + + " <state name='h' />" + + "</process>" + ); + + String deploymentFireId = deployJpdlXmlString( + "<process name='fire'>" + + " <start>" + + " <transition to='f' />" + + " </start>" + + " <state name='f' />" + + "</process>" + ); + + repositoryService.suspendDeployment(deploymentHireId); + + List<ProcessDefinition> processDefinitions = repositoryService + .createProcessDefinitionQuery() + .notSuspended() + .list(); + + Set<String> expectedProcessNames = new HashSet<String>(); + expectedProcessNames.add("claim"); + expectedProcessNames.add("fire"); + + assertEquals(expectedProcessNames, getProcessDefinitionNames(processDefinitions)); + } + int countProcessInstancesFor(List<ProcessInstance> processInstances, String processDefinitionKey) { int count = 0; for (Execution processInstance: processInstances) {