分布式事务操作之Spring+JTA+ibatis

来源：网络整理时间:2016-04-15 关键词:Spring,ibatis

本篇文章主要介绍了"分布式事务操作之Spring+JTA+ibatis"，主要涉及到Spring,ibatis方面的内容，对于软件工程感兴趣的同学可以参考一下：一、技术背景在项目中需要操作多个数据库，同时，需要保证操作的原子性，保证对多个数据库的操作一致性，而传统的JDBC事务被限定在一个单一的数据库连接中，故...

一、技术背景

    在项目中需要操作多个数据库，同时，需要保证操作的原子性，保证对多个数据库的操作一致性，而传统的JDBC事务被限定在一个单一的数据库连接中，故引用JTA，即Java Transaction API。JTA事务比JDBC事务更强大，一个JTA事务可以有多个数据源参与者。
    现在，我们用spring+jta+ibatis来完成基本的测试框架。

二、技术实现

第一步：导入JOTM Jar包

JOTM (Java Open Transaction Manager)，一个开源JTA实现，是由ObjectWeb协会开发的功能完整的独立的事务管理器。JOTM（ow2-jotm-dist-2.2.1-bin.tar.gz）下载地址：http://jotm.objectweb.org/download/index.html，解压tar包导入lib目录下的Jar包。或在Maven pom.xml中添加：

<dependency><groupId>org.ow2.jotmgroupId><artifactId>ow2-jotm-distartifactId><version>2.2.1version><type>pomtype><scope>compilescope>dependency>

第二步：创建JotmFactoryBean

spring为JOTM提供了一个org.springframework.transaction.jta.JotmFactoryBean支持类，通过该支持类可以方便地创建JOTM本地实例。但是spring3以后spring-tx.jar 没有JotmFactoryBean的支持，可以反编译spring2.5的spring-tx.jar，copy新建一个类。

import javax.naming.NamingException;
import javax.transaction.SystemException;
import org.objectweb.jotm.Current;
import org.objectweb.jotm.Jotm;
import org.springframework.beans.factory.DisposableBean;
import org.springframework.beans.factory.FactoryBean;

publicclassJotmFactoryBeanimplementsFactoryBean, DisposableBean {private Current jotmCurrent;
    private Jotm jotm;

    publicJotmFactoryBean() throws NamingException {
        jotmCurrent = Current.getCurrent();
        if (jotmCurrent == null) {
            jotm = new Jotm(true, false);
            jotmCurrent = Current.getCurrent();
        }
    }

    publicvoidsetDefaultTimeout(int defaultTimeout) {
        jotmCurrent.setDefaultTimeout(defaultTimeout);
        try {
            jotmCurrent.setTransactionTimeout(defaultTimeout);
        } catch (SystemException ex) {
        }
    }

    public Jotm getJotm() {
        return jotm;
    }

    public Object getObject() {
        return jotmCurrent;
    }

    public Class getObjectType() {
        return jotmCurrent.getClass();
    }

    publicbooleanisSingleton() {
        returntrue;
    }

    publicvoiddestroy() {
        if (jotm != null)
            jotm.stop();
    }

}

第三步：创建DAO

创建基于ibatis框架的DAO接口和实现类。

IBaseDao

import java.util.List;
import java.util.Map;

import org.apache.ibatis.session.SqlSession;

