feature: support shentongdatabase xa mode (#7664)

Author: dsomehan

.github/workflows/test-druid.yml

@@ -42,6 +42,11 @@ jobs:
       fail-fast: false
       matrix:
         druid: [
+          1.2.25,
+#          1.2.24, #The source code depends on guava, resulting in a class not found, see the commit https://github.com/alibaba/druid/commit/f060c2701587948380bd0d07d5baf4f774c06e8a#diff-5200f514252efbc0c4b2dc51ebad5d840b4b3065b9556eb4368bd3476d4c220eR25
+          1.2.23,
+          1.2.22,
+          1.2.21,
           1.2.20,
           1.2.19,
           #1.2.18, # Unit test triggered a bug in Druid, see the commit https://github.com/alibaba/druid/commit/6c493f852852fb287ed5fd31ee16c27ead0ea5cf

changes/en-us/2.x.md

@@ -26,6 +26,7 @@ Add changes here for all PR submitted to the 2.x branch.
 - [[#7551](https://github.com/apache/incubator-seata/pull/7551)] XAUtils add support for DM Database
 - [[#7559](https://github.com/apache/incubator-seata/pull/7559)] Introduce Cleanup API for TableMetaRefreshHolder Instance
 - [[#7669](https://github.com/apache/incubator-seata/pull/7669)] add support for Jackson serialization and deserialization of PostgreSQL array types
+- [[#7664](https://github.com/apache/incubator-seata/pull/7664)] support shentongdatabase XA mode
 
 ### bugfix:
 
@@ -107,5 +108,6 @@ Thanks to these contributors for their code commits. Please report an unintended
 - [YoWuwuuuw](https://github.com/YoWuwuuuw)
 - [jihun4452](https://github.com/jihun4452)
 - [psxjoy](https://github.com/psxjoy)
+- [dsomehan](https://github.com/dsomehan)
 
 Also, we receive many valuable issues, questions and advices from our community. Thanks for you all.

changes/zh-cn/2.x.md

@@ -26,6 +26,7 @@
 - [[#7551](https://github.com/apache/incubator-seata/pull/7551)] XAUtils支持达梦数据库
 - [[#7559](https://github.com/apache/incubator-seata/pull/7559)] 为 TableMetaRefreshHolder 实例引入清理 API
 - [[#7669](https://github.com/apache/incubator-seata/pull/7669)] 添加对 Jackson 序列化和反序列化 PostgreSQL 数组类型的支持
+- [[#7664](https://github.com/apache/incubator-seata/pull/7565)] 支持神通数据库的XA模式
 
 
 ### bugfix:
@@ -109,5 +110,7 @@
 - [YoWuwuuuw](https://github.com/YoWuwuuuw)
 - [jihun4452](https://github.com/jihun4452)
 - [psxjoy](https://github.com/psxjoy)
+- [dsomehan](https://github.com/dsomehan)
+
 
 同时，我们收到了社区反馈的很多有价值的issue和建议，非常感谢大家。

compatible/src/test/java/io/seata/rm/datasource/xa/DataSourceProxyXATest.java

@@ -17,6 +17,7 @@
 package io.seata.rm.datasource.xa;
 
 import com.alibaba.druid.pool.DruidDataSource;
+import com.alibaba.druid.pool.DruidStatementConnection;
 import com.mysql.jdbc.JDBC4MySQLConnection;
 import com.mysql.jdbc.jdbc2.optional.JDBC4ConnectionWrapper;
 import io.seata.core.context.RootContext;
@@ -66,6 +67,7 @@ public void testGetConnection() throws SQLException {
 
         DruidDataSource druidDataSource = new DruidDataSource();
         druidDataSource.setDriver(driver);
+        druidDataSource.setUrl("jdbc:mysql:xxx");
         DataSourceProxyXA dataSourceProxyXA = new DataSourceProxyXA(druidDataSource);
         RootContext.unbind();
         Connection connFromDataSourceProxyXA = dataSourceProxyXA.getConnection();
@@ -79,6 +81,9 @@ public void testGetConnection() throws SQLException {
         Assertions.assertTrue(wrappedConnection instanceof PooledConnection);
 
         Connection wrappedPhysicalConn = ((PooledConnection) wrappedConnection).getConnection();
+        if (wrappedPhysicalConn instanceof DruidStatementConnection) {
+            wrappedPhysicalConn = ((DruidStatementConnection) wrappedPhysicalConn).getConnection();
+        }
         Assertions.assertSame(wrappedPhysicalConn, connection);
 
         XAConnection xaConnection = connectionProxyXA.getWrappedXAConnection();
@@ -101,6 +106,7 @@ public void testGetMariaXaConnection() throws SQLException, ClassNotFoundExcepti
 
         DruidDataSource druidDataSource = new DruidDataSource();
         druidDataSource.setDriver(driver);
+        druidDataSource.setUrl("jdbc:mariadb:xxx");
         DataSourceProxyXA dataSourceProxyXA = new DataSourceProxyXA(druidDataSource);
         RootContext.unbind();
         Connection connFromDataSourceProxyXA = dataSourceProxyXA.getConnection();
@@ -115,6 +121,9 @@ public void testGetMariaXaConnection() throws SQLException, ClassNotFoundExcepti
         Assertions.assertTrue(wrappedConnection instanceof PooledConnection);
 
         Connection wrappedPhysicalConn = ((PooledConnection) wrappedConnection).getConnection();
+        if (wrappedPhysicalConn instanceof DruidStatementConnection) {
+            wrappedPhysicalConn = ((DruidStatementConnection) wrappedPhysicalConn).getConnection();
+        }
         Assertions.assertSame(wrappedPhysicalConn, connection);
 
         XAConnection xaConnection = connectionProxyXA.getWrappedXAConnection();

dependencies/pom.xml

@@ -114,8 +114,9 @@
         <h2.version>1.4.181</h2.version>
         <mariadb.version>2.7.2</mariadb.version>
         <kingbase.version>9.0.0</kingbase.version>
+        <oscar.version>4.1.152</oscar.version>
         <!-- db connection pool -->
-        <druid.version>1.2.20</druid.version>
+        <druid.version>1.2.25</druid.version>
         <commons-dbcp2.version>2.9.0</commons-dbcp2.version>
         <hikari.version>3.4.3</hikari.version>
         <caffeine.version>2.9.3</caffeine.version>
@@ -924,6 +925,11 @@
                 <artifactId>kingbase8</artifactId>
                 <version>${kingbase.version}</version>
             </dependency>
+            <dependency>
+                <groupId>com.shentongdata</groupId>
+                <artifactId>oscarJDBC8</artifactId>
+                <version>${oscar.version}</version>
+            </dependency>
         </dependencies>
     </dependencyManagement>
 </project>

distribution/LICENSE

@@ -221,7 +221,7 @@ Apache-2.0 licenses
     com.alibaba.nacos:nacos-api 1.4.6 Apache-2.0
     com.alibaba.nacos:nacos-client 1.4.6 Apache-2.0
     com.alibaba.nacos:nacos-common 1.4.6 Apache-2.0
-    com.alibaba:druid 1.2.20 Apache-2.0
+    com.alibaba:druid 1.2.25 Apache-2.0
     com.alibaba:fastjson 1.2.83 Apache-2.0
     com.alibaba.fastjson2:fastjson2 2.0.52 Apache-2.0
     com.alipay.sofa.common:sofa-common-tools 1.0.12 Apache-2.0

distribution/LICENSE-server

@@ -243,7 +243,7 @@ Apache-2.0 licenses
     org.apache.curator:curator-test 5.1.0 Apache-2.0
     com.lmax:disruptor 3.3.7 Apache-2.0
     com.dameng:DmJdbcDriver18 8.1.2.192 Apache-2.0
-    com.alibaba:druid 1.2.20 Apache-2.0
+    com.alibaba:druid 1.2.25 Apache-2.0
     com.google.errorprone:error_prone_annotations 2.21.1 Apache-2.0
     com.netflix.eureka:eureka-client 1.10.18 Apache-2.0
     net.jodah:failsafe 2.3.3 Apache-2.0

distribution/NOTICE.md

@@ -562,7 +562,7 @@ Please copy database driver dependencies, such as `mysql-connector-java.jar`, to
     │   ├── curator-test-5.1.0.jar
     │   ├── dexx-collections-0.2.jar
     │   ├── disruptor-3.3.7.jar
-    │   ├── druid-1.2.20.jar
+    │   ├── druid-1.2.25.jar
     │   ├── error_prone_annotations-2.21.1.jar
     │   ├── eureka-client-1.10.18.jar
     │   ├── failsafe-2.3.3.jar
@@ -1719,7 +1719,7 @@ Please copy database driver dependencies, such as `mysql-connector-java.jar`, to
     │   ├── curator-test-5.1.0.jar
     │   ├── dexx-collections-0.2.jar
     │   ├── disruptor-3.3.7.jar
-    │   ├── druid-1.2.20.jar
+    │   ├── druid-1.2.25.jar
     │   ├── error_prone_annotations-2.21.1.jar
     │   ├── eureka-client-1.10.18.jar
     │   ├── failsafe-2.3.3.jar

rm-datasource/pom.xml

@@ -154,5 +154,10 @@
             <artifactId>kingbase8</artifactId>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>com.shentongdata</groupId>
+            <artifactId>oscarJDBC8</artifactId>
+            <scope>test</scope>
+        </dependency>
     </dependencies>
 </project>

rm-datasource/src/main/java/org/apache/seata/rm/datasource/util/XAUtils.java

@@ -70,6 +70,8 @@ public static XAConnection createXAConnection(Connection physicalConn, Driver dr
                         return PGUtils.createXAConnection(physicalConn);
                     case JdbcConstants.KINGBASE:
                         return createXAConnection(physicalConn, "com.kingbase8.xa.KBXAConnection", dbType);
+                    case JdbcConstants.OSCAR:
+                        return createXAConnection(physicalConn, "com.oscar.xa.Jdbc3XAConnection", dbType);
                     case JdbcConstants.DM:
                         return createXAConnection(physicalConn, "dm.jdbc.driver.DmdbXAConnection", dbType);
                     default:
@@ -118,6 +120,8 @@ private static Constructor<XAConnection> getConstructorByDBType(Class xaConnecti
                     return xaConnectionClass.getConstructor(kingbaseConnectionClass);
                 case JdbcConstants.DM:
                     return xaConnectionClass.getConstructor(Connection.class);
+                case JdbcConstants.OSCAR:
+                    return xaConnectionClass.getConstructor(Connection.class);
                 default:
                     throw new SQLException("xa reflect not support dbType: " + dbType);
             }
@@ -143,6 +147,9 @@ private static <T> List<T> getInitargsByDBType(String dbType, Object... params)
                 case JdbcConstants.KINGBASE:
                     result.add(params[0]);
                     return result;
+                case JdbcConstants.OSCAR:
+                    result.add(params[0]);
+                    return result;
                 case JdbcConstants.MARIADB:
                     Class mariaDbConnectionClass = Class.forName("org.mariadb.jdbc.MariaDbConnection");
                     if (mariaDbConnectionClass.isInstance(params[0])) {