IT博客汇
  • 首页
  • 精华
  • 技术
  • 设计
  • 资讯
  • 扯淡
  • 权利声明
  • 登录 注册

    [原]如何处理Ibatis结合MySQL数据库使用时的事务操作

    wangshuxuncom发表于 2015-03-04 08:37:42
    love 0

    Ibatis是MyBatis的前身,它是一个开源的持久层框架。它的核心是SqlMap——将实体Bean跟关系数据库进行映射,将业务代码和SQL语句的书写进行分开。Ibatis是“半自动化”的ORM持久层框架。这里的“半自动化”是相对Hibernate等提供了全面的数据库封装机制的“全自动化”ORM实现而言的,“全自动”ORM实现了POJO与数据库表字段之间的映射并且实现了SQL的自动生成和执行。而Ibatis的着力点,则在于POJO与SQL之间的映射关系,即Ibatis并不会为程序员在运行期自动生成并执行SQL,具体的SQL语句需要程序员编写,然后通过映射配置文件将SQL语句所需的参数和返回的结果字段映射到指定POJO中。本篇博客演示了如何处理Ibatis结合MySQL数据库使用时的事务操作:

    工程结构如下图:


    由于该例子介绍的比较全面,文件比较多,这里只给出上图标出的两个文件中的代码,完整的源码可通过点击本文最下面的超链接下载:

    BankCardDao.java文件中的代码:

    package com.ghj.dao.imp;
    
    import java.io.IOException;
    import java.io.Reader;
    import java.sql.SQLException;
    import java.util.HashMap;
    import java.util.Map;
    
    import com.ghj.dao.IBankCardDao;
    import com.ibatis.common.resources.Resources;
    import com.ibatis.sqlmap.client.SqlMapClient;
    import com.ibatis.sqlmap.client.SqlMapClientBuilder;
    
    /**
     * 银行卡管理数据访问层接口实现类
     * 
     * @author 高焕杰
     */
    public class BankCardDao implements IBankCardDao {
    
    	private SqlMapClient sqlMapClient;
    
    	public BankCardDao() {
    		String resource = "config/sqlMapConfig.xml";
    		try {
    			Reader reader = Resources.getResourceAsReader(resource);//读取配置文件
    			sqlMapClient = SqlMapClientBuilder.buildSqlMapClient(reader);
    		} catch (IOException e) {
    			e.printStackTrace();
    		}
    	}
    	
    	/**
    	 * 转账
    	 * @param outAccount 转出账户
    	 * @param inAccount 转入账号
    	 * @param amountOfMoney 金额
    	 * 
    	 * @author 高焕杰
    	 */
    	@Override
    	public boolean transferAccounts(String outAccount, String inAccount, long amountOfMoney){
    		try {
    			sqlMapClient.startTransaction();
    			long outAccountDeposit = findDepositByAccount(outAccount);//转出账户的存款
    			long inAccountDeposit = findDepositByAccount(inAccount);//转入账户的存款
    			if(updateDepositByAccount(outAccountDeposit - amountOfMoney, outAccount)){//更新转出账号存款
    				updateDepositByAccount(inAccountDeposit + amountOfMoney, inAccount);//更新转入账号存款
    //				outAccount = null;
    //				System.out.println(outAccount.equals(inAccount));//故意出现异常以测试事务是否回滚
    			}
    			sqlMapClient.commitTransaction();
    			return true;
    		} catch (SQLException e) {
    			System.err.println("转账失败,事务回滚");
    			e.printStackTrace();
    		} finally {
    			try {
    				sqlMapClient.endTransaction();
    			} catch (SQLException e) {
    				System.err.println("转账失败,结束事务出现异常,事务回滚");
    				e.printStackTrace();
    			}
    		}
    		return false;
    	}
    
    	/**
    	 * 依据账号查询存款
    	 * @param deposit 存款
    	 * 
    	 * @author 高焕杰
    	 */
    	private long findDepositByAccount(String account) throws SQLException{
    		return (Long)sqlMapClient.queryForObject("findDepositByAccount", account);
    	}
    
    	/**
    	 * 依据账号更新存款
    	 * @param deposit 存款
    	 * @param account 账号
    	 * 
    	 * @author 高焕杰
    	 */
    	private boolean updateDepositByAccount(long deposit, String account) throws SQLException{
    		Map params = new HashMap();
    		params.put("deposit", deposit);
    		params.put("account", account);
    		return sqlMapClient.update("updateDepositByAccount", params) > 0;
    	}
    }

    bankcard.xml文件中的代码:

    
    
    
    
    	
    	
    
    	
    	
            update lm_bank_card set deposit=#deposit# where account=#account# 
    	
    

    【0分下载该示例代码】



沪ICP备19023445号-2号
友情链接