You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ju...@apache.org on 2026/06/22 08:02:15 UTC
(iotdb) branch codex/jdbc-driver-info updated: Fix filter IT result set lifecycle
This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a commit to branch codex/jdbc-driver-info
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/codex/jdbc-driver-info by this push:
new accc54f4761 Fix filter IT result set lifecycle
accc54f4761 is described below
commit accc54f4761205d0c3f78b21f682892c702b179d
Author: Caideyipi <87...@users.noreply.github.com>
AuthorDate: Mon Jun 22 16:01:57 2026 +0800
Fix filter IT result set lifecycle
---
.../java/org/apache/iotdb/db/it/IoTDBFilterIT.java | 22 ++++++++++++----------
.../it/query/old/IoTDBFilterTableIT.java | 20 +++++++++++---------
2 files changed, 23 insertions(+), 19 deletions(-)
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 b8dd88ea9d7..166ebb2703b 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 @@ public class IoTDBFilterIT {
@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 7ecc9673b23..00f9633e5b4 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 @@ public class IoTDBFilterTableIT {
@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(