spring 整合 mybatis 中数据源的几种配置方式(总结篇)

因为spring 整合mybatis的过程中， 有好几种整合方式，尤其是数据源那块，经常看到不一样的配置方式，总感觉有点乱，所以今天有空总结下。

　　一、采用org.mybatis.spring.mapper.MapperScannerConfigurer

　　其实逆向工程也是这种方式

　　1、数据源配配置文件

　2、DAO文件

 package com.jdd.mapper;
 import com.jdd.pojo.Employee;
 import java.util.List;
 public interface EmployeeMapper {
   public Employee getEmployeeById(int id);
   public List findAllEmployees();
 }

　　3、Mapper.xml 文件

　　 
 
 
   
     
   
   
     
   
 



 　　这样在service类里就可以直接注入dao接口了

 package com.jdd.service.impl;
 import com.jdd.mapper.EmployeeMapper;
 import com.jdd.pojo.Employee;
 import com.jdd.service.EmployeeService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import java.util.List;
 @Service("employeeService")
 public class EmployeeServiceImpl implements EmployeeService{
   @Autowired
   private EmployeeMapper employeeMapper;
   @Override
   public Employee getEmployeeById(int id) {
     return employeeMapper.getEmployeeById(id);
   }
   @Override
   public List findAllEmployees() {
     return employeeMapper.findAllEmployees();
   }
 }



　　　　二、 采用抽象类org.mybatis.spring.support.SqlSessionDaoSupport， 给它注入 sqlSessionFactory的方式
　　1、数据源配置文件

　　 
 
   
   
   
   
     
     
     
     
     
     
   
   
   
     
     
     
   
 



 　　2、baseDao类

 package com.jdd.dao;
 import org.apache.ibatis.session.SqlSessionFactory;
 import org.mybatis.spring.support.SqlSessionDaoSupport;
 import javax.annotation.Resource;
 public abstract class baseDao extends SqlSessionDaoSupport {
   @Resource
   public void setSqlSessionFactory(SqlSessionFactory sqlSessionFactory) {
     super.setSqlSessionFactory(sqlSessionFactory);
   }
 }



 　　3、接口 EmployeeDao.java 类

 package com.jdd.dao;
 import com.jdd.pojo.Employee;
 import java.util.List;
 public interface EmployeeDao {
   Employee getEmployeeById(int id);
   List findAllEmployees();
 }

　　4、dao实现类 EmployeeDaoImpl

 package com.jdd.dao.impl;
 import com.jdd.dao.baseDao;
 import com.jdd.dao.EmployeeDao;
 import com.jdd.pojo.Employee;
 import org.springframework.stereotype.Repository;
 import java.util.List;
 @Repository("employeeDao")
 public class EmployeeDaoImpl extends baseDao implements EmployeeDao {
   @Override
   public Employee getEmployeeById(int id) {
     return this.getSqlSession().selectOne("com.jdd.dao.EmployeeDao.getEmployeeById", id);
   }
   @Override
   public List findAllEmployees() {
     return this.getSqlSession().selectList("com.jdd.dao.EmployeeDao.findAllEmployees");
   }
 }

　　5、这样就可以在service类里注入 employeeDao了
　　三、采用 org.mybatis.spring.SqlSessionTemplate 模板类
　　1、数据源文件

 
 
   
   
   
     
     
     
     
     
     
     
   
   
   
     
     
     
   
   
     
   
 

　　2、 basedao.java 类

 package com.jdd.dao;
 import org.mybatis.spring.SqlSessionTemplate;
 import javax.annotation.Resource;
 public abstract class baseDao {
   public SqlSessionTemplate sqlSessionTemplate;
   @Resource
   public void setSqlSessionTemplate(SqlSessionTemplate sqlSessionTemplate) {
     this.sqlSessionTemplate = sqlSessionTemplate;
   }
 }


　　3、接口 EmployeeDao.java 类　　



package com.jdd.dao;
 import com.jdd.pojo.Employee;
 import java.util.List;
 public interface EmployeeDao {
   Employee getEmployeeById(int id);
   List findAllEmployees();
 }

　　4、dao实现类 EmployeeDaoImpl

 package com.jdd.dao.impl;
 import com.jdd.dao.baseDao;
 import com.jdd.dao.EmployeeDao;
 import com.jdd.pojo.Employee;
 import org.springframework.stereotype.Repository;
 import java.util.List;
 @Repository("employeeDao")
 public class EmployeeDaoImpl extends baseDao implements EmployeeDao {
   @Override
   public Employee getEmployeeById(int id) {
     return sqlSessionTemplate.selectOne("com.jdd.dao.EmployeeDao.getEmployeeById", id);
   }
   @Override
   public List findAllEmployees() {
     return sqlSessionTemplate.selectList("com.jdd.dao.EmployeeDao.findAllEmployees");
   }
 }

