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/11/30 08:23:17 UTC
svn commit: r480864 -
/incubator/ode/trunk/dao-jpa-ojpa/src/main/java/org/apache/ode/dao/jpa/ojpa/BPELDAOConnectionFactoryImpl.java
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);