/**
 * Title： 
 * Description：  Dao 接口类
 */publicinterfaceIBaseDao {/**
     * 根据Id获取对象
     * 
     * @param id 主键
     * @param sqlId 脚本编号
     * @return Object对象
     */public Object queryForObject(int id, String sqlId);

    /**
     * 根据Id获取对象
     * 
     * @param id 主键
     * @param cls 返回的对象Class
     * @param sqlId 脚本编号
     * @return cls对应的类
     */public  T queryForObject(int id, Class cls, String sqlId);

    /**
     * 根据条件获取对象
     * 
     * @param params  参数
     * @param sqlId 脚本编号
     * @return Object对象
     */public Object queryForObject(Map params, String sqlId);

    /**
     * 根据条件获取对象
     * 
     * @param params 参数
     * @param cls 返回的对象Class
     * @param sqlId 脚本编号
     * @return cls对应的类
     */public  T queryForObject(Map params, Class cls, String sqlId);

    /**
     * 获取数据总条数
     * 
     * @param params 参数
     * @param sqlId 脚本编号
     * @return 条数
     */publicintgetTotalCount(Map params, String sqlId);

    /**
     * 查询列表
     * 
     * @param params 参数
     * @param cls 返回的对象Class
     * @param sqlId 脚本编号
     * @return 列表
     */public  List queryForList(Map params, Class cls, String sqlId);

    /**
     * 查询列表
     * 
     * @param params 参数
     * @param sqlId 脚本编号
     * @return 列表
     */public List<>> queryForList(Map params, String sqlId);

    /**
     * 修改数据
     * 
     * @param object 待更新对象
     * @param sqlId 脚本编号
     * @return 条数 
     */publicintupdate(Object object, String sqlId);

    /**
     * 插入数据
     * 
     * @param sqlId 脚本编号
     * @param object 待插入的对象
     * @return 条数
     */publicintinsert(Object object, String sqlId);

    /**
     * 删除数据
     * 
     * @param id 主键
     * @param sqlId 脚本编号
     * @return 条数
     */publicintdelete(int id, String sqlId);

    /**
     * 删除数据
     * 
     * @param map 待删除的对象
     * @param sqlId  脚本编号
     * @return 条数
     */publicintdelete(Map map, String sqlId);

    /**
     * 获取sqlSession
     * @return
     */public SqlSession getSqlSession();

    /**
     * 设置sqlSession
     * @param sqlSession
     */publicvoidsetSqlSession(SqlSession sqlSession);

}

BaseDaoImpl

import java.util.List;
import java.util.Map;

import org.apache.ibatis.session.SqlSession;

import com.ai.dimensyn.dao.common.IBaseDao;
import com.ai.frame.util.ConvertUtil;

/**
 * Title： 
 * Description：Dao接口实现类
 */publicclassBaseDaoImplimplementsIBaseDao {private SqlSession sqlSession;

    @Overridepublic SqlSession getSqlSession() {
        return sqlSession;
    }

    @OverridepublicvoidsetSqlSession(SqlSession sqlSession) {
        this.sqlSession = sqlSession;
    }

    @Overridepublic Object queryForObject(int id, String sqlId) {
        return getSqlSession().selectOne(sqlId, id);
    }

    @Override@SuppressWarnings("unchecked")
    public  T queryForObject(int id, Class cls, String sqlId) {
        return (T) getSqlSession().selectOne(sqlId, id);
    }

    @Overridepublic Object queryForObject(Map params, String sqlId) {
        return getSqlSession().selectOne(sqlId, params);
    }

    @Override@SuppressWarnings("unchecked")
    public  T queryForObject(Map params, Class cls, String sqlId) {
        return (T) getSqlSession().selectOne(sqlId, params);
    }

    @OverridepublicintgetTotalCount(Map params, String sqlId) {
        return (Integer) getSqlSession().selectOne(sqlId, params);
    }

    @Overridepublic  List queryForList(Map params, Class cls, String sqlId) {
        return getSqlSession().selectList(sqlId, params);
    }

    @Overridepublic List<>> queryForList(Map params, String sqlId) {
        List<>> list = getSqlSession().selectList(sqlId, params);
        List<>> beans = ConvertUtil.convertSqlMap2JavaMap(list);
        return beans;
    }

    @Overridepublicintupdate(Object object, String sqlId) {
        return getSqlSession().update(sqlId, object);
    }

    @Overridepublicintinsert(Object object, String sqlId) {
        return (Integer) getSqlSession().insert(sqlId, object);
    }

    @Overridepublicintdelete(int id, String sqlId) {
        return getSqlSession().delete(sqlId, id);
    }

    @Overridepublicintdelete(Map params, String sqlId) {
        return getSqlSession().delete(sqlId, params);
    }

}

IBaseMDao

import java.util.List;
import java.util.Map;

