Apache
/
openjpa
mirror of https://github.com/apache/openjpa.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

only cleanup after all tests are complete due to DB2 performance issues 

git-svn-id: https://svn.apache.org/repos/asf/openjpa/trunk@1024419 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Donald Woods 2010-10-19 21:25:27 +00:00
parent 005a18a739
commit 0a7e318638
1 changed files with 13 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
openjpa-persistence-jdbc/src/test/java/org/apache/openjpa/persistence/jdbc/kernel/TestByteArrayAppId.java
View File

@ -32,11 +32,7 @@ import org.apache.openjpa.persistence.common.utils.AbstractTestCase;
import java.util.*; import java.util.*;
import java.lang.annotation.Annotation;
import junit.framework.*;
import javax.persistence.EntityManager; import javax.persistence.EntityManager;
import javax.persistence.EntityManagerFactory;
import org.apache.openjpa.persistence.OpenJPAEntityManagerFactory; import org.apache.openjpa.persistence.OpenJPAEntityManagerFactory;
import org.apache.openjpa.persistence.OpenJPAEntityManager; import org.apache.openjpa.persistence.OpenJPAEntityManager;
import org.apache.openjpa.persistence.OpenJPAEntityManagerSPI; import org.apache.openjpa.persistence.OpenJPAEntityManagerSPI;
@ -45,15 +41,14 @@ import org.apache.openjpa.jdbc.meta.MappingTool;
import org.apache.openjpa.jdbc.conf.JDBCConfiguration; import org.apache.openjpa.jdbc.conf.JDBCConfiguration;
import org.apache.openjpa.kernel.Extent; import org.apache.openjpa.kernel.Extent;
import org.apache.openjpa.persistence.OpenJPAPersistence; import org.apache.openjpa.persistence.OpenJPAPersistence;
import org.apache.openjpa.kernel.OpenJPAStateManager;
import org.apache.openjpa.kernel.Query; import org.apache.openjpa.kernel.Query;
public class TestByteArrayAppId extends BaseJDBCTest { public class TestByteArrayAppId extends BaseJDBCTest {
private static boolean _init = false; private static boolean _init = false;
private OpenJPAEntityManagerFactory _pmf = null; private static int TEST_COUNT = 0;
private static OpenJPAEntityManagerFactory _pmf = null;
/** Creates a new instance of TestByteArrayAppId */ /** Creates a new instance of TestByteArrayAppId */
public TestByteArrayAppId(String name) public TestByteArrayAppId(String name)
@ -65,12 +60,11 @@ public class TestByteArrayAppId extends BaseJDBCTest {
return getCurrentPlatform() != AbstractTestCase.Platform.DB2; return getCurrentPlatform() != AbstractTestCase.Platform.DB2;
} }
public void setUp() @Override
throws Exception { public void setUp() throws Exception {
// we have to use getbytes/setbytes for byte arrays to work properly // we have to use getbytes/setbytes for byte arrays to work properly
_pmf =(OpenJPAEntityManagerFactory) getEmf(getProps());
if (!_init) { if (!_init) {
_pmf =(OpenJPAEntityManagerFactory) getEmf(getProps());
initialize((JDBCConfiguration) ((OpenJPAEntityManagerFactorySPI) initialize((JDBCConfiguration) ((OpenJPAEntityManagerFactorySPI)
OpenJPAPersistence.cast(_pmf)).getConfiguration()); OpenJPAPersistence.cast(_pmf)).getConfiguration());
_init = true; _init = true;
@ -78,7 +72,7 @@ public class TestByteArrayAppId extends BaseJDBCTest {
EntityManager pm = _pmf.createEntityManager(); EntityManager pm = _pmf.createEntityManager();
startTx(pm); startTx(pm);
deleteAll(ByteArrayPKPC.class,pm); deleteAll(ByteArrayPKPC.class,pm);
endTx(pm); endTx(pm);
pm.close(); pm.close();
pm = currentEntityManager(); pm = currentEntityManager();
@ -90,20 +84,22 @@ public class TestByteArrayAppId extends BaseJDBCTest {
pm.persist(testBytes); pm.persist(testBytes);
endTx(pm); endTx(pm);
pm.close(); pm.close();
TEST_COUNT++;
} }
public void tearDown() public void tearDown()
throws Exception { throws Exception {
// closing the pmf every time slows things down too much b/c // closing the pmf every time slows things down too much b/c
// schema reflection is so slow on DB2 // schema reflection is so slow on DB2
// try { _pmf.close (); } catch (Exception e) {} if (TEST_COUNT >= 9) {
closeEMF(_pmf);
super.tearDown(); _pmf = null;
super.tearDown();
}
} }
private void initialize(JDBCConfiguration conf) private void initialize(JDBCConfiguration conf)
throws Exception { throws Exception {
EntityManager em= currentEntityManager(); EntityManager em= currentEntityManager();
OpenJPAEntityManager kem = OpenJPAPersistence.cast (em); OpenJPAEntityManager kem = OpenJPAPersistence.cast (em);
//JDBCConfiguration conf = (JDBCConfiguration) kem.getConfiguration(); //JDBCConfiguration conf = (JDBCConfiguration) kem.getConfiguration();