Fix:

- добавлены rollback к DML операциям
shpali4 · Dec 15, 2022 · a9cb519 · a9cb519
1 parent 73078f6
commit a9cb519
Showing 1 changed file with 9 additions and 4 deletions.
diff --git a/src/main/java/jm/task/core/jdbc/dao/UserDaoHibernateImpl.java b/src/main/java/jm/task/core/jdbc/dao/UserDaoHibernateImpl.java
@@ -4,6 +4,7 @@
 import jm.task.core.jdbc.util.Util;
 import org.hibernate.Session;
 import org.hibernate.SessionFactory;
+import org.hibernate.Transaction;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -43,19 +44,21 @@ public void dropUsersTable() {
 
     @Override
     public void saveUser(String name, String lastName, byte age) {
+        Transaction transaction = null;
         try (Session session = sessionFactory.openSession()) {
             session.beginTransaction();
             User user = new User(name, lastName, age);
             session.save(user);
             session.getTransaction().commit();
             System.out.println("User с именем - " + user.getName() + " добавлен в базу данных");
         } catch (Exception e) {
-            e.printStackTrace();
+            transaction.rollback();
         }
     }
 
     @Override
     public void removeUserById(long id) {
+        Transaction transaction = null;
         try (Session session = sessionFactory.openSession()) {
             session.beginTransaction();
             User user = session.get(User.class, id);
@@ -64,31 +67,33 @@ public void removeUserById(long id) {
             }
             session.getTransaction().commit();
         } catch (Exception e) {
-            e.printStackTrace();
+            transaction.rollback();
         }
     }
 
     @Override
     public List<User> getAllUsers() {
+        Transaction transaction = null;
         List<User> users = new ArrayList<>();
         try (Session session = sessionFactory.openSession()) {
             session.beginTransaction();
             users = session.createQuery("SELECT x FROM User x", User.class).list();
             session.getTransaction().commit();
         } catch (Exception e) {
-            e.printStackTrace();
+            transaction.rollback();
         }
         return users;
     }
 
     @Override
     public void cleanUsersTable() {
+        Transaction transaction = null;
         try (Session session = sessionFactory.openSession()) {
             session.beginTransaction();
             session.createNativeQuery("DELETE FROM users").executeUpdate();
             session.getTransaction().commit();
         } catch (Exception e) {
-            e.printStackTrace();
+            transaction.rollback();
         }
     }
 }