PolarDB-X 1.0-用户指南-分布式事务-基于 MySQL 5.6 的分布式事务

本文描述的分布式事务适用于MySQL 5.6版本，或版本早于5.3.4的DRDS实例。

基本原理

关于分布式事务的原理，详情请参见分布式事务基本原理。

对于 MySQL 5.6 版本，由于 MySQL XA 协议实现尚不成熟，PolarDB-X自主实现了 2PC 事务策略用于分布式事务。MySQL 5.7 及更高版本中，推荐您使用 XA 事务策略。

如何使用

如果某个事务可能涉及多个数据分库，则需要将当前事务声明为分布式事务。如果事务仅涉及单个数据分库，则无需开启分布式事务，直接像 MySQL 单机事务那样即可，无需额外操作。

分布式事务开启方式如下：

在事务开启后，执行 SET drds_transaction_policy = '...' 即可。

MySQL 命令行客户端使用示例（以2PC事务为例）

1. SET AUTOCOMMIT=0;
2. SET drds_transaction_policy ='2PC';--建议MySQL5.6用户使用
3. ....--业务 SQL
4. COMMIT;--或 ROLLBACK

Java JDBC 代码示例（以 2PC 事务为例）

1. conn.setAutoCommit(false);
2. try(Statement stmt = conn.createStatement()){
3.    stmt.execute("SET drds_transaction_policy = '2PC'");
4. }
5. // ... 运行业务 SQL ...
6. conn.commit();// 或 rollback()

常见问题

如何在 Spring 框架中使用PolarDB-X分布式事务？

如果使用 Spring 的 @Transactional 注解开启事务，可以通过扩展事务管理器来开启PolarDB-X分布式事务。

代码示例：

1. import org.springframework.jdbc.datasource.DataSourceTransactionManager;
2. import org.springframework.transaction.TransactionDefinition;
3. 
   
4. import javax.sql.DataSource;
5. import java.sql.Connection;
6. import java.sql.SQLException;
7. import java.sql.Statement;
8. 
   
9. publicclassDrdsTransactionManagerextendsDataSourceTransactionManager{
10. 
    
11.    publicDrdsTransactionManager(DataSource dataSource){
12.        super(dataSource);
13.    }
14. 
    
15.    @Override
16.    protectedvoid prepareTransactionalConnection(Connection con,TransactionDefinition definition)throwsSQLException{
17.        try(Statement stmt = con.createStatement()){
18.            stmt.executeUpdate("SET drds_transaction_policy = '2PC'");// 以 2PC 为例
19.        }
20.    }
21. }

之后，在 Spring 配置中将上述类实例化，例如：

1. id="drdsTransactionManager"class="my.app.DrdsTransactionManager">
2.     name="dataSource"ref="yourDataSource"/>
3. 
   

对于需要开启PolarDB-X分布式事务的类，加上注解 @Transactional("drdsTransactionManager") 即可。