#927 Fix infinite loop in FBPooledConnection.fireConnectionError

Author: mrotteveel

src/main/org/firebirdsql/ds/FBPooledConnection.java

@@ -151,7 +151,7 @@ void fireConnectionError(SQLException ex) {
                 fireFatalConnectionError(ex);
                 return;
             }
-            currentException = ex.getNextException();
+            currentException = currentException.getNextException();
         }
     }
 

src/test/org/firebirdsql/ds/FBPooledConnectionMockTest.java

@@ -1,14 +1,16 @@
-// SPDX-FileCopyrightText: Copyright 2011-2024 Mark Rotteveel
+// SPDX-FileCopyrightText: Copyright 2011-2026 Mark Rotteveel
 // SPDX-License-Identifier: LGPL-2.1-or-later
 package org.firebirdsql.ds;
 
 import java.sql.Connection;
 import java.sql.SQLException;
+import java.util.concurrent.TimeUnit;
 
 import javax.sql.ConnectionEvent;
 import javax.sql.ConnectionEventListener;
 
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
 import org.junit.jupiter.api.extension.ExtendWith;
 import org.mockito.InjectMocks;
 import org.mockito.Mock;
@@ -173,4 +175,24 @@ void testGetConnectionRestoresAutoCommit() throws SQLException {
 
         verify(physical).setAutoCommit(true);
     }
+
+    /**
+     * See also <a href="https://github.com/FirebirdSQL/jaybird/issues/927">#927</a>.
+     */
+    @Test
+    @Timeout(value = 200, unit = TimeUnit.MILLISECONDS, threadMode = Timeout.ThreadMode.SEPARATE_THREAD)
+    void noInfiniteLoopWithNonFatalChainedExceptions(@Mock ConnectionEventListener cel) throws Exception {
+        pooled.addConnectionEventListener(cel);
+        Connection connection = pooled.getConnection();
+
+        var nonFatalChainedException = new SQLException("Not fatal");
+        nonFatalChainedException.setNextException(new SQLException("Not fatal either"));
+        doThrow(nonFatalChainedException).when(physical).setAutoCommit(false);
+
+        var exception = assertThrows(SQLException.class, () -> connection.setAutoCommit(false));
+        assertSame(nonFatalChainedException, exception);
+
+        verify(cel, never()).connectionErrorOccurred(any(ConnectionEvent.class));
+    }
+
 }