/**
 * Title： 
 * Description：  多数据源Dao接口类
 */publicinterfaceIBaseMDao {/**
     * 根据Id获取对象
     * 
     * @param id 主键
     * @param sqlIds 脚本编号
     * @return Object对象
     */public Object[] queryForObject(int id, String... sqlIds);

    /**
     * 根据Id获取对象
     * 
     * @param id 主键
     * @param cls 返回的对象Class
     * @param sqlIds 脚本编号
     * @return cls对应的类
     */public  T[] queryForObject(int id, Class cls, String... sqlIds);

    /**
     * 根据条件获取对象
     * 
     * @param params 参数
     * @param sqlIds 脚本编号
     * @return Object对象
     */public Object[] queryForObject(Map params, String... sqlIds);

    /**
     * 根据条件获取对象
     * 
     * @param params 参数
     * @param cls 返回的对象Class
     * @param sqlIds 脚本编号
     * @return cls对应的类
     */public  T[] queryForObject(Map params, Class cls, String... sqlIds);

    /**
     * 获取数据总条数
     * 
     * @param params 参数
     * @param sqlIds 脚本编号
     * @return 条数
     */publicint[] getTotalCount(Map params, String... sqlIds);

    /**
     * 查询列表
     * 
     * @param params 参数
     * @param cls 返回的对象Class
     * @param sqlIds 脚本编号
     * @return 列表
     */public  List[] queryForList(Map params, Class cls, String... sqlIds);

    /**
     * 查询列表
     * 
     * @param params 参数
     * @param sqlIds 脚本编号
     * @return 列表
     */public List<>>[] queryForList(Map params, String... sqlIds);

    /**
     * 修改数据
     * 
     * @param object 待更新对象
     * @param sqlIds 脚本编号
     * @return 条数 
     */publicint[] update(Object object, String... sqlIds);

    /**
     * 插入数据
     * 
     * @param object 待插入的对象
     * @param sqlIds 脚本编号
     * @return 条数
     */publicint[] insert(Object object, String... sqlIds);

    /**
     * 删除数据
     * 
     * @param id 主键
     * @param sqlIds
     * @return 条数
     */publicint[] delete(int id, String... sqlIds);

    /**
     * 删除数据
     * 
     * @param params 参数
     *  @param sqlIds  脚本编号
     * @return 条数
     */publicint[] delete(Map params, String... sqlIds);
    /**
     * 先删数据，后插入
     * @param params
     * @param delSqlId
     * @param insertSqlId
     * @return
     */publicint[] executeDeleteInsert(Map params, String delSqlId, String insertSqlId);
}

BaseMDaoImpl

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.ResourceBundle;

import javax.transaction.UserTransaction;

import org.apache.ibatis.session.SqlSession;
import org.springframework.transaction.jta.JtaTransactionManager;

