Thanks Jitendra for the helpful post. In the end, I managed to get my processes
(with sub process) to delete successfully. I initially had problems with your
exact method, but in the end it seemed to work. Here is how I got my
implementation to work.
1) I copied the method deleteProcessInstance(ProcessInstance processInstance,
boolean includeTasks, boolean includeJobs) from
jbpm-jpdl-3.2.3\src\jpdl\org\jbpm\db\GraphSession.java, and put it into my own
manager class, and modified as mentioned in point 3).
2) I copied the method deleteSubProcesses(Token token) from
jbpm-jpdl-3.2.3\src\jpdl\org\jbpm\db\GraphSession.java, and put it into my own
manager class and modified as mentioned in point 4).
3)
Modified deleteProcessInstance method to look as follows:
| public void deleteProcessInstance(ProcessInstance processInstance, boolean
includeTasks, boolean includeJobs) {
| log.info("Deleting process instance: " +
processInstance.getProcessDefinition().getName()+"
("+processInstance.getId()+")");
| if (processInstance==null) throw new
JbpmException("processInstance is null in JbpmSession.deleteProcessInstance()");
| try {
| // find the tokens
| Query query =
hibernateSession.getNamedQuery("GraphSession.findTokensForProcessInstance");
| query.setEntity("processInstance", processInstance);
| List tokens = query.list();
|
| // deleteSubProcesses
| Iterator iter = tokens.iterator();
| while (iter.hasNext()) {
| Token token = (Token) iter.next();
| deleteSubProcesses(token);
| }
|
| // jobs
| if (includeJobs) {
| query =
hibernateSession.getNamedQuery("GraphSession.deleteJobsForProcessInstance");
| query.setEntity("processInstance",
processInstance);
| query.executeUpdate();
| }
|
| // tasks
| if (includeTasks) {
| query =
hibernateSession.getNamedQuery("GraphSession.findTaskInstanceIdsForProcessInstance");
| query.setEntity("processInstance",
processInstance);
| List taskInstances = query.list();
| //This is where the code differs from
GraphSession.deleteProcessInstance---------
| if(taskInstances.size() > 0 ) {
| for (int x = 0; x <
taskInstances.size(); x++) {
| TaskInstance ti =
(TaskInstance)taskInstances.get(x);
| hibernateSession.delete(ti);
| }
| }
|
//---------------------------------------------------------------------------------
| }
|
| // delete the logs for all the process instance's tokens
| query =
hibernateSession.getNamedQuery("GraphSession.selectLogsForTokens");
| query.setParameterList("tokens", tokens);
| List logs = query.list();
| iter = logs.iterator();
| while (iter.hasNext()) {
| hibernateSession.delete(iter.next());
| }
|
| //This code is in addition to the code found in
GraphSession.deleteProcessInstance--
| //Delete tokens
| iter = tokens.iterator();
| while(iter.hasNext()) {
| Token token = (Token)iter.next();
| if(processInstance.getRootToken().getId()!=
token.getId()) {
| hibernateSession.delete(token);
| }
| }
|
//------------------------------------------------------------------------------------
|
| // then delete the process instance
| hibernateSession.delete(processInstance);
|
| }
| catch (Exception e) {
| throw new JbpmException("couldn't delete process
instance '" + processInstance.getId() + "'", e);
| }
|
| }
|
4) Modified deleteSubProcesses method to look as follows:
| private void deleteSubProcesses(Token token) {
| //This is where the code different from
GraphSession.deleteSubProcesses(Token)--------------------
| //Commented out the following 2
lines-----------------------------------------------------
| //Query query =
hibernateSession.getNamedQuery("GraphSession.findSubProcessInstances");
| //query.setEntity("processInstance",
token.getProcessInstance());
|
//----------------------------------------------------------------------------------------
| //Added the following 2 lines
instead-----------------------------------------------------
| Query query = hibernateSession.createQuery("select pi from
org.jbpm.graph.exe.ProcessInstance as pi where pi.superProcessToken = :token");
| query.setParameter("token", token);
|
//----------------------------------------------------------------------------------------
|
//------------------------------------------------------------------------------------------------
| List processInstances = query.list();
|
| if (processInstances == null || processInstances.isEmpty()) {
| return;
| }
|
| Iterator iter = processInstances.iterator();
| while (iter.hasNext()) {
| ProcessInstance subProcessInstance = (ProcessInstance)
iter.next();
| subProcessInstance.setSuperProcessToken(null);
| token.setSubProcessInstance(null);
| deleteProcessInstance(subProcessInstance, true, true);
| }
| if (token.getChildren()!=null) {
| iter = token.getChildren().values().iterator();
| while (iter.hasNext()) {
| Token child = (Token) iter.next();
| deleteSubProcesses(child);
| }
| }
| }
|
When I wanted to delete a process instance, I use my modified methods instead.
It seemed to work.
Can anyone see anything wrong with doing it this way?
Hope it helps someone else.
View the original post :
http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4189806#4189806
Reply to the post :
http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=4189806
_______________________________________________
jboss-user mailing list
[email protected]
https://lists.jboss.org/mailman/listinfo/jboss-user
