基于 MySQL 5.6 的分布式事务
⚠️ 本文描述的分布式事务针对 MySQL 5.6 版本用户,或 DRDS 版本低于 5.3.4 的用户。
基本原理
分布式事务的原理请参考文档 DRDS 分布式事务基本原理。
对于 MySQL 5.6 版本,由于 MySQL XA 协议实现尚不成熟,DRDS 自主实现了 2PC 事务策略用于分布式事务。MySQL 5.7 及更高版本中,推荐您使用 XA 事务策略。
如何使用
如果某个事务可能涉及多个数据分库,则需要将当前事务声明为分布式事务。如果事务仅涉及单个数据分库,则无需开启分布式事务,直接像 MySQL 单机事务那样即可,无需额外操作。
分布式事务开启方式如下:
在事务开启后,执行 SET drds_transaction_policy = '...'
即可。
MySQL 命令行客户端使用示例(以 2PC 事务为例)
SET AUTOCOMMIT=0;
SET drds_transaction_policy = '2PC'; -- 建议 MySQL 5.6 用户使用
.... -- 业务 SQL
COMMIT; -- 或 ROLLBACK
Java JDBC 代码示例(以 2PC 事务为例)
conn.setAutoCommit(false);
try (Statement stmt = conn.createStatement()) {
stmt.execute("SET drds_transaction_policy = '2PC'");
}
// ... 运行业务 SQL ...
conn.commit(); // 或 rollback()
常见问题
如何在 Spring 框架中使用 DRDS 分布式事务?
如果使用 Spring 的 @Transactional
注解开启事务,可以通过扩展事务管理器来开启 DRDS 分布式事务。
代码示例:
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.TransactionDefinition;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Statement;
public class DrdsTransactionManager extends DataSourceTransactionManager {
public DrdsTransactionManager(DataSource dataSource) {
super(dataSource);
}
@Override
protected void prepareTransactionalConnection(Connection con, TransactionDefinition definition) throws SQLException {
try (Statement stmt = con.createStatement()) {
stmt.executeUpdate("SET drds_transaction_policy = '2PC'"); // 以 2PC 为例
}
}
}
之后,在 Spring 配置中将上述类实例化,例如:
<bean id="drdsTransactionManager" class="my.app.DrdsTransactionManager">
<property name="dataSource" ref="yourDataSource" />
</bean>
对于需要开启 DRDS 分布式事务的类,加上注解 @Transactional("drdsTransactionManager")
即可。
版权声明
本文仅代表作者观点,不代表本站立场。
本文系作者授权发表,未经许可,不得转载。
评论