| /* |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, |
| * software distributed under the License is distributed on an |
| * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| * KIND, either express or implied. See the License for the |
| * specific language governing permissions and limitations |
| * under the License. |
| */ |
| package org.apache.iotdb.db.it.schema; |
| |
| import org.apache.iotdb.it.env.EnvFactory; |
| import org.apache.iotdb.it.framework.IoTDBTestRunner; |
| import org.apache.iotdb.itbase.category.ClusterIT; |
| import org.apache.iotdb.itbase.category.LocalStandaloneIT; |
| |
| import org.junit.After; |
| import org.junit.Before; |
| import org.junit.Ignore; |
| import org.junit.Test; |
| import org.junit.experimental.categories.Category; |
| import org.junit.runner.RunWith; |
| |
| import java.sql.Connection; |
| import java.sql.ResultSet; |
| import java.sql.Statement; |
| import java.util.Arrays; |
| import java.util.Collections; |
| import java.util.HashSet; |
| import java.util.List; |
| import java.util.Set; |
| |
| import static org.junit.Assert.assertEquals; |
| import static org.junit.Assert.assertFalse; |
| import static org.junit.Assert.assertTrue; |
| import static org.junit.Assert.fail; |
| |
| @RunWith(IoTDBTestRunner.class) |
| @Category({LocalStandaloneIT.class, ClusterIT.class}) |
| public class IoTDBTagIT { |
| |
| @Before |
| public void setUp() throws Exception { |
| EnvFactory.getEnv().initBeforeTest(); |
| } |
| |
| @After |
| public void tearDown() throws Exception { |
| EnvFactory.getEnv().cleanAfterTest(); |
| } |
| |
| @Test |
| public void createOneTimeseriesTest() { |
| List<String> ret = |
| Collections.singletonList( |
| "root.turbine.d1.s1,temperature,root.turbine,FLOAT,RLE,SNAPPY," |
| + "{\"tag1\":\"v1\",\"tag2\":\"v2\"},{\"attr2\":\"v2\",\"attr1\":\"v1\"}"); |
| String sql = |
| "create timeseries root.turbine.d1.s1(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('tag1'='v1', 'tag2'='v2') " |
| + "attributes('attr1'='v1', 'attr2'='v2')"; |
| try (Connection connection = EnvFactory.getEnv().getConnection(); |
| Statement statement = connection.createStatement()) { |
| statement.execute(sql); |
| ResultSet resultSet = statement.executeQuery("show timeseries"); |
| int count = 0; |
| try { |
| while (resultSet.next()) { |
| String ans = |
| resultSet.getString("timeseries") |
| + "," |
| + resultSet.getString("alias") |
| + "," |
| + resultSet.getString("storage group") |
| + "," |
| + resultSet.getString("dataType") |
| + "," |
| + resultSet.getString("encoding") |
| + "," |
| + resultSet.getString("compression") |
| + "," |
| + resultSet.getString("tags") |
| + "," |
| + resultSet.getString("attributes"); |
| assertTrue(ret.contains(ans)); |
| count++; |
| } |
| } finally { |
| resultSet.close(); |
| } |
| assertEquals(ret.size(), count); |
| } catch (Exception e) { |
| e.printStackTrace(); |
| fail(); |
| } |
| } |
| |
| @Test |
| public void createMultiTimeseriesTest() { |
| List<String> ret = |
| Arrays.asList( |
| "root.turbine.d2.s1,temperature,root.turbine,FLOAT,RLE,SNAPPY,{\"tag1\":\"t1\"," |
| + "\"tag2\":\"t2\"},{\"attr2\":\"a2\",\"attr1\":\"a1\"}", |
| "root.turbine.d2.s2,status,root.turbine,INT32,RLE,SNAPPY,{\"tag2\":\"t2\"," |
| + "\"tag3\":\"t3\"},{\"attr4\":\"a4\",\"attr3\":\"a3\"}"); |
| String sql1 = |
| "create timeseries root.turbine.d2.s1(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('tag1'='t1', 'tag2'='t2') " |
| + "attributes('attr1'='a1', 'attr2'='a2')"; |
| String sql2 = |
| "create timeseries root.turbine.d2.s2(status) with datatype=INT32, encoding=RLE " |
| + "tags('tag2'='t2', 'tag3'='t3') " |
| + "attributes('attr3'='a3', 'attr4'='a4')"; |
| try (Connection connection = EnvFactory.getEnv().getConnection(); |
| Statement statement = connection.createStatement()) { |
| statement.execute(sql1); |
| statement.execute(sql2); |
| ResultSet resultSet = statement.executeQuery("show timeseries"); |
| int count = 0; |
| try { |
| while (resultSet.next()) { |
| String ans = |
| resultSet.getString("timeseries") |
| + "," |
| + resultSet.getString("alias") |
| + "," |
| + resultSet.getString("storage group") |
| + "," |
| + resultSet.getString("dataType") |
| + "," |
| + resultSet.getString("encoding") |
| + "," |
| + resultSet.getString("compression") |
| + "," |
| + resultSet.getString("tags") |
| + "," |
| + resultSet.getString("attributes"); |
| |
| assertTrue(ret.contains(ans)); |
| count++; |
| } |
| } finally { |
| resultSet.close(); |
| } |
| assertEquals(ret.size(), count); |
| } catch (Exception e) { |
| e.printStackTrace(); |
| fail(); |
| } |
| } |
| |
| @Test |
| public void showTimeseriesTest() { |
| List<String> ret = |
| Arrays.asList( |
| "root.turbine.d2.s1,temperature,root.turbine,FLOAT,RLE,SNAPPY,{\"tag1\":\"t1\",\"" |
| + "tag2\":\"t2\"},{\"attr2\":\"a2\",\"attr1\":\"a1\"}", |
| "root.turbine.d2.s2,status,root.turbine,INT32,RLE,SNAPPY,{\"tag2\":\"t2\",\"tag3\"" |
| + ":\"t3\"},{\"attr4\":\"a4\",\"attr3\":\"a3\"}"); |
| String sql1 = |
| "create timeseries root.turbine.d2.s1(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('tag1'='t1', 'tag2'='t2') " |
| + "attributes('attr1'='a1', 'attr2'='a2')"; |
| String sql2 = |
| "create timeseries root.turbine.d2.s2(status) with datatype=INT32, encoding=RLE " |
| + "tags('tag2'='t2', 'tag3'='t3') " |
| + "attributes('attr3'='a3', 'attr4'='a4')"; |
| try (Connection connection = EnvFactory.getEnv().getConnection(); |
| Statement statement = connection.createStatement()) { |
| statement.execute(sql1); |
| statement.execute(sql2); |
| ResultSet resultSet = statement.executeQuery("show timeseries"); |
| int count = 0; |
| try { |
| while (resultSet.next()) { |
| String ans = |
| resultSet.getString("timeseries") |
| + "," |
| + resultSet.getString("alias") |
| + "," |
| + resultSet.getString("storage group") |
| + "," |
| + resultSet.getString("dataType") |
| + "," |
| + resultSet.getString("encoding") |
| + "," |
| + resultSet.getString("compression") |
| + "," |
| + resultSet.getString("tags") |
| + "," |
| + resultSet.getString("attributes"); |
| assertTrue(ret.contains(ans)); |
| count++; |
| } |
| } finally { |
| resultSet.close(); |
| } |
| assertEquals(ret.size(), count); |
| } catch (Exception e) { |
| e.printStackTrace(); |
| fail(); |
| } |
| } |
| |
| @Test |
| public void createDuplicateAliasTimeseriesTest1() { |
| String sql1 = |
| "create timeseries root.turbine.d3.s1(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('tag1'='t1', 'tag2'='t2') " |
| + "attributes('attr1'='a1', 'attr2'='a2')"; |
| String sql2 = |
| "create timeseries root.turbine.d3.s2(temperature) with datatype=INT32, encoding=RLE " |
| + "tags('tag2'='t2', 'tag3'='t3') " |
| + "attributes('attr3'='a3', 'attr4'='a4')"; |
| try (Connection connection = EnvFactory.getEnv().getConnection(); |
| Statement statement = connection.createStatement()) { |
| statement.execute(sql1); |
| try { |
| statement.execute(sql2); |
| fail(); |
| } catch (Exception e) { |
| assertTrue( |
| e.getMessage() |
| .contains("Alias [temperature] for Path [root.turbine.d3.s2] already exist")); |
| } |
| } catch (Exception e) { |
| e.printStackTrace(); |
| fail(); |
| } |
| } |
| |
| @Test |
| public void createDuplicateAliasTimeseriesTest2() { |
| String sql1 = |
| "create timeseries root.turbine.d4.s1(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('tag1'='t1', 'tag2'='t2') " |
| + "attributes('attr1'='a1', 'attr2'='a2')"; |
| String sql2 = |
| "create timeseries root.turbine.d4.temperature with datatype=INT32, encoding=RLE " |
| + "tags('tag2'='t2', 'tag3'='t3') " |
| + "attributes('attr3'='a3', 'attr4'='a4')"; |
| try (Connection connection = EnvFactory.getEnv().getConnection(); |
| Statement statement = connection.createStatement()) { |
| statement.execute(sql1); |
| try { |
| statement.execute(sql2); |
| fail(); |
| } catch (Exception e) { |
| assertTrue(e.getMessage().contains("Path [root.turbine.d4.temperature] already exist")); |
| } |
| } catch (Exception e) { |
| e.printStackTrace(); |
| fail(); |
| } |
| } |
| |
| @Test |
| public void createDuplicateAliasTimeseriesTest3() { |
| String sql1 = |
| "create timeseries root.turbine.d5.s1(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('tag1'='t1', 'tag2'='t2') " |
| + "attributes('attr1'='a1', 'attr2'='a2')"; |
| String sql2 = |
| "create timeseries root.turbine.d5.s2(s1) with datatype=INT32, encoding=RLE " |
| + "tags('tag2'='t2', 'tag3'='t3') " |
| + "attributes('attr3'='a3', 'attr4'='a4')"; |
| try (Connection connection = EnvFactory.getEnv().getConnection(); |
| Statement statement = connection.createStatement()) { |
| statement.execute(sql1); |
| try { |
| statement.execute(sql2); |
| fail(); |
| } catch (Exception e) { |
| assertTrue( |
| e.getMessage().contains("Alias [s1] for Path [root.turbine.d5.s2] already exist")); |
| } |
| } catch (Exception e) { |
| e.printStackTrace(); |
| fail(); |
| } |
| } |
| |
| @Test |
| public void queryWithAliasTest() { |
| List<String> ret = |
| Collections.singletonList( |
| "root.turbine.d6.s1,temperature,root.turbine,FLOAT,RLE,SNAPPY," |
| + "{\"tag1\":\"v1\",\"tag2\":\"v2\"},{\"attr2\":\"v2\",\"attr1\":\"v1\"}"); |
| String sql = |
| "create timeseries root.turbine.d6.s1(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('tag1'='v1', 'tag2'='v2') " |
| + "attributes('attr1'='v1', 'attr2'='v2')"; |
| try (Connection connection = EnvFactory.getEnv().getConnection(); |
| Statement statement = connection.createStatement()) { |
| statement.execute(sql); |
| int count = 0; |
| try (ResultSet resultSet = |
| statement.executeQuery("show timeseries root.turbine.d6.temperature")) { |
| while (resultSet.next()) { |
| String ans = |
| resultSet.getString("timeseries") |
| + "," |
| + resultSet.getString("alias") |
| + "," |
| + resultSet.getString("storage group") |
| + "," |
| + resultSet.getString("dataType") |
| + "," |
| + resultSet.getString("encoding") |
| + "," |
| + resultSet.getString("compression") |
| + "," |
| + resultSet.getString("tags") |
| + "," |
| + resultSet.getString("attributes"); |
| assertTrue(ret.contains(ans)); |
| count++; |
| } |
| } |
| assertEquals(ret.size(), count); |
| } catch (Exception e) { |
| e.printStackTrace(); |
| fail(); |
| } |
| } |
| |
| @Test |
| public void queryWithLimitTest() { |
| List<String> ret = |
| Arrays.asList( |
| "root.turbine.d1.s2,temperature2,root.turbine,FLOAT,RLE,SNAPPY," |
| + "{\"tag1\":\"v1\",\"tag2\":\"v2\"},{\"attr2\":\"v2\",\"attr1\":\"v1\"}", |
| "root.turbine.d1.s3,temperature3,root.turbine,FLOAT,RLE,SNAPPY," |
| + "{\"tag1\":\"v1\",\"tag2\":\"v2\"},{\"attr2\":\"v2\",\"attr1\":\"v1\"}"); |
| try (Connection connection = EnvFactory.getEnv().getConnection(); |
| Statement statement = connection.createStatement()) { |
| statement.execute( |
| "create timeseries root.turbine.d1.s1(temperature1) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('tag1'='v1', 'tag2'='v2') " |
| + "attributes('attr1'='v1', 'attr2'='v2')"); |
| statement.execute( |
| "create timeseries root.turbine.d1.s2(temperature2) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('tag1'='v1', 'tag2'='v2') " |
| + "attributes('attr1'='v1', 'attr2'='v2')"); |
| statement.execute( |
| "create timeseries root.turbine.d1.s3(temperature3) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('tag1'='v1', 'tag2'='v2') " |
| + "attributes('attr1'='v1', 'attr2'='v2')"); |
| int count = 0; |
| try (ResultSet resultSet = |
| statement.executeQuery( |
| "show timeseries root.turbine.d1.** where 'tag1'='v1' limit 2 offset 1")) { |
| while (resultSet.next()) { |
| String ans = |
| resultSet.getString("timeseries") |
| + "," |
| + resultSet.getString("alias") |
| + "," |
| + resultSet.getString("storage group") |
| + "," |
| + resultSet.getString("dataType") |
| + "," |
| + resultSet.getString("encoding") |
| + "," |
| + resultSet.getString("compression") |
| + "," |
| + resultSet.getString("tags") |
| + "," |
| + resultSet.getString("attributes"); |
| assertTrue(ret.contains(ans)); |
| count++; |
| } |
| } |
| assertEquals(ret.size(), count); |
| } catch (Exception e) { |
| e.printStackTrace(); |
| fail(); |
| } |
| } |
| |
| @Ignore |
| @Test |
| public void deleteTest() { |
| List<String> ret1 = |
| Arrays.asList( |
| "root.turbine.d7.s1,temperature,root.turbine,FLOAT,RLE,SNAPPY," |
| + "{\"tag1\":\"t1\",\"tag2\":\"t2\"},{\"attr2\":\"a2\",\"attr1\":\"a1\"}", |
| "root.turbine.d7.s2,status,root.turbine,INT32,RLE,SNAPPY,{\"tag2\"" |
| + ":\"t2\",\"tag3\":\"t3\"},{\"attr4\":\"a4\",\"attr3\":\"a3\"}"); |
| List<String> ret2 = |
| Collections.singletonList( |
| "root.turbine.d7.s1,temperature,root.turbine,FLOAT,RLE,SNAPPY," |
| + "{\"tag1\":\"t1\",\"tag2\":\"t2\"},{\"attr2\":\"a2\",\"attr1\":\"a1\"}"); |
| |
| String sql1 = |
| "create timeseries root.turbine.d7.s1(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('tag1'='t1', 'tag2'='t2') " |
| + "attributes('attr1'='a1', 'attr2'='a2')"; |
| String sql2 = |
| "create timeseries root.turbine.d7.s2(status) with datatype=INT32, encoding=RLE " |
| + "tags('tag2'='t2', 'tag3'='t3') " |
| + "attributes('attr3'='a3', 'attr4'='a4')"; |
| try (Connection connection = EnvFactory.getEnv().getConnection(); |
| Statement statement = connection.createStatement()) { |
| statement.execute(sql1); |
| statement.execute(sql2); |
| int count = 0; |
| try (ResultSet resultSet = statement.executeQuery("show timeseries")) { |
| while (resultSet.next()) { |
| String ans = |
| resultSet.getString("timeseries") |
| + "," |
| + resultSet.getString("alias") |
| + "," |
| + resultSet.getString("storage group") |
| + "," |
| + resultSet.getString("dataType") |
| + "," |
| + resultSet.getString("encoding") |
| + "," |
| + resultSet.getString("compression") |
| + "," |
| + resultSet.getString("tags") |
| + "," |
| + resultSet.getString("attributes"); |
| |
| assertTrue(ret1.contains(ans)); |
| count++; |
| } |
| } |
| assertEquals(ret1.size(), count); |
| |
| statement.execute("delete timeseries root.turbine.d7.s2"); |
| count = 0; |
| try (ResultSet resultSet = statement.executeQuery("show timeseries")) { |
| while (resultSet.next()) { |
| String ans = |
| resultSet.getString("timeseries") |
| + "," |
| + resultSet.getString("alias") |
| + "," |
| + resultSet.getString("storage group") |
| + "," |
| + resultSet.getString("dataType") |
| + "," |
| + resultSet.getString("encoding") |
| + "," |
| + resultSet.getString("compression") |
| + "," |
| + resultSet.getString("tags") |
| + "," |
| + resultSet.getString("attributes"); |
| |
| assertTrue(ret2.contains(ans)); |
| count++; |
| } |
| } |
| assertEquals(ret2.size(), count); |
| } catch (Exception e) { |
| e.printStackTrace(); |
| fail(); |
| } |
| } |
| |
| @Ignore |
| @Test |
| public void deleteWithAliasTest() { |
| List<String> ret1 = |
| Arrays.asList( |
| "root.turbine.d7.s1,temperature,root.turbine,FLOAT,RLE,SNAPPY," |
| + "{\"tag1\":\"t1\",\"tag2\":\"t2\"},{\"attr2\":\"a2\",\"attr1\":\"a1\"}", |
| "root.turbine.d7.s2,status,root.turbine,INT32,RLE,SNAPPY," |
| + "{\"tag2\":\"t2\",\"tag3\":\"t3\"},{\"attr4\":\"a4\",\"attr3\":\"a3\"}"); |
| List<String> ret2 = |
| Collections.singletonList( |
| "root.turbine.d7.s1,temperature,root.turbine,FLOAT,RLE,SNAPPY," |
| + "{\"tag1\":\"t1\",\"tag2\":\"t2\"},{\"attr2\":\"a2\",\"attr1\":\"a1\"}"); |
| |
| String sql1 = |
| "create timeseries root.turbine.d7.s1(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('tag1'='t1', 'tag2'='t2') " |
| + "attributes('attr1'='a1', 'attr2'='a2')"; |
| String sql2 = |
| "create timeseries root.turbine.d7.s2(status) with datatype=INT32, encoding=RLE " |
| + "tags('tag2'='t2', 'tag3'='t3') " |
| + "attributes('attr3'='a3', 'attr4'='a4')"; |
| try (Connection connection = EnvFactory.getEnv().getConnection(); |
| Statement statement = connection.createStatement()) { |
| statement.execute(sql1); |
| statement.execute(sql2); |
| int count = 0; |
| try (ResultSet resultSet = statement.executeQuery("show timeseries")) { |
| while (resultSet.next()) { |
| String ans = |
| resultSet.getString("timeseries") |
| + "," |
| + resultSet.getString("alias") |
| + "," |
| + resultSet.getString("storage group") |
| + "," |
| + resultSet.getString("dataType") |
| + "," |
| + resultSet.getString("encoding") |
| + "," |
| + resultSet.getString("compression") |
| + "," |
| + resultSet.getString("tags") |
| + "," |
| + resultSet.getString("attributes"); |
| |
| assertTrue(ret1.contains(ans)); |
| count++; |
| } |
| } |
| assertEquals(ret1.size(), count); |
| |
| statement.execute("delete timeseries root.turbine.d7.status"); |
| count = 0; |
| try (ResultSet resultSet = statement.executeQuery("show timeseries")) { |
| while (resultSet.next()) { |
| String ans = |
| resultSet.getString("timeseries") |
| + "," |
| + resultSet.getString("alias") |
| + "," |
| + resultSet.getString("storage group") |
| + "," |
| + resultSet.getString("dataType") |
| + "," |
| + resultSet.getString("encoding") |
| + "," |
| + resultSet.getString("compression") |
| + "," |
| + resultSet.getString("tags") |
| + "," |
| + resultSet.getString("attributes"); |
| |
| assertTrue(ret2.contains(ans)); |
| count++; |
| } |
| } |
| assertEquals(ret2.size(), count); |
| } catch (Exception e) { |
| e.printStackTrace(); |
| fail(); |
| } |
| } |
| |
| @Test |
| public void queryWithWhereTest1() { |
| List<String> ret1 = |
| Arrays.asList( |
| "root.turbine.d0.s0,temperature,root.turbine,FLOAT,RLE,SNAPPY,{\"description\":\"turbine " |
| + "this is a test1\",\"unit\":\"f\"},{\"H_Alarm\":\"100\",\"M_Alarm\":\"50\"}", |
| "root.turbine.d0.s1,power,root.turbine,FLOAT,RLE,SNAPPY,{\"description\":\"turbine this " |
| + "is a test2\",\"unit\":\"kw\"},{\"H_Alarm\":\"99.9\",\"M_Alarm\":\"44.4\"}", |
| "root.turbine.d1.s0,status,root.turbine,INT32,RLE,SNAPPY,{\"description\":\"turbine this " |
| + "is a test3\"},{\"H_Alarm\":\"9\",\"M_Alarm\":\"5\"}", |
| "root.turbine.d2.s0,temperature,root.turbine,FLOAT,RLE,SNAPPY,{\"description\":\"turbine " |
| + "d2 this is a test1\",\"unit\":\"f\"},{\"MinValue\":\"1\",\"MaxValue\":\"100\"}", |
| "root.turbine.d2.s1,power,root.turbine,FLOAT,RLE,SNAPPY,{\"description\":\"turbine d2 this" |
| + " is a test2\",\"unit\":\"kw\"},{\"MinValue\":\"44.4\",\"MaxValue\":\"99.9\"}", |
| "root.turbine.d2.s3,status,root.turbine,INT32,RLE,SNAPPY,{\"description\":\"turbine d2 " |
| + "this is a test3\"},{\"MinValue\":\"5\",\"MaxValue\":\"9\"}", |
| "root.ln.d0.s0,temperature,root.ln,FLOAT,RLE,SNAPPY,{\"description\":\"ln this is a " |
| + "test1\",\"unit\":\"c\"},{\"H_Alarm\":\"1000\",\"M_Alarm\":\"500\"}", |
| "root.ln.d0.s1,power,root.ln,FLOAT,RLE,SNAPPY,{\"description\":\"ln this is a " |
| + "test2\",\"unit\":\"w\"},{\"H_Alarm\":\"9.9\",\"M_Alarm\":\"4.4\"}", |
| "root.ln.d1.s0,status,root.ln,INT32,RLE,SNAPPY,{\"description\":\"ln this is a test3\"}," |
| + "{\"H_Alarm\":\"90\",\"M_Alarm\":\"50\"}"); |
| |
| Set<String> ret2 = new HashSet<>(); |
| ret2.add( |
| "root.turbine.d2.s0,temperature,root.turbine,FLOAT,RLE,SNAPPY,{\"description\":\"turbine " |
| + "d2 this is a test1\",\"unit\":\"f\"},{\"MinValue\":\"1\",\"MaxValue\":\"100\"}"); |
| ret2.add( |
| "root.turbine.d0.s0,temperature,root.turbine,FLOAT,RLE,SNAPPY,{\"description\":\"" |
| + "turbine this is a test1\",\"unit\":\"f\"},{\"H_Alarm\":\"100\",\"M_Alarm\":\"50\"}"); |
| |
| String[] sqls = { |
| "create timeseries root.turbine.d0.s0(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='f', 'description'='turbine this is a test1') " |
| + "attributes('H_Alarm'='100', 'M_Alarm'='50')", |
| "create timeseries root.turbine.d0.s1(power) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='kw', 'description'='turbine this is a test2') " |
| + "attributes('H_Alarm'='99.9', 'M_Alarm'='44.4')", |
| "create timeseries root.turbine.d1.s0(status) with datatype=INT32, encoding=RLE " |
| + "tags('description'='turbine this is a test3') " |
| + "attributes('H_Alarm'='9', 'M_Alarm'='5')", |
| "create timeseries root.turbine.d2.s0(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='f', 'description'='turbine d2 this is a test1') " |
| + "attributes('MaxValue'='100', 'MinValue'='1')", |
| "create timeseries root.turbine.d2.s1(power) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='kw', 'description'='turbine d2 this is a test2') " |
| + "attributes('MaxValue'='99.9', 'MinValue'='44.4')", |
| "create timeseries root.turbine.d2.s3(status) with datatype=INT32, encoding=RLE " |
| + "tags('description'='turbine d2 this is a test3') " |
| + "attributes('MaxValue'='9', 'MinValue'='5')", |
| "create timeseries root.ln.d0.s0(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='c', 'description'='ln this is a test1') " |
| + "attributes('H_Alarm'='1000', 'M_Alarm'='500')", |
| "create timeseries root.ln.d0.s1(power) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='w', 'description'='ln this is a test2') " |
| + "attributes('H_Alarm'='9.9', 'M_Alarm'='4.4')", |
| "create timeseries root.ln.d1.s0(status) with datatype=INT32, encoding=RLE " |
| + "tags('description'='ln this is a test3') " |
| + "attributes('H_Alarm'='90', 'M_Alarm'='50')", |
| }; |
| try (Connection connection = EnvFactory.getEnv().getConnection(); |
| Statement statement = connection.createStatement()) { |
| for (String sql : sqls) { |
| statement.execute(sql); |
| } |
| int count = 0; |
| try (ResultSet resultSet = statement.executeQuery("show timeseries")) { |
| while (resultSet.next()) { |
| String ans = |
| resultSet.getString("timeseries") |
| + "," |
| + resultSet.getString("alias") |
| + "," |
| + resultSet.getString("storage group") |
| + "," |
| + resultSet.getString("dataType") |
| + "," |
| + resultSet.getString("encoding") |
| + "," |
| + resultSet.getString("compression") |
| + "," |
| + resultSet.getString("tags") |
| + "," |
| + resultSet.getString("attributes"); |
| |
| assertTrue(ret1.contains(ans)); |
| count++; |
| } |
| assertEquals(ret1.size(), count); |
| } |
| |
| count = 0; |
| Set<String> res = new HashSet<>(); |
| try (ResultSet resultSet = statement.executeQuery("show timeseries where 'unit'='f'")) { |
| while (resultSet.next()) { |
| String ans = |
| resultSet.getString("timeseries") |
| + "," |
| + resultSet.getString("alias") |
| + "," |
| + resultSet.getString("storage group") |
| + "," |
| + resultSet.getString("dataType") |
| + "," |
| + resultSet.getString("encoding") |
| + "," |
| + resultSet.getString("compression") |
| + "," |
| + resultSet.getString("tags") |
| + "," |
| + resultSet.getString("attributes"); |
| res.add(ans); |
| count++; |
| } |
| assertEquals(ret2, res); |
| assertEquals(ret2.size(), count); |
| } |
| } catch (Exception e) { |
| e.printStackTrace(); |
| fail(); |
| } |
| } |
| |
| @Test |
| public void queryWithWhereTest2() { |
| Set<String> ret = new HashSet<>(); |
| ret.add( |
| "root.turbine.d2.s0,temperature,root.turbine,FLOAT,RLE,SNAPPY,{\"description\":\"turbine " |
| + "d2 this is a test1\",\"unit\":\"f\"},{\"MinValue\":\"1\",\"MaxValue\":\"100\"}"); |
| ret.add( |
| "root.turbine.d0.s0,temperature,root.turbine,FLOAT,RLE,SNAPPY,{\"description\":\"turbine " |
| + "this is a test1\",\"unit\":\"f\"},{\"H_Alarm\":\"100\",\"M_Alarm\":\"50\"}"); |
| |
| String[] sqls = { |
| "create timeseries root.turbine.d0.s0(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='f', 'description'='turbine this is a test1') " |
| + "attributes('H_Alarm'='100', 'M_Alarm'='50')", |
| "create timeseries root.turbine.d0.s1(power) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='kw', 'description'='turbine this is a test2') " |
| + "attributes('H_Alarm'='99.9', 'M_Alarm'='44.4')", |
| "create timeseries root.turbine.d1.s0(status) with datatype=INT32, encoding=RLE " |
| + "tags('description'='turbine this is a test3') " |
| + "attributes('H_Alarm'='9', 'M_Alarm'='5')", |
| "create timeseries root.turbine.d2.s0(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='f', 'description'='turbine d2 this is a test1') " |
| + "attributes('MaxValue'='100', 'MinValue'='1')", |
| "create timeseries root.turbine.d2.s1(power) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='kw', 'description'='turbine d2 this is a test2') " |
| + "attributes('MaxValue'='99.9', 'MinValue'='44.4')", |
| "create timeseries root.turbine.d2.s3(status) with datatype=INT32, encoding=RLE " |
| + "tags('description'='turbine d2 this is a test3') " |
| + "attributes('MaxValue'='9', 'MinValue'='5')", |
| "create timeseries root.ln.d0.s0(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='f', 'description'='ln this is a test1') " |
| + "attributes('H_Alarm'='1000', 'M_Alarm'='500')", |
| "create timeseries root.ln.d0.s1(power) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='w', 'description'='ln this is a test2') " |
| + "attributes('H_Alarm'='9.9', 'M_Alarm'='4.4')", |
| "create timeseries root.ln.d1.s0(status) with datatype=INT32, encoding=RLE " |
| + "tags('description'='ln this is a test3') " |
| + "attributes('H_Alarm'='90', 'M_Alarm'='50')", |
| }; |
| try (Connection connection = EnvFactory.getEnv().getConnection(); |
| Statement statement = connection.createStatement()) { |
| for (String sql : sqls) { |
| statement.execute(sql); |
| } |
| |
| // with * |
| int count = 0; |
| Set<String> res = new HashSet<>(); |
| try (ResultSet resultSet = |
| statement.executeQuery("show timeseries root.turbine.** where 'unit'='f'")) { |
| while (resultSet.next()) { |
| String ans = |
| resultSet.getString("timeseries") |
| + "," |
| + resultSet.getString("alias") |
| + "," |
| + resultSet.getString("storage group") |
| + "," |
| + resultSet.getString("dataType") |
| + "," |
| + resultSet.getString("encoding") |
| + "," |
| + resultSet.getString("compression") |
| + "," |
| + resultSet.getString("tags") |
| + "," |
| + resultSet.getString("attributes"); |
| |
| res.add(ans); |
| count++; |
| } |
| } |
| assertEquals(ret, res); |
| assertEquals(ret.size(), count); |
| |
| // no * |
| count = 0; |
| res.clear(); |
| try (ResultSet resultSet = |
| statement.executeQuery("show timeseries root.turbine.** where 'unit'='f'")) { |
| while (resultSet.next()) { |
| String ans = |
| resultSet.getString("timeseries") |
| + "," |
| + resultSet.getString("alias") |
| + "," |
| + resultSet.getString("storage group") |
| + "," |
| + resultSet.getString("dataType") |
| + "," |
| + resultSet.getString("encoding") |
| + "," |
| + resultSet.getString("compression") |
| + "," |
| + resultSet.getString("tags") |
| + "," |
| + resultSet.getString("attributes"); |
| |
| res.add(ans); |
| count++; |
| } |
| assertEquals(ret, res); |
| assertEquals(ret.size(), count); |
| } |
| |
| count = 0; |
| try (ResultSet resultSet = |
| statement.executeQuery("show timeseries root.turbine where 'unit'='c'")) { |
| while (resultSet.next()) { |
| count++; |
| } |
| assertEquals(0, count); |
| } |
| |
| } catch (Exception e) { |
| e.printStackTrace(); |
| fail(); |
| } |
| } |
| |
| @Ignore |
| @Test |
| public void queryWithWhereAndDeleteTest() { |
| Set<String> ret = new HashSet<>(); |
| ret.add( |
| "root.turbine.d0.s0,temperature,root.turbine,FLOAT,RLE,SNAPPY,{\"description\":\"" |
| + "turbine this is a test1\",\"unit\":\"f\"},{\"H_Alarm\":\"100\",\"M_Alarm\":\"50\"}"); |
| ret.add( |
| "root.ln.d0.s0,temperature,root.ln,FLOAT,RLE,SNAPPY,{\"description\":\"ln this " |
| + "is a test1\",\"unit\":\"f\"},{\"H_Alarm\":\"1000\",\"M_Alarm\":\"500\"}"); |
| |
| String[] sqls = { |
| "create timeseries root.turbine.d0.s0(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='f', 'description'='turbine this is a test1') " |
| + "attributes('H_Alarm'='100', 'M_Alarm'='50')", |
| "create timeseries root.turbine.d0.s1(power) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='kw', 'description'='turbine this is a test2') " |
| + "attributes('H_Alarm'='99.9', 'M_Alarm'='44.4')", |
| "create timeseries root.turbine.d1.s0(status) with datatype=INT32, encoding=RLE " |
| + "tags('description'='turbine this is a test3') " |
| + "attributes('H_Alarm'='9', 'M_Alarm'='5')", |
| "create timeseries root.turbine.d2.s0(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='f', 'description'='turbine d2 this is a test1') " |
| + "attributes('MaxValue'='100', 'MinValue'='1')", |
| "create timeseries root.turbine.d2.s1(power) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='kw', 'description'='turbine d2 this is a test2') " |
| + "attributes('MaxValue'='99.9', 'MinValue'='44.4')", |
| "create timeseries root.turbine.d2.s3(status) with datatype=INT32, encoding=RLE " |
| + "tags('description'='turbine d2 this is a test3') " |
| + "attributes('MaxValue'='9', 'MinValue'='5')", |
| "create timeseries root.ln.d0.s0(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='f', 'description'='ln this is a test1') " |
| + "attributes('H_Alarm'='1000', 'M_Alarm'='500')", |
| "create timeseries root.ln.d0.s1(power) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='w', 'description'='ln this is a test2') " |
| + "attributes('H_Alarm'='9.9', 'M_Alarm'='4.4')", |
| "create timeseries root.ln.d1.s0(status) with datatype=INT32, encoding=RLE " |
| + "tags('description'='ln this is a test3') " |
| + "attributes('H_Alarm'='90', 'M_Alarm'='50')", |
| }; |
| try (Connection connection = EnvFactory.getEnv().getConnection(); |
| Statement statement = connection.createStatement()) { |
| for (String sql : sqls) { |
| statement.execute(sql); |
| } |
| |
| statement.execute("delete timeseries root.turbine.d2.s0"); |
| |
| // with *; |
| int count = 0; |
| Set<String> res = new HashSet<>(); |
| try (ResultSet resultSet = statement.executeQuery("show timeseries where 'unit'='f'")) { |
| while (resultSet.next()) { |
| String ans = |
| resultSet.getString("timeseries") |
| + "," |
| + resultSet.getString("alias") |
| + "," |
| + resultSet.getString("storage group") |
| + "," |
| + resultSet.getString("dataType") |
| + "," |
| + resultSet.getString("encoding") |
| + "," |
| + resultSet.getString("compression") |
| + "," |
| + resultSet.getString("tags") |
| + "," |
| + resultSet.getString("attributes"); |
| |
| res.add(ans); |
| count++; |
| } |
| } |
| assertEquals(ret, res); |
| assertEquals(ret.size(), count); |
| |
| } catch (Exception e) { |
| e.printStackTrace(); |
| fail(); |
| } |
| } |
| |
| @Test |
| public void queryWithWhereContainsTest() { |
| Set<String> ret = new HashSet<>(); |
| ret.add( |
| "root.turbine.d2.s0,temperature,root.turbine,FLOAT,RLE,SNAPPY,{\"description\":\"turbine " |
| + "d2 this is a test1\",\"unit\":\"f\"},{\"MinValue\":\"1\",\"MaxValue\":\"100\"}"); |
| ret.add( |
| "root.turbine.d0.s0,temperature,root.turbine,FLOAT,RLE,SNAPPY,{\"description\":\"turbine " |
| + "this is a test1\",\"unit\":\"f\"},{\"H_Alarm\":\"100\",\"M_Alarm\":\"50\"}"); |
| ret.add( |
| "root.ln.d0.s0,temperature,root.ln,FLOAT,RLE,SNAPPY,{\"description\":\"ln this " |
| + "is a test1\",\"unit\":\"f\"},{\"H_Alarm\":\"1000\",\"M_Alarm\":\"500\"}"); |
| |
| Set<String> ret2 = new HashSet<>(); |
| ret2.add( |
| "root.ln.d0.s0,temperature,root.ln,FLOAT,RLE,SNAPPY,{\"description\":\"ln this" |
| + " is a test1\",\"unit\":\"f\"},{\"H_Alarm\":\"1000\",\"M_Alarm\":\"500\"}"); |
| |
| String[] sqls = { |
| "create timeseries root.turbine.d0.s0(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='f', 'description'='turbine this is a test1') " |
| + "attributes('H_Alarm'='100', 'M_Alarm'='50')", |
| "create timeseries root.turbine.d0.s1(power) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='kw', 'description'='turbine this is a test2') " |
| + "attributes('H_Alarm'='99.9', 'M_Alarm'='44.4')", |
| "create timeseries root.turbine.d1.s0(status) with datatype=INT32, encoding=RLE " |
| + "tags('description'='turbine this is a test3') " |
| + "attributes('H_Alarm'='9', 'M_Alarm'='5')", |
| "create timeseries root.turbine.d2.s0(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='f', 'description'='turbine d2 this is a test1') " |
| + "attributes('MaxValue'='100', 'MinValue'='1')", |
| "create timeseries root.turbine.d2.s1(power) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='kw', 'description'='turbine d2 this is a test2') " |
| + "attributes('MaxValue'='99.9', 'MinValue'='44.4')", |
| "create timeseries root.turbine.d2.s3(status) with datatype=INT32, encoding=RLE " |
| + "tags('description'='turbine d2 this is a test3') " |
| + "attributes('MaxValue'='9', 'MinValue'='5')", |
| "create timeseries root.ln.d0.s0(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='f', 'description'='ln this is a test1') " |
| + "attributes('H_Alarm'='1000', 'M_Alarm'='500')", |
| "create timeseries root.ln.d0.s1(power) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='w', 'description'='ln this is a test2') " |
| + "attributes('H_Alarm'='9.9', 'M_Alarm'='4.4')", |
| "create timeseries root.ln.d1.s0(status) with datatype=INT32, encoding=RLE " |
| + "tags('description'='ln this is a test3') " |
| + "attributes('H_Alarm'='90', 'M_Alarm'='50')", |
| }; |
| try (Connection connection = EnvFactory.getEnv().getConnection(); |
| Statement statement = connection.createStatement()) { |
| for (String sql : sqls) { |
| statement.execute(sql); |
| } |
| |
| int count = 0; |
| Set<String> res = new HashSet<>(); |
| try (ResultSet resultSet = |
| statement.executeQuery("show timeseries where 'description' contains 'test1'")) { |
| while (resultSet.next()) { |
| String ans = |
| resultSet.getString("timeseries") |
| + "," |
| + resultSet.getString("alias") |
| + "," |
| + resultSet.getString("storage group") |
| + "," |
| + resultSet.getString("dataType") |
| + "," |
| + resultSet.getString("encoding") |
| + "," |
| + resultSet.getString("compression") |
| + "," |
| + resultSet.getString("tags") |
| + "," |
| + resultSet.getString("attributes"); |
| |
| System.out.println(ans); |
| res.add(ans); |
| count++; |
| } |
| } |
| assertEquals(ret, res); |
| assertEquals(ret.size(), count); |
| |
| count = 0; |
| res.clear(); |
| try (ResultSet resultSet = |
| statement.executeQuery( |
| "show timeseries root.ln.** where 'description' contains 'test1'")) { |
| while (resultSet.next()) { |
| String ans = |
| resultSet.getString("timeseries") |
| + "," |
| + resultSet.getString("alias") |
| + "," |
| + resultSet.getString("storage group") |
| + "," |
| + resultSet.getString("dataType") |
| + "," |
| + resultSet.getString("encoding") |
| + "," |
| + resultSet.getString("compression") |
| + "," |
| + resultSet.getString("tags") |
| + "," |
| + resultSet.getString("attributes"); |
| |
| res.add(ans); |
| count++; |
| } |
| } |
| assertEquals(ret2, res); |
| assertEquals(ret2.size(), count); |
| |
| } catch (Exception e) { |
| e.printStackTrace(); |
| fail(); |
| } |
| } |
| |
| @Test |
| public void queryWithWhereOnNoneTagTest() { |
| String[] sqls = { |
| "create timeseries root.turbine.d0.s0(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='f', 'description'='turbine this is a test1') " |
| + "attributes('H_Alarm'='100', 'M_Alarm'='50')", |
| "create timeseries root.turbine.d0.s1(power) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='kw', 'description'='turbine this is a test2') " |
| + "attributes('H_Alarm'='99.9', 'M_Alarm'='44.4')", |
| "create timeseries root.turbine.d1.s0(status) with datatype=INT32, encoding=RLE " |
| + "tags('description'='turbine this is a test3') " |
| + "attributes('H_Alarm'='9', 'M_Alarm'='5')", |
| "create timeseries root.turbine.d2.s0(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='f', 'description'='turbine d2 this is a test1') " |
| + "attributes('MaxValue'='100', 'MinValue'='1')", |
| "create timeseries root.turbine.d2.s1(power) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='kw', 'description'='turbine d2 this is a test2') " |
| + "attributes('MaxValue'='99.9', 'MinValue'='44.4')", |
| "create timeseries root.turbine.d2.s3(status) with datatype=INT32, encoding=RLE " |
| + "tags('description'='turbine d2 this is a test3') " |
| + "attributes('MaxValue'='9', 'MinValue'='5')", |
| "create timeseries root.ln.d0.s0(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='c', 'description'='ln this is a test1') " |
| + "attributes('H_Alarm'='1000', 'M_Alarm'='500')", |
| "create timeseries root.ln.d0.s1(power) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('unit'='w', 'description'='ln this is a test2') " |
| + "attributes('H_Alarm'='9.9', 'M_Alarm'='4.4')", |
| "create timeseries root.ln.d1.s0(status) with datatype=INT32, encoding=RLE " |
| + "tags('description'='ln this is a test3') " |
| + "attributes('H_Alarm'='90', 'M_Alarm'='50')", |
| }; |
| try (Connection connection = EnvFactory.getEnv().getConnection(); |
| Statement statement = connection.createStatement()) { |
| for (String sql : sqls) { |
| statement.execute(sql); |
| } |
| |
| try (ResultSet rs = statement.executeQuery("show timeseries where 'H_Alarm'='90'")) { |
| assertFalse(rs.next()); |
| } |
| } catch (Exception e) { |
| e.printStackTrace(); |
| fail(); |
| } |
| } |
| |
| @Test |
| public void sameNameTest() { |
| String sql = |
| "create timeseries root.turbine.d1.s1(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('tag1'='v1', 'tag2'='v2') " |
| + "attributes('tag1'='v1', 'attr2'='v2')"; |
| try (Connection connection = EnvFactory.getEnv().getConnection(); |
| Statement statement = connection.createStatement()) { |
| statement.execute(sql); |
| fail(); |
| } catch (Exception e) { |
| assertTrue(e.getMessage().contains("Tag and attribute shouldn't have the same property key")); |
| } |
| } |
| |
| @Test |
| public void deleteStorageGroupTest() { |
| List<String> ret = |
| Collections.singletonList( |
| "root.turbine.d1.s1,temperature,root.turbine,FLOAT,RLE,SNAPPY," |
| + "{\"tag1\":\"v1\",\"tag2\":\"v2\"},{\"attr2\":\"v2\",\"attr1\":\"v1\"}"); |
| |
| String sql = |
| "create timeseries root.turbine.d1.s1(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY " |
| + "tags('tag1'='v1', 'tag2'='v2') " |
| + "attributes('attr1'='v1', 'attr2'='v2')"; |
| try (Connection connection = EnvFactory.getEnv().getConnection(); |
| Statement statement = connection.createStatement()) { |
| statement.execute(sql); |
| int count = 0; |
| try (ResultSet resultSet = statement.executeQuery("show timeseries")) { |
| while (resultSet.next()) { |
| String ans = |
| resultSet.getString("timeseries") |
| + "," |
| + resultSet.getString("alias") |
| + "," |
| + resultSet.getString("storage group") |
| + "," |
| + resultSet.getString("dataType") |
| + "," |
| + resultSet.getString("encoding") |
| + "," |
| + resultSet.getString("compression") |
| + "," |
| + resultSet.getString("tags") |
| + "," |
| + resultSet.getString("attributes"); |
| assertTrue(ret.contains(ans)); |
| count++; |
| } |
| } |
| assertEquals(ret.size(), count); |
| |
| statement.execute("delete storage group root.turbine"); |
| try (ResultSet rs = statement.executeQuery("show timeseries where 'tag1'='v1'")) { |
| assertFalse(rs.next()); |
| } |
| } catch (Exception e) { |
| e.printStackTrace(); |
| fail(); |
| } |
| } |
| |
| @Test |
| public void insertWithAliasTest() { |
| List<String> ret = Collections.singletonList("1,36.5,36.5"); |
| String[] sqls = { |
| "create timeseries root.turbine.d1.s1(temperature) with datatype=FLOAT, encoding=RLE, compression=SNAPPY", |
| "insert into root.turbine.d1(timestamp, temperature) values(1,36.5)" |
| }; |
| try (Connection connection = EnvFactory.getEnv().getConnection(); |
| Statement statement = connection.createStatement()) { |
| for (String sql : sqls) { |
| statement.execute(sql); |
| } |
| boolean hasResult = statement.execute("select s1, temperature from root.turbine.d1"); |
| assertTrue(hasResult); |
| // FIXME should use the same reader for measurement and its alias |
| |
| // ResultSet resultSet = statement.getResultSet(); |
| // int count = 0; |
| // try { |
| // while (resultSet.next()) { |
| // String ans = |
| // resultSet.getString("Time") |
| // + "," |
| // + resultSet.getString("root.turbine.d1.s1") |
| // + "," |
| // + resultSet.getString("root.turbine.d1.s1"); |
| // assertTrue(ret.contains(ans)); |
| // count++; |
| // } |
| // } finally { |
| // resultSet.close(); |
| // } |
| // assertEquals(ret.size(), count); |
| } catch (Exception e) { |
| e.printStackTrace(); |
| assertEquals( |
| "411: Error occurred in query process: Query for measurement and its alias at the same time!", |
| e.getMessage()); |
| } |
| } |
| } |
