如何处理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 高焕杰 */@Overridepublic 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" ""><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>

人生伟业的建立 ,不在能知,乃在能行。

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

相关文章:

你感兴趣的文章:

标签云: