You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2021/08/12 03:22:21 UTC
[iotdb] 01/01: [To rel/0.12] Fix CI runs slow caused by connection
not closing
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch Fix_CI_SLOW
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 61b9171faa79653be10fe1cdfb88d16731a5a584
Author: HTHou <hh...@outlook.com>
AuthorDate: Thu Aug 12 11:21:31 2021 +0800
[To rel/0.12] Fix CI runs slow caused by connection not closing
---
.../db/integration/IoTDBAutoCreateSchemaIT.java | 4 +
.../db/integration/IoTDBCreateStorageGroupIT.java | 2 +
.../db/integration/IoTDBQueryMemoryControlIT.java | 7 +-
.../db/integration/IoTDBUDFWindowQueryIT.java | 35 ++---
.../integration/IoTDBUDTFAlignByTimeQueryIT.java | 147 ++++++++++++---------
.../db/integration/IoTDBUDTFBuiltinFunctionIT.java | 35 ++---
.../db/integration/IoTDBUDTFHybridQueryIT.java | 28 ++--
.../db/integration/IoTDBUDTFNonAlignQueryIT.java | 42 +++---
8 files changed, 174 insertions(+), 126 deletions(-)
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBAutoCreateSchemaIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBAutoCreateSchemaIT.java
index 912fa33..7a0ccb0 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBAutoCreateSchemaIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBAutoCreateSchemaIT.java
@@ -171,6 +171,8 @@ public class IoTDBAutoCreateSchemaIT {
// ensure that insert data in cache is right.
insertAutoCreate1Tool();
+ statement.close();
+ connection.close();
EnvironmentUtils.stopDaemon();
setUp();
@@ -219,6 +221,8 @@ public class IoTDBAutoCreateSchemaIT {
// ensure that current storage group in cache is right.
InsertAutoCreate2Tool(storageGroup, timeSeriesPrefix);
+ statement.close();
+ connection.close();
EnvironmentUtils.stopDaemon();
setUp();
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBCreateStorageGroupIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBCreateStorageGroupIT.java
index 4333199..06e70fc 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBCreateStorageGroupIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBCreateStorageGroupIT.java
@@ -72,6 +72,8 @@ public class IoTDBCreateStorageGroupIT {
// ensure that current StorageGroup in cache is right.
createStorageGroupTool(storageGroups);
+ statement.close();
+ connection.close();
EnvironmentUtils.stopDaemon();
setUp();
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBQueryMemoryControlIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBQueryMemoryControlIT.java
index 05e3f14..f1876cc 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBQueryMemoryControlIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBQueryMemoryControlIT.java
@@ -72,9 +72,10 @@ public class IoTDBQueryMemoryControlIT {
}
private static void createTimeSeries() {
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
for (String sql : sqls) {
statement.execute(sql);
}
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDFWindowQueryIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDFWindowQueryIT.java
index 4fea6ba..5be7e16 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDFWindowQueryIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDFWindowQueryIT.java
@@ -136,9 +136,10 @@ public class IoTDBUDFWindowQueryIT {
"select counter(s1, \"%s\"=\"%s\") from root.vehicle.d1",
ACCESS_STRATEGY_KEY, ACCESS_STRATEGY_ROW_BY_ROW);
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sql);
int count = 0;
assertEquals(2, resultSet.getMetaData().getColumnCount());
@@ -197,9 +198,10 @@ public class IoTDBUDFWindowQueryIT {
"select accumulator(s1, \"%s\"=\"%s\", \"%s\"=\"%s\") from root.vehicle.d1",
ACCESS_STRATEGY_KEY, ACCESS_STRATEGY_SLIDING_SIZE, WINDOW_SIZE_KEY, windowSize);
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sql);
assertEquals(2, resultSet.getMetaData().getColumnCount());
@@ -328,9 +330,10 @@ public class IoTDBUDFWindowQueryIT {
DISPLAY_WINDOW_END_KEY,
displayWindowEnd);
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sql);
assertEquals(2, resultSet.getMetaData().getColumnCount());
@@ -395,9 +398,10 @@ public class IoTDBUDFWindowQueryIT {
int displayWindowBegin = 0;
int displayWindowEnd = ITERATION_TIMES;
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sql);
assertEquals(2, resultSet.getMetaData().getColumnCount());
@@ -518,9 +522,10 @@ public class IoTDBUDFWindowQueryIT {
"consumptionPoint",
consumptionPoint);
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sql);
assertEquals(3, resultSet.getMetaData().getColumnCount());
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFAlignByTimeQueryIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFAlignByTimeQueryIT.java
index b1184f4..a573de6 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFAlignByTimeQueryIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFAlignByTimeQueryIT.java
@@ -188,9 +188,10 @@ public class IoTDBUDTFAlignByTimeQueryIT {
Set<Integer> s1 = new HashSet<>(Arrays.asList(2, 6));
Set<Integer> s2 = new HashSet<>(Arrays.asList(3, 7));
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sqlStr);
int count = 0;
@@ -229,9 +230,10 @@ public class IoTDBUDTFAlignByTimeQueryIT {
public void queryWithoutValueFilter2() {
String sqlStr = "select udf(*, *) from root.vehicle.d1";
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sqlStr);
int count = 0;
int columnCount = resultSet.getMetaData().getColumnCount();
@@ -256,9 +258,10 @@ public class IoTDBUDTFAlignByTimeQueryIT {
Set<Integer> s1AndS2 = new HashSet<>(Arrays.asList(2, 3, 4, 5, 8, 9, 10, 11));
Set<Integer> s1OrS2 = new HashSet<>(Arrays.asList(0, 1, 6, 7, 12, 13));
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sqlStr);
int count = 0;
int columnCount = resultSet.getMetaData().getColumnCount();
@@ -290,9 +293,10 @@ public class IoTDBUDTFAlignByTimeQueryIT {
Set<Integer> s1AndS2 = new HashSet<>(Arrays.asList(6, 7, 8, 9));
Set<Integer> s1OrS2 = new HashSet<>(Arrays.asList(4, 5));
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sqlStr);
int count = 0;
int columnCount = resultSet.getMetaData().getColumnCount();
@@ -323,9 +327,10 @@ public class IoTDBUDTFAlignByTimeQueryIT {
public void queryWithoutValueFilter5() {
String sqlStr = "select multiplier(s2, \"a\"=\"2\", \"b\"=\"5\") from root.vehicle.d1";
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sqlStr);
assertEquals(1 + 1, resultSet.getMetaData().getColumnCount());
@@ -349,9 +354,10 @@ public class IoTDBUDTFAlignByTimeQueryIT {
public void queryWithoutValueFilter6() {
String sqlStr = "select max(s1), max(s2) from root.vehicle.d4";
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sqlStr);
assertEquals(1 + 2, resultSet.getMetaData().getColumnCount());
@@ -380,9 +386,10 @@ public class IoTDBUDTFAlignByTimeQueryIT {
public void queryWithoutValueFilter7() {
String sqlStr = "select terminate(s1), terminate(s2) from root.vehicle.d4";
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sqlStr);
assertEquals(1 + 2, resultSet.getMetaData().getColumnCount());
@@ -418,9 +425,10 @@ public class IoTDBUDTFAlignByTimeQueryIT {
public void queryWithoutValueFilter8() {
String sqlStr = "select validate(s1, s2, 'k'='') from root.vehicle.d3";
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
statement.executeQuery(sqlStr);
fail();
} catch (SQLException throwable) {
@@ -436,9 +444,10 @@ public class IoTDBUDTFAlignByTimeQueryIT {
public void queryWithoutValueFilter9() {
String sqlStr = "select validate(s1, s2, s1, 'k'=''), * from root.vehicle.d1";
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
statement.executeQuery(sqlStr);
fail();
} catch (SQLException throwable) {
@@ -453,9 +462,10 @@ public class IoTDBUDTFAlignByTimeQueryIT {
public void queryWithoutValueFilter10() {
String sqlStr = "select validate(s1, s2), * from root.vehicle.d1";
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
statement.executeQuery(sqlStr);
fail();
} catch (SQLException throwable) {
@@ -476,9 +486,10 @@ public class IoTDBUDTFAlignByTimeQueryIT {
Set<Integer> s1 = new HashSet<>(Arrays.asList(2, 6));
Set<Integer> s2 = new HashSet<>(Arrays.asList(3, 7));
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sqlStr);
int index = (int) (0.25 * ITERATION_TIMES);
int columnCount = resultSet.getMetaData().getColumnCount();
@@ -516,9 +527,10 @@ public class IoTDBUDTFAlignByTimeQueryIT {
Set<Integer> s1AndS2 = new HashSet<>(Arrays.asList(6, 7, 8, 9));
Set<Integer> s1OrS2 = new HashSet<>(Arrays.asList(4, 5));
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sqlStr);
int index = (int) (0.25 * ITERATION_TIMES);
int columnCount = resultSet.getMetaData().getColumnCount();
@@ -554,9 +566,10 @@ public class IoTDBUDTFAlignByTimeQueryIT {
Set<Integer> s1 = new HashSet<>(Arrays.asList(2, 6));
Set<Integer> s2 = new HashSet<>(Arrays.asList(3, 7));
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sqlStr);
int index = (int) (0.3 * ITERATION_TIMES);
int columnCount = resultSet.getMetaData().getColumnCount();
@@ -605,9 +618,10 @@ public class IoTDBUDTFAlignByTimeQueryIT {
Set<Integer> s1 = new HashSet<>(Arrays.asList(8, 9, 20, 21));
Set<Integer> s2 = new HashSet<>(Arrays.asList(10, 11, 22, 23));
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sqlStr);
int index = (int) (0.3 * ITERATION_TIMES);
int columnCount = resultSet.getMetaData().getColumnCount();
@@ -637,9 +651,10 @@ public class IoTDBUDTFAlignByTimeQueryIT {
" where root.vehicle.d2.s1 >= %d and root.vehicle.d3.s2 < %d",
(int) (0.3 * ITERATION_TIMES), (int) (0.7 * ITERATION_TIMES));
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sqlStr);
int index = (int) (0.3 * ITERATION_TIMES);
int columnCount = resultSet.getMetaData().getColumnCount();
@@ -666,9 +681,10 @@ public class IoTDBUDTFAlignByTimeQueryIT {
(int) (0.3 * ITERATION_TIMES), (int) (0.7 * ITERATION_TIMES))
+ String.format(" limit %d offset %d", LIMIT, OFFSET);
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sqlStr);
int index = (int) (0.3 * ITERATION_TIMES) + OFFSET;
int columnCount = resultSet.getMetaData().getColumnCount();
@@ -695,9 +711,10 @@ public class IoTDBUDTFAlignByTimeQueryIT {
(int) (0.3 * ITERATION_TIMES), (int) (0.7 * ITERATION_TIMES))
+ String.format(" slimit %d soffset %d", SLIMIT, SOFFSET);
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sqlStr);
int index = (int) (0.3 * ITERATION_TIMES);
int columnCount = resultSet.getMetaData().getColumnCount();
@@ -724,9 +741,10 @@ public class IoTDBUDTFAlignByTimeQueryIT {
" where root.vehicle.d4.s1 >= %d and root.vehicle.d4.s2 < %d ",
(int) (0.3 * ITERATION_TIMES), (int) (0.7 * ITERATION_TIMES));
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sqlStr);
assertEquals(1 + 2, resultSet.getMetaData().getColumnCount());
@@ -756,9 +774,10 @@ public class IoTDBUDTFAlignByTimeQueryIT {
" where root.vehicle.d4.s1 >= %d and root.vehicle.d4.s1 < %d ",
(int) (0.3 * ITERATION_TIMES), (int) (0.7 * ITERATION_TIMES));
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sqlStr);
assertEquals(1 + 2, resultSet.getMetaData().getColumnCount());
@@ -792,9 +811,10 @@ public class IoTDBUDTFAlignByTimeQueryIT {
" where root.vehicle.d4.s1 >= %d and root.vehicle.d4.s1 < %d ",
(int) (0.3 * ITERATION_TIMES), (int) (0.7 * ITERATION_TIMES));
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sqlStr);
assertEquals(1 + 2, resultSet.getMetaData().getColumnCount());
@@ -833,9 +853,10 @@ public class IoTDBUDTFAlignByTimeQueryIT {
String sqlStr =
"select max(s100), udf(*, s100), udf(*, s100), udf(s100, s100) from root.vehicle.d4";
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sqlStr);
assertEquals(1, resultSet.getMetaData().getColumnCount());
assertEquals("Time", resultSet.getMetaData().getColumnName(1));
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFBuiltinFunctionIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFBuiltinFunctionIT.java
index 201f087..55541dc 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFBuiltinFunctionIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFBuiltinFunctionIT.java
@@ -148,9 +148,10 @@ public class IoTDBUDTFBuiltinFunctionIT {
}
private void testMathFunction(String functionName, MathFunctionProxy functionProxy) {
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet =
statement.executeQuery(
String.format(
@@ -179,9 +180,10 @@ public class IoTDBUDTFBuiltinFunctionIT {
final String BOTTOM_K = "BOTTOM_K";
final String K = "'k'='2'";
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet =
statement.executeQuery(
String.format(
@@ -201,9 +203,10 @@ public class IoTDBUDTFBuiltinFunctionIT {
fail(throwable.getMessage());
}
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet =
statement.executeQuery(
String.format(
@@ -226,9 +229,10 @@ public class IoTDBUDTFBuiltinFunctionIT {
@Test
public void testStringProcessingFunctions() {
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet =
statement.executeQuery(
"select STRING_CONTAINS(s6, 's'='0'), STRING_MATCHES(s6, 'regex'='\\d') from root.sg.d1");
@@ -260,9 +264,10 @@ public class IoTDBUDTFBuiltinFunctionIT {
}
public void testVariationTrendCalculationFunction(String functionName, double expected) {
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet =
statement.executeQuery(
String.format(
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFHybridQueryIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFHybridQueryIT.java
index 4ab33dd..ce44e09 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFHybridQueryIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFHybridQueryIT.java
@@ -111,9 +111,10 @@ public class IoTDBUDTFHybridQueryIT {
"select count(*), counter(s1, \"%s\"=\"%s\") from root.vehicle.d1",
ACCESS_STRATEGY_KEY, ACCESS_STRATEGY_ROW_BY_ROW);
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
statement.executeQuery(sql);
fail();
} catch (SQLException throwable) {
@@ -131,9 +132,10 @@ public class IoTDBUDTFHybridQueryIT {
"select temperature, counter(temperature, \"%s\"=\"%s\") from root.sgcc.wf03.wt01 where time = 2017-11-01T16:37:50.000 fill(float [linear, 1m, 1m])",
ACCESS_STRATEGY_KEY, ACCESS_STRATEGY_ROW_BY_ROW);
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
statement.executeQuery(sql);
fail();
} catch (SQLException throwable) {
@@ -149,9 +151,10 @@ public class IoTDBUDTFHybridQueryIT {
"select last counter(temperature, \"%s\"=\"%s\") from root.sgcc.wf03.wt01",
ACCESS_STRATEGY_KEY, ACCESS_STRATEGY_ROW_BY_ROW);
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
statement.executeQuery(sql);
fail();
} catch (SQLException throwable) {
@@ -166,9 +169,10 @@ public class IoTDBUDTFHybridQueryIT {
"select adder(temperature), counter(temperature, \"%s\"=\"%s\") from root.sgcc.wf03.wt01 align by device",
ACCESS_STRATEGY_KEY, ACCESS_STRATEGY_ROW_BY_ROW);
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
statement.executeQuery(sql);
fail();
} catch (SQLException throwable) {
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFNonAlignQueryIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFNonAlignQueryIT.java
index bc75c88..69ab2ee 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFNonAlignQueryIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFNonAlignQueryIT.java
@@ -148,9 +148,10 @@ public class IoTDBUDTFNonAlignQueryIT {
Set<Integer> s1AndS2 = new HashSet<>(Arrays.asList(6, 7, 8, 9));
Set<Integer> s1OrS2 = new HashSet<>(Arrays.asList(4, 5));
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sqlStr);
int count = 0;
int columnCount = resultSet.getMetaData().getColumnCount();
@@ -183,9 +184,10 @@ public class IoTDBUDTFNonAlignQueryIT {
public void queryWithoutValueFilter2() {
String sqlStr = "select udf(d1.s1, d1.s2), udf(d2.s1, d2.s2) from root.vehicle disable align";
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sqlStr);
int count = 0;
int columnCount = resultSet.getMetaData().getColumnCount();
@@ -228,9 +230,10 @@ public class IoTDBUDTFNonAlignQueryIT {
Set<Integer> s1 = new HashSet<>(Arrays.asList(2, 6));
Set<Integer> s2 = new HashSet<>(Arrays.asList(3, 7));
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sqlStr);
int index = (int) (0.25 * ITERATION_TIMES);
int columnCount = resultSet.getMetaData().getColumnCount();
@@ -267,9 +270,10 @@ public class IoTDBUDTFNonAlignQueryIT {
" where root.vehicle.d1.s1 >= %d and root.vehicle.d1.s2 < %d disable align",
(int) (0.3 * ITERATION_TIMES), (int) (0.7 * ITERATION_TIMES));
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sqlStr);
int index = (int) (0.3 * ITERATION_TIMES);
int columnCount = resultSet.getMetaData().getColumnCount();
@@ -303,9 +307,10 @@ public class IoTDBUDTFNonAlignQueryIT {
Set<Integer> s1 = new HashSet<>(Arrays.asList(2, 6));
Set<Integer> s2 = new HashSet<>(Arrays.asList(3, 7));
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sqlStr);
int index = (int) (0.25 * ITERATION_TIMES);
int columnCount = resultSet.getMetaData().getColumnCount();
@@ -342,9 +347,10 @@ public class IoTDBUDTFNonAlignQueryIT {
" where root.vehicle.d1.s1 >= %d and root.vehicle.d1.s2 < %d limit %d offset %d disable align",
(int) (0.3 * ITERATION_TIMES), (int) (0.7 * ITERATION_TIMES), LIMIT, OFFSET);
- try (Statement statement =
- DriverManager.getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root")
- .createStatement()) {
+ try (Connection connection =
+ DriverManager.getConnection(
+ Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
+ Statement statement = connection.createStatement()) {
ResultSet resultSet = statement.executeQuery(sqlStr);
int index = (int) (0.3 * ITERATION_TIMES) + OFFSET;
int columnCount = resultSet.getMetaData().getColumnCount();