MyBatis+Spring 事务管理，mybatisspring,在网上查了MyBatis

MyBatis+Spring 事务管理，mybatisspring,在网上查了MyBatis

在网上查了MyBatis+Spring的结合,真的是太多太多了,可是没有几个代码是完整的..这两项整合花了我两天时间,终于被我整合完成...其实也很简单,原因:JAR包的问题... 由于Ibatis被改名为MyBatis,所以,网上很多都是有关Ibatis而MyBatis却很少很少...本文以MyBatis3.0.6 +Spring3.0.6为例结合(一定要这个版本才行):出处：http://kinglixing.blog.51cto.com/3421535/723870

实体类:Emp.java

package com.lixing.scm.entity;public class Emp {  private String id;  private String name;  private String sex;  private int age;  private String phone;  public String getId() {    return id;  }  public void setId(String id) {    this.id = id;  }  public String getName() {    return name;  }  public void setName(String name) {    this.name = name;  }  public String getSex() {    return sex;  }  public void setSex(String sex) {    this.sex = sex;  }  public int getAge() {    return age;  }  public void setAge(int age) {    this.age = age;  }  public String getPhone() {    return phone;  }  public void setPhone(String phone) {    this.phone = phone;  }}

定义实体内操作接口:EmpMapper.java

package com.lixing.scm.test.mapper;import java.util.List;import java.util.Map;import com.lixing.scm.entity.Emp;public interface EmpMapper {  void insertEmp(Emp emp);  List<Emp> getAllEmp();  Emp getById(String id);  void deleteEmp(String id);  void updateEmp(Map<String,Object> map);}

定义实体类操作接口的映射文件:EmpMapper.xml

<?xml version="1.0" encoding="UTF-8" ?> <!DOCTYPE mapper        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"                "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="com.lixing.scm.test.mapper.EmpMapper">   <parameterMap type="com.lixing.scm.entity.Emp" id="parameterMapEmp">    <parameter property="id"/>    <parameter property="name"/>    <parameter property="sex"/>    <parameter property="age"/>    <parameter property="phone"/>  </parameterMap>  <resultMap type="com.lixing.scm.entity.Emp" id="resultMapEmp">    <result property="id" column="id"/>    <result property="name" column="name"/>    <result property="sex" column="sex"/>    <result property="age" column="age"/>    <result property="phone" column="phone"/>  </resultMap>  <insert id="insertEmp" parameterMap="parameterMapEmp">    INSERT INTO emp(id,name,sex,age,phone)    VALUES(?,?,?,?,?)  </insert>  <select id="getAllEmp"    resultMap="resultMapEmp">    SELECT * FROM emp  </select>  <select id="getById" parameterType="String" resultMap="resultMapEmp">    SELECT * FROM emp    WHERE id=#{value}  </select>  <delete id="deleteEmp" parameterType="String">    DELETE FROM emp     WHERE id=#{value}  </delete>  <update id="updateEmp" parameterType="java.util.Map">    UPDATE emp    SET name=#{name},sex=#{sex},age=#{age},phone=#{phone}    WHERE id=#{id}  </update></mapper>

Spring3.0.6定义:applicationContext.xml

