feature: support openGuass and GuassDB in AT mode

changes/en-us/2.x.md

@@ -3,7 +3,7 @@ Add changes here for all PR submitted to the 2.x branch.
 <!-- Please add the `changes` to the following location(feature/bugfix/optimize/test) based on the type of PR -->
 
 ### feature:
-- [[#PR_NO](https://github.com/apache/incubator-seata/pull/PR_NO)] A brief and accurate description of PR
+- [[#6020](https://github.com/apache/incubator-seata/pull/6020)] support openGuass and GuassDB in AT mode
 
 ### bugfix:
 - [[#6090](https://github.com/apache/incubator-seata/pull/6090)] fix the TCC aspect exception handling process, do not wrapping the internal call exceptions
@@ -64,6 +64,7 @@ Thanks to these contributors for their code commits. Please report an unintended
 - [ptyin](https://github.com/ptyin)
 - [laywin](https://github.com/laywin)
 - [imcmai](https://github.com/imcmai)
+- [liuqiufeng](https://github.com/liuqiufeng)
 - [DroidEye2ONGU](https://github.com/DroidEye2ONGU)
 - [funky-eyes](https://github.com/funky-eyes)
 - [Bughue](https://github.com/Bughue)

changes/zh-cn/2.x.md

@@ -3,7 +3,7 @@
 <!-- 请根据PR的类型添加 `变更记录` 到以下对应位置(feature/bugfix/optimize/test) 下 -->
 
 ### feature:
-- [[#PR_NO](https://github.com/apache/incubator-seata/pull/PR_NO)] 准确简要的PR描述
+- [[#6020](https://github.com/apache/incubator-seata/pull/6020)] AT模式下支持openGauss和GaussDB
 
 ### bugfix:
 - [[#6090](https://github.com/apache/incubator-seata/pull/6090)] 修复tcc切面异常处理过程，不对内部调用异常做包装处理，直接向外抛出
@@ -63,6 +63,7 @@
 - [ptyin](https://github.com/ptyin)
 - [laywin](https://github.com/laywin)
 - [imcmai](https://github.com/imcmai)
+- [liuqiufeng](https://github.com/liuqiufeng)
 - [DroidEye2ONGU](https://github.com/DroidEye2ONGU)
 - [funky-eyes](https://github.com/funky-eyes)
 - [Bughue](https://github.com/Bughue)

common/src/main/java/io/seata/common/util/PageUtil.java

@@ -111,6 +111,7 @@ public static String pageSql(String sourceSql, String dbType, int pageNum, int p
             case "postgresql":
             case "oceanbase":
             case "dm":
+            case "gaussdb":
                 return LIMIT_TEMPLATE.replace(SOURCE_SQL_PLACE_HOLD, sourceSql)
                         .replace(LIMIT_PLACE_HOLD, String.valueOf(pageSize))
                         .replace(OFFSET_PLACE_HOLD, String.valueOf((pageNum - 1) * pageSize));
@@ -144,6 +145,7 @@ public static String countSql(String sourceSql, String dbType) {
                 return sourceSql.replaceAll("(?i)(?<=select)(.*)(?=from)", " count(1) ");
             case "postgresql":
             case "sqlserver":
+            case "gaussdb":
                 int lastIndexOfOrderBy = sourceSql.toLowerCase().lastIndexOf("order by");
                 if (lastIndexOfOrderBy != -1) {
                     return sourceSql.substring(0, lastIndexOfOrderBy).replaceAll("(?i)(?<=select)(.*)(?=from)", " count(1) ");

core/src/main/java/io/seata/core/constants/DBType.java

@@ -192,7 +192,12 @@ public enum DBType {
     /**
      * PolarDB db type.
      */
-    POLARDB;
+    POLARDB,
+
+    /**
+     * GaussDB db type.
+     */
+    GAUSSDB;
 
     /**
      * Valueof db type.

core/src/main/java/io/seata/core/store/db/sql/lock/GaussDBLockStoreSql.java

@@ -0,0 +1,28 @@
+/*
+ * 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 io.seata.core.store.db.sql.lock;
+
+import io.seata.common.loader.LoadLevel;
+
+/**
+ * the database lock store GaussDB sql
+ *
+ */
+@LoadLevel(name = "gaussdb")
+public class GaussDBLockStoreSql extends PostgresqlLockStoreSql {
+}

core/src/main/java/io/seata/core/store/db/sql/log/GaussDBLogStoreSqls.java

@@ -0,0 +1,28 @@
+/*
+ * 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 io.seata.core.store.db.sql.log;
+
+import io.seata.common.loader.LoadLevel;
+
+/**
+ * Database log store GaussDB sql
+ *
+ */
+@LoadLevel(name = "gaussdb")
+public class GaussDBLogStoreSqls extends PostgresqlLogStoreSqls {
+}

core/src/main/resources/META-INF/services/io.seata.core.store.db.sql.lock.LockStoreSql

@@ -6,4 +6,5 @@ io.seata.core.store.db.sql.lock.H2LockStoreSql
 io.seata.core.store.db.sql.lock.SqlServerLockStoreSql
 io.seata.core.store.db.sql.lock.MariadbLockStoreSql
 io.seata.core.store.db.sql.lock.PolarDBXLockStoreSql
-io.seata.core.store.db.sql.lock.DmLockStoreSql
+io.seata.core.store.db.sql.lock.DmLockStoreSql
+io.seata.core.store.db.sql.lock.GaussDBLockStoreSql

core/src/main/resources/META-INF/services/io.seata.core.store.db.sql.log.LogStoreSqls

@@ -6,4 +6,5 @@ io.seata.core.store.db.sql.log.H2LogStoreSqls
 io.seata.core.store.db.sql.log.SqlServerLogStoreSqls
 io.seata.core.store.db.sql.log.MariadbLogStoreSqls
 io.seata.core.store.db.sql.log.PolarDBXLogStoreSqls
-io.seata.core.store.db.sql.log.DmLogStoreSqls
+io.seata.core.store.db.sql.log.DmLogStoreSqls
+io.seata.core.store.db.sql.log.GaussDBLogStoreSqls

dependencies/pom.xml

@@ -108,8 +108,9 @@
         <postgresql.version>42.3.3</postgresql.version>
         <h2.version>1.4.181</h2.version>
         <mariadb.version>2.7.2</mariadb.version>
+        <opengauss.version>5.0.0-og</opengauss.version>
         <!-- db connection pool -->
-        <druid.version>1.2.7</druid.version>
+        <druid.version>1.2.12</druid.version>
         <commons-dbcp2.version>2.9.0</commons-dbcp2.version>
         <hikari.version>3.4.3</hikari.version>
         <!-- sql parser -->
@@ -226,6 +227,11 @@
                 <artifactId>DmJdbcDriver18</artifactId>
                 <version>${dm.version}</version>
             </dependency>
+            <dependency>
+                <groupId>org.opengauss</groupId>
+                <artifactId>opengauss-jdbc</artifactId>
+                <version>${opengauss.version}</version>
+            </dependency>
             <dependency>
                 <groupId>org.mariadb.jdbc</groupId>
                 <artifactId>mariadb-java-client</artifactId>

rm-datasource/src/main/java/io/seata/rm/datasource/DataSourceProxy.java

@@ -229,7 +229,7 @@ public String getResourceId() {
     }
 
     private void initResourceId() {
-        if (JdbcConstants.POSTGRESQL.equals(dbType)) {
+        if (JdbcConstants.POSTGRESQL.equals(dbType) || JdbcConstants.GAUSSDB.equals(dbType)) {
             initPGResourceId();
         } else if (JdbcConstants.ORACLE.equals(dbType) && userName != null) {
             initOracleResourceId();

rm-datasource/src/main/java/io/seata/rm/datasource/exec/gaussdb/GaussDBInsertExecutor.java

@@ -0,0 +1,45 @@
+/*
+ * 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 io.seata.rm.datasource.exec.gaussdb;
+
+import io.seata.common.loader.LoadLevel;
+import io.seata.common.loader.Scope;
+import io.seata.rm.datasource.StatementProxy;
+import io.seata.rm.datasource.exec.StatementCallback;
+import io.seata.rm.datasource.exec.postgresql.PostgresqlInsertExecutor;
+import io.seata.sqlparser.SQLRecognizer;
+import io.seata.sqlparser.util.JdbcConstants;
+
+/**
+ * The type GaussDB insert executor.
+ *
+ */
+@LoadLevel(name = JdbcConstants.GAUSSDB, scope = Scope.PROTOTYPE)
+public class GaussDBInsertExecutor extends PostgresqlInsertExecutor {
+
+    /**
+     * Instantiates a new Abstract dml base executor.
+     *
+     * @param statementProxy    the statement proxy
+     * @param statementCallback the statement callback
+     * @param sqlRecognizer     the sql recognizer
+     */
+    public GaussDBInsertExecutor(StatementProxy statementProxy, StatementCallback statementCallback, SQLRecognizer sqlRecognizer) {
+        super(statementProxy, statementCallback, sqlRecognizer);
+    }
+}

rm-datasource/src/main/java/io/seata/rm/datasource/sql/handler/gaussdb/GaussDBEscapeHandler.java

@@ -0,0 +1,30 @@
+/*
+ * 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 io.seata.rm.datasource.sql.handler.gaussdb;
+
+import io.seata.common.loader.LoadLevel;
+import io.seata.rm.datasource.sql.handler.postgresql.PostgresqlEscapeHandler;
+import io.seata.sqlparser.util.JdbcConstants;
+
+/**
+ * The type GaussDB escape handler.
+ *
+ */
+@LoadLevel(name = JdbcConstants.GAUSSDB)
+public class GaussDBEscapeHandler extends PostgresqlEscapeHandler {
+}

rm-datasource/src/main/java/io/seata/rm/datasource/sql/struct/cache/GaussDBTableMetaCache.java

@@ -0,0 +1,29 @@
+/*
+ * 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 io.seata.rm.datasource.sql.struct.cache;
+
+import io.seata.common.loader.LoadLevel;
+import io.seata.sqlparser.util.JdbcConstants;
+
+/**
+ * The type Table meta cache.
+ *
+ */
+@LoadLevel(name = JdbcConstants.GAUSSDB)
+public class GaussDBTableMetaCache extends PostgresqlTableMetaCache {
+}

rm-datasource/src/main/java/io/seata/rm/datasource/undo/gaussdb/GaussDBUndoDeleteExecutor.java

@@ -0,0 +1,43 @@
+/*
+ * 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 io.seata.rm.datasource.undo.gaussdb;
+
+import io.seata.rm.datasource.undo.SQLUndoLog;
+import io.seata.rm.datasource.undo.postgresql.PostgresqlUndoDeleteExecutor;
+import io.seata.sqlparser.util.JdbcConstants;
+
+/**
+ * The type GaussDB undo delete executor.
+ *
+ */
+public class GaussDBUndoDeleteExecutor extends PostgresqlUndoDeleteExecutor {
+
+    /**
+     * Instantiates a new GaussDB undo delete executor.
+     *
+     * @param sqlUndoLog the sql undo log
+     */
+    public GaussDBUndoDeleteExecutor(SQLUndoLog sqlUndoLog) {
+        super(sqlUndoLog);
+    }
+
+    @Override
+    public String getDbType() {
+        return JdbcConstants.GAUSSDB;
+    }
+}

rm-datasource/src/main/java/io/seata/rm/datasource/undo/gaussdb/GaussDBUndoExecutorHolder.java

@@ -0,0 +1,47 @@
+/*
+ * 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 io.seata.rm.datasource.undo.gaussdb;
+
+import io.seata.common.loader.LoadLevel;
+import io.seata.rm.datasource.undo.AbstractUndoExecutor;
+import io.seata.rm.datasource.undo.SQLUndoLog;
+import io.seata.rm.datasource.undo.UndoExecutorHolder;
+import io.seata.sqlparser.util.JdbcConstants;
+
+/**
+ * Undo executor holder for GaussDB
+ *
+ */
+@LoadLevel(name = JdbcConstants.GAUSSDB)
+public class GaussDBUndoExecutorHolder implements UndoExecutorHolder {
+
+    @Override
+    public AbstractUndoExecutor getInsertExecutor(SQLUndoLog sqlUndoLog) {
+        return new GaussDBUndoInsertExecutor(sqlUndoLog);
+    }
+
+    @Override
+    public AbstractUndoExecutor getUpdateExecutor(SQLUndoLog sqlUndoLog) {
+        return new GaussDBUndoUpdateExecutor(sqlUndoLog);
+    }
+
+    @Override
+    public AbstractUndoExecutor getDeleteExecutor(SQLUndoLog sqlUndoLog) {
+        return new GaussDBUndoDeleteExecutor(sqlUndoLog);
+    }
+}