From 5b050eaba0bb71a35d32805d6c1854dc4a834f8c Mon Sep 17 00:00:00 2001 From: Vikash Kumar Date: Tue, 25 Jul 2023 22:32:08 +0530 Subject: [PATCH] Test testPredicatePushdown against comparison operator in mongodb --- .../io/trino/plugin/mongodb/TestMongoConnectorTest.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/plugin/trino-mongodb/src/test/java/io/trino/plugin/mongodb/TestMongoConnectorTest.java b/plugin/trino-mongodb/src/test/java/io/trino/plugin/mongodb/TestMongoConnectorTest.java index 584bbea9f8ce..aeac7f26b9e0 100644 --- a/plugin/trino-mongodb/src/test/java/io/trino/plugin/mongodb/TestMongoConnectorTest.java +++ b/plugin/trino-mongodb/src/test/java/io/trino/plugin/mongodb/TestMongoConnectorTest.java @@ -327,8 +327,12 @@ public void testExplainAnalyzeWithDeleteWithSubquery() public void testPredicatePushdown(String value) { try (TestTable table = new TestTable(getQueryRunner()::execute, "test_predicate_pushdown", "AS SELECT %s col".formatted(value))) { - assertThat(query("SELECT * FROM " + table.getName() + " WHERE col = " + value + "")) - .isFullyPushedDown(); + testPredicatePushdown(table.getName(), "col = " + value); + testPredicatePushdown(table.getName(), "col != " + value); + testPredicatePushdown(table.getName(), "col < " + value); + testPredicatePushdown(table.getName(), "col > " + value); + testPredicatePushdown(table.getName(), "col <= " + value); + testPredicatePushdown(table.getName(), "col >= " + value); } }