Add DAO layer including implementation for user entity

Benjamin Rühl
1 parent aad7d7b1
Showing 8 changed files with 148 additions and 54 deletions
services/Common/src/main/java/de/bht/beuthbot/dataAccess/GenericDAO.java
services/Common/src/main/java/de/bht/beuthbot/dataAccess/UserDAO.java
services/Global/src/main/java/de/bht/beuthbot/daos/AppUserDAO.java
services/Global/src/main/java/de/bht/beuthbot/daos/GenericHibernateDAO.java
services/Global/src/main/java/de/bht/beuthbot/entities/User.java → services/Global/src/main/java/de/bht/beuthbot/entities/AppUser.java
services/Global/src/main/java/de/bht/beuthbot/persistence/UserManager.java
services/Global/src/main/resources/META-INF/persistence.xml
services/Global/src/main/webapp/META-INF/persistence.xml
+package de.bht.beuthbot.dataAccess;
+
+import de.bht.beuthbot.model.entities.Entity;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * Created by Benjamin Rühl on 19.12.2017.
+ */
+public interface GenericDAO<T extends Entity, ID extends Serializable> {
+
+    T findById(ID id);
+
+    List<T> findAll();
+
+    T saveOrUpdate(T entity);
+
+    void delete(T entity);
+}
+package de.bht.beuthbot.dataAccess;
+
+import de.bht.beuthbot.model.entities.User;
+
+import javax.ejb.Remote;
+
+/**
+ * Created by Benjamin Rühl on 19.12.2017.
+ */
+@Remote
+public interface UserDAO extends GenericDAO<User, Long> {
+}
+package de.bht.beuthbot.daos;
+
+import de.bht.beuthbot.dataAccess.UserDAO;
+import de.bht.beuthbot.entities.AppUser;
+import de.bht.beuthbot.model.entities.User;
+
+import javax.ejb.Stateless;
+
+/**
+ * Created by Benjamin Rühl on 19.12.2017.
+ */
+@Stateless
+public class AppUserDAO extends GenericHibernateDAO<User, Long> implements UserDAO {
+
+    public AppUserDAO() {
+        setEntityClass(AppUser.class);
+    }
+}
+package de.bht.beuthbot.daos;
+
+import de.bht.beuthbot.dataAccess.GenericDAO;
+import de.bht.beuthbot.model.entities.Entity;
+import org.hibernate.Criteria;
+import org.hibernate.Session;
+import org.hibernate.criterion.Criterion;
+
+import javax.persistence.EntityManager;
+import javax.persistence.PersistenceContext;
+import java.io.Serializable;
+import java.lang.reflect.ParameterizedType;
+import java.util.List;
+
+/**
+ * Created by Benjamin Rühl on 19.12.2017.
+ */
+public class GenericHibernateDAO<T extends Entity, ID extends Serializable> implements GenericDAO<T, ID> {
+
+    private Class<? extends T> entityClass;
+    private Session session;
+
+    @PersistenceContext
+    private EntityManager em;
+
+    @SuppressWarnings("unchecked cast")
+    public GenericHibernateDAO() {
+        entityClass = (Class<T>) ((ParameterizedType) getClass().getGenericSuperclass()).getActualTypeArguments()[0];
+        setSession( (Session)em.getDelegate() );
+    }
+
+    public void setSession(Session s) {
+        this.session = s;
+    }
+
+    protected Session getSession() {
+        if (session == null)
+            throw new IllegalStateException("Session has not been set on DAO before usage");
+        return session;
+    }
+
+    /**
+     * Use this in subclasses to set entityClass to derived type of T
+     */
+    protected void setEntityClass(Class<? extends T> entityClass) {
+        this.entityClass = entityClass;
+    }
+
+    public Class<? extends T> getEntityClass() {
+        return entityClass;
+    }
+
+    @Override
+    public T findById(ID id) {
+        return getSession().load(getEntityClass(), id);
+    }
+
+    public List<T> findAll() {
+        return findByCriteria();
+    }
+
+    @Override
+    public T saveOrUpdate(T entity) {
+        getSession().saveOrUpdate(entity);
+        return entity;
+    }
+
+    @Override
+    public void delete(T entity) {
+        getSession().delete(entity);
+    }
+
+    public void flush() {
+        getSession().flush();
+    }
+
+    public void clear() {
+        getSession().clear();
+    }
+
+    /**
+     * Use this inside subclasses as a convenience method.
+     */
+    @SuppressWarnings("unchecked")
+    protected List<T> findByCriteria(Criterion... criterion) {
+        Criteria crit = getSession().createCriteria(getEntityClass());
+        for (Criterion c : criterion) {
+            crit.add(c);
+        }
+        return crit.list();
+    }
+}
@@ -5,10 +5,12 @@ import javax.persistence.Table;
  
 /**
  * Created by Benjamin Rühl on 19.11.2017.
+ * Note: This class must not be named "User" except a different table name is provided.
+ * Postgres does not support creating a table named "user".
  */
 @Entity