/**
 * Title： 
 * Description：多数据源Dao接口实现类
 */publicclassBaseMDaoImplimplementsIBaseMDao {privatestatic ResourceBundle resources;

    private JtaTransactionManager transactionManager;

    private IBaseDao baseDao = new BaseDaoImpl();

    static {
        resources = ResourceBundle.getBundle("config/mybaties");
    }

    /**
     * dmcWeb SqlSession
     */private SqlSession dmcWebSession;

    /**
     * dmcWeb DataSource key
     */private String dmcWebSrcKey;
    /**
     * rpt_web SqlSession
     */private SqlSession rptWebSession;

    /**
     * rpt_web DataSource key
    */private String rptWebSrcKey;

    /**
     * idxWeb SqlSession
     */private SqlSession idxWebSession;

    /**
     * idxWeb DataSource key
     */private String idxWebSrcKey;

    /**
     * default DataSource key
     */private String defaultSrcKey;

    public JtaTransactionManager getTransactionManager() {
        return transactionManager;
    }

    publicvoidsetTransactionManager(JtaTransactionManager transactionManager) {
        this.transactionManager = transactionManager;
    }

    public SqlSession getDmcWebSession() {
        return dmcWebSession;
    }

    publicvoidsetDmcWebSession(SqlSession dmcWebSession) {
        this.dmcWebSession = dmcWebSession;
    }

    public String getDmcWebSrcKey() {
        return dmcWebSrcKey;
    }

    publicvoidsetDmcWebSrcKey(String dmcWebSrcKey) {
        this.dmcWebSrcKey = dmcWebSrcKey;
    }

    public SqlSession getIdxWebSession() {
        return idxWebSession;
    }

    publicvoidsetIdxWebSession(SqlSession idxWebSession) {
        this.idxWebSession = idxWebSession;
    }

    public String getIdxWebSrcKey() {
        return idxWebSrcKey;
    }

    publicvoidsetIdxWebSrcKey(String idxWebSrcKey) {
        this.idxWebSrcKey = idxWebSrcKey;
    }

    public SqlSession getRptWebSession() {
        return rptWebSession;
    }

    publicvoidsetRptWebSession(SqlSession rptWebSession) {
        this.rptWebSession = rptWebSession;
    }

    public String getRptWebSrcKey() {
        return rptWebSrcKey;
    }

    publicvoidsetRptWebSrcKey(String rptWebSrcKey) {
        this.rptWebSrcKey = rptWebSrcKey;
    }

    public String getDefaultSrcKey() {
        return defaultSrcKey;
    }

    publicvoidsetDefaultSrcKey(String defaultSrcKey) {
        this.defaultSrcKey = defaultSrcKey;
    }

    /**
     * 获取sqlSession
     * @param sqlId
     * @return
     */private SqlSession getSqlSession(String sqlId) {
        String srcKey = null;

        try {
            srcKey = resources.getString(sqlId);
        } catch (Exception e) {

        }

        if (null == srcKey) {
            srcKey = defaultSrcKey;
        }

        if (dmcWebSrcKey.equals(srcKey)) {
            return dmcWebSession;
        } elseif (idxWebSrcKey.equals(srcKey)) {
            return idxWebSession;
        } elseif (rptWebSrcKey.equals(srcKey)) {
            return rptWebSession;
        } else {
            thrownew NullPointerException("SqlSession null: " + sqlId);
        }
    }

    @Overridepublic Object[] queryForObject(int id, String... sqlIds) {
        Object[] results = new Object[sqlIds.length];
        for (int i = 0; i < sqlIds.length; i++) {
            baseDao.setSqlSession(getSqlSession(sqlIds[i]));
            results[i] = baseDao.queryForObject(id, sqlIds[i]);
        }
        return results;
    }

    @Override@SuppressWarnings("unchecked")
    public  T[] queryForObject(int id, Class cls, String... sqlIds) {
        T[] results = (T[])new Object[sqlIds.length];
        for (int i = 0; i < sqlIds.length; i++) {
            baseDao.setSqlSession(getSqlSession(sqlIds[i]));
            results[i] = baseDao.queryForObject(id, cls, sqlIds[i]);
        }
        return results;
    }

    @Overridepublic Object[] queryForObject(Map params, String... sqlIds) {
        Object[] results = new Object[sqlIds.length];
        for (int i = 0; i < sqlIds.length; i++) {
            baseDao.setSqlSession(getSqlSession(sqlIds[i]));
            results[i] = baseDao.queryForObject(params, sqlIds[i]);
        }
        return results;
    }

    @Override@SuppressWarnings("unchecked")
    public  T[] queryForObject(Map params, Class cls, String... sqlIds) {
        T[] results = (T[])new Object[sqlIds.length];
        for (int i = 0; i < sqlIds.length; i++) {
            baseDao.setSqlSession(getSqlSession(sqlIds[i]));
            results[i] = baseDao.queryForObject(params, cls, sqlIds[i]);
        }
        return results;
    }

    @Overridepublicint[] getTotalCount(Map params, String... sqlIds) {
        int[] results = newint[sqlIds.length];
        for (int i = 0; i < sqlIds.length; i++) {
            baseDao.setSqlSession(getSqlSession(sqlIds[i]));
            results[i] = baseDao.getTotalCount(params, sqlIds[i]);
        }
        return results;
    }

    @Override@SuppressWarnings("unchecked")
    public  List[] queryForList(Map params, Class cls, String... sqlIds) {
        List[] results = new ArrayList[sqlIds.length];
        for (int i = 0; i < sqlIds.length; i++) {
            baseDao.setSqlSession(getSqlSession(sqlIds[i]));
            results[i] = baseDao.queryForList(params, cls, sqlIds[i]);
        }
        return results;
    }

    @Override@SuppressWarnings("unchecked")
    public List<>>[] queryForList(Map params, String... sqlIds) {
        List<>>[] results = new ArrayList[sqlIds.length];
        for (int i = 0; i < sqlIds.length; i++) {
            baseDao.setSqlSession(getSqlSession(sqlIds[i]));
            //单独改造，满足根据 table&方法 共同决定切换数据源
            System.out.println(sqlIds[i].substring(0, sqlIds[i].indexOf("-")));
            results[i] = baseDao.queryForList(params, sqlIds[i].substring(0, sqlIds[i].indexOf("-")));
        }
        return results;
    }

    @Overridepublicint[] update(Object object, String... sqlIds) {
        int[] results = newint[sqlIds.length];
        UserTransaction transaction = this.transactionManager.getUserTransaction();
        try {
            transaction.begin();
            for (int i = 0; i < sqlIds.length; i++) {
                baseDao.setSqlSession(getSqlSession(sqlIds[i]));
                results[i] = baseDao.update(object, sqlIds[i]);
            }
            transaction.commit();
        } catch (Exception e1) {
            try {
                transaction.rollback();
            } catch (Exception e2) {
                thrownew RuntimeException(e2);
            }
            thrownew RuntimeException(e1);
        }
        return results;
    }

    @Overridepublicint[] insert(Object object, String... sqlIds) {
        int[] results = newint[sqlIds.length];
        UserTransaction transaction = this.transactionManager.getUserTransaction();
        try {
            transaction.begin();
            for (int i = 0; i < sqlIds.length; i++) {
                baseDao.setSqlSession(getSqlSession(sqlIds[i]));
                results[i] = baseDao.insert(object, sqlIds[i]);
            }
            transaction.commit();
        } catch (Exception e1) {
            try {
                transaction.rollback();
            } catch (Exception e2) {
                thrownew RuntimeException(e2);
            }
            thrownew RuntimeException(e1);
        }
        return results;
    }

    @Overridepublicint[] delete(int id, String... sqlIds) {
        int[] results = newint[sqlIds.length];
        UserTransaction transaction = this.transactionManager.getUserTransaction();
        try {
            transaction.begin();
            for (int i = 0; i < sqlIds.length; i++) {
                baseDao.setSqlSession(getSqlSession(sqlIds[i]));
                results[i] = baseDao.delete(id, sqlIds[i]);
            }
            transaction.commit();
        } catch (Exception e1) {
            try {
                transaction.rollback();
            } catch (Exception e2) {
                thrownew RuntimeException(e2);
            }
            thrownew RuntimeException(e1);
        }
        return results;
    }

    @Overridepublicint[] delete(Map params, String... sqlIds) {
        int[] results = newint[sqlIds.length];
        UserTransaction transaction = this.transactionManager.getUserTransaction();
        try {
            transaction.begin();
            for (int i = 0; i < sqlIds.length; i++) {
                baseDao.setSqlSession(getSqlSession(sqlIds[i]));
                results[i] = baseDao.delete(params, sqlIds[i]);
            }
            transaction.commit();
        } catch (Exception e1) {
            try {
                transaction.rollback();
            } catch (Exception e2) {
                thrownew RuntimeException(e2);
            }
            thrownew RuntimeException(e1);
        }
        return results;
    }

    @Overridepublicint[] executeDeleteInsert(Map params, String delSqlId, String insertSqlId) {
        UserTransaction transaction = this.transactionManager.getUserTransaction();
        try {
            transaction.begin();
            baseDao.setSqlSession(getSqlSession(delSqlId));
            baseDao.delete(params, delSqlId.substring(0, delSqlId.indexOf("-")));
            baseDao.setSqlSession(getSqlSession(insertSqlId));
            //对sql进行；分隔 迭代插入
            String[] strsOfSql = params.get(Constants.SQL).split(";");
            Map sqlMap = new HashMap();
            for (String sql : strsOfSql) {
                sqlMap.put(Constants.SQL, sql);
                baseDao.insert(sqlMap, insertSqlId.substring(0,insertSqlId.indexOf("-")));
                sqlMap.clear();
            }
            transaction.commit();
        } catch (Exception e1) {
            try {
                transaction.rollback();
            } catch (Exception e2) {
                thrownew RuntimeException(e2);
            }
            thrownew RuntimeException(e1);
        }
        returnnull;
    }

}

