Author: lwaterman
Date: Wed Nov 29 23:24:18 2006
New Revision: 480865
URL: http://svn.apache.org/viewvc?view=rev&rev=480865
Log:
Enhance unit test
Modified:
incubator/ode/trunk/dao-jpa-ojpa-derby/src/test/java/org/apache/ode/dao/jpa/test/SelectObjectTest.java
Modified:
incubator/ode/trunk/dao-jpa-ojpa-derby/src/test/java/org/apache/ode/dao/jpa/test/SelectObjectTest.java
URL:
http://svn.apache.org/viewvc/incubator/ode/trunk/dao-jpa-ojpa-derby/src/test/java/org/apache/ode/dao/jpa/test/SelectObjectTest.java?view=diff&rev=480865&r1=480864&r2=480865
==============================================================================
---
incubator/ode/trunk/dao-jpa-ojpa-derby/src/test/java/org/apache/ode/dao/jpa/test/SelectObjectTest.java
(original)
+++
incubator/ode/trunk/dao-jpa-ojpa-derby/src/test/java/org/apache/ode/dao/jpa/test/SelectObjectTest.java
Wed Nov 29 23:24:18 2006
@@ -1,11 +1,17 @@
package org.apache.ode.dao.jpa.test;
+import java.util.Collection;
+
import javax.persistence.EntityManager;
import javax.persistence.EntityManagerFactory;
import javax.persistence.Persistence;
import javax.persistence.Query;
+import javax.xml.namespace.QName;
+import org.apache.ode.bpel.common.CorrelationKey;
import org.apache.ode.bpel.dao.BpelDAOConnection;
+import org.apache.ode.bpel.dao.ProcessDAO;
+import org.apache.ode.bpel.dao.ProcessInstanceDAO;
import org.apache.ode.dao.jpa.ojpa.BPELDAOConnectionFactoryImpl;
import junit.framework.TestCase;
@@ -13,6 +19,10 @@
public class SelectObjectTest extends TestCase {
private EntityManager em;
+ private static final String TEST_NS = "http://org.apache.ode.jpa.test";;
+ private String[] correlationKeys = { "key1", "key2" };
+ private CorrelationKey key1 = new CorrelationKey(1,correlationKeys);
+
@Override
protected void setUp() throws Exception {
@@ -32,15 +42,22 @@
public void testGetObject() throws Exception {
BPELDAOConnectionFactoryImpl factory = new
BPELDAOConnectionFactoryImpl(em);
- BpelDAOConnection conn1 = factory.getConnection();
- Long connId1 = factory.getConnectionId(conn1);
- BpelDAOConnection conn2 = factory.getConnection(connId1 + 5);
- Long connId2 = factory.getConnectionId(conn2);
-
- if ( conn1 != null && conn2 != null ) {
- System.out.println("got conn1:" + connId1);
- System.out.println("got conn2:" + connId2);
+ BpelDAOConnection conn = factory.getConnection();
+
+ ProcessDAO p = conn.getProcess(new QName(TEST_NS,"testPID1"));
+ Collection<ProcessInstanceDAO> insts = p.findInstance(key1);
+
+ for ( ProcessInstanceDAO inst : insts ) {
+ Long id = inst.getInstanceId();
}
+
+ int instCount = p.getNumInstances();
+
+
+
+ conn.close();
+
+
}
@Override
