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

[lwaterman]

Author: lwaterman
Date: Wed Nov 29 23:23:16 2006
New Revision: 480864

URL: http://svn.apache.org/viewvc?view=rev&rev=480864
Log:
Add new getConnection request

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=480864&r1=480863&r2=480864
==============================================================================
--- 
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
 Wed Nov 29 23:23:16 2006
@@ -5,6 +5,7 @@
 import java.util.Properties;
 
 import javax.persistence.EntityManager;
+import javax.persistence.NoResultException;
 import javax.persistence.Query;
 
 import org.apache.ode.bpel.dao.BpelDAOConnection;
@@ -21,9 +22,15 @@
        
        public BpelDAOConnection getConnection() {
                
+               List<BpelDAOConnection> conns = null;
+               
                Query q = em.createQuery("SELECT x FROM BPELDAOConnectionImpl x 
order by x._id asc");
                
-               List<BpelDAOConnection> conns = 
(List<BpelDAOConnection>)q.getResultList();
+               try {
+                       conns = (List<BpelDAOConnection>)q.getResultList();
+               } catch (NoResultException e) {
+                       return new BPELDAOConnectionImpl(new Long(1));
+               }
                
                if ( conns.size() < 1 ) {
                        return new BPELDAOConnectionImpl(new Long(1));
@@ -33,11 +40,14 @@
        }
        
        public BpelDAOConnection getConnection(Long connID) {
+               BpelDAOConnection conn = null;
                
                Query q = em.createQuery("SELECT x FROM BPELDAOConnectionImpl x 
WHERE x._id = ?1");
                q.setParameter(1, connID);
                
-               BpelDAOConnection conn = (BpelDAOConnection)q.getSingleResult();
+               try {
+                       conn = (BpelDAOConnection)q.getSingleResult();
+               } catch (NoResultException e){}
                
                if ( conn == null ) {
                        conn = new BPELDAOConnectionImpl(connID);