vuminh224/tpjpa
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update DTO

Browse Source
This commit is contained in:
tuanvu
2025-09-29 23:08:56 +02:00
parent 58470b6e46
commit e3ce24a43e
10 changed files with 104 additions and 60 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/DAO/GenericDAOImpl.java → src/main/java/DAO/AbstractJpaDao.java
View File

@@ -2,17 +2,16 @@ package DAO;
import jakarta.persistence.EntityManager;
import jakarta.persistence.EntityTransaction;
import jakarta.persistence.PersistenceException;
import jpa.EntityManagerHelper;
import java.io.Serializable;
import java.util.List;
public abstract class GenericDAOImpl<K, T extends Serializable> implements Generic<K, T> {
public abstract class AbstractJpaDao<K, T extends Serializable> implements IGenericDao<K, T> {
protected EntityManager em;
private Class<T> entityClass;
public GenericDAOImpl() {
public AbstractJpaDao() {
this.em = EntityManagerHelper.getEntityManager();
}
@@ -21,6 +20,10 @@ public abstract class GenericDAOImpl<K, T extends Serializable> implements Gener
this.entityClass= class2;
}
public T findOne(K id) {
return em.find(entityClass, id);
}
public List<T> findAll() {
return em.createQuery("select e from " + entityClass.getName() + " as e", entityClass).getResultList();
}

50
src/main/java/DAO/EntityManagerHelper.java Normal file
View File

@@ -0,0 +1,50 @@
package DAO;
import jakarta.persistence.EntityManager;
import jakarta.persistence.EntityManagerFactory;
import jakarta.persistence.Persistence;
public class EntityManagerHelper {
private static final EntityManagerFactory emf;
private static final ThreadLocal<EntityManager> threadLocal;
static {
emf = Persistence.createEntityManagerFactory("dev");
threadLocal = new ThreadLocal<EntityManager>();
}
public static EntityManager getEntityManager() {
EntityManager em = threadLocal.get();
if (em == null) {
em = emf.createEntityManager();
threadLocal.set(em);
}
return em;
}
public static void closeEntityManager() {
EntityManager em = threadLocal.get();
if (em != null) {
em.close();
threadLocal.set(null);
}
}
public static void closeEntityManagerFactory() {
emf.close();
}
public static void beginTransaction() {
getEntityManager().getTransaction().begin();
}
public static void rollback() {
getEntityManager().getTransaction().rollback();
}
public static void commit() {
getEntityManager().getTransaction().commit();
}
}

3
src/main/java/DAO/Generic.java → src/main/java/DAO/IGenericDao.java
View File

@@ -3,11 +3,12 @@ package DAO;
import java.io.Serializable;
import java.util.List;
public interface Generic<K, T extends Serializable> {
public interface IGenericDao<K, T extends Serializable> {
void create(final T entity);
T findById(final K id);
T update(final T entity);
void delete(final T entity);
void deleteById(final K id);
List<T> findAll();
T findOne(final K id);
}

2
src/main/java/DAO/QuestionDAO.java
View File

@@ -2,7 +2,7 @@ package DAO;
import metier.Question;
public class QuestionDAO extends GenericDAOImpl<Integer, Question> {
public class QuestionDAO extends AbstractJpaDao<Integer, Question> {
public QuestionDAO(){
super();
this.setClass(Question.class);

2
src/main/java/DAO/QuizzDAO.java
View File

@@ -3,7 +3,7 @@ package DAO;
import jakarta.persistence.EntityTransaction;
import metier.Quizz;
public class QuizzDAO extends GenericDAOImpl<Integer, Quizz>{
public class QuizzDAO extends AbstractJpaDao<Integer, Quizz> {
public QuizzDAO(){
super();
this.setClass(Quizz.class);

6
src/main/java/DAO/ReponseDAO.java
View File

@@ -1,12 +1,8 @@
package DAO;
import java.util.List;
import jakarta.persistence.EntityTransaction;
import jakarta.persistence.Query;
import metier.Reponse;
public class ReponseDAO extends GenericDAOImpl<Integer, Reponse> {
public class ReponseDAO extends AbstractJpaDao<Integer, Reponse> {
public ReponseDAO(){
super();
this.setClass(Reponse.class);

3
src/main/java/DAO/SessionDAO.java
View File

@@ -4,11 +4,10 @@ package DAO;
import jakarta.persistence.EntityTransaction;
import jakarta.persistence.Query;
import metier.Session;
import metier.Utilisateur;
import java.util.List;
public class SessionDAO extends GenericDAOImpl<Integer, Session> {
public class SessionDAO extends AbstractJpaDao<Integer, Session> {
public SessionDAO() {
super();
this.setClass(Session.class);

4
src/main/java/DAO/UtilisateurDAO.java
View File

@@ -5,9 +5,7 @@ import jakarta.persistence.Query;
import metier.Session;
import metier.Utilisateur;
import java.util.ArrayList;
public class UtilisateurDAO extends GenericDAOImpl<Integer, Utilisateur>{
public class UtilisateurDAO extends AbstractJpaDao<Integer, Utilisateur> {
public UtilisateurDAO() {
super();
this.setClass(Utilisateur.class);

3
src/main/java/Mapper/UtilisateurMapper.java
View File

@@ -13,7 +13,4 @@ public interface UtilisateurMapper {
UtilisateurDTO toDTO(Utilisateur utilisateur);
Utilisateur toEntity(UtilisateurDTO dto);
List<UtilisateurDTO> toDTOs(List<Utilisateur> utilisateurs);
List<Utilisateur> toEntitys(List<UtilisateurDTO> dtos);
}

82
src/main/java/jpa/JpaTest.java
View File

@@ -11,36 +11,37 @@ import java.util.List;
public class JpaTest {
private EntityManager manager;
private EntityManager manager;
public JpaTest(EntityManager manager) {
this.manager = manager;
}
/**
* @param args
*/
public static void main(String[] args) {
public JpaTest(EntityManager manager) {
this.manager = manager;
}
/**
* @param args
*/
public static void main(String[] args) {
EntityManager manager = EntityManagerHelper.getEntityManager();
JpaTest test = new JpaTest(manager);
JpaTest test = new JpaTest(manager);
EntityTransaction tx = manager.getTransaction();
tx.begin();
try {
EntityTransaction tx = manager.getTransaction();
tx.begin();
try {
//test.create_user_test();
//test.create_session_test();
//test.create_session_test();
//test.list_utilisateur();
//test.list_session();
} catch (Exception e) {
e.printStackTrace();
}
tx.commit();
//test.list_session();
} catch (Exception e) {
e.printStackTrace();
}
tx.commit();
manager.close();
EntityManagerHelper.closeEntityManagerFactory();
System.out.println(".. done");
}
manager.close();
EntityManagerHelper.closeEntityManagerFactory();
System.out.println(".. done");
}
private void create_user_test() {
int numUser = manager.createQuery("SELECT u FROM Utilisateur u", Utilisateur.class).getResultList().size();
@@ -56,42 +57,41 @@ public class JpaTest {
manager.persist(utilisateur1);
manager.persist(utilisateur2);
}
}
}
private void create_session_test() {
private void create_session_test() {
int numUser = manager.createQuery("SELECT u FROM Session u", Session.class).getResultList().size();
if (numUser == 0) {
//Utilisateur
Session session1 = new Session();
session1.setCodePIN(1703);
session1.setTheme("Inphormatik");
session1.setQuizzs(new ArrayList<>());
Session session1 = new Session();
session1.setCodePIN(1703);
session1.setTheme("Inphormatik");
session1.setQuizzs(new ArrayList<>());
List<Utilisateur> ulist = manager.createQuery("select user from Utilisateur user").getResultList();
session1.setUtilisateurs(ulist);
List<Utilisateur> ulist = manager.createQuery("select user from Utilisateur user").getResultList();
session1.setUtilisateurs(ulist);
manager.persist(session1);
manager.persist(session1);
}
}
private void list_utilisateur(){
List<Utilisateur> result_utilisatuer_list= manager.createQuery("select u from Utilisateur u", Utilisateur.class).getResultList();
private void list_utilisateur() {
List<Utilisateur> result_utilisatuer_list = manager.createQuery("select u from Utilisateur u", Utilisateur.class).getResultList();
for (Utilisateur u : result_utilisatuer_list) {
System.out.println(u.getId() + " " + u.getName() +" "+ u.getEmail());
System.out.println(u.getId() + " " + u.getName() + " " + u.getEmail());
}
}
private void list_session(){
List<Session> result_session_list= manager.createQuery("select s from Session s", Session.class).getResultList();
private void list_session() {
List<Session> result_session_list = manager.createQuery("select s from Session s", Session.class).getResultList();
for (Session s : result_session_list) {
System.out.println(s.getCodePIN() + " " + s.getTheme());
for(Utilisateur u : s.getUtilisateurs()){
System.out.println(u.getId() + " " + u.getName() +" "+ u.getEmail());
}
for (Utilisateur u : s.getUtilisateurs()) {
System.out.println(u.getId() + " " + u.getName() + " " + u.getEmail());
}
}
}
}