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

时间:2021-05-19

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")//注册Beanpublic 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@Servicepublic 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与一级缓存的关系:

这里引出一个经典问题,关于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语句查询出结果集


声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。

相关文章