Fix filter IT result set lifecycle
diff --git a/integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBFilterIT.java b/integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBFilterIT.java index b8dd88e..166ebb2 100644 --- a/integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBFilterIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBFilterIT.java
@@ -215,21 +215,23 @@ @Test public void testFilterWithUDTF() { try (Connection connection = EnvFactory.getEnv().getConnection(); - Statement statement = connection.createStatement(); - ResultSet containsResultSet = - statement.executeQuery( - "select s1 from root.vehicle.testUDTF where STRING_CONTAINS(s1, 's'='s')"); - ResultSet sinResultSet = - statement.executeQuery("select s1 from root.vehicle.testUDTF where sin(s2) = 0")) { + Statement statement = connection.createStatement()) { int containsCnt = 0; - while (containsResultSet.next()) { - ++containsCnt; + try (ResultSet containsResultSet = + statement.executeQuery( + "select s1 from root.vehicle.testUDTF where STRING_CONTAINS(s1, 's'='s')")) { + while (containsResultSet.next()) { + ++containsCnt; + } } assertEquals(1, containsCnt); int sinCnt = 0; - while (sinResultSet.next()) { - ++sinCnt; + try (ResultSet sinResultSet = + statement.executeQuery("select s1 from root.vehicle.testUDTF where sin(s2) = 0")) { + while (sinResultSet.next()) { + ++sinCnt; + } } assertEquals(1, sinCnt); assertTestFail(
diff --git a/integration-test/src/test/java/org/apache/iotdb/relational/it/query/old/IoTDBFilterTableIT.java b/integration-test/src/test/java/org/apache/iotdb/relational/it/query/old/IoTDBFilterTableIT.java index 7ecc967..00f9633 100644 --- a/integration-test/src/test/java/org/apache/iotdb/relational/it/query/old/IoTDBFilterTableIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/relational/it/query/old/IoTDBFilterTableIT.java
@@ -212,20 +212,22 @@ @Test public void testFilterWithUDTF() { try (Connection connection = EnvFactory.getEnv().getConnection(); - Statement statement = connection.createStatement(); - ResultSet containsResultSet = - statement.executeQuery("select s1 from testUDTF where STRING_CONTAINS(s1, 's'='s')"); - ResultSet sinResultSet = - statement.executeQuery("select s1 from testUDTF where sin(s2) = 0")) { + Statement statement = connection.createStatement()) { int containsCnt = 0; - while (containsResultSet.next()) { - ++containsCnt; + try (ResultSet containsResultSet = + statement.executeQuery("select s1 from testUDTF where STRING_CONTAINS(s1, 's'='s')")) { + while (containsResultSet.next()) { + ++containsCnt; + } } assertEquals(1, containsCnt); int sinCnt = 0; - while (sinResultSet.next()) { - ++sinCnt; + try (ResultSet sinResultSet = + statement.executeQuery("select s1 from testUDTF where sin(s2) = 0")) { + while (sinResultSet.next()) { + ++sinCnt; + } } assertEquals(1, sinCnt); assertTestFail(