org.apache.ode.dao.jpa
Class BPELDAOConnectionImpl

java.lang.Object
  extended by org.apache.ode.dao.jpa.BPELDAOConnectionImpl
All Implemented Interfaces:
org.apache.ode.bpel.dao.BpelDAOConnection

public class BPELDAOConnectionImpl
extends java.lang.Object
implements org.apache.ode.bpel.dao.BpelDAOConnection


Field Summary
protected  javax.persistence.EntityManager _em
           
 
Constructor Summary
BPELDAOConnectionImpl(javax.persistence.EntityManager em)
           
 
Method Summary
 java.util.List<org.apache.ode.bpel.evt.BpelEvent> bpelEventQuery(org.apache.ode.bpel.common.InstanceFilter ifilter, org.apache.ode.bpel.common.BpelEventFilter efilter)
           
 java.util.List<java.util.Date> bpelEventTimelineQuery(org.apache.ode.bpel.common.InstanceFilter ifilter, org.apache.ode.bpel.common.BpelEventFilter efilter)
           
 void close()
           
 org.apache.ode.bpel.dao.MessageExchangeDAO createMessageExchange(char dir)
           
 org.apache.ode.bpel.dao.ProcessDAO createProcess(javax.xml.namespace.QName pid, javax.xml.namespace.QName type, java.lang.String guid, long version)
           
 org.apache.ode.bpel.dao.ProcessDAO createTransientProcess(java.io.Serializable id)
           
 void deleteMessageExchange(org.apache.ode.bpel.dao.MessageExchangeDAO mexDao)
           
 java.util.Collection<org.apache.ode.bpel.dao.CorrelationSetDAO> getActiveCorrelationSets()
           
 java.util.Map<java.lang.Long,java.util.Collection<org.apache.ode.bpel.dao.CorrelationSetDAO>> getCorrelationSets(java.util.Collection<org.apache.ode.bpel.dao.ProcessInstanceDAO> instances)
           
 javax.persistence.EntityManager getEntityManager()
           
 org.apache.ode.bpel.dao.ProcessInstanceDAO getInstance(java.lang.Long iid)
           
 org.apache.ode.bpel.dao.MessageExchangeDAO getMessageExchange(java.lang.String mexid)
           
 int getNumInstances(javax.xml.namespace.QName processId)
           
 org.apache.ode.bpel.dao.ProcessDAO getProcess(javax.xml.namespace.QName processId)
           
 org.apache.ode.bpel.dao.ProcessManagementDAO getProcessManagement()
           
 org.apache.ode.bpel.dao.ScopeDAO getScope(java.lang.Long siidl)
           
 void insertBpelEvent(org.apache.ode.bpel.evt.BpelEvent event, org.apache.ode.bpel.dao.ProcessDAO process, org.apache.ode.bpel.dao.ProcessInstanceDAO instance)
           
 java.util.Collection<org.apache.ode.bpel.dao.ProcessInstanceDAO> instanceQuery(org.apache.ode.bpel.common.InstanceFilter criteria)
           
 java.util.Collection<org.apache.ode.bpel.dao.ProcessInstanceDAO> instanceQuery(java.lang.String expression)
           
 void setEntityManger(javax.persistence.EntityManager em)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

_em

protected javax.persistence.EntityManager _em
Constructor Detail

BPELDAOConnectionImpl

public BPELDAOConnectionImpl(javax.persistence.EntityManager em)
Method Detail

bpelEventQuery

public java.util.List<org.apache.ode.bpel.evt.BpelEvent> bpelEventQuery(org.apache.ode.bpel.common.InstanceFilter ifilter,
                                                                        org.apache.ode.bpel.common.BpelEventFilter efilter)
Specified by:
bpelEventQuery in interface org.apache.ode.bpel.dao.BpelDAOConnection

bpelEventTimelineQuery

public java.util.List<java.util.Date> bpelEventTimelineQuery(org.apache.ode.bpel.common.InstanceFilter ifilter,
                                                             org.apache.ode.bpel.common.BpelEventFilter efilter)
