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 <[email protected]>
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(