第四步：XML配置

<beansxmlns="http://www.springframework.org/schema/beans"xmlns:context="http://www.springframework.org/schema/context"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:p="http://www.springframework.org/schema/p"xsi:schemaLocation="
    http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
    http://www.springframework.org/schema/context
    http://www.springframework.org/schema/context/spring-context.xsd
    "><beanid="SpringFactory"class="com.ai.dimensyn.util.SpringFactory" /><beanid="jotm"class="com.ai.dimensyn.dynamicDataSoure.JotmFactoryBean" /><beanid="transactionManager"class="org.springframework.transaction.jta.JtaTransactionManager"><propertyname="userTransaction"ref="jotm">property>bean><beanid="dmcWebSession"class="org.mybatis.spring.SqlSessionTemplate"><constructor-argindex="0"ref="dmcWebSessionFactory" />bean><beanid="idxWebSession"class="org.mybatis.spring.SqlSessionTemplate"><constructor-argindex="0"ref="idxWebSessionFactory" />bean><beanid="rptWebSession"class="org.mybatis.spring.SqlSessionTemplate"><constructor-argindex="0"ref="rptWebSessionFactory" />bean><beanid="dmcWebSessionFactory"class="org.mybatis.spring.SqlSessionFactoryBean"><propertyname="configLocation"value="classpath:orm/Configuration.xml">property><propertyname="dataSource"ref="dataSourceDmcWeb">property>bean><beanid="idxWebSessionFactory"class="org.mybatis.spring.SqlSessionFactoryBean"><propertyname="configLocation"value="classpath:orm/Configuration.xml">property><propertyname="dataSource"ref="dataSourceIdxWeb">property>bean><beanid="rptWebSessionFactory"class="org.mybatis.spring.SqlSessionFactoryBean"><propertyname="configLocation"value="classpath:orm/Configuration.xml">property><propertyname="dataSource"ref="dataSourceRptWeb">property>bean><beanid="dataSourceDmcWeb"class="org.enhydra.jdbc.pool.StandardXAPoolDataSource"destroy-method="shutdown"><propertyname="dataSource"><beanclass="org.enhydra.jdbc.standard.StandardXADataSource"destroy-method="shutdown"><propertyname="transactionManager"ref="jotm" /><propertyname="driverName"value="com.mysql.jdbc.Driver" /><propertyname="url"value="jdbc:mysql://ip:port/dmc?useUnicode=true&characterEncoding=utf-8" /><propertyname="user"value="xxx" /><propertyname="password"value="xxx" />bean>property><propertyname="user"value="xxx" /><propertyname="password"value="xxx" />bean><beanid="dataSourceIdxWeb"class="org.enhydra.jdbc.pool.StandardXAPoolDataSource"destroy-method="shutdown"><propertyname="dataSource"><beanclass="org.enhydra.jdbc.standard.StandardXADataSource"destroy-method="shutdown"><propertyname="transactionManager"ref="jotm" /><propertyname="driverName"value="com.mysql.jdbc.Driver" /><propertyname="url"value="jdbc:mysql://ip:port/idx_web?useUnicode=true&characterEncoding=utf-8" /><propertyname="user"value="xxx" /><propertyname="password"value="xxx" />bean>property><propertyname="user"value="xxx" /><propertyname="password"value="xxx" />bean><beanid="dataSourceRptWeb"class="org.enhydra.jdbc.pool.StandardXAPoolDataSource"destroy-method="shutdown"><propertyname="dataSource"><beanclass="org.enhydra.jdbc.standard.StandardXADataSource"destroy-method="shutdown"><propertyname="transactionManager"ref="jotm" /><propertyname="driverName"value="com.mysql.jdbc.Driver" /><propertyname="url"value="jdbc:mysql://v/rpt_web?useUnicode=true&characterEncoding=utf-8" /><propertyname="user"value="xxx" /><propertyname="password"value="xxx" />bean>property><propertyname="user"value="xxx" /><propertyname="password"value="xxx" />bean><beanid="baseMDao"class="com.ai.dimensyn.dao.common.impl.BaseMDaoImpl" ><propertyname="transactionManager"ref="transactionManager"/><propertyname="dmcWebSession"ref="dmcWebSession"/><propertyname="dmcWebSrcKey"value="dmcWeb">property><propertyname="idxWebSession"ref="idxWebSession"/><propertyname="idxWebSrcKey"value="indexWeb">property><propertyname="rptWebSession"ref="rptWebSession"/><propertyname="rptWebSrcKey"value="reportWeb">property><propertyname="defaultSrcKey"value="dmcWeb ">property>bean>beans>

