remove unnecessary checks

hakan-krgn · Nov 4, 2023 · bff1661 · bff1661
1 parent dc9deaf
commit bff1661
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 27 deletions.
diff --git a/...ase/hibernate/src/main/java/com/hakan/spinjection/database/executor/DatabaseExecutor.java b/...ase/hibernate/src/main/java/com/hakan/spinjection/database/executor/DatabaseExecutor.java
@@ -9,7 +9,6 @@
 import com.hakan.spinjection.database.connection.query.DbQuery;
 import com.hakan.spinjection.executor.SpigotExecutor;
 import com.hakan.spinjection.utils.ProxyUtils;
-import org.bukkit.Bukkit;
 import org.hibernate.Session;
 
 import javax.annotation.Nonnull;
@@ -104,15 +103,11 @@ public void execute(@Nonnull SpigotBootstrap bootstrap,
                 bootstrap.getReflection()
         );
 
-        try {
-            Session session = this.dbConnection.getSession();
-            session.getTransaction().begin();
-            Arrays.stream(this.repository.queries())
-                    .forEach(query -> session.createNativeQuery(query).executeUpdate());
-            session.getTransaction().commit();
-        } catch (Exception e) {
-            Bukkit.getLogger().warning("Error while executing queries!");
-        }
+        Session session = this.dbConnection.getSession();
+        session.getTransaction().begin();
+        Arrays.stream(this.repository.queries())
+                .forEach(query -> session.createNativeQuery(query).executeUpdate());
+        session.getTransaction().commit();
     }
 
     /**

diff --git a/...se/hibernate8/src/main/java/com/hakan/spinjection/database/executor/DatabaseExecutor.java b/...se/hibernate8/src/main/java/com/hakan/spinjection/database/executor/DatabaseExecutor.java
@@ -9,7 +9,6 @@
 import com.hakan.spinjection.database.connection.query.DbQuery;
 import com.hakan.spinjection.executor.SpigotExecutor;
 import com.hakan.spinjection.utils.ProxyUtils;
-import org.bukkit.Bukkit;
 import org.hibernate.Session;
 
 import javax.annotation.Nonnull;
@@ -104,15 +103,11 @@ public void execute(@Nonnull SpigotBootstrap bootstrap,
                 bootstrap.getReflection()
         );
 
-        try {
-            Session session = this.dbConnection.getSession();
-            session.getTransaction().begin();
-            Arrays.stream(this.repository.queries())
-                    .forEach(query -> session.createNativeQuery(query).executeUpdate());
-            session.getTransaction().commit();
-        } catch (Exception e) {
-            Bukkit.getLogger().warning("Error while executing queries!");
-        }
+        Session session = this.dbConnection.getSession();
+        session.getTransaction().begin();
+        Arrays.stream(this.repository.queries())
+                .forEach(query -> session.createNativeQuery(query).executeUpdate());
+        session.getTransaction().commit();
     }
 
     /**

diff --git a/...tabase/native/src/main/java/com/hakan/spinjection/database/executor/DatabaseExecutor.java b/...tabase/native/src/main/java/com/hakan/spinjection/database/executor/DatabaseExecutor.java
@@ -9,7 +9,6 @@
 import com.hakan.spinjection.database.connection.result.DbResult;
 import com.hakan.spinjection.executor.SpigotExecutor;
 import com.hakan.spinjection.utils.ProxyUtils;
-import org.bukkit.Bukkit;
 
 import javax.annotation.Nonnull;
 import javax.annotation.Nullable;
@@ -93,12 +92,8 @@ public void execute(@Nonnull SpigotBootstrap bootstrap,
                         @Nonnull Object instance) {
         this.dbConnection = new DbConnection(DbCredential.of(bootstrap, this.repository));
 
-        try {
-            Arrays.stream(this.repository.queries())
-                    .forEach(query -> this.dbConnection.executeUpdate(query));
-        } catch (Exception e) {
-            Bukkit.getLogger().warning("Error while executing queries!");
-        }
+        Arrays.stream(this.repository.queries())
+                .forEach(query -> this.dbConnection.executeUpdate(query));
     }
 
     /**