[hibernate-commits] Hibernate SVN: r18185 - core/trunk/cache-infinispan/src/test/java/org/hibernate/test/cache/infinispan/functional.

[hibernate-commits at lists.jboss.org]

Author: galder.zamarreno at jboss.com
Date: 2009-12-09 13:21:07 -0500 (Wed, 09 Dec 2009)
New Revision: 18185

Added:
   core/trunk/cache-infinispan/src/test/java/org/hibernate/test/cache/infinispan/functional/BasicJdbcTransactionalTestCase.java
Log:
Added JDBC transaction test.

Added: core/trunk/cache-infinispan/src/test/java/org/hibernate/test/cache/infinispan/functional/BasicJdbcTransactionalTestCase.java
===================================================================
--- core/trunk/cache-infinispan/src/test/java/org/hibernate/test/cache/infinispan/functional/BasicJdbcTransactionalTestCase.java	                        (rev 0)
+++ core/trunk/cache-infinispan/src/test/java/org/hibernate/test/cache/infinispan/functional/BasicJdbcTransactionalTestCase.java	2009-12-09 18:21:07 UTC (rev 18185)
@@ -0,0 +1,110 @@
+/*
+ * JBoss, Home of Professional Open Source.
+ * Copyright 2009, Red Hat, Inc. and/or its affiliates, and
+ * individual contributors as indicated by the @author tags. See the
+ * copyright.txt file in the distribution for a full listing of
+ * individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.hibernate.test.cache.infinispan.functional;
+
+import java.util.Map;
+
+import org.hibernate.Session;
+import org.hibernate.stat.SecondLevelCacheStatistics;
+import org.hibernate.stat.Statistics;
+import org.hibernate.transaction.JDBCTransactionFactory;
+import org.hibernate.transaction.TransactionFactory;
+import org.hibernate.transaction.TransactionManagerLookup;
+import org.infinispan.util.logging.Log;
+import org.infinispan.util.logging.LogFactory;
+
+/**
+ * BasicJdbcTransactionalTestCase.
+ * 
+ * @author Galder Zamarreño
+ * @since 3.5
+ */
+public class BasicJdbcTransactionalTestCase extends SingleNodeTestCase {
+   private static final Log log = LogFactory.getLog(BasicJdbcTransactionalTestCase.class);
+
+   public BasicJdbcTransactionalTestCase(String string) {
+      super(string);
+   }
+
+   protected Class<? extends TransactionFactory> getTransactionFactoryClass() {
+      return JDBCTransactionFactory.class;
+   }
+
+   protected Class<? extends TransactionManagerLookup> getTransactionManagerLookupClass() {
+      return null;
+   }
+
+   public void testCollectionCache() throws Exception {
+      Item item = new Item("chris", "Chris's Item");
+      Item another = new Item("another", "Owned Item");
+      item.addItem(another);
+
+      Session s = null;
+      try {
+         s = openSession();
+         s.beginTransaction();
+         s.persist(item);
+         s.persist(another);
+         s.getTransaction().commit();
+      } catch (Exception e) {
+         log.error("Exception", e);
+         s.getTransaction().rollback();
+         throw e;
+      } finally {
+         s.close();
+      }
+
+      try {
+         s = openSession();
+         s.beginTransaction();
+         Item loaded = (Item) s.load(Item.class, item.getId());
+         assertEquals(1, loaded.getItems().size());
+      } catch (Exception e) {
+         log.error("Exception", e);
+         s.getTransaction().rollback();
+         throw e;
+      } finally {
+         s.close();
+      }
+
+      try {
+         s = openSession();
+         s.beginTransaction();
+         Statistics stats = s.getSessionFactory().getStatistics();
+         SecondLevelCacheStatistics cStats = stats.getSecondLevelCacheStatistics(Item.class.getName() + ".items");
+         Item loadedWithCachedCollection = (Item) s.load(Item.class, item.getId());
+         stats.logSummary();
+         assertEquals(item.getName(), loadedWithCachedCollection.getName());
+         assertEquals(item.getItems().size(), loadedWithCachedCollection.getItems().size());
+         assertEquals(1, cStats.getHitCount());
+         Map cacheEntries = cStats.getEntries();
+         assertEquals(1, cacheEntries.size());
+      } catch (Exception e) {
+         log.error("Exception", e);
+         s.getTransaction().rollback();
+         throw e;
+      } finally {
+         s.close();
+      }
+   }
+}