ibatis快速入门及与spring调整事务管理

ibatis快速入门及与spring整合事务管理

ibatis学习（一）--ibatis介绍以及用例

ibatis学习（二）--ibatis使用介绍

ibatis学习（三）---ibatis与spring的整合

介绍

iBATIS是以SQL为中心的持久化层框架。能支持懒加载、关联查询、继承等特性。

iBATIS不同于一般的OR映射框架(eg:hibernate)。OR映射框架，将数据库表、字段等映射到类、属性，那是一种元数据(meta-data)映射。iBATIS则是将SQL查询的参数和结果集映射到类。因此可以说，iBATIS做的是SQL Mapping的工作。它把SQL语句看成输入以及输出，结果集就是输出，而where后面的条件参数则是输入。iBATIS能将输入的普通POJO对象、Map、XML等映射到SQL的条件参数上，同时也可以将查询结果映射到普通POJO对象（集合）、Map、XML等上面。

iBATIS使用xml文件来映射这些输入以及输出。能大大减少数据库存储部分的代码量，而且可以非常方便的利用SQL中的一些小技巧。

简单示例

基于ibatis-2.3.0.677版本。

1、?创建新的项目，并引入jar包

a)???????? ibatis-2.3.0.677.jar

b)??????? mysql驱动

2、?在类路径中（classes下）提供ibatis的配置文件：sqlMapConfig.xml

<?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">

?<transactionManager type="JDBC" commitRequired="false">

??? <dataSource type="SIMPLE">

????? <property name="JDBC.Driver" value="com.mysql.jdbc.Driver"/>

????? <property name="JDBC.ConnectionURL" value="jdbc:mysql://127.0.0.1/ibatis"/>

????? <property name="JDBC.Username" value="root"/>

????? <property name="JDBC.Password" value="mysql"/>

??? </dataSource>

?</transactionManager>

?<sqlMap resource="com/ibatis/model/User.xml"/>

</sqlMapConfig>

3、创建实体类：User.java

package com.ibatis.model;

publicclass User {

??? privateintid;

??? private String username;

??? private String password;

???

??? publicint getId() {

?????? returnid;

??? }

??? publicvoid setId(int id) {

?????? this.id = id;

??? }

??? public String getPassword() {

?????? returnpassword;

??? }

??? publicvoid setPassword(String password) {

?????? this.password = password;

??? }

??? public String getUsername() {

?????? returnusername;

??? }

??? publicvoid setUsername(String username) {

?????? this.username = username;

??? }

}

4、创建针对User对象的CRUD的xml映射配置:User.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">

?

?<typeAlias alias="User" type="com.ibatis.model.User"/>

?

?<select id="selectAllUsers" resultClass="User">

??? select * from t_user

?</select>

?<select id="selectUser" resultClass="User" parameterClass="int">

??select * from t_user where id=#id#

?</select>

?<insert id="insertUser" parameterClass="User">

??insert into t_user values (

?????? null,#username#,#password#

??)

?</insert>

?<update id="updateUser" parameterClass="User">

??update t_user set username = #username#,password=#password#

??where id=#id#

?</update>

?<delete id="deleteUser" parameterClass="int">

??delete from t_user where id=#id#

?</delete>

</sqlMap>

5、创建测试程序测试：

package com.crm.model;

import java.io.Reader;

import java.util.Iterator;

import java.util.List;

import com.ibatis.common.resources.Resources;

import com.ibatis.sqlmap.client.SqlMapClient;

import com.ibatis.sqlmap.client.SqlMapClientBuilder;

/**

?*最简单的形式！

?*@authorq

?*/

publicclass UserTest {

??? /**

??? ?*@paramargs

??? ?*/

??? publicstaticvoid main(String[] args) throws Exception{

?????? //从配置文件中得到SqlMapClient对象

?????? Reader reader = Resources.getResourceAsReader("sqlMapConfig.xml");

?????? SqlMapClient sqlMapper = SqlMapClientBuilder.buildSqlMapClient(reader);

?????? reader.close();

??????

?????? //创建用户数据

?????? for(int i=0; i<10; i++){

?????????? User user = new User();

?????????? user.setUsername("用户"+i);

?????????? user.setPassword("密码"+i);

?????????? sqlMapper.insert("insertUser", user);

?????? }

??????

?????? //查询用户数据

?????? List users = sqlMapper.queryForList("selectAllUsers");

?????? for (Iterator iter = users.iterator(); iter.hasNext();) {

?????????? User user = (User) iter.next();

?????????? System.out.println(user.getUsername());

?????? }

??????

?????? //查询特定用户的数据

?????? User user = (User)sqlMapper.queryForObject("selectUser", 1);

?????? System.out.println("用户【id="+1+"】的名称是："+user.getUsername());

??????

?????? //更新用户的信息

?????? user = new User();

?????? user.setId(3);

?????? user.setUsername("更改之后的用户名称");

?????? user.setPassword("密码被更改");

?????? sqlMapper.update("updateUser", user);

??????

?????? //删除用户的信息

?????? sqlMapper.delete("deleteUser", 6);

??? }

}

