Author: heiko.braun(a)jboss.com Date: 2010-03-10 08:07:43 -0500 (Wed, 10 Mar 2010) New Revision: 996 Added: activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/BPAFDataSource.java activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/DefaultBPAFDataSource.java activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/Runner.java activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/hibernate/ activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/hibernate/HibernateUtil.java activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/hibernate/StateUserType.java activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/metric/ activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/metric/Average.java activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/metric/Metrics.java Removed: activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/HibernateUtil.java activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/StateUserType.java Modified: activity-monitor/trunk/emu/src/main/java/org/jboss/bpm/monitor/emu/Emulation.java activity-monitor/trunk/model/pom.xml activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/bpaf/Event.java activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/bpaf/State.java activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/bpaf/StateAdapter.java activity-monitor/trunk/model/src/main/resources/hibernate.cfg.xml activity-monitor/trunk/model/src/main/resources/org/jboss/bpm/monitor/model/bpaf/BPAF.hbm.xml Log: Begin work on BPAFDataSource interface Modified: activity-monitor/trunk/emu/src/main/java/org/jboss/bpm/monitor/emu/Emulation.java =================================================================== --- activity-monitor/trunk/emu/src/main/java/org/jboss/bpm/monitor/emu/Emulation.java 2010-03-09 14:01:15 UTC (rev 995) +++ activity-monitor/trunk/emu/src/main/java/org/jboss/bpm/monitor/emu/Emulation.java 2010-03-10 13:07:43 UTC (rev 996) @@ -22,7 +22,7 @@ package org.jboss.bpm.monitor.emu; import org.hibernate.Session; -import org.jboss.bpm.monitor.model.HibernateUtil; +import org.jboss.bpm.monitor.model.hibernate.HibernateUtil; import org.jboss.bpm.monitor.model.bpaf.BPAFContext; import org.jboss.bpm.monitor.model.bpaf.Event; Modified: activity-monitor/trunk/model/pom.xml =================================================================== --- activity-monitor/trunk/model/pom.xml 2010-03-09 14:01:15 UTC (rev 995) +++ activity-monitor/trunk/model/pom.xml 2010-03-10 13:07:43 UTC (rev 996) @@ -39,6 +39,12 @@ <artifactId>javassist</artifactId> </dependency> + <dependency> + <groupId>mysql</groupId> + <artifactId>mysql-connector-java</artifactId> + <version>5.1.12</version> + <scope>provided</scope> + </dependency> </dependencies> <build> Added: activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/BPAFDataSource.java =================================================================== --- activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/BPAFDataSource.java (rev 0) +++ activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/BPAFDataSource.java 2010-03-10 13:07:43 UTC (rev 996) @@ -0,0 +1,40 @@ +/* + * JBoss, Home of Professional Open Source. + * Copyright 2006, Red Hat Middleware LLC, and individual contributors + * as indicated by the @author tags. See the copyright.txt file 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.jboss.bpm.monitor.model; + +import org.jboss.bpm.monitor.model.bpaf.Event; + +import java.util.List; + +/** + * @author: Heiko Braun <hbraun(a)redhat.com&gt; + * @date: Mar 10, 2010 + */ +public interface BPAFDataSource +{ + List<String> getProcessDefinitions(); + List<String> getProcessInstances(String processDefinition); + List<String> getActivityDefinitions(String processInstance); + + List<Event> getDefinitionEvents(String processDefinition, long start, long end); + List<Event> getInstanceEvents(String processInstance, long start, long end); +} Added: activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/DefaultBPAFDataSource.java =================================================================== --- activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/DefaultBPAFDataSource.java (rev 0) +++ activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/DefaultBPAFDataSource.java 2010-03-10 13:07:43 UTC (rev 996) @@ -0,0 +1,159 @@ +/* + * JBoss, Home of Professional Open Source. + * Copyright 2006, Red Hat Middleware LLC, and individual contributors + * as indicated by the @author tags. See the copyright.txt file 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.jboss.bpm.monitor.model; + +import org.hibernate.Criteria; +import org.hibernate.Query; +import org.hibernate.SQLQuery; +import org.hibernate.Session; +import org.hibernate.criterion.Restrictions; +import org.jboss.bpm.monitor.model.bpaf.Event; +import org.jboss.bpm.monitor.model.hibernate.HibernateUtil; + +import java.util.List; + +/** + * @author: Heiko Braun <hbraun(a)redhat.com&gt; + * @date: Mar 10, 2010 + */ +public class DefaultBPAFDataSource implements BPAFDataSource +{ + + private interface SQLCommand<T> + { + T execute(Session session); + } + + private <T> T executeCommand(SQLCommand<T> cmd) + { + Session session = HibernateUtil.getSession(); + + try + { + return cmd.execute(session); + } + catch(Exception e) + { + throw new RuntimeException("Failed to execute query", e); + } + finally + { + session.close(); + } + + } + + public List<String> getProcessDefinitions() + { + List<String> result = executeCommand(new SQLCommand<List<String>>() + { + public List<String> execute(Session session) + { + Query query = session.createQuery( + "select distinct e.processDefinitionID from org.jboss.bpm.monitor.model.bpaf.Event as e" + ); + return query.list(); + } + }); + + return result; + } + + public List<String> getProcessInstances(final String processDefinition) + { + List<String> result = executeCommand(new SQLCommand<List<String>>() + { + public List<String> execute(Session session) + { + Query query = session.createQuery( + "select distinct e.processInstanceID from org.jboss.bpm.monitor.model.bpaf.Event as e" + + " where e.processDefinitionID=:id" + ); + query.setString("id", processDefinition); + return query.list(); + } + }); + + return result; + } + + public List<String> getActivityDefinitions(final String processInstance) + { + List<String> result = executeCommand(new SQLCommand<List<String>>() + { + public List<String> execute(Session session) + { + Query query = session.createQuery( + "select distinct e.activityDefinitionID from org.jboss.bpm.monitor.model.bpaf.Event as e" + + " where e.processInstanceID=:id" + + " and e.activityDefinitionID!=null" + ); + query.setString("id", processInstance); + return query.list(); + } + }); + + return result; + } + + public List<Event> getDefinitionEvents(final String processDefinition, long start, long end) + { + List<Event> result = executeCommand(new SQLCommand<List<Event>>() + { + public List<Event> execute(Session session) + { + + SQLQuery query = session.createSQLQuery("select e1.* " + + "from BPAF_EVENT e1, BPAF_EVENT e2 " + + "where e1.processDefinitionID=e2.processDefinitionID " + + "and e1.processInstanceID=e2.processInstanceID " + + "and ((e1.currentState=\"Open\" and e2.currentState=\"Closed\") OR (e2.currentState=\"Open\" and e1.currentState=\"Closed\")) " + + "and e1.activityDefinitionID is null " + + "and e2.activityDefinitionID is null " + + "and e1.processDefinitionID='"+processDefinition+"' "+ + "order by e1.timeStamp;"); + + query.addEntity(Event.class); + + return query.list(); + } + }); + + return result; + } + + public List<Event> getInstanceEvents(final String processInstance, long start, long end) + { + List<Event> result = executeCommand(new SQLCommand<List<Event>>() + { + public List<Event> execute(Session session) + { + Criteria c = session.createCriteria(Event.class); + c.add(Restrictions.isNotNull("activityDefinitionID")); + c.add(Restrictions.eq("processInstanceID", processInstance)); + return c.list(); + } + }); + + return result; + } +} Deleted: activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/HibernateUtil.java =================================================================== --- activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/HibernateUtil.java 2010-03-09 14:01:15 UTC (rev 995) +++ activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/HibernateUtil.java 2010-03-10 13:07:43 UTC (rev 996) @@ -1,57 +0,0 @@ -/* - * JBoss, Home of Professional Open Source. - * Copyright 2006, Red Hat Middleware LLC, and individual contributors - * as indicated by the @author tags. See the copyright.txt file 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.jboss.bpm.monitor.model; - -import org.hibernate.HibernateException; -import org.hibernate.Session; -import org.hibernate.SessionFactory; -import org.hibernate.cfg.Configuration; - -/** - * @author: Heiko Braun <hbraun(a)redhat.com&gt; - * @date: Mar 6, 2010 - */ -public class HibernateUtil { - - private static final SessionFactory sessionFactory; - - static - { - try - { - sessionFactory = - new Configuration() - .configure() - .buildSessionFactory(); - } - catch (Throwable ex) - { - // Log exception! - throw new ExceptionInInitializerError(ex); - } - } - - public static Session getSession() throws HibernateException - { - return sessionFactory.openSession(); - } -} \ No newline at end of file Added: activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/Runner.java =================================================================== --- activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/Runner.java (rev 0) +++ activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/Runner.java 2010-03-10 13:07:43 UTC (rev 996) @@ -0,0 +1,64 @@ +/* + * JBoss, Home of Professional Open Source. + * Copyright 2006, Red Hat Middleware LLC, and individual contributors + * as indicated by the @author tags. See the copyright.txt file 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.jboss.bpm.monitor.model; + +import org.jboss.bpm.monitor.model.bpaf.Event; +import org.jboss.bpm.monitor.model.metric.Metrics; + +import java.util.List; + +/** + * @author: Heiko Braun <hbraun(a)redhat.com&gt; + * @date: Mar 10, 2010 + */ +public class Runner +{ + public static void main(String[] args) + { + BPAFDataSource ds = new DefaultBPAFDataSource(); + + // definitions + List<String> definitions = ds.getProcessDefinitions(); + System.out.println("Definitions: " +definitions); + + // instances + String s0 = definitions.get(0); + List<String> instances = ds.getProcessInstances(s0); + System.out.println("Instances for "+s0 +": "+instances.size()); + + // activities + String s1 = instances.get(0); + List<String> activities = ds.getActivityDefinitions(s1); + System.out.println("Distinct activities: "); + for(String s : activities) System.out.println("- "+s); + + + // definition events + List<Event> defLifecycle = ds.getDefinitionEvents(definitions.get(0), 0, 0); + System.out.println("defLifecycle events: " +defLifecycle.size()); + System.out.println("Stat for definition: " + Metrics.getAverage(defLifecycle)); + + // instance events + List<Event> instLifecycle = ds.getInstanceEvents(instances.get(0), 0, 0); + System.out.println(instLifecycle); + } +} Deleted: activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/StateUserType.java =================================================================== --- activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/StateUserType.java 2010-03-09 14:01:15 UTC (rev 995) +++ activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/StateUserType.java 2010-03-10 13:07:43 UTC (rev 996) @@ -1,106 +0,0 @@ -/* - * JBoss, Home of Professional Open Source. - * Copyright 2006, Red Hat Middleware LLC, and individual contributors - * as indicated by the @author tags. See the copyright.txt file 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.jboss.bpm.monitor.model; - -/** - * @author: Heiko Braun <hbraun(a)redhat.com&gt; - * @date: Mar 7, 2010 - */ -import java.io.Serializable; -import java.sql.PreparedStatement; -import java.sql.ResultSet; -import java.sql.SQLException; -import java.sql.Types; -import java.util.Properties; - -import org.hibernate.HibernateException; -import org.hibernate.MappingException; -import org.hibernate.usertype.ParameterizedType; -import org.hibernate.usertype.UserType; -import org.jboss.bpm.monitor.model.bpaf.State; - -public class StateUserType implements UserType, ParameterizedType { - - private Class clazz = State.class; - - public void setParameterValues(Properties params) { - - } - - private static final int[] SQL_TYPES = {Types.VARCHAR}; - public int[] sqlTypes() { - return SQL_TYPES; - } - - public Class returnedClass() { - return clazz; - } - - public Object nullSafeGet(ResultSet resultSet, String[] names, Object owner) - throws HibernateException, SQLException { - String name = resultSet.getString(names[0]); - Object result = null; - if (!resultSet.wasNull()) { - result = State.valueOf(name); - } - return result; - } - - public void nullSafeSet(PreparedStatement preparedStatement, Object value, int index) - throws HibernateException, SQLException { - if (null == value) { - preparedStatement.setNull(index, Types.VARCHAR); - } else { - preparedStatement.setString(index, ((State)value).toString()); - } - } - - public Object deepCopy(Object value) throws HibernateException{ - return value; - } - - public boolean isMutable() { - return false; - } - - public Object assemble(Serializable cached, Object owner) throws HibernateException { - return cached; - } - - public Serializable disassemble(Object value) throws HibernateException { - return (Serializable)value; - } - - public Object replace(Object original, Object target, Object owner) throws HibernateException { - return original; - } - public int hashCode(Object x) throws HibernateException { - return x.hashCode(); - } - public boolean equals(Object x, Object y) throws HibernateException { - if (x == y) - return true; - if (null == x || null == y) - return false; - return x.equals(y); - } -} \ No newline at end of file Modified: activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/bpaf/Event.java =================================================================== --- activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/bpaf/Event.java 2010-03-09 14:01:15 UTC (rev 995) +++ activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/bpaf/Event.java 2010-03-10 13:07:43 UTC (rev 996) @@ -478,6 +478,23 @@ this.previousState = previousState; } + @Override + public String toString() + { + return "EventDetails{" + + "currentState=" + currentState + + '}'; + } } + @Override + public String toString() + { + return "Event{" + + "timestamp=" + timestamp + + ", processDefinitionID='" + processDefinitionID + '\'' + + ", processInstanceID='" + processInstanceID + '\'' + + ", eventDetails=" + eventDetails + + '}'; + } } Modified: activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/bpaf/State.java =================================================================== --- activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/bpaf/State.java 2010-03-09 14:01:15 UTC (rev 995) +++ activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/bpaf/State.java 2010-03-10 13:07:43 UTC (rev 996) @@ -35,25 +35,116 @@ @XmlJavaTypeAdapter(StateAdapter.class) public enum State { + /** + * An activity or process instance in the state OPEN can change state. + */ Open, + + /** + * No active work is being performed on the process in this state. + * Time spent in this state would be recorded as idle time or wait time. + */ Open_NotRunning, + + /** + * The process/activity is ready to be processed + * but has not been assigned to a particular participant. + */ Open_NotRunning_Ready, + + /** + * The process/activity has been assigned to a role (potentially a group of participants), + * but work has not started yet. + */ Open_NotRunning_Assigned, + + /** + * The process/activity has been assigned to a named user (a single participant), + * but work has not started yet. + */ Open_NotRunning_Reserved, + + /** + * The process/activity has been moved into a hibernation state. + * Execution has not yet begun at this point, + * i.e. the process/activity cannot be executed from this state + * but has to be reactivated before execution can begin. + */ Open_NotRunning_Suspended, + + /** + * The process/activity has been moved + * into a hibernation state after its execution has begun. + */ Open_NotRunning_Suspended_Assigned, Open_NotRunning_Suspended_Reserved, + + /** + * The process is actively being worked on. + * Time spent in this state would be recorded as processing time or work time. + */ Open_Running, Open_Running_InProgress, + + /** + * The process/activity has been moved + * into a hibernation state after its execution has begun. + */ Open_Running_Suspended, + + /** + * An activity or process instance in the state CLOSED can no longer change state. + */ Closed, + + /** + * The process has been fully executed. + * Processes in this state may or may not have achieved their objective. + */ Closed_Completed, + + /** + * The process/activity has completed as planned and has achieved its objectives. + */ Closed_Completed_Success, + + /** + * The process/activity has completed as planned but has not achieved its objectives. + */ Closed_Completed_Failed, + + /** + * The process has been forcefully terminated. + * Processes in this state have not achieved their objective. + */ Closed_Cancelled, + + /** + * The process/activity has ended because it was manually exited prior to its completion + */ Closed_Cancelled_Exited, + + /** + * The process/activity has ended due to an error in the execution. + */ Closed_Cancelled_Error, + + /** + * The process/activity has ended because it has been superseded by a more recent version. + * This might occur if a process instance is migrated to a newer schema during the course of its execution and an activity that was part only + * of the old schema has become ready for execution but has not been executed yet. + */ Closed_Cancelled_Obsolete, + + /** + * The process/activity has been forcibly but gracefully ended, i.e. running activities and subprocesses were allowed + * to complete as scheduled before the end of the process instance. + */ Closed_Cancelled_Aborted, + + /** + * The process/activity has been forcibly ended, i.e. running activities + * and subprocesses were terminated before their scheduled completion. + */ Closed_Cancelled_Terminated } Modified: activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/bpaf/StateAdapter.java =================================================================== --- activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/bpaf/StateAdapter.java 2010-03-09 14:01:15 UTC (rev 995) +++ activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/bpaf/StateAdapter.java 2010-03-10 13:07:43 UTC (rev 996) @@ -32,13 +32,14 @@ @Override public State unmarshal(String v) throws Exception { - return State.valueOf(v); + String interim = v.replace(".", "_"); + return State.valueOf(interim); } @Override public String marshal(State v) throws Exception { if(null==v) return null; - else return v.toString(); + else return v.toString().replace("_", "."); } } Copied: activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/hibernate/HibernateUtil.java (from rev 989, activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/HibernateUtil.java) =================================================================== --- activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/hibernate/HibernateUtil.java (rev 0) +++ activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/hibernate/HibernateUtil.java 2010-03-10 13:07:43 UTC (rev 996) @@ -0,0 +1,57 @@ +/* + * JBoss, Home of Professional Open Source. + * Copyright 2006, Red Hat Middleware LLC, and individual contributors + * as indicated by the @author tags. See the copyright.txt file 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.jboss.bpm.monitor.model.hibernate; + +import org.hibernate.HibernateException; +import org.hibernate.Session; +import org.hibernate.SessionFactory; +import org.hibernate.cfg.Configuration; + +/** + * @author: Heiko Braun <hbraun(a)redhat.com&gt; + * @date: Mar 6, 2010 + */ +public class HibernateUtil { + + private static final SessionFactory sessionFactory; + + static + { + try + { + sessionFactory = + new Configuration() + .configure() + .buildSessionFactory(); + } + catch (Throwable ex) + { + // Log exception! + throw new ExceptionInInitializerError(ex); + } + } + + public static Session getSession() throws HibernateException + { + return sessionFactory.openSession(); + } +} \ No newline at end of file Copied: activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/hibernate/StateUserType.java (from rev 989, activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/StateUserType.java) =================================================================== --- activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/hibernate/StateUserType.java (rev 0) +++ activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/hibernate/StateUserType.java 2010-03-10 13:07:43 UTC (rev 996) @@ -0,0 +1,106 @@ +/* + * JBoss, Home of Professional Open Source. + * Copyright 2006, Red Hat Middleware LLC, and individual contributors + * as indicated by the @author tags. See the copyright.txt file 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.jboss.bpm.monitor.model.hibernate; + +/** + * @author: Heiko Braun <hbraun(a)redhat.com&gt; + * @date: Mar 7, 2010 + */ +import java.io.Serializable; +import java.sql.PreparedStatement; +import java.sql.ResultSet; +import java.sql.SQLException; +import java.sql.Types; +import java.util.Properties; + +import org.hibernate.HibernateException; +import org.hibernate.MappingException; +import org.hibernate.usertype.ParameterizedType; +import org.hibernate.usertype.UserType; +import org.jboss.bpm.monitor.model.bpaf.State; + +public class StateUserType implements UserType, ParameterizedType { + + private Class clazz = State.class; + + public void setParameterValues(Properties params) { + + } + + private static final int[] SQL_TYPES = {Types.VARCHAR}; + public int[] sqlTypes() { + return SQL_TYPES; + } + + public Class returnedClass() { + return clazz; + } + + public Object nullSafeGet(ResultSet resultSet, String[] names, Object owner) + throws HibernateException, SQLException { + String name = resultSet.getString(names[0]); + Object result = null; + if (!resultSet.wasNull()) { + result = State.valueOf(name); + } + return result; + } + + public void nullSafeSet(PreparedStatement preparedStatement, Object value, int index) + throws HibernateException, SQLException { + if (null == value) { + preparedStatement.setNull(index, Types.VARCHAR); + } else { + preparedStatement.setString(index, ((State)value).toString()); + } + } + + public Object deepCopy(Object value) throws HibernateException{ + return value; + } + + public boolean isMutable() { + return false; + } + + public Object assemble(Serializable cached, Object owner) throws HibernateException { + return cached; + } + + public Serializable disassemble(Object value) throws HibernateException { + return (Serializable)value; + } + + public Object replace(Object original, Object target, Object owner) throws HibernateException { + return original; + } + public int hashCode(Object x) throws HibernateException { + return x.hashCode(); + } + public boolean equals(Object x, Object y) throws HibernateException { + if (x == y) + return true; + if (null == x || null == y) + return false; + return x.equals(y); + } +} \ No newline at end of file Added: activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/metric/Average.java =================================================================== --- activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/metric/Average.java (rev 0) +++ activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/metric/Average.java 2010-03-10 13:07:43 UTC (rev 996) @@ -0,0 +1,79 @@ +/* + * JBoss, Home of Professional Open Source. + * Copyright 2006, Red Hat Middleware LLC, and individual contributors + * as indicated by the @author tags. See the copyright.txt file 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.jboss.bpm.monitor.model.metric; + +/** + * @author: Heiko Braun <hbraun(a)redhat.com&gt; + * @date: Mar 10, 2010 + */ +public class Average +{ + String processDefinition; + long min = -1; + long max = -1; + long avg = -1; + + public Average(String processDefinition) + { + this.processDefinition = processDefinition; + } + + public long getMin() + { + return min; + } + + public void setMin(long min) + { + this.min = min; + } + + public long getMax() + { + return max; + } + + public void setMax(long max) + { + this.max = max; + } + + public long getAvg() + { + return avg; + } + + public void setAvg(long avg) + { + this.avg = avg; + } + + @Override + public String toString() + { + return "Average{" + + "min=" + min + + ", max=" + max + + ", avg=" + avg + + '}'; + } +} Added: activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/metric/Metrics.java =================================================================== --- activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/metric/Metrics.java (rev 0) +++ activity-monitor/trunk/model/src/main/java/org/jboss/bpm/monitor/model/metric/Metrics.java 2010-03-10 13:07:43 UTC (rev 996) @@ -0,0 +1,80 @@ +/* + * JBoss, Home of Professional Open Source. + * Copyright 2006, Red Hat Middleware LLC, and individual contributors + * as indicated by the @author tags. See the copyright.txt file 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.jboss.bpm.monitor.model.metric; + +import org.jboss.bpm.monitor.model.bpaf.Event; + +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +/** + * @author: Heiko Braun <hbraun(a)redhat.com&gt; + * @date: Mar 10, 2010 + */ +public class Metrics +{ + public static Average getAverage(List<Event> events) + { + assert events.size()>0; + assert events.size()%2==0 : "Parity error: "+events.size() +" events. Every event should have closing counterpart!"; + + Average stat = new Average(events.get(0).getProcessDefinitionID()); + + Map<String, Long> duration = new HashMap<String,Long>(events.size()/2); + for(Event e : events) + { + String processInstance = e.getProcessInstanceID(); + Long l0 = duration.get(processInstance); + if(l0!=null) + { + long l1 = e.getTimestamp(); + if(l0<l1) + duration.put(processInstance, (l1-l0)); // not necessarily in order + else + duration.put(processInstance, (l0-l1)); + } + else + { + duration.put(processInstance, e.getTimestamp()); + } + } + + long sum = 0; + for(String processInstance : duration.keySet()) + { + long l3 = duration.get(processInstance); + if(stat.getMin()==-1) // first iteration + stat.setMin(l3); + else if(l3<stat.getMin()) + stat.setMin(l3); + else if(l3>stat.getMax()) + stat.setMax(l3); + + sum+=l3; + } + + stat.setAvg(sum/duration.entrySet().size()); + + return stat; + } +} Modified: activity-monitor/trunk/model/src/main/resources/hibernate.cfg.xml =================================================================== --- activity-monitor/trunk/model/src/main/resources/hibernate.cfg.xml 2010-03-09 14:01:15 UTC (rev 995) +++ activity-monitor/trunk/model/src/main/resources/hibernate.cfg.xml 2010-03-10 13:07:43 UTC (rev 996) @@ -13,7 +13,7 @@ <property name="dialect">org.hibernate.dialect.MySQLDialect</property> <property name="show_sql">false</property> - <property name="hibernate.hbm2ddl.auto">create</property> + <!--property name="hibernate.hbm2ddl.auto">create</property--> <mapping resource="org/jboss/bpm/monitor/model/bpaf/BPAF.hbm.xml"/> Modified: activity-monitor/trunk/model/src/main/resources/org/jboss/bpm/monitor/model/bpaf/BPAF.hbm.xml =================================================================== --- activity-monitor/trunk/model/src/main/resources/org/jboss/bpm/monitor/model/bpaf/BPAF.hbm.xml 2010-03-09 14:01:15 UTC (rev 995) +++ activity-monitor/trunk/model/src/main/resources/org/jboss/bpm/monitor/model/bpaf/BPAF.hbm.xml 2010-03-10 13:07:43 UTC (rev 996) @@ -26,12 +26,12 @@ <component name="eventDetails"> <property name="currentState" column="currentState" not-null="true"> - <type name="org.jboss.bpm.monitor.model.StateUserType"> + <type name="org.jboss.bpm.monitor.model.hibernate.StateUserType"> <param name="enumClass">org.jboss.bpm.monitor.model.bpaf.State</param> </type> </property> <property name="previousState" column="previousState"> - <type name="org.jboss.bpm.monitor.model.StateUserType"> + <type name="org.jboss.bpm.monitor.model.hibernate.StateUserType"> <param name="enumClass">org.jboss.bpm.monitor.model.bpaf.State</param> </type> </property>