/** * * Copyright 2003-2004 The Apache Software Foundation * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.apache.agila.impl.dao;
import org.apache.agila.engine.Instance; import org.apache.agila.engine.InstanceID; import org.apache.agila.engine.Token; import org.apache.agila.engine.TokenID; import org.apache.agila.model.BusinessProcess; import org.apache.agila.model.BusinessProcessID; import org.apache.agila.model.NodeID; import org.apache.agila.services.InstanceServiceInfo; import org.apache.agila.services.task.Task; import org.apache.agila.services.task.TaskID; import org.apache.agila.services.user.UserID; import org.apache.agila.services.user.UserInfo; import java.util.List; import java.util.Map; /** * A simple Data Access Object interface to make it easy to plug in alternative presistence mechanisms. * * @author <a href="mailto:[EMAIL PROTECTED]">James Strachan</a> * @version $Revision: 1.1 $ */ public interface AgilaDAO { // BusinessProcess methods BusinessProcessID addGraph(BusinessProcess graph); BusinessProcess getGraphByID(BusinessProcessID id); List getAllProcessGraphs(); BusinessProcessID getGraphIDByName(String name); // Instance methods Instance newInstance(BusinessProcessID processID, Map params); void saveInstance(Instance instance); Instance getInstanceByID(InstanceID id); List listInstanceInfo(); InstanceServiceInfo getInstanceServiceInfo(); // Task methods TaskID updateTask(Task task); TaskID insertTask(Task task); List getTasksForUser(UserID userID, int type); Task getTaskByID(TaskID taskID); List getActiveTokensForInstance(InstanceID instanceID); boolean saveToken(Token t); Token newToken(InstanceID instanceID, NodeID nodeID, int state); Token getTokenByID(TokenID tokenID); // UserInfo methods UserInfo getUserFromPrincipal(String principalName); UserInfo getUserInfo(UserID id); UserID addUser(UserInfo newUser); List listAllUserInfo(); void saveUser(UserInfo info); }
/* * Copyright 2004 The Apache Software Foundation. * * Licensed under the Apache License, Version 2.0 (the "License") * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.apache.agila.impl.dao; import org.apache.agila.services.AbstractBusinessProcessService; import org.apache.agila.model.BusinessProcess; import org.apache.agila.model.BusinessProcessID; import org.apache.agila.util.JDBCUtil; import java.util.List; /** * A provide which delegates to an [EMAIL PROTECTED] AgilaDAO} for all of the detailed * persistence methods. * * @author <a href="mailto:[EMAIL PROTECTED]">James Strachan</a> * @version $Id: $ */ public class BusinessProcessServiceImpl extends AbstractBusinessProcessService { private AgilaDAO dao; public BusinessProcessServiceImpl(AgilaDAO dao) { this.dao = dao; } /** * Takes a graph and adds it to the persistent store, returning it's * new ID. * <p/> * TODO - something smart if already exists (name makes it unique) * * @param graph * @return */ protected BusinessProcessID internalAddGraph(BusinessProcess graph) { return dao.addGraph( graph ); } /** * returns a saved graph * * @param id * @return */ protected BusinessProcess internalGetByID(BusinessProcessID id) { return dao.getGraphByID( id ); } /** * returns all saved graph * * @return */ protected List internalGetAllProcessGraphs() { return dao.getAllProcessGraphs(); } protected BusinessProcessID internalGetIDByName(String name) { return dao.getGraphIDByName( name ); } }
/* * Copyright 2004 The Apache Software Foundation. * * Licensed under the Apache License, Version 2.0 (the "License") * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.apache.agila.impl.dao; import org.apache.agila.services.AbstractInstanceService; import org.apache.agila.services.InstanceServiceInfo; import org.apache.agila.engine.Instance; import org.apache.agila.engine.InstanceID; import org.apache.agila.model.BusinessProcessID; import org.apache.agila.util.JDBCUtil; import java.util.Map; import java.util.List; /** * A provide which delegates to an [EMAIL PROTECTED] AgilaDAO} for all of the detailed * persistence methods. * * @author <a href="mailto:[EMAIL PROTECTED]">James Strachan</a> * @version $Id: $ */ public class InstanceServiceImpl extends AbstractInstanceService { private AgilaDAO dao; public InstanceServiceImpl(AgilaDAO dao) { this.dao = dao; } /** * Method to create a new instance. Implementations can just override to * use a different kind of persistent store * @param processID * @param params * @return */ protected Instance internalCreate(BusinessProcessID processID, Map params) { return dao.newInstance( processID, params ); } /** * Method to save an instance (update/persiste). Implementations can just * override. * * @param instance */ protected void internalSave(Instance instance) { dao.saveInstance( instance ); } /** * returns an instance by ID from the persistence store * * @param id * @return */ protected Instance internalGetByID(InstanceID id) { return dao.getInstanceByID( id ); } /** * Returns all instances from the persistence store * @return */ protected List internalListInstanceInfo() { return dao.listInstanceInfo(); } protected InstanceServiceInfo internalInstanceServiceInfo() { return dao.getInstanceServiceInfo(); } // TODO need to modify this using message queue public void stop(InstanceID id) { Instance instance = dao.getInstanceByID( id ); instance.setStatus( Instance.STATUS_STOPPED ); dao.saveInstance( instance ); } // TODO need to modify this using message queue public void suspend(InstanceID id) { Instance instance = dao.getInstanceByID( id ); instance.setStatus( Instance.STATUS_SUSPENDED ); dao.saveInstance( instance ); } // TODO need to modify this using message queue public void resume(InstanceID id) { Instance instance = dao.getInstanceByID( id ); instance.setStatus( Instance.STATUS_RUNNING ); dao.saveInstance( instance ); } }
/* * Copyright 2004 The Apache Software Foundation. * * Licensed under the Apache License, Version 2.0 (the "License") * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.apache.agila.impl.dao; import org.apache.agila.services.task.AbstractTaskService; import org.apache.agila.services.task.Task; import org.apache.agila.services.task.TaskID; import org.apache.agila.services.user.UserID; import org.apache.agila.util.JDBCUtil; import java.util.List; /** * A provide which delegates to an [EMAIL PROTECTED] AgilaDAO} for all of the detailed * persistence methods. * * @author <a href="mailto:[EMAIL PROTECTED]">James Strachan</a> * @version $Id: $ */ public class TaskServiceImpl extends AbstractTaskService { private AgilaDAO dao; public TaskServiceImpl(AgilaDAO dao) { this.dao = dao; } /** * Add or update a task. */ protected void internalSave(Task task) { // Add or update task if (task.getTaskID() != null && task.getTaskID().getID() > 0) { dao.updateTask(task); } else { task.setTaskID(dao.insertTask(task)); } } protected List internalGetTasksByUserID(UserID userID, int type) { return dao.getTasksForUser(userID, type); } protected Task internalGetTask(TaskID taskID) { return dao.getTaskByID(taskID); } }
/* * Copyright 2004 The Apache Software Foundation. * * Licensed under the Apache License, Version 2.0 (the "License") * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.apache.agila.impl.dao; import org.apache.agila.impl.TokenImpl; import org.apache.agila.engine.InstanceID; import org.apache.agila.engine.Token; import org.apache.agila.engine.TokenID; import org.apache.agila.model.Connection; import org.apache.agila.model.NodeID; import org.apache.agila.services.TokenService; import org.apache.agila.util.JDBCUtil; import java.util.ArrayList; import java.util.HashMap; import java.util.Iterator; import java.util.List; /** * A provide which delegates to an [EMAIL PROTECTED] AgilaDAO} for all of the detailed * persistence methods. * * @author <a href="mailto:[EMAIL PROTECTED]">James Strachan</a> * @version $Id: $ */ public class TokenServiceImpl implements TokenService { private AgilaDAO dao; public TokenServiceImpl(AgilaDAO dao) { this.dao = dao; } public List getActiveTokensForInstance( InstanceID instanceID ) { return dao.getActiveTokensForInstance( instanceID ); } public boolean saveToken(Token t) { return dao.saveToken( t ); } /* * creates a new token w/ no parents, starting at a given node * * @param instanceID * @param nodeID * @param state * @return */ public Token newToken(InstanceID instanceID, NodeID nodeID, int state) { return dao.newToken(instanceID, nodeID, state); } /** * Returns a set of tokens, advanced along the connections given. The * implementation is responsible for tracking 'fork trees', to provide * for join resolution in 'getParallelTokens()' * * @param connSet * @param parentToken * @return */ public Token[] nextToken(Connection[] connSet, Token parentToken) { if (connSet == null || connSet.length == 0) { return null; } Token[] newSet = new Token[connSet.length]; for(int i = 0; i < connSet.length; i++) { Connection conn = connSet[i]; Token newToken = dao.newToken( parentToken.getInstanceID(), conn.getChildNode().getNodeId(), Token.PRE ); conn.traverse(newToken); newSet[i] = newToken; } return newSet; } public Token getTokenByID(TokenID tokenID) { return dao.getTokenByID( tokenID ); } // TODO need to implement this public List getParallelTokens(TokenID tokenID) { return null; } }
/* * Copyright 2004 The Apache Software Foundation. * * Licensed under the Apache License, Version 2.0 (the "License") * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.apache.agila.impl.dao; import org.apache.agila.services.user.UserID; import org.apache.agila.services.user.AbstractUserService; import org.apache.agila.services.user.UserInfo; import org.apache.agila.util.JDBCUtil; import java.util.List; import java.util.Map; import java.util.HashMap; import java.util.ArrayList; /** * A provide which delegates to an [EMAIL PROTECTED] AgilaDAO} for all of the detailed * persistence methods. * * @author <a href="mailto:[EMAIL PROTECTED]">James Strachan</a> * @version $Id: $ */ public class UserServiceImpl extends AbstractUserService{ private AgilaDAO dao; public UserServiceImpl(AgilaDAO dao) { this.dao = dao; } protected UserInfo internalGetUserFromPrincipal(String principalName) { UserInfo info = dao.getUserFromPrincipal(principalName); return info; } protected UserInfo internalGetUserInfo(UserID id) { return dao.getUserInfo(id); } protected UserID internalAddUser(UserInfo newUser) { return dao.addUser(newUser); } protected List internalListAllUserInfo() { return dao.listAllUserInfo(); } protected void internalSaveUser(UserInfo info) { dao.saveUser(info); } }
On 24 Nov 2004, at 11:51, [EMAIL PROTECTED] wrote:
Attached is a patch, including the previous DAO refactoring patch (to make providing alternative persistence implementations easy, which never seemed to get through the mail list) which adds support for associating tasks with groups of users and providing methods to query tasks associated with a group that are available and to lock/unlock tasks for a specific user.
So the idea is that tasks can be associated with exact users as before - or they can be associated with a Group of users. The definition of what users are in what groups is left outside of Agila - so any mechanism can be chosen - using LDAP, a custom database schema, business rules etc.
Then if the app/user wishes, the user can grab tasks that are associated with a group they are in and 'lock' it (that is associating the task with the user in question) so that others don't attempt to work with the task. Or they can unlock it - which just disassociates the task from the user and gives it back to the group.
The change is pretty trivial (the DAO patch was way bigger), which just adds a new column to bpm_task and 3 new JDBC operations (lock/unlock and find tasks by groups).
I don't see a way of getting SVN to include new files in patches, so apologies if I've missed a new file off of this patch.
<patch.txt><GroupID.java><DAOTestCaseSupport.java>
James ------- http://radio.weblogs.com/0112098/
James ------- http://radio.weblogs.com/0112098/
--------------------------------------------------------------------- To unsubscribe, e-mail: [EMAIL PROTECTED] For additional commands, e-mail: [EMAIL PROTECTED]
