Grundsatzstruktur eingeführt

Thomas Ziemer
1 parent 52fa3280
Showing 8 changed files with 282 additions and 1 deletions
src/main/java/net/ziemers/swxercise/db/BaseEntity.java
src/main/java/net/ziemers/swxercise/db/dao/GenericDao.java
src/main/java/net/ziemers/swxercise/lg/user/Address.java
src/main/java/net/ziemers/swxercise/lg/user/Profile.java
src/main/java/net/ziemers/swxercise/lg/user/User.java
src/main/java/net/ziemers/swxercise/lg/user/service/UserService.java
src/main/java/net/ziemers/swxercise/ui/RestController.java
src/main/resources/META-INF/persistence.xml
+package net.ziemers.swxercise.db;
+
+import javax.persistence.GeneratedValue;
+import javax.persistence.Id;
+
+public class BaseEntity {
+    
+    @Id
+    @GeneratedValue
+    protected Long id;
+    
+    public Long getId() {
+        return id;
+    }
+
+}
 \ No newline at end of file
+package net.ziemers.swxercise.db.dao;
+
+import java.util.Collection;
+
+import javax.ejb.Stateless;
+import javax.inject.Inject;
+import javax.persistence.EntityManager;
+import javax.persistence.criteria.CriteriaBuilder;
+import javax.persistence.criteria.CriteriaQuery;
+// import javax.persistence.criteria.Predicate;
+// import javax.persistence.criteria.Root;
+
+import net.ziemers.swxercise.db.BaseEntity;
+
+@Stateless
+public class GenericDao {
+
+    @Inject
+    private EntityManager entityManager;
+
+    /**
+     * Speichert die gegebene Entität.
+     *
+     * @see EntityManager#persist(Object)
+     * @param entity die zu speichernde Entität
+     * @param <T> Generic für den Entity-Typ.
+     * @return die Id der persistierten Entität
+     */
+    public <T extends BaseEntity> Long save(final T entity) {
+        entityManager.persist(entity);
+        return entity.getId();
+    }
+
+    public <T extends BaseEntity> T saveOrUpdate(final T entity) {
+        return entityManager.merge(entity);
+    }
+
+    /**
+     * @param entityType Entity-Typ.
+     * @param primaryKey Id
+     * @param <T> Generic für Entity-Typ
+     * @return die Entität mit gegebener Id oder <code>null</code>, wenn keine gefunden
+     */
+    public <T extends BaseEntity> T findById(Class<T> entityType, Long primaryKey) {
+        T entity = entityManager.find(entityType, primaryKey);
+        return entity;
+    }
+
+    /**
+     * @param entityType Entity-Typ.
+     * @param <T> Generic für den Entity-Typ.
+     * @return alle (aktiven) Entitäten vom gegebenen Typ
+     */
+    public <T extends BaseEntity> Collection<T> findAll(Class<T> entityType) {
+        CriteriaBuilder cb = entityManager.getCriteriaBuilder();
+        CriteriaQuery<T> query = cb.createQuery(entityType);
+        // Root<T> root = query.from(entityType);
+        // Predicate activeStatus = cb.equal(root.get(STATUS), Status.ACTIVE);
+        // query.where(activeStatus);
+        return entityManager.createQuery(query).getResultList();
+    }
+
+}
+package net.ziemers.swxercise.lg.user;
+
+import javax.persistence.Entity;
+
+import net.ziemers.swxercise.db.BaseEntity;
+
+@Entity
+public class Address extends BaseEntity {
+
+    private String street;
+
+    private String zipcode;
+
+    private String city;
+
+    private String country;
+
+    public String getStreet() {
+        return street;
+    }
+
+    public void setStreet(String street) {
+        this.street = street;
+    }
+
+    public String getZipcode() {
+        return zipcode;
+    }
+
+    public void setZipcode(String zipcode) {
+        this.zipcode = zipcode;
+    }
+
+    public String getCity() {
+        return city;
+    }
+
+    public void setCity(String city) {
+        this.city = city;
+    }
+
+    public String getCountry() {
+        return country;
+    }
+
+    public void setCountry(String country) {
+        this.country = country;
+    }
+
+}
+package net.ziemers.swxercise.lg.user;
+
+import javax.persistence.Entity;
+
+import net.ziemers.swxercise.db.BaseEntity;
+
+@Entity
+public class Profile extends BaseEntity {
+
+    private String passwordHash;
+
+    private String mailaddress;
+
+    public String getPasswordHash() {
+        return passwordHash;
+    }
+
+    public void setPasswordHash(String passwordHash) {
+        this.passwordHash = passwordHash;
+    }
+
+    public String getMailaddress() {
+        return mailaddress;
+    }
+
+    public void setMailaddress(String mailaddress) {
+        this.mailaddress = mailaddress;
+    }
+
+}
+package net.ziemers.swxercise.lg.user;
+
+import javax.persistence.Entity;
+
+import net.ziemers.swxercise.db.BaseEntity;
+
+@Entity
+public class User extends BaseEntity {
+
+    private String firstname;
+
+    private String lastname;
+
+    public String getFirstname() {
+        return firstname;
+    }
+
+    public void setFirstname(String firstname) {
+        this.firstname = firstname;
+    }
+
+    public String getLastname() {
+        return lastname;
+    }
+
+    public void setLastname(String lastname) {
+        this.lastname = lastname;
+    }
+
+}
+package net.ziemers.swxercise.lg.user.service;
+
+import java.util.Collection;
+
+import javax.ejb.Stateless;
+import javax.inject.Inject;
+
+import net.ziemers.swxercise.db.BaseEntity;
+import net.ziemers.swxercise.db.dao.GenericDao;
+import net.ziemers.swxercise.lg.user.User;
+
+@Stateless
+public class UserService {
+
+    @Inject
+    private GenericDao genericDao;
+
+    public User findUser(final Long id) {
+        return genericDao.findById(User.class, id);
+    }
+
+    public Collection<User> findAllUsers() {
+        return genericDao.findAll(User.class);
+    }
+
+    public <T extends BaseEntity> Long saveUser(final User user) {
+        return genericDao.save(user);
+    }
+
+}
 package net.ziemers.swxercise.ui;
  
