This is an automated email from the ASF dual-hosted git repository. hui pushed a commit to branch lmh/fixMergeReader in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit a0b0a715a22f57d6b7f8f7f832358a1d1f0bbb0f Author: Minghui Liu <[email protected]> AuthorDate: Thu Feb 22 17:03:10 2024 +0800 add IT --- .../db/it/aligned/IoTDBAlignedSeriesQueryIT.java | 48 ++++++++++++++++++++++ 1 file changed, 48 insertions(+) diff --git a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQueryIT.java b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQueryIT.java index 18530ff77f4..235a3d3bf0d 100644 --- a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQueryIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQueryIT.java @@ -1014,6 +1014,54 @@ public class IoTDBAlignedSeriesQueryIT { } } + @Test + public void selectAllAlignedWithLimitOffsetTest() { + + String[] retArray = + new String[] { + "14,14.0,14,14,null,null", + "15,15.0,15,15,null,null", + "16,16.0,16,16,null,null", + "17,17.0,17,17,null,null", + "18,18.0,18,18,null,null", + }; + + String[] columnNames = { + "root.sg1.d1.s1", "root.sg1.d1.s2", "root.sg1.d1.s3", "root.sg1.d1.s4", "root.sg1.d1.s5" + }; + + try (Connection connection = EnvFactory.getEnv().getConnection(); + Statement statement = connection.createStatement()) { + + try (ResultSet resultSet = + statement.executeQuery( + "select * from root.sg1.d1 where time >= 9 and time <= 33 offset 5 limit 5")) { + ResultSetMetaData resultSetMetaData = resultSet.getMetaData(); + Map<String, Integer> map = new HashMap<>(); + for (int i = 1; i <= resultSetMetaData.getColumnCount(); i++) { + map.put(resultSetMetaData.getColumnName(i), i); + } + assertEquals(columnNames.length + 1, resultSetMetaData.getColumnCount()); + int cnt = 0; + while (resultSet.next()) { + StringBuilder builder = new StringBuilder(); + builder.append(resultSet.getString(1)); + for (String columnName : columnNames) { + int index = map.get(columnName); + builder.append(",").append(resultSet.getString(index)); + } + assertEquals(retArray[cnt], builder.toString()); + cnt++; + } + assertEquals(retArray.length, cnt); + } + + } catch (SQLException e) { + e.printStackTrace(); + fail(e.getMessage()); + } + } + @Test public void selectSomeAlignedWithValueFilterTest1() {
