org.apache.ode.dao.jpa
Class BPELDAOConnectionImpl
java.lang.Object
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
|
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 |
_em
protected javax.persistence.EntityManager _em
BPELDAOConnectionImpl
public BPELDAOConnectionImpl(javax.persistence.EntityManager em)
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