Added tests for service-layer pattern

Author: fluxw42

service-layer/pom.xml

@@ -22,5 +22,10 @@
       <artifactId>junit</artifactId>
       <scope>test</scope>
     </dependency>
+    <dependency>
+      <groupId>org.mockito</groupId>
+      <artifactId>mockito-core</artifactId>
+      <scope>test</scope>
+    </dependency>
   </dependencies>
 </project>

service-layer/src/main/java/com/iluwatar/servicelayer/common/BaseEntity.java

@@ -12,8 +12,37 @@
  */
 @MappedSuperclass
 @Inheritance(strategy = InheritanceType.TABLE_PER_CLASS)
-public class BaseEntity {
+public abstract class BaseEntity {
 
   @Version
   private Long version;
+
+  /**
+   * Indicates the unique id of this entity
+   *
+   * @return The id of the entity, or 'null' when not persisted
+   */
+  public abstract Long getId();
+
+  /**
+   * Set the id of this entity
+   *
+   * @param id The new id
+   */
+  public abstract void setId(Long id);
+
+  /**
+   * Get the name of this entity
+   *
+   * @return The name of the entity
+   */
+  public abstract String getName();
+
+  /**
+   * Set the name of this entity
+   *
+   * @param name The new name
+   */
+  public abstract void setName(final String name);
+
 }

service-layer/src/main/java/com/iluwatar/servicelayer/hibernate/HibernateUtil.java

@@ -1,41 +1,56 @@
 package com.iluwatar.servicelayer.hibernate;
 
-import org.hibernate.SessionFactory;
-import org.hibernate.cfg.Configuration;
-
 import com.iluwatar.servicelayer.spell.Spell;
 import com.iluwatar.servicelayer.spellbook.Spellbook;
 import com.iluwatar.servicelayer.wizard.Wizard;
 
+import org.hibernate.SessionFactory;
+import org.hibernate.cfg.Configuration;
+
 /**
- * 
  * Produces the Hibernate {@link SessionFactory}.
- *
  */
 public class HibernateUtil {
 
-  private static final SessionFactory SESSION_FACTORY;
-
-  static {
-    try {
-      SESSION_FACTORY =
-          new Configuration().addAnnotatedClass(Wizard.class).addAnnotatedClass(Spellbook.class)
-              .addAnnotatedClass(Spell.class)
-              .setProperty("hibernate.dialect", "org.hibernate.dialect.H2Dialect")
-              .setProperty("hibernate.connection.url", "jdbc:h2:mem:test;DB_CLOSE_DELAY=-1")
-              .setProperty("hibernate.current_session_context_class", "thread")
-              .setProperty("hibernate.show_sql", "true")
-              .setProperty("hibernate.hbm2ddl.auto", "create-drop").buildSessionFactory();
-    } catch (Throwable ex) {
-      System.err.println("Initial SessionFactory creation failed." + ex);
-      throw new ExceptionInInitializerError(ex);
-    }
-  }
+  /**
+   * The cached session factory
+   */
+  private static volatile SessionFactory sessionFactory;
 
   private HibernateUtil() {
   }
 
-  public static SessionFactory getSessionFactory() {
-    return SESSION_FACTORY;
+  /**
+   * Create the current session factory instance, create a new one when there is none yet.
+   *
+   * @return The session factory
+   */
+  public static synchronized SessionFactory getSessionFactory() {
+    if (sessionFactory == null) {
+      try {
+        sessionFactory =
+            new Configuration().addAnnotatedClass(Wizard.class).addAnnotatedClass(Spellbook.class)
+                .addAnnotatedClass(Spell.class)
+                .setProperty("hibernate.dialect", "org.hibernate.dialect.H2Dialect")
+                .setProperty("hibernate.connection.url", "jdbc:h2:mem:test;DB_CLOSE_DELAY=-1")
+                .setProperty("hibernate.current_session_context_class", "thread")
+                .setProperty("hibernate.show_sql", "true")
+                .setProperty("hibernate.hbm2ddl.auto", "create-drop").buildSessionFactory();
+      } catch (Throwable ex) {
+        System.err.println("Initial SessionFactory creation failed." + ex);
+        throw new ExceptionInInitializerError(ex);
+      }
+    }
+    return sessionFactory;
+  }
+
+  /**
+   * Drop the current connection, resulting in a create-drop clean database next time. This is
+   * mainly used for JUnit testing since one test should not influence the other
+   */
+  public static void dropSession() {
+    getSessionFactory().close();
+    sessionFactory = null;
   }
+
 }

service-layer/src/main/java/com/iluwatar/servicelayer/spell/SpellDaoImpl.java

@@ -1,12 +1,12 @@
 package com.iluwatar.servicelayer.spell;
 
+import com.iluwatar.servicelayer.common.DaoBaseImpl;
+
 import org.hibernate.Criteria;
 import org.hibernate.Session;
 import org.hibernate.Transaction;
 import org.hibernate.criterion.Restrictions;
 
-import com.iluwatar.servicelayer.common.DaoBaseImpl;
-
 /**
  * 
  * SpellDao implementation.
@@ -24,7 +24,6 @@ public Spell findByName(String name) {
       Criteria criteria = session.createCriteria(persistentClass);
       criteria.add(Restrictions.eq("name", name));
       result = (Spell) criteria.uniqueResult();
-      result.getSpellbook().getWizards().size();
       tx.commit();
     } catch (Exception e) {
       if (tx != null) {

service-layer/src/main/java/com/iluwatar/servicelayer/spellbook/Spellbook.java

@@ -6,6 +6,7 @@
 import javax.persistence.CascadeType;
 import javax.persistence.Column;
 import javax.persistence.Entity;
+import javax.persistence.FetchType;
 import javax.persistence.GeneratedValue;
 import javax.persistence.Id;
 import javax.persistence.ManyToMany;
@@ -50,7 +51,7 @@ public void setId(Long id) {
 
   private String name;
 
-  @ManyToMany(mappedBy = "spellbooks")
+  @ManyToMany(mappedBy = "spellbooks", fetch = FetchType.EAGER)
   private Set<Wizard> wizards;
 
   @OneToMany(mappedBy = "spellbook", orphanRemoval = true, cascade = CascadeType.ALL)

service-layer/src/test/java/com/iluwatar/servicelayer/app/AppTest.java

@@ -1,5 +1,8 @@
 package com.iluwatar.servicelayer.app;
 
+import com.iluwatar.servicelayer.hibernate.HibernateUtil;
+
+import org.junit.After;
 import org.junit.Test;
 
 /**
@@ -14,4 +17,10 @@ public void test() {
     String[] args = {};
     App.main(args);
   }
+
+  @After
+  public void tearDown() throws Exception {
+    HibernateUtil.dropSession();
+  }
+
 }

service-layer/src/test/java/com/iluwatar/servicelayer/common/BaseDaoTest.java

@@ -0,0 +1,123 @@
+package com.iluwatar.servicelayer.common;
+
+import com.iluwatar.servicelayer.hibernate.HibernateUtil;
+
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+
+import java.util.List;
+import java.util.concurrent.atomic.AtomicInteger;
+import java.util.function.Function;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertNull;
+
+/**
+ * Date: 12/28/15 - 10:53 PM
+ *
+ * @author Jeroen Meulemeester
+ */
+public abstract class BaseDaoTest<E extends BaseEntity, D extends DaoBaseImpl<E>> {
+
+  /**
+   * The number of entities stored before each test
+   */
+  private static final int INITIAL_COUNT = 5;
+
+  /**
+   * The unique id generator, shared between all entities
+   */
+  private static final AtomicInteger ID_GENERATOR = new AtomicInteger();
+
+  /**
+   * Factory, used to create new entity instances with the given name
+   */
+  private final Function<String, E> factory;
+
+  /**
+   * The tested data access object
+   */
+  private final D dao;
+
+  /**
+   * Create a new test using the given factory and dao
+   *
+   * @param factory The factory, used to create new entity instances with the given name
+   * @param dao     The tested data access object
+   */
+  public BaseDaoTest(final Function<String, E> factory, final D dao) {
+    this.factory = factory;
+    this.dao = dao;
+  }
+
+  @Before
+  public void setUp() throws Exception {
+    for (int i = 0; i < INITIAL_COUNT; i++) {
+      final String className = dao.persistentClass.getSimpleName();
+      final String entityName = String.format("%s%d", className, ID_GENERATOR.incrementAndGet());
+      this.dao.persist(this.factory.apply(entityName));
+    }
+  }
+
+  @After
+  public void tearDown() throws Exception {
+    HibernateUtil.dropSession();
+  }
+
+  protected final D getDao() {
+    return this.dao;
+  }
+
+  @Test
+  public void testFind() throws Exception {
+    final List<E> all = this.dao.findAll();
+    for (final E entity : all) {
+      final E byId = this.dao.find(entity.getId());
+      assertNotNull(byId);
+      assertEquals(byId.getId(), byId.getId());
+    }
+  }
+
+  @Test
+  public void testDelete() throws Exception {
+    final List<E> originalEntities = this.dao.findAll();
+    this.dao.delete(originalEntities.get(1));
+    this.dao.delete(originalEntities.get(2));
+
+    final List<E> entitiesLeft = this.dao.findAll();
+    assertNotNull(entitiesLeft);
+    assertEquals(INITIAL_COUNT - 2, entitiesLeft.size());
+  }
+
+  @Test
+  public void testFindAll() throws Exception {
+    final List<E> all = this.dao.findAll();
+    assertNotNull(all);
+    assertEquals(INITIAL_COUNT, all.size());
+  }
+
+  @Test
+  public void testSetId() throws Exception {
+    final E entity = this.factory.apply("name");
+    assertNull(entity.getId());
+
+    final Long expectedId = Long.valueOf(1);
+    entity.setId(expectedId);
+    assertEquals(expectedId, entity.getId());
+  }
+
+  @Test
+  public void testSetName() throws Exception {
+    final E entity = this.factory.apply("name");
+    assertEquals("name", entity.getName());
+    assertEquals("name", entity.toString());
+
+    final String expectedName = "new name";
+    entity.setName(expectedName);
+    assertEquals(expectedName, entity.getName());
+    assertEquals(expectedName, entity.toString());
+  }
+
+}