SpringFactory：

import org.springframework.beans.BeansException;
import org.springframework.beans.factory.BeanFactory;
import org.springframework.beans.factory.BeanFactoryAware;

publicclassSpringFactoryimplementsBeanFactoryAware {privatestatic BeanFactory beanFactory;  

    // private static ApplicationContext context;  publicvoidsetBeanFactory(BeanFactory factory) throws BeansException {  
        this.beanFactory = factory;  
    }  

    /** 
     * 根据beanName名字取得bean 
     *  
     * @param beanName 
     * @return     */publicstatic  T getBean(String beanName) {  
        if (null != beanFactory) {  
            return (T) beanFactory.getBean(beanName);  
        }  
        returnnull;  
    }  

}

第五步：测试

在后台测试分布式事务管理：

private IBaseMDao baseMDao = SpringFactory.getBean("baseMDao");

publicvoidtestBaseMDao() {
    try {
        Map params = new HashMap();
        params.put("table_tb",table);
        params.put(Constants.SQL,sql);
        baseMDao.executeDeleteInsert(params,"dimensyn.deleteDimenTable"+"-"+table, "dimensyn.insertDimenTable"+"-"+table);

    } catch (Exception e) {
        e.printStackTrace();
    }
}

public IBaseMDao getBaseMDao() {
    return baseMDao;
}

