[Improve][E2E][Doris] Add no schema test case for connector-doris-e2e (apache#7076)

Author: bingquanzhao

seatunnel-e2e/seatunnel-connector-v2-e2e/connector-doris-e2e/src/test/java/org/apache/seatunnel/e2e/connector/doris/DorisIT.java

@@ -224,7 +224,7 @@ private void checkAllTypeSinkData() {
         }
     }
 
-    private void checkSinkData() {
+    protected void checkSinkData() {
         try {
             assertHasData(sourceDB, UNIQUE_TABLE);
             assertHasData(sinkDB, UNIQUE_TABLE);
@@ -371,7 +371,7 @@ private void clearDuplicateTable() {
         }
     }
 
-    private void initializeJdbcTable() {
+    protected void initializeJdbcTable() {
         try {
             URLClassLoader urlClassLoader =
                     new URLClassLoader(
@@ -528,7 +528,7 @@ private String createDuplicateTableForTest(String db) {
         return String.format(createDuplicateTableSql, db, DUPLICATE_TABLE);
     }
 
-    private void batchInsertUniqueTableData() {
+    protected void batchInsertUniqueTableData() {
         List<SeaTunnelRow> rows = genUniqueTableTestData(100L);
         try {
             conn.setAutoCommit(false);

seatunnel-e2e/seatunnel-connector-v2-e2e/connector-doris-e2e/src/test/java/org/apache/seatunnel/e2e/connector/doris/DorisNoSchemaIT.java

@@ -0,0 +1,38 @@
+/*
+ * 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.seatunnel.e2e.connector.doris;
+
+import org.apache.seatunnel.e2e.common.container.TestContainer;
+
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.TestTemplate;
+import org.testcontainers.containers.Container;
+
+import java.io.IOException;
+
+public class DorisNoSchemaIT extends DorisIT {
+
+    @TestTemplate
+    public void testDoris(TestContainer container) throws IOException, InterruptedException {
+        initializeJdbcTable();
+        batchInsertUniqueTableData();
+        Container.ExecResult execResult1 = container.executeJob("/doris_source_no_schema.conf");
+        Assertions.assertEquals(0, execResult1.getExitCode());
+        checkSinkData();
+    }
+}

seatunnel-e2e/seatunnel-connector-v2-e2e/connector-doris-e2e/src/test/resources/doris_source_no_schema.conf

@@ -0,0 +1,50 @@
+#
+# 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.
+#
+
+env{
+  parallelism = 1
+  job.mode = "BATCH"
+}
+
+source{
+  Doris {
+      fenodes = "doris_e2e:8030"
+      username = root
+      password = ""
+      database = "e2e_source"
+      table = "doris_e2e_unique_table"
+      doris.filter.query = "F_ID > 50"
+  }
+}
+
+transform {}
+
+sink{
+  Doris {
+          fenodes = "doris_e2e:8030"
+          schema_save_mode = "RECREATE_SCHEMA"
+          username = root
+          password = ""
+          table.identifier = "e2e_sink.doris_e2e_unique_table"
+          sink.enable-2pc = "false"
+          sink.label-prefix = "no_schema"
+          doris.config = {
+              format="json"
+              read_json_by_line="true"
+          }
+      }
+  }