svn commit: r966201 - /ode/trunk/dao-hibernate/src/test/java/org/apache/ode/daohib/bpel/MexTest.java

[rr]

Author: rr
Date: Wed Jul 21 12:09:04 2010
New Revision: 966201

URL: http://svn.apache.org/viewvc?rev=966201&view=rev
Log:
Cleanup mex properties test

Modified:
    
ode/trunk/dao-hibernate/src/test/java/org/apache/ode/daohib/bpel/MexTest.java

Modified: 
ode/trunk/dao-hibernate/src/test/java/org/apache/ode/daohib/bpel/MexTest.java
URL: 
http://svn.apache.org/viewvc/ode/trunk/dao-hibernate/src/test/java/org/apache/ode/daohib/bpel/MexTest.java?rev=966201&r1=966200&r2=966201&view=diff
==============================================================================
--- 
ode/trunk/dao-hibernate/src/test/java/org/apache/ode/daohib/bpel/MexTest.java 
(original)
+++ 
ode/trunk/dao-hibernate/src/test/java/org/apache/ode/daohib/bpel/MexTest.java 
Wed Jul 21 12:09:04 2010
@@ -20,13 +20,22 @@
 package org.apache.ode.daohib.bpel;
 
 import java.util.ArrayList;
+import java.util.EnumSet;
 import java.util.HashMap;
+import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
+import java.util.Set;
+
+import javax.xml.namespace.QName;
 
 import org.apache.ode.bpel.common.CorrelationKeySet;
 import org.apache.ode.bpel.common.InstanceFilter;
+import org.apache.ode.bpel.dao.CorrelatorDAO;
 import org.apache.ode.bpel.dao.MessageExchangeDAO;
+import org.apache.ode.bpel.dao.ProcessDAO;
+import org.apache.ode.bpel.dao.ProcessInstanceDAO;
+import org.apache.ode.bpel.iapi.ProcessConf.CLEANUP_CATEGORY;
 import org.apache.ode.daohib.SessionManager;
 import org.apache.ode.daohib.bpel.hobj.HCorrelator;
 
@@ -59,4 +68,26 @@ public class MexTest extends BaseTestDAO
         sm.getSession().save(correlator);
         new CorrelatorDaoImpl(sm, correlator).dequeueMessage(new 
CorrelationKeySet("@2[12~a~b]"));
     }
+    
+    public void testCleanup() throws Exception {
+        SessionManager sm = ((BpelDAOConnectionImpl) daoConn)._sm;
+        ProcessDAO p = daoConn.createProcess(QName.valueOf("abc"), 
QName.valueOf("abc"), "abc", 1);
+        CorrelatorDAO correlator = p.addCorrelator("abc");
+        ProcessInstanceDAO instance = p.createInstance(correlator);
+
+        MessageExchangeDAO mex = daoConn.createMessageExchange('M');
+        mex.setProperty("abc", "def");
+        mex.setInstance(instance);
+
+        txm.commit();
+        txm.begin();
+        assertEquals(1, sm.getSession().createSQLQuery("select count(*) from 
BPEL_MEX_PROPS").list().get(0));
+        
+        Set<CLEANUP_CATEGORY> cleanupCategories = 
EnumSet.allOf(CLEANUP_CATEGORY.class);
+        instance.delete(cleanupCategories);
+        txm.commit();
+        txm.begin();
+
+        assertEquals(0, sm.getSession().createSQLQuery("select count(*) from 
BPEL_MEX_PROPS").list().get(0));
+    }
 }