　　5、同样现在也可以在service类里直接注入 employeeDao使用了。
　　注：这里basedao的注入比较灵活，也可以注入 SqlSessionFactory， 然后再setter方法里创建 SqlSessionTemplate，如下：

 package com.jdd.dao;
 import org.apache.ibatis.session.SqlSessionFactory;
 import org.mybatis.spring.SqlSessionTemplate;
 import javax.annotation.Resource;
 public abstract class baseDao {
   public SqlSessionTemplate sqlSessionTemplate;
   @Resource
   public void setSqlSessionFactory(SqlSessionFactory sqlSessionFactory) {
     sqlSessionTemplate = new SqlSessionTemplate(sqlSessionFactory);
   }
 }

　　其实不管是采用 继承SqlSessionDaoSupport类， 注入 sqlSessionFactory的方式， 还是直接注入 SqlSessionTemplate 的方式， 本质上是一样的。
　　如果你采用 注入 sqlSessionFactory的方式， 它在底层也是通过sqlSessionFactory 来创建 SqlSessionTemplate ，然后通过其api来操作。
　　不信给你们看下 SqlSessionDaoSupport 的源码：

 //
 // Source code recreated from a .class file by IntelliJ IDEA
 // (powered by Fernflower decompiler)
 //
 package org.mybatis.spring.support;
 import org.apache.ibatis.session.SqlSession;
 import org.apache.ibatis.session.SqlSessionFactory;
 import org.mybatis.spring.SqlSessionTemplate;
 import org.springframework.dao.support.DaoSupport;
 import org.springframework.util.Assert;
 public abstract class SqlSessionDaoSupport extends DaoSupport {
   private SqlSession sqlSession;
   private boolean externalSqlSession;
   public SqlSessionDaoSupport() {
   }
   public void setSqlSessionFactory(SqlSessionFactory sqlSessionFactory) {
     if (!this.externalSqlSession) {
this.sqlSession = new SqlSessionTemplate(sqlSessionFactory);
     }
   }
   public void setSqlSessionTemplate(SqlSessionTemplate sqlSessionTemplate) {
     this.sqlSession = sqlSessionTemplate;
     this.externalSqlSession = true;
   }
   public SqlSession getSqlSession() {
     return this.sqlSession;
   }
   protected void checkDaoConfig() {
     Assert.notNull(this.sqlSession, "Property 'sqlSessionFactory' or 'sqlSessionTemplate' are required");
   }
 }

 　　同样 SqlSessionTemplate 继承了 SqlSession 接口， 因此不管操作哪个效果都一样

 //
  // Source code recreated from a .class file by IntelliJ IDEA
  // (powered by Fernflower decompiler)
  //
  package org.mybatis.spring;
  import java.lang.reflect.InvocationHandler;
  import java.lang.reflect.Method;
 import java.lang.reflect.Proxy;
 import java.sql.Connection;
 import java.util.List;
 import java.util.Map;
 import org.apache.ibatis.exceptions.PersistenceException;
 import org.apache.ibatis.executor.BatchResult;
 import org.apache.ibatis.reflection.ExceptionUtil;
 import org.apache.ibatis.session.Configuration;
 import org.apache.ibatis.session.ExecutorType;
 import org.apache.ibatis.session.ResultHandler;
 import org.apache.ibatis.session.RowBounds;
 import org.apache.ibatis.session.SqlSession;
 import org.apache.ibatis.session.SqlSessionFactory;
 import org.springframework.dao.support.PersistenceExceptionTranslator;
 import org.springframework.util.Assert;
 public class SqlSessionTemplate implements SqlSession {
   private final SqlSessionFactory sqlSessionFactory;
   private final ExecutorType executorType;
   private final SqlSession sqlSessionProxy;
   private final PersistenceExceptionTranslator exceptionTranslator;
   public SqlSessionTemplate(SqlSessionFactory sqlSessionFactory) {
     this(sqlSessionFactory, sqlSessionFactory.getConfiguration().getDefaultExecutorType());
   }
   public SqlSessionTemplate(SqlSessionFactory sqlSessionFactory, ExecutorType executorType) {
     this(sqlSessionFactory, executorType, new MyBatisExceptionTranslator(sqlSessionFactory.getConfiguration().getEnvironment().getDataSource(), true));
   }
   public SqlSessionTemplate(SqlSessionFactory sqlSessionFactory, ExecutorType executorType, PersistenceExceptionTranslator exceptionTranslator) {
     Assert.notNull(sqlSessionFactory, "Property 'sqlSessionFactory' is required");
     Assert.notNull(executorType, "Property 'executorType' is required");
     this.sqlSessionFactory = sqlSessionFactory;
     this.executorType = executorType;
     this.exceptionTranslator = exceptionTranslator;
     this.sqlSessionProxy = (SqlSession)Proxy.newProxyInstance(SqlSessionFactory.class.getClassLoader(), new Class[]{SqlSession.class}, new SqlSessionTemplate.SqlSessionInterceptor());
   }
   public SqlSessionFactory getSqlSessionFactory() {
     return this.sqlSessionFactory;
   }
   public ExecutorType getExecutorType() {
     return this.executorType;
   }
   public PersistenceExceptionTranslator getPersistenceExceptionTranslator() {
     return this.exceptionTranslator;
   }
   public  T selectOne(String statement) {
     return this.sqlSessionProxy.selectOne(statement);
   }
   public  T selectOne(String statement, Object parameter) {
     return this.sqlSessionProxy.selectOne(statement, parameter);
   }
   public  Map selectMap(String statement, String mapKey) {
     return this.sqlSessionProxy.selectMap(statement, mapKey);
   }
   public  Map selectMap(String statement, Object parameter, String mapKey) {
     return this.sqlSessionProxy.selectMap(statement, parameter, mapKey);
   }
   public  Map selectMap(String statement, Object parameter, String mapKey, RowBounds rowBounds) {
     return this.sqlSessionProxy.selectMap(statement, parameter, mapKey, rowBounds);
   }
   public  List selectList(String statement) {
     return this.sqlSessionProxy.selectList(statement);
   }
   public  List selectList(String statement, Object parameter) {
     return this.sqlSessionProxy.selectList(statement, parameter);
   }
   public  List selectList(String statement, Object parameter, RowBounds rowBounds) {
     return this.sqlSessionProxy.selectList(statement, parameter, rowBounds);
   }
   public void select(String statement, ResultHandler handler) {
     this.sqlSessionProxy.select(statement, handler);
   }
   public void select(String statement, Object parameter, ResultHandler handler) {
     this.sqlSessionProxy.select(statement, parameter, handler);
   }
   public void select(String statement, Object parameter, RowBounds rowBounds, ResultHandler handler) {
     this.sqlSessionProxy.select(statement, parameter, rowBounds, handler);
   }
   public int insert(String statement) {
     return this.sqlSessionProxy.insert(statement);
   }
   public int insert(String statement, Object parameter) {
     return this.sqlSessionProxy.insert(statement, parameter);
   }
   public int update(String statement) {
     return this.sqlSessionProxy.update(statement);
   }
   public int update(String statement, Object parameter) {
     return this.sqlSessionProxy.update(statement, parameter);
   }
   public int delete(String statement) {
     return this.sqlSessionProxy.delete(statement);
   }
   public int delete(String statement, Object parameter) {
     return this.sqlSessionProxy.delete(statement, parameter);
   }
   public  T getMapper(Class type) {
     return this.getConfiguration().getMapper(type, this);
   }
   public void commit() {
     throw new UnsupportedOperationException("Manual commit is not allowed over a Spring managed SqlSession");
   }
   public void commit(boolean force) {
     throw new UnsupportedOperationException("Manual commit is not allowed over a Spring managed SqlSession");
   }
   public void rollback() {
     throw new UnsupportedOperationException("Manual rollback is not allowed over a Spring managed SqlSession");
   }
   public void rollback(boolean force) {
     throw new UnsupportedOperationException("Manual rollback is not allowed over a Spring managed SqlSession");
   }
   public void close() {
     throw new UnsupportedOperationException("Manual close is not allowed over a Spring managed SqlSession");
   }
   public void clearCache() {
     this.sqlSessionProxy.clearCache();
   }
   public Configuration getConfiguration() {
     return this.sqlSessionFactory.getConfiguration();
   }
   public Connection getConnection() {
     return this.sqlSessionProxy.getConnection();
   }
   public List flushStatements() {
     return this.sqlSessionProxy.flushStatements();
   }
   private class SqlSessionInterceptor implements InvocationHandler {
     private SqlSessionInterceptor() {
     }
     public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
SqlSession sqlSession = SqlSessionUtils.getSqlSession(SqlSessionTemplate.this.sqlSessionFactory, SqlSessionTemplate.this.executorType, SqlSessionTemplate.this.exceptionTranslator);
Object unwrapped;
try {
  Object result = method.invoke(sqlSession, args);
  if (!SqlSessionUtils.isSqlSessionTransactional(sqlSession, SqlSessionTemplate.this.sqlSessionFactory)) {
    sqlSession.commit(true);
  }
  unwrapped = result;
} catch (Throwable var) {
  unwrapped = ExceptionUtil.unwrapThrowable(var);
  if (SqlSessionTemplate.this.exceptionTranslator != null && unwrapped instanceof PersistenceException) {
    SqlSessionUtils.closeSqlSession(sqlSession, SqlSessionTemplate.this.sqlSessionFactory);
    sqlSession = null;
    Throwable translated = SqlSessionTemplate.this.exceptionTranslator.translateExceptionIfPossible((PersistenceException)unwrapped);
    if (translated != null) {
      unwrapped = translated;
    }
  }
  throw (Throwable)unwrapped;
} finally {
  if (sqlSession != null) {
    SqlSessionUtils.closeSqlSession(sqlSession, SqlSessionTemplate.this.sqlSessionFactory);
  }
}
return unwrapped;
     }
   }
 }

