diff --git a/jdbc-v2/src/main/java/com/clickhouse/jdbc/internal/ExceptionUtils.java b/jdbc-v2/src/main/java/com/clickhouse/jdbc/internal/ExceptionUtils.java index b3a64fe4e..b86c01c4a 100644 --- a/jdbc-v2/src/main/java/com/clickhouse/jdbc/internal/ExceptionUtils.java +++ b/jdbc-v2/src/main/java/com/clickhouse/jdbc/internal/ExceptionUtils.java @@ -64,7 +64,7 @@ public static SQLException toSqlState(String message, String debugMessage, Excep } else if (cause instanceof ConnectionInitiationException) { return new SQLException(exceptionMessage, SQL_STATE_CONNECTION_EXCEPTION, cause); } else if (cause instanceof ServerException) { - return new SQLException(exceptionMessage, SQL_STATE_DATA_EXCEPTION, cause); + return new SQLException(exceptionMessage, SQL_STATE_DATA_EXCEPTION, ((ServerException) cause).getCode(), cause); } else if (cause instanceof ClientException) { return new SQLException(exceptionMessage, SQL_STATE_CLIENT_ERROR, cause); } else if (cause instanceof MalformedURLException) {