Externalize some exception messages and states

Author: mrotteveel

jaybird-native/src/main/java/org/firebirdsql/gds/impl/jni/EmbeddedGDSFactoryPlugin.java

@@ -22,7 +22,6 @@
 import org.firebirdsql.gds.ng.jna.FbEmbeddedDatabaseFactory;
 
 import java.sql.SQLException;
-import java.sql.SQLNonTransientConnectionException;
 import java.util.List;
 
 public final class EmbeddedGDSFactoryPlugin extends BaseGDSFactoryPlugin {
@@ -72,10 +71,7 @@ public String getDefaultProtocol() {
 
     @Override
     public String getDatabasePath(String server, Integer port, String path) throws SQLException {
-        if (path == null) {
-            throw new SQLNonTransientConnectionException("Database name/path is required");
-        }
-
+        requirePath(path);
         return path;
     }
 

jaybird-native/src/main/java/org/firebirdsql/gds/impl/jni/NativeGDSFactoryPlugin.java

@@ -22,7 +22,6 @@
 import org.firebirdsql.gds.ng.jna.FbClientDatabaseFactory;
 
 import java.sql.SQLException;
-import java.sql.SQLNonTransientConnectionException;
 import java.util.List;
 
 public final class NativeGDSFactoryPlugin extends BaseGDSFactoryPlugin {
@@ -77,10 +76,7 @@ public String getDefaultProtocol() {
 
     @Override
     public String getDatabasePath(String server, Integer port, String path) throws SQLException {
-        if (path == null) {
-            throw new SQLNonTransientConnectionException("Database name/path is required");
-        }
-
+        requirePath(path);
         if (server == null) {
             return path;
         }

jaybird-native/src/main/java/org/firebirdsql/gds/ng/jna/JnaBlob.java

@@ -23,19 +23,18 @@
 import com.sun.jna.ptr.ShortByReference;
 import org.firebirdsql.gds.BlobParameterBuffer;
 import org.firebirdsql.gds.ISCConstants;
+import org.firebirdsql.gds.JaybirdErrorCodes;
 import org.firebirdsql.gds.ng.AbstractFbBlob;
 import org.firebirdsql.gds.ng.FbBlob;
 import org.firebirdsql.gds.ng.FbExceptionBuilder;
 import org.firebirdsql.gds.ng.LockCloseable;
 import org.firebirdsql.gds.ng.listeners.DatabaseListener;
 import org.firebirdsql.jaybird.util.ByteArrayHelper;
-import org.firebirdsql.jdbc.SQLStateConstants;
 import org.firebirdsql.jna.fbclient.FbClientLibrary;
 import org.firebirdsql.jna.fbclient.ISC_STATUS;
 
 import java.nio.ByteBuffer;
 import java.sql.SQLException;
-import java.sql.SQLNonTransientException;
 
 import static org.firebirdsql.gds.JaybirdErrorCodes.jb_blobGetSegmentNegative;
 import static org.firebirdsql.gds.JaybirdErrorCodes.jb_blobPutSegmentEmpty;
@@ -203,9 +202,9 @@ protected int get(final byte[] b, final int off, final int len, final int minLen
             validateBufferLength(b, off, len);
             if (len == 0) return 0;
             if (minLen <= 0 || minLen > len ) {
-                throw new SQLNonTransientException(
-                        "Value out of range 0 < minLen <= %d, minLen was: %d".formatted(len, minLen),
-                        SQLStateConstants.SQL_STATE_INVALID_STRING_LENGTH);
+                throw FbExceptionBuilder.forNonTransientException(JaybirdErrorCodes.jb_invalidStringLength)
+                        .messageParameter("minLen", len, minLen)
+                        .toSQLException();
             }
             checkDatabaseAttached();
             checkTransactionActive();

jaybird-native/src/main/java/org/firebirdsql/gds/ng/jna/JnaDatabase.java

@@ -119,9 +119,7 @@ public void attach() throws SQLException {
     }
 
     protected void attachOrCreate(final DatabaseParameterBuffer dpb, final boolean create) throws SQLException {
-        if (isAttached()) {
-            throw new SQLException("Already attached to a database");
-        }
+        requireNotAttached();
         final byte[] dbName = getEncoding().encodeToCharset(connection.getAttachUrl());
         final byte[] dpbArray = dpb.toBytesWithType();
 

jaybird-native/src/main/java/org/firebirdsql/gds/ng/jna/JnaService.java

@@ -131,10 +131,8 @@ public void startServiceAction(ServiceRequestBuffer serviceRequestBuffer) throws
     @Override
     public void attach() throws SQLException {
         try {
-            if (isAttached()) {
-                throw new SQLException("Already attached to a service");
-            }
-            try (LockCloseable ignored = withLock()) {
+            requireNotAttached();
+            try (var ignored = withLock()) {
                 attachImpl();
                 setAttached();
                 afterAttachActions();

jaybird-native/src/main/java/org/firebirdsql/gds/ng/jna/JnaStatement.java

@@ -37,7 +37,6 @@
 import java.lang.ref.Cleaner;
 import java.nio.ByteBuffer;
 import java.sql.SQLException;
-import java.sql.SQLNonTransientException;
 import java.util.Arrays;
 
 import static java.util.Objects.requireNonNull;
@@ -143,13 +142,8 @@ public void prepare(String statementText) throws SQLException {
                             .toSQLException();
                 }
             }
-            try (LockCloseable ignored = withLock()) {
-                checkTransactionActive(getTransaction());
-                final StatementState initialState = getState();
-                if (!isPrepareAllowed(initialState)) {
-                    throw new SQLNonTransientException(String.format(
-                            "Current statement state (%s) does not allow call to prepare", initialState));
-                }
+            try (var ignored = withLock()) {
+                final StatementState initialState = checkPrepareAllowed();
                 resetAll();
 
                 final JnaDatabase db = getDatabase();

src/jna-test/org/firebirdsql/gds/ng/jna/JnaDatabaseTest.java

@@ -89,7 +89,7 @@ void doubleAttach() throws Exception {
 
             SQLException exception = assertThrows(SQLException.class, db::attach,
                     "Second attach should throw exception");
-            assertThat(exception, message(equalTo("Already attached to a database")));
+            assertThat(exception, message(startsWith("Already attached to a database")));
         }
     }
 
@@ -266,7 +266,7 @@ void testExecuteImmediate_createDatabase() throws Exception {
     @Test
     public void testOdsVersionInformation() throws Exception {
         usesDatabase.createDefaultDatabase();
-        try (JnaDatabase db = factory.connect(connectionInfo);) {
+        try (JnaDatabase db = factory.connect(connectionInfo)) {
             db.attach();
 
             OdsVersion expectedOds = getDefaultSupportInfo().getDefaultOdsVersion();

src/jna-test/org/firebirdsql/gds/ng/jna/JnaServiceTest.java

@@ -82,7 +82,7 @@ void doubleAttach() throws Exception {
             //Second attach should throw exception
             SQLException exception = assertThrows(SQLException.class, service::attach,
                     "Second attach should throw exception");
-            assertThat(exception, message(equalTo("Already attached to a service")));
+            assertThat(exception, message(startsWith("Already attached to a service")));
         }
     }
 

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

@@ -20,7 +20,6 @@
 
 import java.sql.Connection;
 import java.sql.SQLException;
-import java.sql.SQLNonTransientConnectionException;
 import java.util.List;
 import java.util.concurrent.CopyOnWriteArrayList;
 import java.util.concurrent.locks.Lock;
@@ -31,11 +30,12 @@
 import javax.sql.PooledConnection;
 import javax.sql.StatementEventListener;
 
+import org.firebirdsql.gds.JaybirdErrorCodes;
+import org.firebirdsql.gds.ng.FbExceptionBuilder;
 import org.firebirdsql.gds.ng.LockCloseable;
 import org.firebirdsql.jaybird.util.SQLExceptionChainBuilder;
 import org.firebirdsql.jaybird.xca.FatalErrorHelper;
 import org.firebirdsql.jdbc.FirebirdConnection;
-import org.firebirdsql.jdbc.SQLStateConstants;
 
 /**
  * PooledConnection implementation for {@link FBConnectionPoolDataSource}
@@ -63,28 +63,31 @@ LockCloseable withLock() {
 
     @Override
     public Connection getConnection() throws SQLException {
-        try (LockCloseable ignored = withLock()) {
-            if (connection == null) {
-                var ex = new SQLNonTransientConnectionException("The PooledConnection has been closed",
-                        SQLStateConstants.SQL_STATE_CONNECTION_CLOSED);
-                fireFatalConnectionError(ex);
-                throw ex;
-            }
+        try (var ignored = withLock()) {
             try {
+                Connection connection = requireConnection();
                 if (handler != null) {
                     handler.close();
                 }
                 resetConnection(connection);
+                handler = createConnectionHandler(connection);
+
+                return handler.getProxy();
             } catch (SQLException ex) {
                 fireFatalConnectionError(ex);
                 throw ex;
             }
-            handler = createConnectionHandler(connection);
-
-            return handler.getProxy();
         }
     }
 
+    private Connection requireConnection() throws SQLException {
+        Connection connection = this.connection;
+        if (connection != null) return connection;
+        throw FbExceptionBuilder
+                .forNonTransientConnectionException(JaybirdErrorCodes.jb_pooledConnectionClosed)
+                .toSQLException();
+    }
+
     void resetConnection(Connection connection) throws SQLException {
         connection.setAutoCommit(true);
         if (connection.isWrapperFor(FirebirdConnection.class)) {

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

@@ -18,9 +18,11 @@
  */
 package org.firebirdsql.ds;
 
+import org.firebirdsql.gds.JaybirdErrorCodes;
 import org.firebirdsql.gds.TransactionParameterBuffer;
 import org.firebirdsql.gds.impl.GDSFactory;
 import org.firebirdsql.gds.impl.GDSType;
+import org.firebirdsql.gds.ng.FbExceptionBuilder;
 import org.firebirdsql.jaybird.props.def.ConnectionProperty;
 import org.firebirdsql.jaybird.xca.FBManagedConnectionFactory;
 import org.firebirdsql.jdbc.FBDataSource;
@@ -243,7 +245,9 @@ public boolean isWrapperFor(Class<?> iface) throws SQLException {
     @Override
     public <T> T unwrap(Class<T> iface) throws SQLException {
         if (!isWrapperFor(iface)) {
-            throw new SQLException("Unable to unwrap to class " + iface.getName());
+            throw FbExceptionBuilder.forException(JaybirdErrorCodes.jb_unableToUnwrap)
+                    .messageParameter(iface != null ? iface.getName() : "(null)")
+                    .toSQLException();
         }
 
         return iface.cast(this);