Lanmikeman/Launcher
1
1
Fork 0
mirror of https://github.com/GravitLauncher/Launcher synced 2025-04-19 14:33:04 +03:00
Code Issues Projects Releases Packages Wiki Activity

[FEATURE] Удален SessionFactoryManager

Browse source
This commit is contained in:
Gravit 2019-07-01 15:27:55 +07:00
parent 8ef61b8673
commit c44208fed3
No known key found for this signature in database
GPG key ID: 061981E1E85D3216
3 changed files with 14 additions and 35 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
LaunchServer/src/main/java/pro/gravit/launchserver/dao/impl/HibernateUserDAOImpl.java
View file

@ -9,30 +9,29 @@
import javax.persistence.criteria.Root; import javax.persistence.criteria.Root;
import org.hibernate.Session; import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.Transaction; import org.hibernate.Transaction;
import pro.gravit.launcher.OshiHWID; import pro.gravit.launcher.OshiHWID;
import pro.gravit.launchserver.LaunchServer;
import pro.gravit.launchserver.dao.User; import pro.gravit.launchserver.dao.User;
import pro.gravit.launchserver.dao.UserDAO; import pro.gravit.launchserver.dao.UserDAO;
import pro.gravit.launchserver.dao.UserHWID; import pro.gravit.launchserver.dao.UserHWID;
import pro.gravit.launchserver.hibernate.SessionFactoryManager;
public class HibernateUserDAOImpl implements UserDAO { public class HibernateUserDAOImpl implements UserDAO {
private final SessionFactoryManager manager; private final SessionFactory factory;
public HibernateUserDAOImpl(LaunchServer srv) { public HibernateUserDAOImpl(SessionFactory factory) {
manager = SessionFactoryManager.forLaunchServer(srv); this.factory = factory;
} }
public User findById(int id) { public User findById(int id) {
try (Session s = manager.fact.openSession()) { try (Session s = factory.openSession()) {
return s.get(User.class, id); return s.get(User.class, id);
} }
} }
public User findByUsername(String username) { public User findByUsername(String username) {
EntityManager em = manager.fact.createEntityManager(); EntityManager em = factory.createEntityManager();
em.getTransaction().begin(); em.getTransaction().begin();
CriteriaBuilder cb = em.getCriteriaBuilder(); CriteriaBuilder cb = em.getCriteriaBuilder();
CriteriaQuery<User> personCriteria = cb.createQuery(User.class); CriteriaQuery<User> personCriteria = cb.createQuery(User.class);
@ -44,7 +43,7 @@ public User findByUsername(String username) {
} }
public User findByUUID(UUID uuid) { public User findByUUID(UUID uuid) {
EntityManager em = manager.fact.createEntityManager(); EntityManager em = factory.createEntityManager();
em.getTransaction().begin(); em.getTransaction().begin();
CriteriaBuilder cb = em.getCriteriaBuilder(); CriteriaBuilder cb = em.getCriteriaBuilder();
CriteriaQuery<User> personCriteria = cb.createQuery(User.class); CriteriaQuery<User> personCriteria = cb.createQuery(User.class);
@ -57,7 +56,7 @@ public User findByUUID(UUID uuid) {
@Override @Override
public List<UserHWID> findHWID(OshiHWID hwid) { public List<UserHWID> findHWID(OshiHWID hwid) {
EntityManager em = manager.fact.createEntityManager(); EntityManager em = factory.createEntityManager();
em.getTransaction().begin(); em.getTransaction().begin();
CriteriaBuilder cb = em.getCriteriaBuilder(); CriteriaBuilder cb = em.getCriteriaBuilder();
CriteriaQuery<UserHWID> personCriteria = cb.createQuery(UserHWID.class); CriteriaQuery<UserHWID> personCriteria = cb.createQuery(UserHWID.class);
@ -77,7 +76,7 @@ public List<UserHWID> findHWID(OshiHWID hwid) {
} }
public void save(User user) { public void save(User user) {
try (Session session = manager.fact.openSession()) { try (Session session = factory.openSession()) {
Transaction tx1 = session.beginTransaction(); Transaction tx1 = session.beginTransaction();
session.save(user); session.save(user);
tx1.commit(); tx1.commit();
@ -85,7 +84,7 @@ public void save(User user) {
} }
public void update(User user) { public void update(User user) {
try (Session session = manager.fact.openSession()) { try (Session session = factory.openSession()) {
Transaction tx1 = session.beginTransaction(); Transaction tx1 = session.beginTransaction();
session.update(user); session.update(user);
tx1.commit(); tx1.commit();
@ -93,7 +92,7 @@ public void update(User user) {
} }
public void delete(User user) { public void delete(User user) {
try (Session session = manager.fact.openSession()) { try (Session session = factory.openSession()) {
Transaction tx1 = session.beginTransaction(); Transaction tx1 = session.beginTransaction();
session.delete(user); session.delete(user);
tx1.commit(); tx1.commit();
@ -102,7 +101,7 @@ public void delete(User user) {
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
public List<User> findAll() { public List<User> findAll() {
try (Session s = manager.fact.openSession()) { try (Session s = factory.openSession()) {
return (List<User>) s.createQuery("From User").list(); return (List<User>) s.createQuery("From User").list();
} }
} }

6
LaunchServer/src/main/java/pro/gravit/launchserver/dao/provider/HibernateDaoProvider.java
View file

@ -6,7 +6,6 @@
import pro.gravit.launchserver.dao.UserHWID; import pro.gravit.launchserver.dao.UserHWID;
import pro.gravit.launchserver.dao.UserService; import pro.gravit.launchserver.dao.UserService;
import pro.gravit.launchserver.dao.impl.HibernateUserDAOImpl; import pro.gravit.launchserver.dao.impl.HibernateUserDAOImpl;
import pro.gravit.launchserver.hibernate.SessionFactoryManager;
import pro.gravit.utils.helper.CommonHelper; import pro.gravit.utils.helper.CommonHelper;
import java.nio.file.Paths; import java.nio.file.Paths;
@ -22,8 +21,6 @@ public class HibernateDaoProvider extends DaoProvider {
@Override @Override
public void init(LaunchServer server) { public void init(LaunchServer server) {
userDAO = new HibernateUserDAOImpl(server);
userService = new UserService(userDAO);
Runnable init = () -> { Runnable init = () -> {
Configuration cfg = new Configuration() Configuration cfg = new Configuration()
.addAnnotatedClass(User.class) .addAnnotatedClass(User.class)
@ -35,7 +32,8 @@ public void init(LaunchServer server) {
.setProperty("hibernate.connection.pool_size", pool_size); .setProperty("hibernate.connection.pool_size", pool_size);
if(hibernateConfig != null) if(hibernateConfig != null)
cfg.configure(Paths.get(hibernateConfig).toFile()); cfg.configure(Paths.get(hibernateConfig).toFile());
SessionFactoryManager.forLaunchServer(server).fact = cfg.buildSessionFactory(); userDAO = new HibernateUserDAOImpl(cfg.buildSessionFactory());
userService = new UserService(userDAO);
}; };
if(parallelHibernateInit) if(parallelHibernateInit)
CommonHelper.newThread("Hibernate Thread", true, init); CommonHelper.newThread("Hibernate Thread", true, init);

18
LaunchServer/src/main/java/pro/gravit/launchserver/hibernate/SessionFactoryManager.java
View file

@ -1,18 +0,0 @@
package pro.gravit.launchserver.hibernate;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.function.Function;
import org.hibernate.SessionFactory;
import pro.gravit.launchserver.LaunchServer;
public class SessionFactoryManager {
public SessionFactory fact;
private static final Map<LaunchServer, SessionFactoryManager> sessionFactories = new ConcurrentHashMap<>();
private static final Function<LaunchServer, SessionFactoryManager> cr = e -> new SessionFactoryManager();
public static SessionFactoryManager forLaunchServer(LaunchServer srv) {
return sessionFactories.computeIfAbsent(srv, cr);
}
}