_br-ode-1.X.svn/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/ProcessManagementDaoImpl.java

package org.apache.ode.daohib.bpel;

import java.util.Collection;
import java.util.List;

import org.apache.ode.bpel.common.InstanceFilter;
import org.apache.ode.bpel.dao.BpelDAOConnection;
import org.apache.ode.bpel.dao.ProcessInstanceDAO;
import org.apache.ode.bpel.dao.ProcessManagementDAO;
import org.apache.ode.daohib.SessionManager;
import org.apache.ode.daohib.bpel.hobj.HProcessInstance;
import org.hibernate.Query;
import org.hibernate.transform.ResultTransformer;

public class ProcessManagementDaoImpl extends HibernateDao implements ProcessManagementDAO {
	protected ProcessManagementDaoImpl(SessionManager sessionManager) {
		super(sessionManager, null);
	}

	@SuppressWarnings("unchecked")
	public Object[] findFailedCountAndLastFailedDateForProcessId(BpelDAOConnection conn, String status, String processId) {
		Object[] results = new Object[] {0, null};
		
		Query query = getSession().getNamedQuery(HProcessInstance.COUNT_FAILED_INSTANCES_BY_STATUS_AND_PROCESS_ID);
		query.setParameterList("states", new InstanceFilter("status=" + status).convertFilterState());
		query.setParameter("processId", processId);
		query.setResultTransformer(new ResultTransformer() {
			private static final long serialVersionUID = 8034301512569916379L;

			public List transformList(List collection) {
				return collection;
			}
			public Object transformTuple(Object[] tuple, String[] aliases) {
				return tuple;
			}
		});
		
		List result = query.list();
		if( !result.isEmpty() ) {
			results = (Object[])result.iterator().next();
		}
		
		return results;
	}
	
	public void prefetchActivityFailureCounts(Collection<ProcessInstanceDAO> instances) {
		// do nothing; activity failures counts are already in a column 
	}
}