Pipe: Checked the enable_auto_create_schema in database auto creation (apache#16354)

Author: Caideyipi

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java

@@ -986,7 +986,8 @@ private TSStatus executeStatementForTableModel(
   }
 
   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;
     }
 

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/writeback/WriteBackSink.java

@@ -428,7 +428,8 @@ private TSStatus executeStatementForTableModel(
   }
 
   private void autoCreateDatabaseIfNecessary(final String database) {
-    if (ALREADY_CREATED_DATABASES.contains(database)) {
+    if (ALREADY_CREATED_DATABASES.contains(database)
+        || !IoTDBDescriptor.getInstance().getConfig().isAutoCreateSchemaEnabled()) {
       return;
     }
 

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileTableSchemaCache.java

@@ -302,6 +302,13 @@ private void autoCreateTableDatabaseIfAbsent(final String database) throws LoadA
       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);