This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch GroupByBug in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit a806d7932e245ea666a1122521845c9baa5f97c6 Author: JackieTien97 <[email protected]> AuthorDate: Fri May 21 18:32:21 2021 +0800 format code --- .../iotdb/db/integration/IoTDBGroupByUnseqIT.java | 96 +++++++++++----------- 1 file changed, 48 insertions(+), 48 deletions(-) diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBGroupByUnseqIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBGroupByUnseqIT.java index 746b004..c8c69b3 100644 --- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBGroupByUnseqIT.java +++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBGroupByUnseqIT.java @@ -18,72 +18,72 @@ */ package org.apache.iotdb.db.integration; -import static org.apache.iotdb.db.constant.TestConstant.count; -import static org.junit.Assert.fail; - -import java.sql.Connection; -import java.sql.DriverManager; -import java.sql.ResultSet; -import java.sql.Statement; import org.apache.iotdb.db.conf.IoTDBDescriptor; import org.apache.iotdb.db.utils.EnvironmentUtils; import org.apache.iotdb.jdbc.Config; import org.apache.iotdb.tsfile.common.conf.TSFileDescriptor; + import org.junit.After; import org.junit.Assert; import org.junit.Before; import org.junit.Test; +import java.sql.Connection; +import java.sql.DriverManager; +import java.sql.ResultSet; +import java.sql.Statement; + +import static org.apache.iotdb.db.constant.TestConstant.count; +import static org.junit.Assert.fail; + /** - * This test contains one seq file and one unseq file. - * In the seq file, it contains two pages: 1,2,3,4 in one page, 8,10,11,12 in another page. - * In the unseq file, it only contains one page: 7, 9. - * The unseq page is overlapped with the second seq page. + * This test contains one seq file and one unseq file. In the seq file, it contains two pages: + * 1,2,3,4 in one page, 8,10,11,12 in another page. In the unseq file, it only contains one page: 7, + * 9. The unseq page is overlapped with the second seq page. */ public class IoTDBGroupByUnseqIT { - private static String[] dataSet1 = new String[]{ - "SET STORAGE GROUP TO root.sg1", - "CREATE TIMESERIES root.sg1.d1.s1 WITH DATATYPE=INT32, ENCODING=PLAIN", - "INSERT INTO root.sg1.d1(time,s1) values(1, 1)", - "INSERT INTO root.sg1.d1(time,s1) values(2, 2)", - "INSERT INTO root.sg1.d1(time,s1) values(3, 3)", - "INSERT INTO root.sg1.d1(time,s1) values(4, 4)", - "INSERT INTO root.sg1.d1(time,s1) values(8, 8)", - "INSERT INTO root.sg1.d1(time,s1) values(10, 10)", - "INSERT INTO root.sg1.d1(time,s1) values(11, 11)", - "INSERT INTO root.sg1.d1(time,s1) values(12, 12)", - "flush", - "INSERT INTO root.sg1.d1(time,s1) values(7, 7)", - "INSERT INTO root.sg1.d1(time,s1) values(9, 9)", - "flush" - }; + private static String[] dataSet1 = + new String[] { + "SET STORAGE GROUP TO root.sg1", + "CREATE TIMESERIES root.sg1.d1.s1 WITH DATATYPE=INT32, ENCODING=PLAIN", + "INSERT INTO root.sg1.d1(time,s1) values(1, 1)", + "INSERT INTO root.sg1.d1(time,s1) values(2, 2)", + "INSERT INTO root.sg1.d1(time,s1) values(3, 3)", + "INSERT INTO root.sg1.d1(time,s1) values(4, 4)", + "INSERT INTO root.sg1.d1(time,s1) values(8, 8)", + "INSERT INTO root.sg1.d1(time,s1) values(10, 10)", + "INSERT INTO root.sg1.d1(time,s1) values(11, 11)", + "INSERT INTO root.sg1.d1(time,s1) values(12, 12)", + "flush", + "INSERT INTO root.sg1.d1(time,s1) values(7, 7)", + "INSERT INTO root.sg1.d1(time,s1) values(9, 9)", + "flush" + }; private static final String TIMESTAMP_STR = "Time"; private boolean enableUnseqCompaction; private int maxNumberOfPointsInPage; - @Before public void setUp() throws Exception { EnvironmentUtils.closeStatMonitor(); enableUnseqCompaction = IoTDBDescriptor.getInstance().getConfig().isEnableUnseqCompaction(); IoTDBDescriptor.getInstance().getConfig().setEnableUnseqCompaction(false); - maxNumberOfPointsInPage = TSFileDescriptor.getInstance().getConfig() - .getMaxNumberOfPointsInPage(); + maxNumberOfPointsInPage = + TSFileDescriptor.getInstance().getConfig().getMaxNumberOfPointsInPage(); TSFileDescriptor.getInstance().getConfig().setMaxNumberOfPointsInPage(4); EnvironmentUtils.envSetUp(); Class.forName(Config.JDBC_DRIVER_NAME); prepareData(); } - private void prepareData() { - try (Connection connection = DriverManager - .getConnection(Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", - "root"); - Statement statement = connection.createStatement();) { + try (Connection connection = + DriverManager.getConnection( + Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root"); + Statement statement = connection.createStatement(); ) { for (String sql : dataSet1) { statement.execute(sql); @@ -103,26 +103,26 @@ public class IoTDBGroupByUnseqIT { @Test public void test1() { - String[] retArray1 = new String[]{ - "1,3", - "4,1", - "7,3", - "10,3", - }; - - try (Connection connection = DriverManager. - getConnection("jdbc:iotdb://127.0.0.1:6667/", "root", "root"); + String[] retArray1 = + new String[] { + "1,3", "4,1", "7,3", "10,3", + }; + + try (Connection connection = + DriverManager.getConnection("jdbc:iotdb://127.0.0.1:6667/", "root", "root"); Statement statement = connection.createStatement()) { - boolean hasResultSet = statement.execute( - "select count(s1) from root.sg1.d1 group by ([1, 13), 3ms)"); + boolean hasResultSet = + statement.execute("select count(s1) from root.sg1.d1 group by ([1, 13), 3ms)"); Assert.assertTrue(hasResultSet); int cnt; try (ResultSet resultSet = statement.getResultSet()) { cnt = 0; while (resultSet.next()) { - String ans = resultSet.getString(TIMESTAMP_STR) + "," + resultSet - .getString(count("root.sg1.d1.s1")); + String ans = + resultSet.getString(TIMESTAMP_STR) + + "," + + resultSet.getString(count("root.sg1.d1.s1")); Assert.assertEquals(retArray1[cnt], ans); cnt++; }