总结
以上所述是小编给大家介绍的spring 整合 mybatis 中数据源的几种配置方式，希望对大家有所帮助，如果大家有任何疑问欢迎给我留言，小编会及时回复大家的！



转载请注明：文章转载自 www.mshxw.com
本文地址：https://www.mshxw.com/it/140989.html


   上一篇  Spring 整合多个配置文件的方法
 
   下一篇  JAVA代码设置selector不同状态下的背景颜色
  






Java相关栏目本月热门文章

  
1【Linux驱动开发】设备树详解（二）设备树语法详解
  
2别跟客户扯细节
  
3Springboot+RabbitMQ+ACK机制(生产方确认(全局、局部)、消费方确认)、知识盲区
  
4【Java】对象处理流（ObjectOutputStream和ObjectInputStream）
  
5【分页】常见两种SpringBoot项目中分页技巧
  
6一文带你搞懂OAuth2.0
  
7我要写整个中文互联网界最牛逼的JVM系列教程 | 「JVM与Java体系架构」章节：虚拟机与Java虚拟机介绍
  
8【Spring Cloud】新闻头条微服务项目：FreeMarker模板引擎实现文章静态页面生成
  
9JavaSE - 封装、static成员和内部类
  
10树莓派mjpg-streamer实现监控及拍照功能调试
  
