文档章节

mybatis-4 mybatis与spring结合使用及原理

o
 osc_gu9d45li
发布于 2019/04/10 02:03
字数 1909
阅读 8
收藏 0

「深度学习福利」大神带你进阶工程师,立即查看>>>

1、创建项目maven,方便依赖下载。使用的jar如下:

<dependencies>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>5.0.8.RELEASE</version>
</dependency>

<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis-spring</artifactId>
<version>2.0.0</version>
</dependency>

<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
<version>3.4.6</version>
</dependency>

<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.34</version>
</dependency>

<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
<version>5.0.8.RELEASE</version>
</dependency>

<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-core</artifactId>
<version>5.0.8.RELEASE</version>
</dependency>

</dependencies>

2、创建包com >config、dao、service、test

 

3、使用spring创建AppConfig文件,创建Bean>SqlSessionFactoryBean、DataSourceBean

  1、spring注解@Configuration,说明是配置层

  2、注册扫描映射

  3、注册包扫描器

  4、创建SqlSessionFactoryBean

  5、创建数据源Bean

package com.config;

import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.datasource.DriverManagerDataSource;

import javax.sql.DataSource;


@Configuration
@MapperScan("com.dao")//注解 与XML<mybatis:scan base-package="org.mybatis.spring.sample.mapper" />
//注册包中递归搜索映射器
@ComponentScan("com")//注册Bean
public class AppConfig {

    @Bean
    @Autowired
    public SqlSessionFactoryBean sqlSessionFactoryBean(DataSource dataSource ){
        SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
        sqlSessionFactoryBean.setDataSource(dataSource);
        return sqlSessionFactoryBean;
    }

    @Bean
    public DataSource getDataSource(){
        DriverManagerDataSource dataSource = new DriverManagerDataSource();
        dataSource.setDriverClassName("com.mysql.jdbc.Driver");
        dataSource.setUsername("root");
        dataSource.setPassword("110226wjwj");
        dataSource.setUrl("jdbc:mysql://localhost:3306/mybatis_wjw?useUnicode=true&characterEncoding=UTF-8&useSSL=false");
        return dataSource;
    }
}

4、创建Dao接口

  1、创建query方法并使用注解@Select(Mybatis提供,mybatis-spring官网有相关解释)

package com.dao;

import org.apache.ibatis.annotations.Select;

import java.util.List;
import java.util.Map;

public interface UserDao {

    @Select ("select * from t_user where tid =3")
    public List<Map> query();

}

5、创建服务层

  1、注解服务层

  2、引入DaoBean

package com.service;

import com.dao.UserDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

//spring注解中service与component意思差不多,区别在于component是中立注解,而service是业务逻辑层的注解
//@Component
@Service
public class UserService {

    @Autowired
    UserDao userDao;


    public void query(){
        System.out.println(userDao.query());
    }
}

 6、测试 

  1、创建application

  2、创建service

package com.test;

import com.config.AppConfig;
import com.service.UserService;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;


public class MainTest {
    public static void main(String args[]){
        AnnotationConfigApplicationContext acc = new AnnotationConfigApplicationContext(AppConfig.class);
        UserService us = acc.getBean(UserService.class);
        us.query();
    }
}

  

jar包之家:https://mvnrepository.com/artifact

使用spring依赖注入mapper   根据官网提示需要

<mybatis:scan base-package="org.mybatis.spring.sample.mapper" />==@MapperScan(“需要注入的包”)

 

mybatis缺点:使用XML方式与dao开发结合出现严重的臃肿现象,需要维护很多sql语句。

 

测试的时候出现这个问题。(版本导致,我直接将最新[mybatis-spring]的导入进来就没问题了)

 

 上面的问题解决后有出现这个问题,此问题出现的原因是java compiler改成8就OK了

 

 测试结果:


 

 