?SqlMapClient对象

这个对象是iBatis操作数据库的接口（执行CRUD等操作），它也可以执行事务管理等操作。这个类是我们使用iBATIS的最主要的类。它是线程安全的。通常，将它定义为单例。（与hibernate中sessionFactory的定义类似）。如：

import java.io.Reader;

import com.ibatis.common.resources.Resources;

import com.ibatis.sqlmap.client.SqlMapClient;

import com.ibatis.sqlmap.client.SqlMapClientBuilder;

public class IbatisSQLMapConfig {

??? private static final SqlMapClient sqlMap;

??? //在静态区块中初试化返回

??? static {

??????? try {

??????????? //声明配置文件的名称（映射文件被定义在其中）

??????????? String resource = "sql_map_config.xml";

??????????? //利用工具类Resources来读取到配置文件

??????????? Reader reader = Resources.getResourceAsReader(resource);

??????????? //创建SqlMapClient接口的变量实例

??????????? sqlMap = SqlMapClientBuilder.buildSqlMapClient(reader);

??????? } catch (Exception e) {

?? ?????????e.printStackTrace();

??????????? throw new RuntimeException(

??????????????????? "Error initializing MyAppSqlConfig class. Cause: " + e);

??????? }

??? }

??? public static SqlMapClient getSqlMapInstance() {

??????? //提供静态方法返回静态区块中得到的SqlMapClient

??????? return sqlMap;

??? }

}

主要用法：如何获得刚插入记录的自增长ID值？

以下所有虚线上面代表User.xml中的内容，虚线下方是测试类中的内容：User类沿用上一篇中的User类

?<insert id="insertUser" parameterClass="User">

??insert into t_user values (

?????? null,#username#,#password#

??)

??<selectKey resultClass="int" keyProperty="id">

?????? SELECT @@IDENTITY AS ID

??</selectKey>?

?</insert>

?????? User user = new User();

?????? user.setUsername("张三");

?????? user.setPassword("张三密码");

??????

?????? //如果主键是自动生成的，则其返回值可以通过<selectKey>标签来设置

?????? //如果不通过<selectKey>标签来设置，则返回值为空！

?????? //<selectKey >中的keyProperty，是指定User中的id属性，当调用结束之后，

?????? //user对象的id值和insert方法的返回值都是这条记录的ID值！

?????? Object obj?= sqlMapper.insert("insertUser", user);

parameterClass的使用

?<insert id="insertUser" parameterClass="User">

??insert into t_user values (

?????? null,#username#,#password#

??)

??<selectKey resultClass="int" keyProperty="id">

?????? SELECT @@IDENTITY AS ID

??</selectKey>?

?</insert>

?<insert id="insertUser2">

??insert into t_user values (

?????? null,#username#,#password#

??)

??<selectKey resultClass="int" keyProperty="id">

?????? SELECT @@IDENTITY AS ID

??</selectKey>?

?</insert>

insertUser使用了parameterClass，所以必需传入User类型的对象

?????? User user = new User();

?????? user.setUsername("张三");

?????? user.setPassword("张三密码");

??????

?????? //传递进去的对象，必须是User类型

?????? Object obj?= sqlMapper.insert("insertUser", user);

insertUser2没有使用parameterClass，所以可以传入任意具有相应属性值的对象

?????? JustAnObject anobj = new JustAnObject();

?????? anobj.setUsername("用户名");

?????? anobj.setPassword("用户密码");

??????

?????? //如果没有指定parameterClass属性，则任何一个具有相应属性值

?????? //的对象都可以被传递进去

?????? Object obj?= sqlMapper.insert("insertUser2", anobj);

parameterMap的使用

?<parameterMap class="User" id="insertUser-param">

??<parameter property="username"/>

??<parameter property="password"/>

?</parameterMap>

?<insert id="insertUser" parameterMap="insertUser-param">

??insert into t_user values (

?????? null,?,?

??)

??<selectKey resultClass="int" keyProperty="id">

?????? SELECT @@IDENTITY AS ID