11用c++写一个蓝屏代码
  
12从JDK8源码中看ArrayList和LinkedList的区别
  
13idea 1、报错java: 找不到符号 符号: 变量 log 2、转换成Maven项目
  
14在openwrt使用C语言增加ubus接口（包含C uci操作）
  
15Spring 解决循环依赖
  
16SpringMVC——基于MVC架构的Spring框架
  
17Andy‘s First Dictionary C++ STL set应用
  
18动态内存管理
  
19我的创作纪念日
  
20Docker自定义镜像-Dockerfile







热门相关搜索



路由器设置
木托盘
宝塔面板
儿童python教程
心情低落
朋友圈
vim
双一流学科
专升本
我的学校
日记学校
西点培训学校
汽修学校
情书
化妆学校
塔沟武校
异形模板
西南大学排名
最精辟人生短句
6步教你追回被骗的钱
南昌大学排名
清朝十二帝
北京印刷学院排名
北方工业大学排名
北京航空航天大学排名
首都经济贸易大学排名
中国传媒大学排名
首都师范大学排名
中国地质大学(北京)排名
北京信息科技大学排名
中央民族大学排名
北京舞蹈学院排名
北京电影学院排名
中国戏曲学院排名
河北政法职业学院排名
河北经贸大学排名
天津中德应用技术大学排名
天津医学高等专科学校排名
天津美术学院排名
天津音乐学院排名
天津工业大学排名
北京工业大学耿丹学院排名
北京警察学院排名
天津科技大学排名
北京邮电大学(宏福校区)排名
北京网络职业学院排名
北京大学医学部排名
河北科技大学排名
河北地质大学排名
河北体育学院排名







学习工具
代数计算器
三角函数
解析几何
立体几何


知识解答
教育知识
百科知识
生活知识
常识知识


写作必备
作文大全
作文素材
句子大全

实用范文


关于我们
关于我们
联系我们
网站地图


 
名师互学网交流群


名师互学网客服





名师互学网 版权所有 (c)2021-2022      ICP备案号：晋ICP备2021003244-6号
 






关于我们
文章归档
网站地图
联系我们
版权所有 (c)2021-2022 MSHXW.COM
ICP备案号：晋ICP备2021003244-6号