diff --git a/plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/TracingDataSource.java b/plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/TracingDataSource.java index c9a1a91dca7f..453d6956c0a6 100644 --- a/plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/TracingDataSource.java +++ b/plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/TracingDataSource.java @@ -25,6 +25,7 @@ import java.util.Properties; import java.util.logging.Logger; +import static com.google.common.base.Preconditions.checkState; import static java.util.Objects.requireNonNull; public class TracingDataSource @@ -70,7 +71,9 @@ public JdbcDataSource(Driver driver, String connectionUrl, Properties properties public Connection getConnection() throws SQLException { - return driver.connect(connectionUrl, properties); + Connection connection = driver.connect(connectionUrl, properties); + checkState(connection != null, "Driver returned null connection, make sure the connection URL '%s' is valid for the driver %s", connectionUrl, driver); + return connection; } @Override