重点:

  mybatis运行原理

    我们可以看到,再测试类中用的是UserService对象调用Dao接口中的query,但是mybatis是如何实现将接口转换成对象的呢? 答案:动态代理 ,我们常用的代理(proxy)一共有两种:cglib和jdk两用代理模式
    无论哪一种最终都是使用反射机制进行代理。详情自己查看度娘(哈哈@0@)

    

    

  mybatis源码解析

    DefaultSqlSession下如何实现返回一条数据的:底层调用的是selectList方法,对返回的结果集进行数量判断如果==1则直接放回,>1直接抛出TooManyResultsException(感觉很傻)

public <T> T selectOne(String statement, Object parameter) {
        List<T> list = this.selectList(statement, parameter);
        if (list.size() == 1) {
            return list.get(0);
        } else if (list.size() > 1) {
            throw new TooManyResultsException("Expected one result (or null) to be returned by selectOne(), but found: " + list.size());
        } else {
            return null;
        }
    }

  下面我们继续看selectList是如何实现的

 

public <E> List<E> selectList(String statement, Object parameter, RowBounds rowBounds) {
        List var5;
        try {
            MappedStatement ms = this.configuration.getMappedStatement(statement);
            var5 = this.executor.query(ms, this.wrapCollection(parameter), rowBounds, Executor.NO_RESULT_HANDLER);
        } catch (Exception var9) {
            throw ExceptionFactory.wrapException("Error querying database.  Cause: " + var9, var9);
        } finally {
            ErrorContext.instance().reset();
        }

        return var5;
    }

  我们来看看这个defaultSqlSession.configuration.getMappedStatement方法具体是什么

结论:再启动项目的时候,mybatis会进行初始化,这个初始化就是将我们的"包+类+方法名"作为key 和 sql语句作为value 的键值对形式赋给下面Map类型的mappedStatements

protected final Map<String, MappedStatement> mappedStatements;
这也是为什么我们使用XML方式一定要将方法名字与id对应上才能使用,如果对应不上再进行Id传值的时候找不到对应的key。

继续往下分析:

已发帖子询问大神具体是什么原因导致不进入124行,等大佬们回答后我将公布结果。直接看看executor是什么鬼

是一个接口,https://blog.csdn.net/ykzhen2015/article/details/50315027

protected Set<BeanDefinitionHolder> doScan(String... basePackages) {
        Assert.notEmpty(basePackages, "At least one base package must be specified");
        Set<BeanDefinitionHolder> beanDefinitions = new LinkedHashSet();
        String[] var3 = basePackages;
        int var4 = basePackages.length;

        for(int var5 = 0; var5 < var4; ++var5) {
            String basePackage = var3[var5];
            Set<BeanDefinition> candidates = this.findCandidateComponents(basePackage);
            Iterator var8 = candidates.iterator();

            while(var8.hasNext()) {
                BeanDefinition candidate = (BeanDefinition)var8.next();
                ScopeMetadata scopeMetadata = this.scopeMetadataResolver.resolveScopeMetadata(candidate);
                candidate.setScope(scopeMetadata.getScopeName());
                String beanName = this.beanNameGenerator.generateBeanName(candidate, this.registry);
                if (candidate instanceof AbstractBeanDefinition) {
                    this.postProcessBeanDefinition((AbstractBeanDefinition)candidate, beanName);
                }

                if (candidate instanceof AnnotatedBeanDefinition) {
                    AnnotationConfigUtils.processCommonDefinitionAnnotations((AnnotatedBeanDefinition)candidate);
                }

                if (this.checkCandidate(beanName, candidate)) {
                    BeanDefinitionHolder definitionHolder = new BeanDefinitionHolder(candidate, beanName);
                    definitionHolder = AnnotationConfigUtils.applyScopedProxyMode(scopeMetadata, definitionHolder, this.registry);
                    beanDefinitions.add(definitionHolder);
                    this.registerBeanDefinition(definitionHolder, this.registry);
                }
            }
        }

        return beanDefinitions;
    }

  

关于mybatis中的executor与一级缓存的关系:https://blog.csdn.net/lmn669/article/details/77900625

这里引出一个经典问题,关于mybatis一级缓存问题,这个缓存存储在session中,当sql关闭的时候就会自动销毁,涉及到mybatis中的session生命周期问题

为什么mybatis与spring结合后一级缓存会失效?以为SqlSession是由SqlSessionFactoryBean生成,二这个SqlSessionFactoryBean是由spring管理,也就是此时的session是由spring进行管理的并不是mybatis管理,所以此时session缓存会失效。

public interface Executor {
    ResultHandler NO_RESULT_HANDLER = null;

    int update(MappedStatement var1, Object var2) throws SQLException;

    <E> List<E> query(MappedStatement var1, Object var2, RowBounds var3, ResultHandler var4, CacheKey var5, BoundSql var6) throws SQLException;

    <E> List<E> query(MappedStatement var1, Object var2, RowBounds var3, ResultHandler var4) throws SQLException;

    <E> Cursor<E> queryCursor(MappedStatement var1, Object var2, RowBounds var3) throws SQLException;

    List<BatchResult> flushStatements() throws SQLException;

    void commit(boolean var1) throws SQLException;

    void rollback(boolean var1) throws SQLException;

    CacheKey createCacheKey(MappedStatement var1, Object var2, RowBounds var3, BoundSql var4);

    boolean isCached(MappedStatement var1, CacheKey var2);

    void clearLocalCache();

    void deferLoad(MappedStatement var1, MetaObject var2, String var3, CacheKey var4, Class<?> var5);

    Transaction getTransaction();

    void close(boolean var1);

    boolean isClosed();

    void setExecutorWrapper(Executor var1);
}

mybatis-spring依赖中MapperScannerRegistrar的作用:registerBeanDefinitions方法中的doScan()此方法是将Mapper扫描到初始化中。原理就是获取到项目路径找到对应的classes路径,获取了com.dao包名,将获取的路径+包名转成文件夹,循环获取文件夹下面的文件(UserDao.class),然后使用将UserDao拿到。此时包名+类名都拿到后使用Class.forName(包名+类名)反射出对象,进行bean注册

总结运行原理:

  初始化信息(数据库连接信息,扫描mapper包中的class用于创建bean对象,spring中的类applicationFactory用于创建变对象、mapper中的xml的id与sql放到MapperStatement对象中)
      其中对于扫描mapper包中的class路径+参数basePackages转成文件夹,然后循环找到所有的类名,使用.......(请看MapperScannerRegistrar引出的doScan方法)

  执行过程:根据SqlSessionFactoryBean创建出sqlSession,调用selectList方法,之后根据参数(nameSpaceName+id)作为key找到MapperStatement对象中存储的value获取到sql语句,再有Executor(mybatis默认使用                               CacheExecutor)执行sql语句查询出结果集

 

补充很重要的知识:为什么调用Dao接口的方法,就会执行我们的sql?

因为会生成代理类,最终调用的是代理的invoke方法,最终在MapperProxy中的invoke方法中,有兴趣的朋友可以在调用本章节的代码的时候在invoke中打断点试试。
spring-mybatis Mapper初始化所有的mapper类的时候,使用的是InitializingBean接口的afterPropertiestSet方法

mybatis中解析mapper有几种方式? url、class、resource、package

http://www.mybatis.org/mybatis-3/zh/configuration.html#mappers

 

<exclusions> //用来排除的jar
<exclusion>
<groupId>org.springfromwork</groupId>
<artifactId>spring-jcl</artifactId>
</exclusion>
</exclusions>

为什么spring5与mybatis结合日志不打印?
因为spring5中的新特性,日志是JUL(Jakarta commons logging)而不是JCL(Java util logging),JUL日志级别是infoUp,JCL日志级别是infoDown
所以当使用spring5与mybatis结合使用的时候需要扩展mybatis输出日志的级别。
源码:LogFactory中setImplementation方法会判断是否是debug↑级别,如果是则打印,反之不打印
解决办法:扩展日志

 



