zoukankan      html  css  js  c++  java
  • mybatis-4 mybatis与spring结合使用及原理

    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

     

  • 相关阅读:
    MapReduce原理
    用redis构建分布式锁
    Python中类的特殊变量
    Python之元类
    python之WSGI与Guincorn
    一种消息和任务队列——beanstalkd
    LRU 算法
    extern、static、restrict、volatile 关键字
    bigtable原理
    Go的微服务库kite
  • 原文地址:https://www.cnblogs.com/gnwzj/p/10680940.html
Copyright © 2011-2022 走看看