You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2024/11/28 14:36:47 UTC
(iotdb) branch fix_deletion_merge updated: spotless
This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a commit to branch fix_deletion_merge
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/fix_deletion_merge by this push:
new 514febf95aa spotless
514febf95aa is described below
commit 514febf95aaab9f30e20f5fd0cfe05037682c2fd
Author: Tian Jiang <jt...@163.com>
AuthorDate: Thu Nov 28 22:39:07 2024 +0800
spotless
---
.../relational/it/db/it/IoTDBDeletionTableIT.java | 22 ++++++++++++++--------
1 file changed, 14 insertions(+), 8 deletions(-)
diff --git a/integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBDeletionTableIT.java b/integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBDeletionTableIT.java
index 5e5a0932fe7..e31dcd1aa6f 100644
--- a/integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBDeletionTableIT.java
+++ b/integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBDeletionTableIT.java
@@ -679,32 +679,38 @@ public class IoTDBDeletionTableIT {
statement.execute("use db1");
statement.execute(
"create table t1(country id,region id, city id, device id, ab1 ATTRIBUTE, s1 int32, s2 float, s3 boolean, s4 string)");
- statement.execute("INSERT INTO t1(time,country,region,city,device,ab1,s1,s2,s3,s4) values (100,'china','hebei','shijiazhuang','d1','ab1',1,1,1,1),(200,null,'hebei','shijiazhuang','d2','ab2',1,1,1,1),(300,'china','beijing','beijing','d1','ab3',1,1,1,1),(400,'china','tianjin','tianjin','d1','ab4',1,1,1,1),(500,'china','sichuan','chengdu','d1',null,1,1,1,1),(600,'china','zhejiang','hangzhou','d1','ab6',1,1,1,1),(700,'japan','dao','tokyo','d1','ab7',1,1,1,1),(800,'canada','tronto','shi [...]
+ statement.execute(
+ "INSERT INTO t1(time,country,region,city,device,ab1,s1,s2,s3,s4) values (100,'china','hebei','shijiazhuang','d1','ab1',1,1,1,1),(200,null,'hebei','shijiazhuang','d2','ab2',1,1,1,1),(300,'china','beijing','beijing','d1','ab3',1,1,1,1),(400,'china','tianjin','tianjin','d1','ab4',1,1,1,1),(500,'china','sichuan','chengdu','d1',null,1,1,1,1),(600,'china','zhejiang','hangzhou','d1','ab6',1,1,1,1),(700,'japan','dao','tokyo','d1','ab7',1,1,1,1),(800,'canada','tronto','shijiazhuang','d1 [...]
statement.execute("flush");
int cnt = 0;
- try (ResultSet set = statement.executeQuery("select time,country,region,city,device,ab1,s1,s2,s3,s4 from t1 order by time")) {
+ try (ResultSet set =
+ statement.executeQuery(
+ "select time,country,region,city,device,ab1,s1,s2,s3,s4 from t1 order by time")) {
while (set.next()) {
- cnt ++;
+ cnt++;
}
assertEquals(13, cnt);
}
cnt = 0;
statement.execute("delete from t1 where country='japan'");
- try (ResultSet set = statement.executeQuery("select time,country,region,city,device,ab1,s1,s2,s3,s4 from t1 order by time")) {
+ try (ResultSet set =
+ statement.executeQuery(
+ "select time,country,region,city,device,ab1,s1,s2,s3,s4 from t1 order by time")) {
while (set.next()) {
- cnt ++;
+ cnt++;
}
assertEquals(12, cnt);
}
cnt = 0;
statement.execute("delete from t1 where country='china' and region='beijing'");
- try (ResultSet set = statement.executeQuery("select time,country,region,city,device,ab1,s1,s2,s3,s4 from t1 order by time")) {
+ try (ResultSet set =
+ statement.executeQuery(
+ "select time,country,region,city,device,ab1,s1,s2,s3,s4 from t1 order by time")) {
while (set.next()) {
- cnt ++;
+ cnt++;
}
assertEquals(11, cnt);
}
-
}
}