spring+jotm+ibatis+mysql实现JTA分布式事务

1 环境

1.1 软件环境

 spring-framework-2.5.6.SEC01-with-dependencies.zip
 ibatis-2.3.4
 ow2-jotm-dist-2.1.4-bin.tar.gz
 MySQL-5.1
 JDK1.5

 

1.2 创建数据库环境

注意mysql里数据库引擎为InnoDB，只有这样才能支持事务。

CREATE DATABASE IF NOT EXISTS testdb_a    DEFAULT CHARACTER SET utf8; 

USE testdb_a; 

DROP TABLE IF EXISTS tab_a; 

CREATE TABLE tab_a ( 
    id bigint(20) NOT NULL, 
    name varchar(60) DEFAULT NULL, 
    address varchar(120) DEFAULT NULL, 
    PRIMARY KEY (id) 
) ENGINE=InnoDB DEFAULT CHARSET=utf8; 


CREATE DATABASE IF NOT EXISTS testdb_b    DEFAULT CHARACTER SET utf8; 

USE testdb_b; 

DROP TABLE IF EXISTS tab_b; 

CREATE TABLE tab_b ( 
    id bigint(20) NOT NULL, 
    name varchar(60) DEFAULT NULL, 
    address varchar(120) DEFAULT NULL, 
    PRIMARY KEY (id) 
) ENGINE=InnoDB DEFAULT CHARSET=utf8; 

2 建立项目testJOTM

2.1 建立项目后，准备依赖的类库，结构如下

2.2 主要代码

/**
 * 测试JOTM的Service
 *
 * @author leizhimin 2009-6-25 12:53:55
 */
public interface StuJotmService {
    /**
     * 同时保存TabA、TabB
     *
     * @param a
     *            TabA对象
     * @param b
     *            TabB对象
     */
    void saveAB(TabA a, TabB b);

    /**
     * 同时更新TabA、TabB
     *
     * @param a
     *            TabA对象
     * @param b
     *            TabB对象
     */
    void updateAB(TabA a, TabB b);

    /**
     * 删除指定id的TabA、TabB记录
     *
     * @param id
     *            指定id
     */
    void deleteABif(Long id);
}

public class StuJotmServiceImpl implements StuJotmService {
    private TabADAO tabADAO;
    private TabBDAO tabBDAO;

    /**
     * 同时保存TabA、TabB
     *
     * @param a
     *            TabA对象
     * @param b
     *            TabB对象
     */
//    @Transactional(readOnly=false)
    public void saveAB(TabA a, TabB b) {
        tabADAO.saveTabA(a);
        tabBDAO.saveTabB(b);
    }

    /**
     * 同时更新TabA、TabB
     *
     * @param a
     *            TabA对象
     * @param b
     *            TabB对象
     */
    // @Transactional(readOnly=false)
    public void updateAB(TabA a, TabB b) {
        tabADAO.updateTabA(a);
        tabBDAO.updateTabB(b);
    }

    /**
     * 删除指定id的TabA、TabB记录
     *
     * @param id
     *            指定id
     */
    // @Transactional(readOnly=false)
    public void deleteABif(Long id) {
        tabADAO.deleteTabAById(id);
        tabBDAO.deleteTabBById(id);
    }

    public void setTabADAO(TabADAO tabADAO) {
        this.tabADAO = tabADAO;
    }

    public void setTabBDAO(TabBDAO tabBDAO) {
        this.tabBDAO = tabBDAO;
    }
}

