(iotdb) branch TableModelIngestion updated: add visitInsertRow

[jiangtian]

This is an automated email from the ASF dual-hosted git repository.

jiangtian pushed a commit to branch TableModelIngestion
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/TableModelIngestion by this 
push:
     new ba49c610703 add visitInsertRow
ba49c610703 is described below

commit ba49c61070311571b25c101033c556d01a5d4b5c
Author: Tian Jiang <jt2594...@163.com>
AuthorDate: Fri Jul 5 15:58:49 2024 +0800

    add visitInsertRow
---
 .../db/queryengine/plan/analyze/schema/SchemaValidator.java   |  2 --
 .../plan/relational/analyzer/StatementAnalyzer.java           | 11 +++++++++++
 2 files changed, 11 insertions(+), 2 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/schema/SchemaValidator.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/schema/SchemaValidator.java
index 5661fa27690..d1c1aac54d4 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/schema/SchemaValidator.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/schema/SchemaValidator.java
@@ -69,8 +69,6 @@ public class SchemaValidator {
       final TableSchema incomingSchema = insertStatement.getTableSchema();
       final TableSchema realSchema =
           metadata.validateTableHeaderSchema(databaseName, incomingSchema, 
context);
-      LOGGER.info("incoming table header schema: {}", incomingSchema);
-      LOGGER.info("real table header schema: {}", realSchema);
       insertStatement.validate(realSchema);
       metadata.validateDeviceSchema(insertStatement, context);
       insertStatement.updateAfterSchemaValidation(context);
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/StatementAnalyzer.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/StatementAnalyzer.java
index 641d8d0804e..cf23989fd54 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/StatementAnalyzer.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/StatementAnalyzer.java
@@ -62,6 +62,7 @@ import 
org.apache.iotdb.db.queryengine.plan.relational.sql.ast.GroupingElement;
 import org.apache.iotdb.db.queryengine.plan.relational.sql.ast.GroupingSets;
 import org.apache.iotdb.db.queryengine.plan.relational.sql.ast.Identifier;
 import org.apache.iotdb.db.queryengine.plan.relational.sql.ast.Insert;
+import org.apache.iotdb.db.queryengine.plan.relational.sql.ast.InsertRow;
 import org.apache.iotdb.db.queryengine.plan.relational.sql.ast.InsertTablet;
 import org.apache.iotdb.db.queryengine.plan.relational.sql.ast.Intersect;
 import org.apache.iotdb.db.queryengine.plan.relational.sql.ast.Join;
@@ -104,6 +105,7 @@ import 
org.apache.iotdb.db.queryengine.plan.relational.sql.ast.Use;
 import org.apache.iotdb.db.queryengine.plan.relational.sql.ast.Values;
 import org.apache.iotdb.db.queryengine.plan.relational.sql.ast.With;
 import org.apache.iotdb.db.queryengine.plan.relational.sql.ast.WithQuery;
+import 
org.apache.iotdb.db.queryengine.plan.relational.sql.ast.WrappedInsertStatement;
 import org.apache.iotdb.db.queryengine.plan.statement.crud.InsertBaseStatement;
 
 import com.google.common.collect.ArrayListMultimap;
@@ -366,7 +368,16 @@ public class StatementAnalyzer {
       throw new SemanticException("Insert statement is not supported yet.");
     }
 
+    @Override
+    protected Scope visitInsertRow(InsertRow node, Optional<Scope> context) {
+      return visitInsert(node, context);
+    }
+
     protected Scope visitInsertTablet(InsertTablet insert, Optional<Scope> 
scope) {
+      return visitInsert(insert, scope);
+    }
+
+    protected Scope visitInsert(WrappedInsertStatement insert, Optional<Scope> 
scope) {
       final Scope ret = Scope.create();
 
       final MPPQueryContext context = insert.getContext();