publicvoidsetBaseMDao(IBaseMDao baseMDao) {
    this.baseMDao = baseMDao;
}

在indexWeb、dmcWeb库中创建测试表，并插入测试数据，配置：

<mappernamespace="dimensyn"><selectid="queryDimenColName"parameterType="java.util.Map"resultType="java.util.Map">
        select DISTINCT column_name from information_schema.columns where table_name = #{table_tb,jdbcType=VARCHAR}
    select><selectid="queryDimenTable"parameterType="java.util.Map"resultType="java.util.Map">
        select * from ${table_tb}
    select><deleteid="deleteDimenTable"parameterType="java.util.Map">
        delete from ${table_tb}
    delete><insertid="insertDimenTable"parameterType="java.util.Map">insert>mapper>

Configuration.xml
<configuration><mappers><mapperresource="orm/mapping/dimensynMapper.xml"/>mappers>configuration>mybaties.properties：
dimensyn.deleteDimenTable-testtable_xuchun=indexWeb
dimensyn.insertDimenTable-testtable_xuchun=dmcWeb

').addClass('pre-numbering').hide(); $(this).addClass('has-numbering').parent().append($numbering); for (i = 1; i <= lines; i++) { $numbering.append($('

').text(i)); }; $numbering.fadeIn(1700); }); });

以上就介绍了分布式事务操作之Spring+JTA+ibatis，包括了Spring,ibatis方面的内容，希望对软件工程有兴趣的朋友有所帮助。

本文网址链接：http://www.codes51.com/article/detail_706118.html

上一篇：数据中心解决方案安全技术 下一篇：大话设计模式1：初识设计模式及设计模式五大基本原则

分布式事务操作之Spring+JTA+ibatis

相关图片

相关文章