<?xml version="1.0" encoding="UTF-8"?>
<!-- 局部单元测试使用，不正式发布，不要删除 -->
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jee="http://www.springframework.org/schema/jee"
    xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
                     http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-2.0.xsd
                     http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.0.xsd
                     http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.0.xsd">

    <!--指定Spring配置中用到的属性文件 -->
    <bean id="propertyConfig"
        class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="locations">
            <list>
                <value>classpath:jdbc.properties</value>
            </list>
        </property>
    </bean>
    <!-- JOTM实例 -->
    <bean id="jotm" class="org.springframework.transaction.jta.JotmFactoryBean" />
    <!-- JTA事务管理器 -->
    <bean id="myJtaManager"
        class="org.springframework.transaction.jta.JtaTransactionManager">
        <property name="userTransaction">
            <ref local="jotm" />
        </property>
    </bean>
    <!-- 数据源A -->
    <bean id="dataSourceA" class="org.enhydra.jdbc.pool.StandardXAPoolDataSource"
        destroy-method="shutdown">
        <property name="dataSource">
            <bean class="org.enhydra.jdbc.standard.StandardXADataSource"
                destroy-method="shutdown">
                <property name="transactionManager" ref="jotm" />
                <property name="driverName" value="${jdbc.driver}" />
                <property name="url" value="${jdbc.url}" />
            </bean>
        </property>
        <property name="user" value="${jdbc.username}" />
        <property name="password" value="${jdbc.password}" />
    </bean>
    <!-- 数据源B -->
    <bean id="dataSourceB" class="org.enhydra.jdbc.pool.StandardXAPoolDataSource"
        destroy-method="shutdown">
        <property name="dataSource">
            <bean class="org.enhydra.jdbc.standard.StandardXADataSource"
                destroy-method="shutdown">
                <property name="transactionManager" ref="jotm" />
                <property name="driverName" value="${jdbc2.driver}" />
                <property name="url" value="${jdbc2.url}" />
            </bean>
        </property>
        <property name="user" value="${jdbc2.username}" />
        <property name="password" value="${jdbc.password}" />
    </bean>
    <!-- 事务切面配置 -->
    <aop:config>
        <aop:pointcut id="serviceOperation" expression="execution(* *..service*..*(..))" />
        <aop:advisor pointcut-ref="serviceOperation" advice-ref="txAdvice" />
    </aop:config>
    <!-- 通知配置 -->
    <tx:advice id="txAdvice" transaction-manager="myJtaManager">
        <tx:attributes>
            <tx:method name="delete*" rollback-for="Exception" />
            <tx:method name="save*" rollback-for="Exception" />
            <tx:method name="update*" rollback-for="Exception" />
            <tx:method name="*" read-only="true" rollback-for="Exception" />
        </tx:attributes>
    </tx:advice>

    <!--根据dataSourceA和sql-map-config_A.xml创建一个SqlMapClientA -->
    <bean id="sqlMapClientA" class="org.springframework.orm.ibatis.SqlMapClientFactoryBean">
        <property name="dataSource">
            <ref local="dataSourceA" />
        </property>
        <property name="configLocation">
            <value>sql-map-config_A.xml</value>
        </property>
    </bean>
    <!--根据dataSourceB和sql-map-config_B.xml创建一个SqlMapClientB -->
    <bean id="sqlMapClientB" class="org.springframework.orm.ibatis.SqlMapClientFactoryBean">
        <property name="dataSource">
            <ref local="dataSourceB" />
        </property>
        <property name="configLocation">
            <value>sql-map-config_B.xml</value>
        </property>
    </bean>
    <!--根据sqlMapClientA创建一个SqlMapClientTemplate的模版类实例sqlMapClientTemplateA -->
    <bean id="sqlMapClientTemplateA" class="org.springframework.orm.ibatis.SqlMapClientTemplate">
        <property name="sqlMapClient" ref="sqlMapClientA" />
    </bean>
    <!--根据sqlMapClientB创建一个SqlMapClientTemplate的模版类实例sqlMapClientTemplateB -->
    <bean id="sqlMapClientTemplateB" class="org.springframework.orm.ibatis.SqlMapClientTemplate">
        <property name="sqlMapClient" ref="sqlMapClientB" />
    </bean>

    <!-- 配置DAO，并注入所使用的sqlMapClientTemplate实例 -->
    <bean id="tabADAO" class="com.lavasoft.stu.jtom.dao.impl.TabADAOImpl">
        <property name="sqlMapClientTemplate" ref="sqlMapClientTemplateA" />
    </bean>
    <bean id="tabBDAO" class="com.lavasoft.stu.jtom.dao.impl.TabBDAOImpl">
        <property name="sqlMapClientTemplate" ref="sqlMapClientTemplateB" />
    </bean>

    <!-- Service配置，注入DAO -->
    <bean id="stuJotmService" class="com.lavasoft.stu.jtom.service.StuJotmServiceImpl">
        <property name="tabADAO" ref="tabADAO" />
        <property name="tabBDAO" ref="tabBDAO" />
    </bean>
</beans>

jdbc.database=cms_release
jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://192.168.0.1:3306/test?useUnicode=true&characterEncoding=utf8&autoReconnect=true&zeroDateTimeBehavior=convertToNull
jdbc.username=root
jdbc.password=123456

jdbc2.database=cms_release
jdbc2.driver=com.mysql.jdbc.Driver
jdbc2.url=jdbc:mysql://192.168.0.2:3306/test?useUnicode=true&characterEncoding=utf8&autoReconnect=true&zeroDateTimeBehavior=convertToNull
jdbc2.username=root
jdbc2.password=123456

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE sqlMapConfig
                PUBLIC "-//ibatis.apache.org//DTD SQL Map Config 2.0//EN"
                "http://ibatis.apache.org/dtd/sql-map-config-2.dtd">

<sqlMapConfig>
        <settings cacheModelsEnabled="true" enhancementEnabled="true"
                            lazyLoadingEnabled="true" errorTracingEnabled="true"
                            useStatementNamespaces="true"/>

        <sqlMap resource="com/lavasoft/stu/jtom/entity/sqlmap/TabA.xml"/>

</sqlMapConfig>

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE sqlMapConfig
                PUBLIC "-//ibatis.apache.org//DTD SQL Map Config 2.0//EN"
                "http://ibatis.apache.org/dtd/sql-map-config-2.dtd">

<sqlMapConfig>
        <settings cacheModelsEnabled="true" enhancementEnabled="true"
                            lazyLoadingEnabled="true" errorTracingEnabled="true"
                            useStatementNamespaces="true"/>

        <sqlMap resource="com/lavasoft/stu/jtom/entity/sqlmap/TabB.xml"/>

</sqlMapConfig>

public class Test {
    private static ApplicationContext ctx = ApplicationContextUtil.getApplicationContext();
    private static StuJotmService ser = (StuJotmService) ctx.getBean("stuJotmService");

    public static void test_() {
        TabA a = new TabA();
        a.setId(2L);
        a.setName("aaa4");
        a.setAddress("address a4");

        TabB b = new TabB();
        b.setId(3L);
        b.setName("bbb3");
        b.setAddress("address b5");
        
        ser.saveAB(a, b);
    }

    public static void main(String[] args) {
        test_();
    }
}

2.3 测试效果

先运行Test文件，可以看到两个库两个表都正常插入值。

 

再把TabA的setId改为其他任意一个长整型，那么TabB肯定会报主键重复错，因为TabB的setId没改，那么如果事务生效的话，最后应该是两张表都没插入值，如果事务没生效，那么TabA会插入一条新的数据。

 

 2.3 完整结构

 完整代码下载：