(shardingsphere) branch master updated: Add test cases on OpenGaussPipelineJobDataSourcePrepareOption (#33429)

[duanzhengqiang]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 84f80f7d9af Add test cases on 
OpenGaussPipelineJobDataSourcePrepareOption (#33429)
84f80f7d9af is described below

commit 84f80f7d9af4ce54fa13ffe13531f9cedf4f533c
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Sun Oct 27 20:57:27 2024 +0800

    Add test cases on OpenGaussPipelineJobDataSourcePrepareOption (#33429)
---
 ...aussPipelineJobDataSourcePrepareOptionTest.java | 46 ++++++++++++++++++++++
 1 file changed, 46 insertions(+)

diff --git 
a/kernel/data-pipeline/dialect/opengauss/src/test/java/org/apache/shardingsphere/data/pipeline/opengauss/prepare/datasource/OpenGaussPipelineJobDataSourcePrepareOptionTest.java
 
b/kernel/data-pipeline/dialect/opengauss/src/test/java/org/apache/shardingsphere/data/pipeline/opengauss/prepare/datasource/OpenGaussPipelineJobDataSourcePrepareOptionTest.java
new file mode 100644
index 00000000000..ffe435bdc29
--- /dev/null
+++ 
b/kernel/data-pipeline/dialect/opengauss/src/test/java/org/apache/shardingsphere/data/pipeline/opengauss/prepare/datasource/OpenGaussPipelineJobDataSourcePrepareOptionTest.java
@@ -0,0 +1,46 @@
+/*
+ * 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.shardingsphere.data.pipeline.opengauss.prepare.datasource;
+
+import 
org.apache.shardingsphere.data.pipeline.core.preparer.datasource.option.DialectPipelineJobDataSourcePrepareOption;
+import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
+import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
+import org.junit.jupiter.api.Test;
+
+import java.util.Arrays;
+
+import static org.hamcrest.CoreMatchers.is;
+import static org.hamcrest.MatcherAssert.assertThat;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+
+class OpenGaussPipelineJobDataSourcePrepareOptionTest {
+    
+    private final DatabaseType databaseType = 
TypedSPILoader.getService(DatabaseType.class, "openGauss");
+    
+    private final DialectPipelineJobDataSourcePrepareOption 
dataSourcePrepareOption = 
TypedSPILoader.getService(DialectPipelineJobDataSourcePrepareOption.class, 
databaseType);
+    
+    @Test
+    void assertIsSupportIfNotExistsOnCreateSchema() {
+        
assertFalse(dataSourcePrepareOption.isSupportIfNotExistsOnCreateSchema());
+    }
+    
+    @Test
+    void assertGetIgnoredExceptionMessages() {
+        assertThat(dataSourcePrepareOption.getIgnoredExceptionMessages(), 
is(Arrays.asList("multiple primary keys for table", "already exists")));
+    }
+}