Extended support of standard JDBC exceptions

Author: alex268

jdbc/src/main/java/tech/ydb/jdbc/exception/ExceptionFactory.java

@@ -24,9 +24,24 @@ public static SQLException createException(String message, UnexpectedResultExcep
         String sqlState = getSQLState(code);
         int vendorCode = getVendorCode(code);
 
+        // base retryable statuses are translated to SQLRecoverableException
         if (code.isRetryable(false)) {
             return new YdbRetryableException(message, sqlState, vendorCode, cause);
         }
+
+        // transport problems are translated to SQLTransientConnectionException
+        if (code == StatusCode.TRANSPORT_UNAVAILABLE || code == StatusCode.UNAVAILABLE) {
+            return new YdbUnavailbaleException(message, sqlState, vendorCode, cause);
+        }
+
+        // timeouts are translated to SQLTimeoutException
+        if (code == StatusCode.TIMEOUT ||
+                code == StatusCode.CLIENT_DEADLINE_EXPIRED ||
+                code == StatusCode.CLIENT_DEADLINE_EXCEEDED) {
+            return new YdbTimeoutException(message, sqlState, vendorCode, cause);
+        }
+
+        // all others transient problems are translated to base SQLTransientException
         if (code.isRetryable(true)) {
             return new YdbConditionallyRetryableException(message, sqlState, vendorCode, cause);
         }

jdbc/src/main/java/tech/ydb/jdbc/exception/YdbTimeoutException.java

@@ -0,0 +1,25 @@
+package tech.ydb.jdbc.exception;
+
+import java.sql.SQLTimeoutException;
+
+import tech.ydb.core.Status;
+import tech.ydb.core.UnexpectedResultException;
+
+/**
+ *
+ * @author Aleksandr Gorshenin
+ */
+public class YdbTimeoutException extends SQLTimeoutException {
+    private static final long serialVersionUID = -6309565506198809222L;
+
+    private final Status status;
+
+    YdbTimeoutException(String message, String sqlState, int code, UnexpectedResultException cause) {
+        super(message, sqlState, code, cause);
+        this.status = cause.getStatus();
+    }
+
+    public Status getStatus() {
+        return status;
+    }
+}

jdbc/src/main/java/tech/ydb/jdbc/exception/YdbUnavailbaleException.java

@@ -0,0 +1,26 @@
+package tech.ydb.jdbc.exception;
+
+import java.sql.SQLTransientConnectionException;
+
+import tech.ydb.core.Status;
+import tech.ydb.core.UnexpectedResultException;
+
+/**
+ *
+ * @author Aleksandr Gorshenin
+ */
+public class YdbUnavailbaleException extends SQLTransientConnectionException {
+    private static final long serialVersionUID = 7162301155514557562L;
+
+    private final Status status;
+
+    YdbUnavailbaleException(String message, String sqlState, int code, UnexpectedResultException cause) {
+        super(message, sqlState, code, cause);
+        this.status = cause.getStatus();
+    }
+
+    public Status getStatus() {
+        return status;
+    }
+
+}