MyBatis 是一款优秀的持久层框架,它支持定制化 SQL、存储过程以及高级映射。MyBatis 避免了几乎所有的 JDBC 代码和手动设置参数以及获取结果集。MyBatis 可以使用简单的 XML 或注解来配置和映射原生信息,将接口和 Java 的 POJOs(Plain Old Java Objects,普通的 Java对象)映射成数据库中的记录。
上面是mybatis官方介绍,从介绍我们可以得知mybatis有以下特点:
以下为mybatis内的一些基本概念:
那mybatis是如果构建和执行的呢,先看一个小例子(这里以xml配置方式为例):
<dependency> <groupId>org.mybatis</groupId> <artifactId>mybatis</artifactId> <version>3.4.5</version> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>6.0.6</version> </dependency> 复制代码
<?xml version="1.0" encoding="UTF-8" ?> <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd"> <configuration> <properties resource="config.properties"/> <settings> <setting name="logImpl" value="LOG4J2"/> <!-- 关闭一级缓存 --> <setting name="localCacheScope" value="STATEMENT"/> </settings> <environments default="development"> <environment id="development"> <transactionManager type="JDBC"/> <dataSource type="POOLED"> <property name="driver" value="${driver}"/> <property name="url" value="${url}"/> <property name="username" value="${username}"/> <property name="password" value="${password}"/> </dataSource> </environment> </environments> <mappers> <mapper resource="mapper/UserMapper.xml"/> </mappers> </configuration> 复制代码
public interface UserMapper { List<Map> selectUser(); } 复制代码
<?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="test.demos.mybatis.UserMapper"> <select id="selectUser" resultType="java.util.Map"> select * from user </select> </mapper> 复制代码
public class App { public static void main(String[] args) throws Exception { SqlSessionFactoryBuilder factoryBuilder = new SqlSessionFactoryBuilder(); InputStream resource = Resources.getResourceAsStream("config.xml"); SqlSessionFactory sessionFactory = factoryBuilder.build(resource); SqlSession sqlSession = sessionFactory.openSession(); /* 这里通过jdk的动态代理获取UserMapper接口的代理类 */ UserMapper userMapper = sqlSession.getMapper(UserMapper.class); List<Map> list = userMapper.selectUser(); System.out.println(list.size()); } } 复制代码
以上就是搭建纯mybatis运行环境的过程,程序配置过程不详述,这里说一下mybatis的启动构建和执行过程。
加载mybatis配置文件
(XMLConfigBuilder.parse)解析配置文件:解析过程是将xml配置文件内的所有配置标签都解析并包括
<properties/> <settings/> <typeAliases/> <plugins/> <objectFactory/> <objectWrapperFactory/> <reflectorFactory/> <environments/> <databaseIdProvider/> <typeHandlers/> <mappers/>
解析每个标签调用不同的方法处理该标签的配置,例如解析标签是会把内配置的所有映射记录解析将mapper记录添加到Configuration的MapperRegistry中去,并且将对应mapper配置文件里的所有的sql操作解析成MapperStatement(XMLMapperBuilder.parse),同时也会解析resultMap和缓存配置。
sqlSession.getMapper(UserMapper.class)
,这里其实就是通过jdk的动态代理获取得到UserMapper接口的代理类,实际代理的InvocationHandler是MapperProxy,在MapperProxy.invoke方法中会拦截映射接口的方法调用,然后创建(可能会被缓存)MapperMethod实例通过执行MapperMethod.execute方法执行sql操作,接着会调用SqlSession内的一系列方法如selectList、insert、query等,根据调用的接口和方法组合的全限定名 例如:com.test.UserMapper.getUser
来获取MappedStatement,最后通过Executor来作sql的操作(当然其内部也有些封装执行操作,详情可看Executor的实现类BaseExecutor、CachingExecutor的源码)。 以上就是Mybatis大致的启动构建和执行过程,只能将主要的节点描述,很多细节还需阅读源码。
下图为mybatis启动示意图:
mybatis内置了两种缓存,一种是一级缓存(默认开启),一种是二级缓存(默认开启),一级缓存是会话级别的也就是一个SqlSession实例内的缓存,而二级缓存是namespace级别的,所谓namespace就是一个映射接口的范围,也就是说如果开启了二级缓存那么多个会话如果调用的是同一个映射接口那么是有可能命中二级缓存的。下面详细描述。
一级缓存:在上一部分我们知道对于SqlSession里的一系列操作方法,实际上最终会调用Executor执行器内的方法来进行sql操作,Executor在mybatis种提供了几个实现类,在不开启二级缓存的情况下默认使用SimpleExecutor实现类,SimpleExecutor是集成的BaseExecutor抽象类,大部分的方法已在BaseExecutor实现,我们关注BaseExecutor,当作查询操作的时候最终会执行BaseExecutor.query方法,在BaseExecutor类的152行有这样的代码 list = resultHandler == null ? (List<E>) localCache.getObject(key) : null;
这里就是一级缓存实现的地方,即一级缓存是保存在BaseExecutor内部属性localCache中,而localCache其实就是个PerpetualCache而该类是mybatis缓存的一个实现类,下钻到PerpetualCache内可以发现其内部有个类型为Map的cache属性其中key为CacheKey值就是查询结果。当执行了update、commit等方法后一级缓存会被清空。我们可以看到,一级缓存只提供了简单的缓存更新的策略,如果使用一个SqlSession实例作同一个查询不管查询多少此其结果都不会变,这就有可能出现脏数据,所以需要斟酌使用一级缓存,如果对数据实时性要求高可以在mybatis配置文件配置标签里设置 <setting name="localCacheScope" value="STATEMENT"/>
来关闭一级缓存。
二级缓存:二级缓存是默认开启的,如果要关闭可以在mybatis配置文件配置标签里设置 <setting name="cacheEnabled" value="false"/>
,开启二级缓存后SqlSession内的Executor为CachingExecutor,实际CachingExecutor是使用装饰器模式将包了一层,具体sql操作委托给其他的Executor执行(其实默认是委托给SimpleExecutor),CachingExecutor只做二级缓存的处理。源码CachingExecutor第95行,在执行查询之前先从MappedStatement中获取cache(如果对应mapper映射文件中未配置那么此处的cache是空的,其实这里的cache在mybatis启动构建解析配置文件的时候就已经创建好了,这个cache实例是和namespace一一对应的)。如果部位空那么就从cache中获取值。但是这里不是直接从cache中获取值而是通过CacheExecutor内部的TransactionalCacheManager来获取,之所以这样是为了保证事务成功或失败后缓存的正常保存和清理。例如这里如果开启二级缓存做一次查询其实没发真正保存缓存,此时缓存是保存在TransactionalCache中的,TransactionalCache内保存了所有本次事务操作需有需要缓存的值,只有调用SqlSession.commit方法后将commit传递到TransactionalCache.commit才能真正保存缓存到namespace的cache实例中。在作insert、update、delete时二级缓存也会被清除,想比一级缓存二级缓存有淘汰策略,默认策略上LRU(淘汰最急最少使用),可以在映射配置文件的配置标签中自定义,除此之外还有:
例如:
<cache eviction="FIFO" flushInterval="60000" size="512" readOnly="true"/> 复制代码
Cache:Cache是mybatis在一二级缓存是对缓存的抽象,Cache接口有一系列的实现类,这些实现类使用装饰器模式来实现对不能缓存功能的包装和功能叠加。
MyBatis 允许你在已映射语句执行过程中的某一点进行拦截调用。默认情况下,MyBatis 允许使用插件来拦截的方法调用包括:
以上是官方的对plugin的介绍,本质上plugin在sql操作的执行周期中作用的,可以作用的点包括Executor、ParameterHandler、ResultSetHandler、StatementHandler内部的一系列方法。mybatis通过动态代理实现对作用点前后的自定义操作。在Configuration中有个interceptorChain属性,即插件作用链,在Configuration中newParameterHandler、newResultSetHandler、newStatementHandler、newExecutor这些方法都会调用InterceptorChain.pluginAll方法通过动态代理的方式将每个插件穿起来,生成插件动态代理链是通过插件工具类Plugin来实现,调用Plugin.wrap这个静态方法来创建代理类,代理InvocationHandler类就是Plugin(Plugin本身实现了InvocationHandler接口),当然在创建插件代理类的过程中还会判断插件类的签名信息即插件类的@Intercepts注解配置信息,该配置信息里配置了该插件的作用点(实际上就是作用的函数调用点)。例如我们想把查询出来为 List<Map>
类型的结果内部的Map字段转成驼峰形式(如:user_name转成userName)我们可以使用插件来实现。
@Intercepts({@Signature( type= ResultSetHandler.class, method = "handleResultSets", args = {Statement.class})}) public class MyPlugin implements Interceptor { @Override @SuppressWarnings("unchecked") public Object intercept(Invocation invocation) throws Throwable { List result = (List) invocation.proceed(); if (result != null && result.size() > 0) { if (result.get(0) instanceof Map) { List reList = new ArrayList(); for (Map el : (List<Map>) result) { Map map = new HashMap(); for (String key : (Set<String>) el.keySet()) { map.put(getCamelKey(key), el.get(key)); } reList.add(map); } return reList; } } return result; } @Override public Object plugin(Object target) { return Plugin.wrap(target, this); } @Override public void setProperties(Properties properties) { } private String getCamelKey(String key) { String[] split = key.split("_"); String camelKey = ""; for (int i = 0; i < split.length; i++) { if (i != 0) camelKey += split[i].substring(0, 1).toUpperCase() + split[i].substring(1, split[i].length()); else camelKey += split[i]; } return camelKey; } } 复制代码
Mybatis 的内置日志工厂提供日志功能,内置日志工厂将日志交给以下其中一种工具作代理:
实际mybatis只提供了一个日志工厂LogFactory,mybatis通过日志工厂获取日志对象,mybatis本身不提供日志实现,具体的日志交给第三方日志框架来作。可以在mybatis配置文件配置具体日志实现,我门以log4j2为例:
<configuration> <settings> <setting name="logImpl" value="LOG4J2"/> </settings> </configuration> 复制代码
配置了mybatis的log实现以后,需要引入相对应的日志依赖包。
<dependency> <groupId>org.apache.logging.log4j</groupId> <artifactId>log4j-api</artifactId> <version>2.11.1</version> </dependency> <dependency> <groupId>org.apache.logging.log4j</groupId> <artifactId>log4j-core</artifactId> <version>2.11.1</version> </dependency> 复制代码
然后配置日志框架的配置文件(每个日志框架的配置不同这里以log4j2为例)
<?xml version="1.0" encoding="UTF-8"?> <Configuration status="info" name="RoutingTest"> <Appenders> <Console name="Console" target="SYSTEM_OUT"> <PatternLayout pattern="%d{yyyy-MM-dd HH:mm:ss.SSS} [%t] %-5level %logger{36} - %msg%n"/> </Console> </Appenders> <Loggers> <Root level="debug"> <AppenderRef ref="Console"/> </Root> </Loggers> </Configuration> 复制代码
mybatis在实现的时候用了一些设计模式,如:
mybatis集成到spring需要添加mybatis-spring依赖,这个依赖包是mybatis和spring对接依赖包。添加spring依赖和mybatis-spring依赖
<!-- spring --> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-core</artifactId> <version>5.0.4.RELEASE</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-beans</artifactId> <version>5.0.4.RELEASE</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context</artifactId> <version>5.0.4.RELEASE</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jdbc</artifactId> <version>5.0.4.RELEASE</version> </dependency> <!-- mybatis-spring --> <dependency> <groupId>org.mybatis</groupId> <artifactId>mybatis-spring</artifactId> <version>1.3.1</version> </dependency> 复制代码
配置spring
<?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" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd"> <!-- 属性扫描 --> <context:property-placeholder location="config.properties"/> <!-- 组件扫描 --> <context:component-scan base-package="test.demos.mybatis"/> <!-- 数据源 --> <bean id="dataSource" class="com.mysql.cj.jdbc.MysqlDataSource"> <property name="url" value="${url}"/> <property name="user" value="${username}"/> <property name="password" value="${password}"/> <property name="databaseName" value="test"/> </bean> <!-- 配置sqlSessionFactory工厂bean --> <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"> <property name="configLocation" value="classpath:config.xml"/> <property name="dataSource" ref="dataSource"/> </bean> <!-- 配置sqlSessionTemplate --> <bean id="sqlSessionTemplate" class="org.mybatis.spring.SqlSessionTemplate"> <constructor-arg ref="sqlSessionFactory"/> </bean> <!-- 注册扫描映射接口bean --> <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer"> <property name="basePackage" value="test.demos.mybatis"/> </bean> </beans> 复制代码
从spring配置可以知道mybatis-spring主要做了一下几件事:
mybatis集成springboot需要添加一个start
<dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> <version>1.3.0</version> </dependency> 复制代码
其实mybatis-spring-boot-starter只是个空的依赖,mybatis-spring-boot-starter依赖了mybatis-spring-boot-autoconfigure,主要的代码在这个自动化配置包里。自动化配置依赖会读取mybatis相关的配置属性,然后自动配置我们上面提到的mybatis相关的组件。配置例子:
mybatis.mapper-locations=classpath:/mapper/**/*Mapper.xml mybatis.typeAliasesPackage=com.test.*.model mybatis.configuration.map-underscore-to-camel-case=true mybatis.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl mybatis.configuration.callSettersOnNulls=true 复制代码
这里不将springboot相关内容,只做配置样例介绍。