Add relational it

integration-test/src/test/java/org/apache/iotdb/db/it/utils/TestUtils.java

@@ -369,11 +369,21 @@ public static void assertNonQueryTestFail(String sql, String errMsg) {
     assertNonQueryTestFail(sql, errMsg, SessionConfig.DEFAULT_USER, SessionConfig.DEFAULT_PASSWORD);
   }
 
+  public static void assertTableNonQueryTestFail(String sql, String errMsg, String dbName) {
+    assertTableNonQueryTestFail(
+        sql, errMsg, SessionConfig.DEFAULT_USER, SessionConfig.DEFAULT_PASSWORD, dbName);
+  }
+
   public static void assertNonQueryTestFail(
       String sql, String errMsg, String userName, String password) {
     assertNonQueryTestFail(EnvFactory.getEnv(), sql, errMsg, userName, password);
   }
 
+  public static void assertTableNonQueryTestFail(
+      String sql, String errMsg, String userName, String password, String dbName) {
+    assertTableNonQueryTestFail(EnvFactory.getEnv(), sql, errMsg, userName, password, dbName);
+  }
+
   public static void assertNonQueryTestFail(
       BaseEnv env, String sql, String errMsg, String userName, String password) {
     try (Connection connection = env.getConnection(userName, password);
@@ -385,6 +395,18 @@ public static void assertNonQueryTestFail(
     }
   }
 
+  public static void assertTableNonQueryTestFail(
+      BaseEnv env, String sql, String errMsg, String userName, String password, String db) {
+    try (Connection connection = env.getConnection(userName, password, BaseEnv.TABLE_SQL_DIALECT);
+        Statement statement = connection.createStatement()) {
+      statement.execute("use " + "\"" + db + "\"");
+      statement.execute(sql);
+      fail("No exception!");
+    } catch (SQLException e) {
+      Assert.assertTrue(e.getMessage(), e.getMessage().contains(errMsg));
+    }
+  }
+
   public static void assertResultSetEqual(
       ResultSet actualResultSet, String expectedHeader, String[] expectedRetArray) {
     assertResultSetEqual(

integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IOTDBInsertWithTimeAtAnyIndexIT.java

@@ -0,0 +1,106 @@
+/*
+ * 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.relational.it.db.it;
+
+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.AfterClass;
+import org.junit.BeforeClass;
+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.SQLException;
+import java.sql.Statement;
+
+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 IOTDBInsertWithTimeAtAnyIndexIT {
+
+  @BeforeClass
+  public static void setUp() throws Exception {
+    EnvFactory.getEnv().getConfig().getCommonConfig().setAutoCreateSchemaEnabled(true);
+    EnvFactory.getEnv().initClusterEnvironment();
+  }
+
+  @AfterClass
+  public static void tearDown() throws Exception {
+    EnvFactory.getEnv().cleanClusterEnvironment();
+  }
+
+  @Test
+  public void testInsertTimeAtAnyIndex() throws SQLException {
+    try (Connection connection = EnvFactory.getEnv().getConnection();
+        Statement statement = connection.createStatement()) {
+      statement.addBatch("create database test");
+      statement.addBatch("use \"test\"");
+      statement.addBatch(
+          "create table (id1 string id, s1 int32 measurement, s2 int32 measurement)");
+      statement.addBatch("insert into db(id, s1, s2, time) ('d1', 2, 3, 1)");
+      statement.addBatch("insert into db(id, s1, time, s2) values ('d1', 20, 10, 30)");
+      statement.addBatch("insert into db(id, `time`, s1, s2) values ('d1', 100, 200, 300)");
+      statement.executeBatch();
+
+      try (ResultSet resultSet = statement.executeQuery("select time, s1 from db")) {
+        assertTrue(resultSet.next());
+        assertEquals(1, resultSet.getLong(1));
+        assertEquals(2, resultSet.getDouble(2), 0.00001);
+        assertTrue(resultSet.next());
+        assertEquals(10, resultSet.getLong(1));
+        assertEquals(20, resultSet.getDouble(2), 0.00001);
+        assertTrue(resultSet.next());
+        assertEquals(100, resultSet.getLong(1));
+        assertEquals(200, resultSet.getDouble(2), 0.00001);
+        assertFalse(resultSet.next());
+      }
+    }
+  }
+
+  @Test
+  public void testInsertMultiTime() {
+    try (Connection connection = EnvFactory.getEnv().getConnection();
+        Statement statement = connection.createStatement()) {
+      try {
+        statement.addBatch("create database test");
+        statement.addBatch("use \"test\"");
+        statement.addBatch(
+            "create table (id1 string id, s1 int32 measurement, s2 int32 measurement)");
+        statement.addBatch("insert into db(id1, s1, s2, time, time) values ('d1', 2, 3, 1, 1)");
+        statement.executeBatch();
+        fail();
+      } catch (SQLException e) {
+        // expected
+      }
+
+    } catch (SQLException e) {
+      fail();
+    }
+  }
+}