+import java.util.Collection;
+
 import javax.annotation.PostConstruct;
 import javax.enterprise.context.ApplicationScoped;
+import javax.inject.Inject;
 import javax.ws.rs.GET;
 import javax.ws.rs.Path;
 import javax.ws.rs.PathParam;
 import javax.ws.rs.Produces;
 import javax.ws.rs.core.MediaType;
  
+import net.ziemers.swxercise.lg.user.User;
+import net.ziemers.swxercise.lg.user.service.UserService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
  
@@ -15,10 +20,13 @@ import org.slf4j.LoggerFactory;
 @Path(RestController.webContextPath)
 public class RestController {
  
-    static final String webContextPath = "/misc";
+    static final String webContextPath = "/user";
  
     private Logger logger;
  
+    @Inject
+    private UserService userService;
+
     @PostConstruct
     public void init() {
         logger = LoggerFactory.getLogger(RestController.class);
@@ -39,4 +47,11 @@ public class RestController {
         return String.format("Hello %s", name);
     }
  
+    @GET
+    @Path("/get")
+    @Produces(MediaType.APPLICATION_JSON)
+    public Collection<User> getAllUsers() {
+        return userService.findAllUsers();
+    }
+
 }
+<persistence version="2.0"
+	xmlns="http://java.sun.com/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://java.sun.com/xml/ns/persistence http://java.sun.com/xml/ns/persistence/persistence_2_0.xsd">
+	<persistence-unit name="swXercisePU" transaction-type="JTA">
+		<jta-data-source>java:jboss/datasources/swXerciseDS</jta-data-source>
+		<properties>
+			<!-- property name="hibernate.hbm2ddl.auto" value="create-drop" / -->
+			<property name="hibernate.hbm2ddl.auto" value="update" />
+		</properties>
+	</persistence-unit>
+	<persistence-unit name="swXerciseTestPU"
+		transaction-type="RESOURCE_LOCAL">
+		<provider>org.hibernate.jpa.HibernatePersistenceProvider</provider>
+		<exclude-unlisted-classes>false</exclude-unlisted-classes>
+
+		<properties>
+			<!-- Property for WildFly to ignore this -->
+			<property name="jboss.as.jpa.managed" value="false" />
+			<!-- Properties for Hibernate -->
+			<property name="javax.persistence.jdbc.url"
+				value="jdbc:mariadb://${abisnext.test.host}:${abisnext.test.port}/${abisnext.test.schema}" />
+			<property name="javax.persistence.jdbc.user" value="${abisnext.test.user}" />
+			<property name="javax.persistence.jdbc.password" value="${abisnext.test.password}" />
+			<property name="javax.persistence.jdbc.driver" value="org.mariadb.jdbc.Driver" />
+			<property name="hibernate.show_sql" value="false" />
+			<property name="hibernate.format_sql" value="false" />
+			<property name="hibernate.dialect" value="org.hibernate.dialect.MySQL5Dialect" />
+			<!--<property name="hibernate.hbm2ddl.auto" value="create-drop" /> -->
+			<property name="hibernate.connection.useUnicode" value="true" />
+			<property name="hibernate.connection.characterEncoding"
+				value="UTF-8" />
+			<property name="hibernate.connection.provider_class"
+				value="org.hibernate.connection.C3P0ConnectionProvider" />
+
+			<property name="hibernate.c3p0.min_size" value="2" />
+			<property name="hibernate.c3p0.max_size" value="100" />
+			<property name="hibernate.c3p0.timeout" value="10" />
+			<property name="hibernate.c3p0.max_statements" value="100" />
+			<property name="hibernate.c3p0.idle_test_period" value="30" />
+
+			<property name="hibernate.temp.use_jdbc_metadata_defaults"
+				value="false" />
+			<property name="hibernate.ejb.entitymanager_factory_name"
+				value="abisnext_test" />
+		</properties>
+	</persistence-unit>
+</persistence>
 \ No newline at end of file