(iotdb) branch master updated: Pipe: Checked the enable_auto_create_schema in database auto creation (#16354)

[justinchen]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 0b74d2b923b Pipe: Checked the enable_auto_create_schema in database 
auto creation (#16354)
0b74d2b923b is described below

commit 0b74d2b923b21e89a731b41ce37965798f10750f
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Fri Sep 5 14:08:43 2025 +0800

    Pipe: Checked the enable_auto_create_schema in database auto creation 
(#16354)
---
 .../db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java    | 3 ++-
 .../iotdb/db/pipe/sink/protocol/writeback/WriteBackSink.java       | 3 ++-
 .../queryengine/plan/analyze/load/LoadTsFileTableSchemaCache.java  | 7 +++++++
 3 files changed, 11 insertions(+), 2 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java
index 0469bb7b152..5760dfc9fb1 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java
@@ -986,7 +986,8 @@ public class IoTDBDataNodeReceiver extends 
IoTDBFileReceiver {
   }
 
   private void autoCreateDatabaseIfNecessary(final String database) {
-    if (ALREADY_CREATED_TABLE_MODEL_DATABASES.contains(database)) {
+    if (ALREADY_CREATED_TABLE_MODEL_DATABASES.contains(database)
+        || 
!IoTDBDescriptor.getInstance().getConfig().isAutoCreateSchemaEnabled()) {
       return;
     }
 
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/writeback/WriteBackSink.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/writeback/WriteBackSink.java
index 4a14810be5a..30dcb38c0ae 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/writeback/WriteBackSink.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/writeback/WriteBackSink.java
@@ -428,7 +428,8 @@ public class WriteBackSink implements PipeConnector {
   }
 
   private void autoCreateDatabaseIfNecessary(final String database) {
-    if (ALREADY_CREATED_DATABASES.contains(database)) {
+    if (ALREADY_CREATED_DATABASES.contains(database)
+        || 
!IoTDBDescriptor.getInstance().getConfig().isAutoCreateSchemaEnabled()) {
       return;
     }
 
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileTableSchemaCache.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileTableSchemaCache.java
index 1fb6da702c3..7bfb5509e98 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileTableSchemaCache.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileTableSchemaCache.java
@@ -302,6 +302,13 @@ public class LoadTsFileTableSchemaCache {
       return;
     }
 
+    if 
(!IoTDBDescriptor.getInstance().getConfig().isAutoCreateSchemaEnabled()) {
+      throw new LoadAnalyzeException(
+          "The database "
+              + database
+              + " does not exist, please enable 'enable_auto_create_schema' to 
enable auto creation.");
+    }
+
     Coordinator.getInstance()
         .getAccessControl()
         .checkCanCreateDatabase(context.getSession().getUserName(), database);