[jbosscache-commits] JBoss Cache SVN: r5973 - core/trunk/src/test/java/org/jboss/cache/commands.

[jbosscache-commits at lists.jboss.org]

Author: mircea.markus
Date: 2008-06-11 09:22:08 -0400 (Wed, 11 Jun 2008)
New Revision: 5973

Added:
   core/trunk/src/test/java/org/jboss/cache/commands/StructuralNodesOnRollbackTest.java
Log:
added unit test to reproduce error

Added: core/trunk/src/test/java/org/jboss/cache/commands/StructuralNodesOnRollbackTest.java
===================================================================
--- core/trunk/src/test/java/org/jboss/cache/commands/StructuralNodesOnRollbackTest.java	                        (rev 0)
+++ core/trunk/src/test/java/org/jboss/cache/commands/StructuralNodesOnRollbackTest.java	2008-06-11 13:22:08 UTC (rev 5973)
@@ -0,0 +1,75 @@
+package org.jboss.cache.commands;
+
+import org.testng.annotations.Test;
+import org.testng.annotations.BeforeMethod;
+import org.testng.annotations.AfterMethod;
+import org.jboss.cache.CacheSPI;
+import org.jboss.cache.DefaultCacheFactory;
+import org.jboss.cache.Fqn;
+import org.jboss.cache.factories.UnitTestCacheConfigurationFactory;
+import org.jboss.cache.config.Configuration;
+
+import javax.transaction.TransactionManager;
+import java.util.HashMap;
+
+/**
+ * Test to check that structural nodes are being removed on rollback: http://jira.jboss.com/jira/browse/JBCACHE-1365.
+ *
+ * @author Mircea.Markus at jboss.com
+ * @since 2.2
+ */
+ at Test(groups = "functional")
+public class StructuralNodesOnRollbackTest
+{
+   private CacheSPI<Object, Object> cache;
+   private TransactionManager txMgr;
+
+   @BeforeMethod(alwaysRun = true)
+   public void setUp()
+   {
+      Configuration cacheConfig = UnitTestCacheConfigurationFactory.createConfiguration(Configuration.CacheMode.LOCAL, false);
+      cache = (CacheSPI<Object, Object>) new DefaultCacheFactory().createCache(cacheConfig, false);
+      cache.start();
+      txMgr = cache.getTransactionManager();
+   }
+
+   @AfterMethod(alwaysRun = true)
+   public void tearDown()
+   {
+      cache.stop();
+      cache.destroy();
+   }
+
+   public void testPutDataMap() throws Exception
+   {
+      HashMap map = new HashMap();
+      map.put("k","v");
+
+      assert  !cache.exists("/a/b");
+      txMgr.begin();
+      cache.put("/a/b/c", map);
+      assert  cache.exists("/a/b");
+      txMgr.rollback();
+      assert  !cache.exists("/a/b");
+   }
+   
+   public void testPutForExternalRead() throws Exception
+   {
+      assert  !cache.exists("/a/b");
+      txMgr.begin();
+      cache.putForExternalRead(Fqn.fromString("/a/b/c"), "key", "value");
+      assert  cache.exists("/a/b");
+      txMgr.rollback();
+      assert  !cache.exists("/a/b");
+   }
+
+   public void testPutKeyValueCommand() throws Exception
+   {
+      assert  !cache.exists("/a/b");
+      txMgr.begin();
+      cache.put("/a/b/c", "key", "value");
+      assert  cache.exists("/a/b");
+      txMgr.rollback();
+      assert  !cache.exists("/a/b");
+   }
+}