-@Table(name = "user_entity")
-public class User extends EntityBase implements de.bht.beuthbot.model.entities.User {
+@Table
+public class AppUser extends EntityBase implements de.bht.beuthbot.model.entities.User {
  
     private String facebookUserId;
     private String telegramUserId;
-package de.bht.beuthbot.persistence;
-
-import de.bht.beuthbot.entities.User;
-
-import javax.ejb.Stateless;
-import javax.persistence.EntityManager;
-import javax.persistence.PersistenceContext;
-
-//@Stateless
-public class UserManager {
-
-    /*@PersistenceContext(unitName="PostgreSQLDS")
-    protected EntityManager entityManager;
-
-    public void createUser() {
-        User user = new User();
-        user.setFacebookUserId("FacebookUserId");
-        user.setTelegramUserId("TelegramUserId");
-
-        entityManager.persist(user);
-    }*/
-}
@@ -4,18 +4,17 @@
              http://xmlns.jcp.org/xml/ns/persistence/persistence_2_1.xsd"
              version="2.1">
  
-    <persistence-unit name="PostgreSQLDS" transaction-type="RESOURCE_LOCAL">
+    <persistence-unit name="PostgreSQLDS" transaction-type="JTA">
  
         <provider>org.hibernate.jpa.HibernatePersistenceProvider</provider>
  
         <jta-data-source>java:jboss/datasources/PostgreSQLDS</jta-data-source>
  
-        <class>de.bht.beuthbot.entities.User</class>
-
         <properties>
  
             <!--<property name="hibernate.dialect" value="org.hibernate.dialect.PostgreSQLDialect"/>--> <!-- DB Dialect -->
             <property name="hibernate.dialect" value="de.bht.beuthbot.persistence.ExtendedPostgreSQLDialect"/>
+            <!--<property name="hibernate.ejb.naming_strategy" value="org.hibernate.cfg.ImprovedNamingStrategy"/>-->
             <property name="hibernate.hbm2ddl.auto" value="create-drop" /> <!-- create / create-drop / update / none -->
             <property name="hibernate.archive.autodetection" value="class"/>
  
-<persistence xmlns="http://xmlns.jcp.org/xml/ns/persistence"
-             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-             xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/persistence
-             http://xmlns.jcp.org/xml/ns/persistence/persistence_2_1.xsd"
-             version="2.1">
-
-    <persistence-unit name="de.bht.beuthbot.jpa" transaction-type="RESOURCE_LOCAL">
-
-        <provider>org.hibernate.jpa.HibernatePersistenceProvider</provider>
-
-        <properties>
-            <property name="javax.persistence.jdbc.driver" value="org.postgresql.Driver" /> <!-- DB Driver -->
-            <property name="javax.persistence.jdbc.url" value="jdbc:postgresql://localhost:5432/beuthbot" /> <!-- BD Name -->
-            <property name="javax.persistence.jdbc.user" value="beuthbot_app" /> <!-- DB User -->
-            <property name="javax.persistence.jdbc.password" value="VhS7WPVpdYEHYLpf" /> <!-- DB Password -->
-
-            <property name="hibernate.dialect" value="org.hibernate.dialect.PostgreSQL95Dialect"/> <!-- DB Dialect -->
-            <property name="hibernate.hbm2ddl.auto" value="create-drop" /> <!-- create / create-drop / update / none -->
-            <property name="hibernate.archive.autodetection" value="class"/>
-
-            <property name="hibernate.show_sql" value="true" /> <!-- Show SQL in console -->
-            <property name="hibernate.format_sql" value="true" /> <!-- Show SQL formatted -->
-        </properties>
-
-    </persistence-unit>
-
-</persistence>
 \ No newline at end of file