Specified by:
bpelEventTimelineQuery in interface org.apache.ode.bpel.dao.BpelDAOConnection

getInstance

public org.apache.ode.bpel.dao.ProcessInstanceDAO getInstance(java.lang.Long iid)
Specified by:
getInstance in interface org.apache.ode.bpel.dao.BpelDAOConnection

close

public void close()
Specified by:
close in interface org.apache.ode.bpel.dao.BpelDAOConnection

createMessageExchange

public org.apache.ode.bpel.dao.MessageExchangeDAO createMessageExchange(char dir)
Specified by:
createMessageExchange in interface org.apache.ode.bpel.dao.BpelDAOConnection

createProcess

public org.apache.ode.bpel.dao.ProcessDAO createProcess(javax.xml.namespace.QName pid,
                                                        javax.xml.namespace.QName type,
                                                        java.lang.String guid,
                                                        long version)
Specified by:
createProcess in interface org.apache.ode.bpel.dao.BpelDAOConnection

createTransientProcess

public org.apache.ode.bpel.dao.ProcessDAO createTransientProcess(java.io.Serializable id)
Specified by:
createTransientProcess in interface org.apache.ode.bpel.dao.BpelDAOConnection

getProcess

public org.apache.ode.bpel.dao.ProcessDAO getProcess(javax.xml.namespace.QName processId)
Specified by:
getProcess in interface org.apache.ode.bpel.dao.BpelDAOConnection

getNumInstances

public int getNumInstances(javax.xml.namespace.QName processId)
Specified by:
getNumInstances in interface org.apache.ode.bpel.dao.BpelDAOConnection

getScope

public org.apache.ode.bpel.dao.ScopeDAO getScope(java.lang.Long siidl)
Specified by:
getScope in interface org.apache.ode.bpel.dao.BpelDAOConnection

insertBpelEvent

public void insertBpelEvent(org.apache.ode.bpel.evt.BpelEvent event,
                            org.apache.ode.bpel.dao.ProcessDAO process,
                            org.apache.ode.bpel.dao.ProcessInstanceDAO instance)
Specified by:
insertBpelEvent in interface org.apache.ode.bpel.dao.BpelDAOConnection

instanceQuery

public java.util.Collection<org.apache.ode.bpel.dao.ProcessInstanceDAO> instanceQuery(org.apache.ode.bpel.common.InstanceFilter criteria)
Specified by:
instanceQuery in interface org.apache.ode.bpel.dao.BpelDAOConnection

instanceQuery

public java.util.Collection<org.apache.ode.bpel.dao.ProcessInstanceDAO> instanceQuery(java.lang.String expression)
Specified by:
instanceQuery in interface org.apache.ode.bpel.dao.BpelDAOConnection

setEntityManger

public void setEntityManger(javax.persistence.EntityManager em)

getMessageExchange

public org.apache.ode.bpel.dao.MessageExchangeDAO getMessageExchange(java.lang.String mexid)
Specified by:
getMessageExchange in interface org.apache.ode.bpel.dao.BpelDAOConnection

deleteMessageExchange

public void deleteMessageExchange(org.apache.ode.bpel.dao.MessageExchangeDAO mexDao)

getEntityManager

public javax.persistence.EntityManager getEntityManager()

getCorrelationSets

public java.util.Map<java.lang.Long,java.util.Collection<org.apache.ode.bpel.dao.CorrelationSetDAO>> getCorrelationSets(java.util.Collection<org.apache.ode.bpel.dao.ProcessInstanceDAO> instances)
Specified by:
getCorrelationSets in interface org.apache.ode.bpel.dao.BpelDAOConnection

getActiveCorrelationSets

public java.util.Collection<org.apache.ode.bpel.dao.CorrelationSetDAO> getActiveCorrelationSets()
Specified by:
getActiveCorrelationSets in interface org.apache.ode.bpel.dao.BpelDAOConnection

getProcessManagement

public org.apache.ode.bpel.dao.ProcessManagementDAO getProcessManagement()
Specified by:
getProcessManagement in interface org.apache.ode.bpel.dao.BpelDAOConnection