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

        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<String, Object> params = new HashMap<String, Object>();
		params.put("deposit", deposit);
		params.put("account", account);
		return sqlMapClient.update("updateDepositByAccount", params) > 0;
	}
}

        bankcard.xml文件中的代码：

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

	<!-- 依据账号查询存款 -->
	<select id="findDepositByAccount" parameterClass="string" resultClass="long">
		select deposit from lm_bank_card where account=#account# 
	</select>

	<!-- 依据账号更新存款 -->
	<update id="updateDepositByAccount" parameterClass="java.util.HashMap">
        update lm_bank_card set deposit=#deposit# where account=#account# 
	</update>
</sqlMap>

        【0分下载该示例代码】