关于日志级别问题:

 

 

 下节内容:自己创建mybatis

 

 

 

 

o
粉丝 0
博文 500
码字总数 0
作品 0
私信 提问
加载中
请先登录后再评论。
SQLServer实现split分割字符串到列

网上已有人实现sqlserver的split函数可将字符串分割成行,但是我们习惯了split返回数组或者列表,因此这里对其做一些改动,最终实现也许不尽如意,但是也能解决一些问题。 先贴上某大牛写的s...

cwalet
2014/05/21
9.6K
0
CDH5: 使用parcels配置lzo

一、Parcel 部署步骤 1 下载: 首先需要下载 Parcel。下载完成后,Parcel 将驻留在 Cloudera Manager 主机的本地目录中。 2 分配: Parcel 下载后,将分配到群集中的所有主机上并解压缩。 3 激...

cloud-coder
2014/07/01
6.8K
1
Swift百万线程攻破单例(Singleton)模式

一、不安全的单例实现 在上一篇文章我们给出了单例的设计模式,直接给出了线程安全的实现方法。单例的实现有多种方法,如下面: class SwiftSingleton { } 这段代码的实现,在shared中进行条...

一叶博客
2014/06/20
3.4K
16
Nutch学习笔记4-Nutch 1.7 的 索引篇 ElasticSearch

上一篇讲解了爬取和分析的流程,很重要的收获就是: 解析过程中,会根据页面的ContentType获得一系列的注册解析器, 依次调用每个解析器,当其中一个解析成功后就返回,否则继续执行下一个解...

强子哥哥
2014/06/26
712
0
StreetPass

StreetPass,最初是想模拟任天堂NDS掌机中的StreetPass开发的(但未完成,大体框架已可行)。适用于记录每天在街上偶遇的纸妹Or帅锅的信息。 原理是想采用Wifi hot技术,由此可以在搜索到附近...

口米巴
2013/03/18
1.6K
0

没有更多内容

加载失败,请刷新页面

加载更多

OSPF综合实验

OSPF开放路径最短选择优先协议(IGP协议、链路状态协议) 支持大型网络,通过彼此交互hello建立邻居关系,在通过彼此交互的LSA通过SPF算法算出最优路由的到自己去往其他节点路径。 OSPF的DR、...

osc_qmxpov5s
刚刚
0
0
vmlogin多平台·多账号·安全提速系统·稳定浏览器指纹环境

VMLogin-稳定浏览器指纹环境,Cookie隔离,稳定,更高效,更智能的多账号管,从超级浏览器开始,让你的跨境之旅更便捷! VMLogin生成多个唯一指纹浏览器,每个指纹浏览器都是相互隔离的。 可以...

VMlogin中文版防关联浏览器
1分钟前
0
0
Buurst SoftNAS操作手册—Part1 如何在AWS上部署SoftNAS

前言 Buurst SoftNAS为企业提供高性能、易管理、高可用、极具经济效益的存储服务,无论是在私有云还是公有云环境下均可实现一键部署。Buurst SoftNAS可为企业提供软件定义NAS文件管理器并提供...

osc_cyo5y1ey
1分钟前
0
0
《闲扯Redis十》Redis 跳跃表的结构实现

一、前言 Redis 提供了5种数据类型:String(字符串)、Hash(哈希)、List(列表)、Set(集合)、Zset(有序集合),理解每种数据类型的特点对于redis的开发和运维非常重要。 原文解析:h...

大道七哥
2分钟前
0
0
BGP综合实验

BGP边界网关协议 BGP是目前使用的唯一的自治系统间的路由协议,它是一种矢量路由协议,基于TCP的179号端口,它采用单播增量更新的方式更新路由,与其他的路由协议不同的是,BGP只要TCP可达,...

osc_tybx1rlt
3分钟前
0
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部