diff --git a/plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/BaseJdbcClient.java b/plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/BaseJdbcClient.java index 1e17f762c864..aa7c18f16f83 100644 --- a/plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/BaseJdbcClient.java +++ b/plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/BaseJdbcClient.java @@ -412,9 +412,10 @@ protected static Optional getAdditionalPredicate(List constraint if (constraintExpressions.isEmpty() && splitPredicate.isEmpty()) { return Optional.empty(); } + return Optional.of( Stream.concat(constraintExpressions.stream(), splitPredicate.stream()) - .collect(joining(" AND "))); + .collect(joining(") AND (", "(", ")"))); } @Override