svn commit: r483750 - /incubator/ode/trunk/dao-jpa-ojpa/src/main/java/org/apache/ode/dao/jpa/ojpa/BPELDAOConnectionFactoryImpl.java

[lwaterman]

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;