<?xml version="1.0" encoding="UTF-8"?><beans xmlns="http://www.springframework.org/schema/beans"  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"   xmlns:context="http://www.springframework.org/schema/context"  xmlns:aop="http://www.springframework.org/schema/aop"  xmlns:tx="http://www.springframework.org/schema/tx"  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-3.0.xsd         http://www.springframework.org/schema/tx         http://www.springframework.org/schema/tx/spring-tx-3.0.xsd         http://www.springframework.org/schema/aop          http://www.springframework.org/schema/aop/spring-aop-3.0.xsd">  <!--    -->  <context:annotation-config />  <context:component-scan base-package="com.lixing.scm.test.*" />  <!-- jdbc.propertis Directory -->  <bean    class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">    <property name="locations" value="classpath:jdbc.properties" />  </bean>  <bean id="MyDataSource" destroy-method="close"    class="org.apache.commons.dbcp.BasicDataSource">    <property name="driverClassName" value="${jdbc.driverClassName}" />    <property name="url" value="${jdbc.url}" />    <property name="username" value="${jdbc.username}" />    <property name="password" value="${jdbc.password}" />  </bean>  <!-- SqlSessionFactory -->  <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">    <property name="dataSource" ref="MyDataSource" />  </bean>  <!-- ScanMapperFiles -->  <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">    <property name="basePackage" value="com.lixing.scm.test.mapper" />  </bean>  <!-- ================================事务相关控制=================================================    -->  <bean name="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">               <property name="dataSource" ref="MyDataSource"></property>    </bean>       <tx:advice id="userTxAdvice" transaction-manager="transactionManager">    <tx:attributes>      <tx:method name="delete*" propagation="REQUIRED" read-only="false"                             rollback-for="java.lang.Exception" no-rollback-for="java.lang.RuntimeException"/>      <tx:method name="insert*" propagation="REQUIRED" read-only="false"                             rollback-for="java.lang.RuntimeException" />      <tx:method name="update*" propagation="REQUIRED" read-only="false"                             rollback-for="java.lang.Exception" />      <tx:method name="find*" propagation="SUPPORTS"/>      <tx:method name="get*" propagation="SUPPORTS"/>      <tx:method name="select*" propagation="SUPPORTS"/>    </tx:attributes>  </tx:advice>  <aop:config>        <aop:pointcut id="pc" expression="execution(public * com.lixing.scm.test.service.*.*(..))" /> <!--把事务控制在Service层-->    <aop:advisor pointcut-ref="pc" advice-ref="userTxAdvice" />  </aop:config>  <!-- 以下为自定义Bean-->  <bean id="empDao" class="com.lixing.scm.test.dao.impl.EmpDaoImpl"    autowire="byName" />    <bean id="empService" class="com.lixing.scm.test.service.impl.EmpServiceImpl"    autowire="byName"/></beans>

DAO接口:EmpDAO.java

package com.lixing.scm.test.dao;import java.util.List;import java.util.Map;import com.lixing.scm.entity.Emp;public interface EmpDao {  void insertEmp(Emp emp);  List<Emp> getAllEmp();  Emp getById(String id);  void deleteEmp(String id);  void updateEmp(Map<String, Object> map);}

DAO接口实现类：EmpDaoImpl.java

package com.lixing.scm.test.dao.impl;import java.util.List;import java.util.Map;import com.lixing.scm.entity.Emp;import com.lixing.scm.test.dao.EmpDao;import com.lixing.scm.test.mapper.EmpMapper;public class EmpDaoImpl implements EmpDao {  private EmpMapper empMapper;   //在此处注入一个empMapper                        //这个empMapper由 Spring自动生成                       //不需要我们自己手工去定义  @Override  public void insertEmp(Emp emp) {    this.empMapper.insertEmp(emp);    throw new RuntimeException("Error");   //测试抛出RuntimeException                           //异常查看数据库是否存在记录  }  @Override  public void deleteEmp(String id) {    this.empMapper.deleteEmp(id);  }  @Override  public List<Emp> getAllEmp() {    return this.empMapper.getAllEmp();  }  @Override  public Emp getById(String id) {    return this.empMapper.getById(id);  }  @Override  public void updateEmp(Map<String, Object> map) {    this.empMapper.updateEmp(map);  }  public EmpMapper getEmpMapper() {    return empMapper;  }  public void setEmpMapper(EmpMapper empMapper) {    this.empMapper = empMapper;  }}

Service层接口:EmpService.java

package com.lixing.scm.test.service;import com.lixing.scm.entity.Emp;public interface EmpService {  void insertEmp(Emp emp);}

Service层接口实现类:EmpServiceImpl.java

package com.lixing.scm.test.service.impl;import com.lixing.scm.entity.Emp;import com.lixing.scm.test.dao.EmpDao;import com.lixing.scm.test.service.EmpService;public class EmpServiceImpl implements EmpService {  private EmpDao empDao;  @Override  public void insertEmp(Emp emp) {    empDao.insertEmp(emp);  }  public EmpDao getEmpDao() {    return empDao;  }  public void setEmpDao(EmpDao empDao) {    this.empDao = empDao;  }}

测试类:TestEmpService.java

import org.junit.Test;import org.springframework.context.ApplicationContext;import org.springframework.context.support.ClassPathXmlApplicationContext;import com.lixing.scm.entity.Emp;import com.lixing.scm.test.service.EmpService;public class TestEmpService {  @Test  public void testTrasaction(){    Emp emp=new Emp();    emp.setId("00000003");    emp.setName("某某某");    emp.setAge(50);    emp.setSex("男");    emp.setPhone("566666");    ApplicationContext ctx=new ClassPathXmlApplicationContext("classpath:applicationContext.xml");    EmpService service=ctx.getBean(EmpService.class);    service.insertEmp(emp);  }}