Influxdb tag adaptation

example/influxdb-protocol-example/src/main/java/org/apache/iotdb/influxdb/InfluxDBExample.java

@@ -102,7 +102,7 @@ private static void queryData() {
 
     query =
         new Query(
-            "select count(temperature),first(temperature),last(temperature),max(temperature),mean(temperature),median(temperature),min(temperature),mode(temperature),spread(temperature),stddev(temperature),sum(temperature) from student where ((workshop=\"A1\" and production=\"B1\" and cell =\"C1\" ) or temperature< 15 )",
+            "select count(temperature),first(temperature),last(temperature),max(temperature),mean(temperature),median(temperature),min(temperature),mode(temperature),spread(temperature),stddev(temperature),sum(temperature) from factory where ((workshop=\"A1\" and production=\"B1\" and cell =\"C1\" ) or temperature< 15 )",
             database);
     result = influxDB.query(query);
     System.out.println("query2 result:" + result.getResults().get(0).getSeries().get(0).toString());

influxdb-protocol/src/test/java/org/apache/iotdb/influxdb/integration/IoTDBInfluxDBIT.java

@@ -33,11 +33,15 @@
 import org.testcontainers.containers.GenericContainer;
 import org.testcontainers.utility.DockerImageName;
 
+import java.util.Arrays;
 import java.util.HashMap;
+import java.util.HashSet;
 import java.util.Map;
+import java.util.Set;
 import java.util.concurrent.TimeUnit;
 
 import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertTrue;
 
 public class IoTDBInfluxDBIT {
 
@@ -164,8 +168,9 @@ public void testCommonQueryColumn() {
     QueryResult.Series series = result.getResults().get(0).getSeries().get(0);
 
     String[] retArray = new String[] {"time", "name", "sex", "province", "country", "score", "tel"};
+    Set<String> columnNames = new HashSet<>(Arrays.asList(retArray));
     for (int i = 0; i < series.getColumns().size(); i++) {
-      assertEquals(retArray[i], series.getColumns().get(i));
+      assertTrue(columnNames.contains(series.getColumns().get(i)));
     }
   }
 

server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaEngine.java

@@ -35,6 +35,7 @@
 import org.apache.iotdb.db.metadata.mnode.IStorageGroupMNode;
 import org.apache.iotdb.db.metadata.mtree.ConfigMTree;
 import org.apache.iotdb.db.metadata.rescon.SchemaResourceManager;
+import org.apache.iotdb.db.metadata.schemaregion.tagschemaregion.MockTagSchemaRegion;
 import org.apache.iotdb.db.metadata.visitor.SchemaExecutionVisitor;
 import org.apache.iotdb.db.mpp.plan.planner.plan.node.PlanNode;
 import org.apache.iotdb.external.api.ISeriesNumerLimiter;
@@ -323,6 +324,11 @@ private ISchemaRegion createSchemaRegionWithoutExistenceCheck(
             new RSchemaRegionLoader()
                 .loadRSchemaRegion(storageGroup, schemaRegionId, storageGroupMNode);
         break;
+      case Tag:
+        schemaRegion =
+            new MockTagSchemaRegion(
+                storageGroup, schemaRegionId, storageGroupMNode, seriesNumerLimiter);
+        break;
       default:
         throw new UnsupportedOperationException(
             String.format(

server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaEngineMode.java

@@ -22,5 +22,6 @@
 public enum SchemaEngineMode {
   Memory,
   Schema_File,
-  Rocksdb_based
+  Rocksdb_based,
+  Tag
 }