I'm really having problems trying to make openJPA work with DBUnit. Here is a
snippet of my test class. The moment I have a situation where DBUnit does
some sort of initializing operations on the database, openJPA starts
behaving really strangely. Specifically the second test method which uses
inheritance fails to fire a query for the bae class.

The moment I stop using DBUnit, everything starts working fine and openJPA
fires the queries for the base class and derived class in the proper order.

I've tried using two separate connections for DBUnit and openJPA and then
finally passing a connection from openJPA to DBUnit.

I really don't understand what is going wrong....Can someone please give me
some pointers?


public class BaseDAOTest extends BaseDBUnitTestCase {
   
 @Override
 protected DatabaseOperation getSetUpOperation() {
   return DatabaseOperation.DELETE;
                //return DatabaseOperation.NONE;  //This works....

 }

 @Override
 protected IDataSet getDataSet() throws Exception {
   return new FlatXmlDataSet(
       ClassLoader.getSystemResourceAsStream("BaseDAOTestClean.xml"));
 }
 
 protected IDataSet getDataSet(String datasetName) throws Exception {
   return new FlatXmlDataSet(
             ClassLoader.getSystemResourceAsStream(datasetName));  
 }
 
 
 public void testCreate() {
   System.out.println("testCreate");
   EntityManager manager = null;
   Customer customer = new Customer(new Double(123), new Double(123),
       new String("DK1"), new Date(), new Date(),
       new Date(), "KMD", new Date());
   Customer anotherCustomer = new Customer(new Double(124), new Double(124),
       new String("DK2"), new Date(), new Date(),
       new Date(), "ATP", new Date());
   try {  
     //Invocations to the processing logic
     manager = PersistenceBootstrapper.getEntityManager();
     EntityTransaction tx = manager.getTransaction();
     tx.begin();
     BaseDAO.create(manager, customer);
     BaseDAO.create(manager, anotherCustomer);
     tx.commit();
     
     //Do the asserts... Result verification.
     ITable addedData = getConnection().createQueryTable(
           "customer",
           "select pbs_no, cvr_no, postal_cd," +
           " update_by from customer where" +
           " pbs_no in (123, 124) order by pbs_no");
     Assertion.assertEquals(getDataSet("BaseDAOTest1.xml"),
                       new DefaultDataSet(addedData));
   } catch (Exception e) {
     e.printStackTrace();
     assertEquals("Failed", "Normal flow failed for BaseDAOTest",
             e.getMessage());
   } finally {
     //Do this instead of closing the manager directly on your own.
     manager.close();
   }
 }
 

 public void testCreateInheritance() {
   System.out.println("testInheritacne");
   //EntityManagerFactory factory =
Persistence.createEntityManagerFactory("refimpl-nocontainer");
   EntityManager manager = null;
   Creditor creditor = new Creditor(new Double(125), new Double(125),
       "DK3", new Date(), new Date(), new Date(), "PROG", new Date());    
   try {
     //Note the new dataset
     IDataSet expectedDataset = getDataSet("BaseDAOTest2.xml");
     
     //Invocations to the processing logic
     manager = PersistenceBootstrapper.getEntityManager();
     EntityTransaction transaction =  manager.getTransaction();
     transaction.begin();
     BaseDAO.create(manager, creditor);
     transaction.commit();
     
     //Do the asserts... Result verification.
     //Note the way the actual dataset is created.
     QueryDataSet actual = new QueryDataSet(getConnection());
     actual.addTable("customer", "select pbs_no, cvr_no, " +
         "postal_cd, update_by from customer where" +
         " pbs_no = 125");
     actual.addTable("creditor", "select pbs_no, cred_type, " +
         "billing_type, update_by from creditor where" +
         " pbs_no = 125");
     
     //compare with expected dataset.
     Assertion.assertEquals(actual, expectedDataset);
   } catch (Exception e) {
     e.printStackTrace();
     assertEquals("Failed", "Normal flow failed for BaseDAOTest",
                               e.getMessage());
   } finally {
     //Do this instead of closing the manager directly on your own.
     //PersistenceBootstrapper.closeManager();
     manager.close();
   }
 }
 


 public void testCreateManyToOne() {
   System.out.println("manytoone");
   EntityManager manager = null;
   
   Creditor creditor = new Creditor(new Double(126), new Double(126),
       "DK3", new Date(), new Date(), new Date(), "PROG", new Date());
   
   Country creditorsCountry = new Country("DK", "Denmark", "PROG");
   
       
   try {
     
     IDataSet dataset = new FlatXmlDataSet(
       ClassLoader.getSystemResourceAsStream("BaseDAOTestClean.xml"));  
     
     //Invocations to the processing logic
     manager = PersistenceBootstrapper.getEntityManager();
     EntityTransaction transaction = manager.getTransaction();
     transaction.begin();
     BaseDAO.create(manager, creditor);
     creditor.setCountry(creditorsCountry);
     transaction.commit();
     
     //Do the asserts... Result verification.
     QueryDataSet actual = new QueryDataSet(getConnection());
     actual.addTable("customer", "select pbs_no, cvr_no, " +
         "postal_cd, update_by from customer where" +
         " pbs_no = 125");
     actual.addTable("creditor", "select pbs_no, cred_type, " +
         "billing_type, update_by from creditor where" +
         " pbs_no = 125");
     actual.addTable("country_master", "select country_cd, country, " +
         "update_by from country_master where country_cd = \'DK\'");
     
     Assertion.assertEquals(actual, dataset);
   } catch (Exception e) {
     e.printStackTrace();
     assertEquals("Failed", "Normal flow failed for BaseDAOTest",
             e.getMessage());
   } finally {
     //Do this instead of closing the manager directly on your own.
     //PersistenceBootstrapper.closeManager();
     manager.close();
   }
 }
}
http://n2.nabble.com/file/n723864/src.zip src.zip
--
Sent from the OpenJPA Users mailing list archive at Nabble.com.