??</selectKey>?

?</insert>

parameterMap用于传入参数，以便匹配SQL语句中的?号

?????? User user = new User();

?????? user.setUsername("张三dd");

?????? user.setPassword("张三密码dd");

??????

?????? Object obj?= sqlMapper.insert("insertUser", user);

利用parameterMap，可以定义参数对象的属性如何映射到SQL查询语句的动态参数上，注意parameterMap中<parameter/>标签的先后顺序不能颠倒！

如何将查询结果映射到不同的对象？(resultClass的使用)

package com.ibatis.model;

publicclassOtherObject {

??? privateintid;

??? private String prop1;

??? private String prop2;

???

??? publicint getId() {

?????? returnid;

??? }

??? publicvoid setId(int id) {

?????? this.id = id;

??? }

??? public String getProp1() {

?????? return Prop1;

??? }

??? publicvoid set Prop1 (String Prop1) {

?????? this. Prop1 = Prop1;

??? }

??? public String getProp2() {

?????? returnusername;

??? }

??? publicvoid setProp2 (String Prop2) {

?????? this.Prop2 = Prop2;

??? }

}

?<select id="selectUserForOtherObject" resultClass="com. ibatis.OtherObject" parameterClass="int">

??select

??username as prop1,

??password as prop2

??from t_user where id=#value#

?</select>

?????? //查找t_user表，将其结果映射到一个属性名不同的对象中！

?????? OtherObject obj = (OtherObject)sqlMapper.queryForObject("selectUserForOtherObject", 1);

?????? System.out.println(obj.getProp1()+","+obj.getProp2());

如何将查询结果集映射到不同的对象？(resultMap的基本使用)

?<resultMap class="com.ibatis.model.OtherObject" id="ooResult">

??<result property="prop1" column="username"/>

??<result property="prop2" column="password"/>

?</resultMap>

?<!--

?如果使用resultMap来定义如何映射，则如下语句不可写成：

?select username as prop1,password as prop2 ....

?-->

?<select id="selectUserForOtherObject2" parameterClass="int" resultMap="ooResult">

??? ??select

??? ??username,

??? ??password

??? ??from t_user where id=#value#

?</select>

?????? //查找t_user表，将其结果映射到一个属性名不同的对象中！

?????? OtherObject obj = (OtherObject)sqlMapper.queryForObject("selectUserForOtherObject2", 17);

?????? System.out.println(obj.getProp1()+","+obj.getProp2());

如何将查询结果集映射为xml格式的数据？

?<select id="selectXmlData" resultClass="xml" xmlResultName="User" parameterClass="int">

??select * from t_user where id=#value#

?</select>

?<select id="selectXmlDatas" resultClass="xml" xmlResultName="User">

??select * from t_user

?</select>

?????? //查找t_user表，将其结果映射到xml！

?????? //返回值是xml形式的字符串

?????? Object obj = (Object)sqlMapper.queryForObject("selectXmlData", 1);

?????? System.out.println(obj);

?????? //查找t_user表，将其结果映射到xml！

?????? List list ?= (List)sqlMapper.queryForList("selectXmlDatas");

?????? System.out.println(list);

如何用Map类型的对象作为传入参数？

?<!--

?这里，可以使用全路径类名，如：

?java.util.Map

?java.util.HashMap

?java.util.TreeMap

?或

?map

?-->

?<insert id="insertUser" parameterClass="map">

??insert into t_user values (

?????? null,#username#,#password#

??)

?</insert>

?????? Map user = new TreeMap();

?????? user.put("username", "Map用户");

?????? user.put("password", "Map用户密码");

?????? sqlMapper.insert("insertUser",user);

如何将查询结果集的元素转换为Map类型的对象？

?<!--

?resultClass可以定义为java.util.HashMap类型，

?将能自动转换

?-->

?<select id="selectMapUsers" resultClass="java.util.HashMap">

??select * from t_user

?</select>

?????? List list = (List)sqlMapper.queryForList("selectMapUsers");

?????? System.out.println(list);

?????? for (Iterator iter = list.iterator(); iter.hasNext();) {

?????????? Map map = (Map) iter.next();

?????????? //可在此输出map的数据

?????? }

事务处理

可以使用sqlMapClient的startTransaction/commitTransaction/endTransaction等方法来控制事务的边界。

如果与spring整合（这是iBatis推荐的方式），则我们需要在spring配置文件中指定其事务特性。

Spring通过DAO模式，提供了对iBATIS的良好支持。SqlMapClient对象是iBATIS中的主要对象，我们可以通过配置让spring来管理SqlMapClient对象的创建。

