Added more logs about the transaction

Author: milanmajchrak

dspace-api/src/main/java/org/dspace/core/HibernateDBConnection.java

@@ -30,6 +30,7 @@
 import org.hibernate.Transaction;
 import org.hibernate.engine.spi.SessionFactoryImplementor;
 import org.hibernate.proxy.HibernateProxyHelper;
+import org.hibernate.query.NativeQuery;
 import org.hibernate.resource.transaction.spi.TransactionStatus;
 import org.hibernate.stat.Statistics;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -81,7 +82,11 @@ public Session getSession() throws SQLException {
         // If we don't yet have a live transaction, start a new one
         // NOTE: a Session cannot be used until a Transaction is started.
         if (!isTransActionAlive()) {
+            log.info("getSession() - Starting new transaction");
+            getTransactionPid();
             sessionFactory.getCurrentSession().beginTransaction();
+            getTransactionPid();
+            log.info("getSession() - New transaction started");
             configureDatabaseMode();
         }
         // Return the current Hibernate Session object (Hibernate will create one if it doesn't yet exist)
@@ -135,7 +140,11 @@ public boolean isSessionAlive() {
     @Override
     public void rollback() throws SQLException {
         if (isTransActionAlive()) {
+            log.info("rollback() - rolling back transaction");
+            getTransactionPid();
             getTransaction().rollback();
+            getTransactionPid();
+            log.info("rollback() - transaction rolled back");
         }
     }
 
@@ -150,7 +159,11 @@ public void rollback() throws SQLException {
     @Override
     public void closeDBConnection() throws SQLException {
         if (sessionFactory.getCurrentSession() != null && sessionFactory.getCurrentSession().isOpen()) {
+            log.info("closeDBConnection() - Closing current session");
+            getTransactionPid();
             sessionFactory.getCurrentSession().close();
+            log.info("closeDBConnection() - Session closed");
+            getTransactionPid();
         }
     }
 
@@ -170,8 +183,12 @@ public void commit() throws SQLException {
                                                                           TransactionStatus.ROLLING_BACK)) {
             // Flush synchronizes the database with in-memory objects in Session (and frees up that memory)
             getSession().flush();
+            log.info("commit() - commiting transaction");
+            getTransactionPid();
             // Commit those results to the database & ends the Transaction
             getTransaction().commit();
+            getTransactionPid();
+            log.info("commit() - transaction committed");
         }
     }
 
@@ -235,7 +252,8 @@ public <E extends ReloadableEntity> E reloadEntity(final E entity) throws SQLExc
                 return entity;
             } else {
                 log.info("reloadEntity() - Entity is not in the session - return entity with ID {}", entity.getID());
-                return (E) getSession().get(HibernateProxyHelper.getClassWithoutInitializingProxy(entity), entity.getID());
+                return (E) getSession().get(HibernateProxyHelper.getClassWithoutInitializingProxy(entity),
+                        entity.getID());
             }
         } catch (Exception e) {
             log.error("reloadEntity() - Error reloading entity: {}", e.getMessage());
@@ -420,5 +438,23 @@ public String getHibernateStatistics() {
             return "SessionFactory is not available for logging Hibernate statistics.";
         }
     }
+
+    // Method to get the current transaction's PID from PostgreSQL
+    public Integer getTransactionPid() {
+        Integer pid = -1;
+        try {
+            Session session = sessionFactory.getCurrentSession(); // Get the current session
+            String sql = "SELECT pg_backend_pid()"; // SQL query to get the PID
+
+            // Execute the query and get the PID
+            NativeQuery<Integer> query = session.createNativeQuery(sql);
+            pid = query.getSingleResult();  // Get the single result
+
+            log.info("Current transaction PID: " + pid); // Optional logging
+        } catch (Exception e) {
+            log.error("Cannot get PID because: " + e.getMessage());
+        }
+        return pid;
+    }
 }
 

dspace-server-webapp/src/main/java/org/dspace/app/rest/filter/DSpaceRequestContextFilter.java

@@ -50,8 +50,13 @@ public void doFilter(ServletRequest request, ServletResponse response, FilterCha
         } finally {
             // Abort the context if it's still valid, thus closing any open
             // database connections
+            log.info("DSpaceRequestContextFilter: Aborting Context - finally block");
             if ((context != null) && context.isValid()) {
+                log.info("DSpaceRequestContextFilter: Aborting Context");
                 ContextUtil.abortContext(request);
+                log.info("DSpaceRequestContextFilter: Context Aborted");
+            } else {
+                log.info("DSpaceRequestContextFilter: Context was already null or invalid");
             }
         }
     }