程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> JAVA編程 >> 關於JAVA >> 詳解Java的MyBatis框架和Spring框架的整合應用

詳解Java的MyBatis框架和Spring框架的整合應用

編輯:關於JAVA

詳解Java的MyBatis框架和Spring框架的整合應用。本站提示廣大學習愛好者:(詳解Java的MyBatis框架和Spring框架的整合應用)文章只能為提供參考,不一定能成為您想要的結果。以下是詳解Java的MyBatis框架和Spring框架的整合應用正文


零丁應用mybatis是有許多限制的(好比沒法完成逾越多個session的事務),並且許多營業體系原來就是應用spring來治理的事務,是以mybatis最好與spring集成起來應用。

版本請求

項目

版本

下載地址

解釋

mybatis

3.0及以上

https://github.com/mybatis/mybatis-3/releases

 

spring

3.0及以上

http://projects.spring.io/spring-framework/

 

mybatis-spring

1.0及以上

https://github.com/mybatis/spring/releases

 


spring事務設置裝備擺設

<!-- 主動掃描營業包 --> 
<context:component-scan base-package="com.xxx.service" /> 
 
<!-- 數據源 --> 
<jee:jndi-lookup id="jndiDataSource" jndi-name="java:comp/env/jdbc/datasource" /> 
 
<!-- 設置裝備擺設事務 --> 
<bean id="txManager" 
    class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> 
  <property name="dataSource" ref="jndiDataSource" /> 
</bean> 
<!-- 設置裝備擺設基於注解的事物aop --> 
<tx:annotation-driven transaction-manager="txManager" proxy-target-class="true"/> 

單個集成

<!-- 集成mybatis --> 
<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"> 
  <property name="dataSource" ref="jndiDataSource" /> 
  <property name="configLocation" value="classpath:/mybatis/mybatis-config.xml" /> 
  <!-- 主動設置裝備擺設別號 --> 
  <property name="typeAliasesPackage" value="com.xxx.dto" /> 
</bean> 
 
<!--創立dao bean(只需供給接口不需供給完成類 )--> 
<bean id="userDao" class="org.mybatis.spring.mapper.MapperFactoryBean"> 
  <property name="mapperInterface" value="com.xxx.dao.UserDao" /> 
  <property name="sqlSessionFactory" ref="sqlSessionFactory" /> 
</bean> 

我們不只要明確若何應用,更要明確為何要這麼應用。

SqlSessionFactoryBean是一個工場bean,它的感化就是解析設置裝備擺設(數據源、別號等)。

MapperFactoryBean是一個工場bean,在spring容器裡,工場bean是有特別用處的,當spring將工場bean注入到其他bean裡時,它不是注入工場bean自己而是挪用bean的getObject辦法。我們接上去就看看這個getObjec辦法干了些甚麼:

public T getObject() throws Exception { 
 return getSqlSession().getMapper(this.mapperInterface); 
} 

看到這裡年夜家應當就很明確了,這個辦法和我們之前零丁應用Mybatis的方法是一樣的,都是先獲得一個Sqlsession對象,然後再從Sqlsession裡獲得Mapper對象(再次強調Mapper是一個署理對象,它署理的是mapperInterface接口,而這個接口是用戶供給的dao接口)。天然,終究注入到營業層就是這個Mapper對象。

現實的項目普通來講不止一個Dao,假如你有多個Dao那就依照下面的設置裝備擺設順次設置裝備擺設便可。

若何應用批量更新
前一節講了若何注入一個mapper對象到營業層, mapper的行動依附於設置裝備擺設,mybatis默許應用單個更新(即ExecutorType默許為SIMPLE而不是BATCH),固然我們可以經由過程修正mybatis設置裝備擺設文件來修正默許行動,但假如我們只想讓某個或某幾個mapper應用批量更新就不得行了。這個時刻我們就須要應用模板技巧:

<!--經由過程模板定制mybatis的行動 --> 
lt;bean id="sqlSessionTemplateSimple" class="org.mybatis.spring.SqlSessionTemplate">   
<constructor-arg index="0" ref="sqlSessionFactory" /> 
<!--更新采取單個形式 --> 
<constructor-arg index="1" value="SIMPLE"/> 
</bean> 
   
<!--經由過程模板定制mybatis的行動 --> 
lt;bean id="sqlSessionTemplateBatch" class="org.mybatis.spring.SqlSessionTemplate">   
<constructor-arg index="0" ref="sqlSessionFactory" /> 
<!--更新采取批量形式 --> 
<constructor-arg index="1" value="BATCH"/> 
</bean> 

這裡筆者界說了兩個模板對象,一個應用單個更新,一個應用批量更新。有了模板以後我們便可以轉變mapper的行動方法了:

<bean id="userDao" class="org.mybatis.spring.mapper.MapperFactoryBean"> 
  <property name="mapperInterface" value="com.xxx.dao.UserDao" /> 
  <property name="sqlSessionTemplate" ref=" sqlSessionTemplateBatch " /> 
</bean> 

 
跟上一節的mapper設置裝備擺設分歧的是,這裡不須要設置裝備擺設sqlSessionFactory屬性,只須要設置裝備擺設sqlSessionTemplate(sqlSessionFactory屬性在模板裡曾經設置裝備擺設好了)。

經由過程主動掃描簡化mapper的設置裝備擺設
後面的章節可以看到,我們的dao須要一個一個的設置裝備擺設在設置裝備擺設文件中,假如有許多個dao的話設置裝備擺設文件就會異常年夜,如許治理起來就會比擬苦楚。幸虧mybatis團隊也認識到了這點,他們應用spring供給的主動掃描功效封裝了一個主動掃描dao的對象類,如許我們便可以應用這個功效簡化設置裝備擺設:

<!-- 采取主動掃描方法創立mapper bean(單個更新形式) --> 
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer"> 
  <property name="basePackage" value="com.xxx.dao" /> 
  <property name="sqlSessionTemplateBeanName" value="sqlSessionTemplateSimple" /> 
  <property name="markerInterface" value="com.xxx.dao.SimpleDao" /> 
</bean> 
    
<!-- 采取主動掃描方法創立mapper bean(批量更新形式) --> 
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer"> 
  <property name="basePackage" value="com.xxx.dao" /> 
  <property name="sqlSessionTemplateBeanName" value="sqlSessionTemplateBatch" /> 
  <property name="markerInterface" value="com.xxx.dao.BatchDao" /> 
</bean> 

MapperScannerConfigurer自己觸及的spring的技巧我就不多講了,感興致且對spring道理比擬懂得的可以去看下它的源碼。我們重點看一下它的三個屬性:

  • basePackage:掃描器開端掃描的基本包名,支撐嵌套掃描;
  • sqlSessionTemplateBeanName:前文提到的模板bean的稱號;
  • markerInterface:基於接口的過濾器,完成了該接口的dao才會被掃描器掃描,與basePackage是與的感化。

除應用接口過濾外,還可以使用注解過濾:

<!-- 采取主動掃描方法創立mapper bean(批量更新形式) --> 
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer"> 
  <property name="basePackage" value="com.xxx.dao" /> 
  <property name="sqlSessionTemplateBeanName" value="sqlSessionTemplateBatch" /> 
  <property name="annotationClass" value="com.xxx.dao.BatchAnnotation" /> 
</bean> 

annotationClass:設置裝備擺設了該注解的dao才會被掃描器掃描,與basePackage是與的感化。

須要留意的是,兩個過濾前提只能配一個。

實例:事務治理
界說一個實體類: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);
 }
}

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved