You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by lw...@apache.org on 2006/12/08 01:12:21 UTC
svn commit: r483750 -
/incubator/ode/trunk/dao-jpa-ojpa/src/main/java/org/apache/ode/dao/jpa/ojpa/BPELDAOConnectionFactoryImpl.java
Author: lwaterman
Date: Thu Dec 7 16:12:20 2006
New Revision: 483750
URL: http://svn.apache.org/viewvc?view=rev&rev=483750
Log:
add support for delete
Modified:
incubator/ode/trunk/dao-jpa-ojpa/src/main/java/org/apache/ode/dao/jpa/ojpa/BPELDAOConnectionFactoryImpl.java
Modified: incubator/ode/trunk/dao-jpa-ojpa/src/main/java/org/apache/ode/dao/jpa/ojpa/BPELDAOConnectionFactoryImpl.java
URL: http://svn.apache.org/viewvc/incubator/ode/trunk/dao-jpa-ojpa/src/main/java/org/apache/ode/dao/jpa/ojpa/BPELDAOConnectionFactoryImpl.java?view=diff&rev=483750&r1=483749&r2=483750
==============================================================================
--- incubator/ode/trunk/dao-jpa-ojpa/src/main/java/org/apache/ode/dao/jpa/ojpa/BPELDAOConnectionFactoryImpl.java (original)
+++ incubator/ode/trunk/dao-jpa-ojpa/src/main/java/org/apache/ode/dao/jpa/ojpa/BPELDAOConnectionFactoryImpl.java Thu Dec 7 16:12:20 2006
@@ -28,29 +28,34 @@
try {
conns = (List<BpelDAOConnection>)q.getResultList();
+
} catch (NoResultException e) {
- return new BPELDAOConnectionImpl(new Long(1));
+ return new BPELDAOConnectionImpl(new Long(1),em);
}
if ( conns.size() < 1 ) {
- return new BPELDAOConnectionImpl(new Long(1));
+ return new BPELDAOConnectionImpl(new Long(1),em);
}
- return conns.get(conns.size()-1);
+ BPELDAOConnectionImpl conn = (BPELDAOConnectionImpl)conns.get(conns.size()-1);
+ conn.setEntityManger(em);
+
+ return conn;
}
public BpelDAOConnection getConnection(Long connID) {
- BpelDAOConnection conn = null;
+ BPELDAOConnectionImpl conn = null;
Query q = em.createQuery("SELECT x FROM BPELDAOConnectionImpl x WHERE x._id = ?1");
q.setParameter(1, connID);
try {
- conn = (BpelDAOConnection)q.getSingleResult();
+ conn = (BPELDAOConnectionImpl)q.getSingleResult();
+ conn.setEntityManger(em);
} catch (NoResultException e){}
if ( conn == null ) {
- conn = new BPELDAOConnectionImpl(connID);
+ conn = new BPELDAOConnectionImpl(connID,em);
}
return conn;