与hibernate类似，Spring 提供了SqlMapClientDaoSupport对象，我们的DAO可以继承这个类，通过它所提供的SqlMapClientTemplate对象来操纵数据库。看起来这些概念都与hibernate类似。

通过SqlMapClientTemplate来操纵数据库的CRUD是没有问题的，这里面关键的问题是事务处理。Spring提供了强大的声明式事务处理的功能，我们已经清楚hibernate中如何配置声明式的事务，那么在iBATIS中如何获得声明式事务的能力呢？

第一，我们需要了解的是spring通过AOP来拦截方法的调用，从而在这些方法上面添加声明式事务处理的能力。典型配置如下：applicationContext-common.xml

???

??? <tx:advice id="txAdvice" transaction-manager="事务管理器名称">

??? ??? <tx:attributes>

?????????? <tx:method name="add*" propagation="REQUIRED"/>

?????????? <tx:method name="del*" propagation="REQUIRED"/>

?????????? <tx:method name="update*" propagation="REQUIRED"/>

?????????? <tx:method name="*" read-only="true"/>

?????? </tx:attributes>

??? </tx:advice>

???

???

??? <aop:config>

?????? <aop:pointcut id="allManagerMethod" expression="execution(* com.ibatis.manager.*.*(..))"/>

?????? <aop:advisor advice-ref="txAdvice" pointcut-ref="allManagerMethod"/>

??? </aop:config>

这些事务都是声明在业务逻辑层的对象上的。

第二，我们需要一个事务管理器，对事务进行管理。

??? <bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">

??? <property name="dataSource" ref="dataSource"/>

??? </bean>

??? <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">

??????? <property name="driverClassName" value="com.mysql.jdbc.Driver"/>

??????? <property name="url" value="jdbc:mysql://127.0.0.1/ibatis"/>

??????? <property name="username" value="root"/>

??????? <property name="password" value="mysql"/>

??? </bean>

此后，我们需要让spring来管理SqlMapClient对象：

??? <bean id="sqlMapClient" class="org.springframework.orm.ibatis.SqlMapClientFactoryBean">

?????? <property name="configLocation"><value>classpath:sqlMapConfig.xml</value></property>

??? </bean>

我们的sqlMapConfig.xml就可以简写为：

<?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">

??? <settings

?????? lazyLoadingEnabled="true"

??? ??? useStatementNamespaces="true" />

???

??<sqlMap resource="com/ibatis/dao/impl/ibatis/User.xml"/>

</sqlMapConfig>

User.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">

?

?<typeAlias alias="User" type="com.ibatis.User"/>

?

?<select id="selectAllUsers" resultClass="User">

??? select * from t_user

?</select>

?<select id="selectUser" resultClass="User" parameterClass="int">

??select * from t_user where id=#id#

?</select>

?<insert id="insertUser" parameterClass="User">

??insert into t_user values (

?????? null,#username#,#password#

??)

?</insert>

?<update id="updateUser" parameterClass="User">

??update t_user set username = #username#,password=#password#

??where id=#id#

??</update>

?<delete id="deleteUser" parameterClass="int">

??delete from t_user where id=#id#

?</delete>

</sqlMap>

我们的DAO的编写：

package com.iabtis.dao.impl.ibatis;

import java.util.List;

import org.springframework.orm.ibatis.support.SqlMapClientDaoSupport;

import com.ibatis.dao.UserDAO;

import com.ibatis.crm.model.User;

public class UserDAOImpl extends SqlMapClientDaoSupport implements UserDAO {

??? public void select(User user) {

????????????? getSqlMapClientTemplate().delete("selectUser ",user.getId());

?????? }

???public List findAll() {

????????????? return getSqlMapClientTemplate().queryForList("selectAllUsers ");

?????? }

?????? public void delete(User user) {

????????????? getSqlMapClientTemplate().delete("deleteUser ",user.getId());

?????? }

?????? public void save(User user) {

????????????? getSqlMapClientTemplate().insert("insertUser ",user);

?????? }

?????? public void update(User user) {

????????????? getSqlMapClientTemplate().update("updateUser ",user);

?????? }

}

继承SqlMapClientDaoSupport，要求我们注入SqlMapClient对象，因此，需要有如下的DAO配置：

???? <property name=”sqlMapClient” ref=”sqlMapClient”/>

</bean>

这就是所有需要注意的问题了，此后就可以在业务逻辑层调用DAO对象了！

ibatis快速入门及与spring调整事务管理

热点推荐