MyBatis 实践 -配置

MyBatis 实践

标签： Java与存储

---

Configuration

mybatis-configuration.xml是MyBatis的全局配置文件(文件名称随意),其配置内容和顺序例如以下:

1. properties : 属性(文件)载入/配置
2. settings : 全局配置參数
3. typeAliases : 定义类型别名
4. typeHandlers : 类型处理器
5. objectFactory : 对象工厂
6. plugins : 插件
7. environments : 环境集合属性对象
   
   • environment
     
     • transactionManager : 事务管理
     • dataSource : 数据源
8. databaseIdProvider:P数据库厂商标识
9. mappers : 映射器

---

properties

方便对配置參数统一管理,供其它XML引用,我们能够将数据库的连接參数抽取出来:

• db.properties

## Data Source
mysql.driver.class=com.mysql.jdbc.Driver
mysql.url=jdbc:mysql://host:port/db?characterEncoding=utf-8
mysql.user=user
mysql.password=password

• mybatis-configuration.xml

<properties resource="db.properties"/>

<environments default="development">
    <environment id="development">
        <!-- 配置JDBC事务管理-->
        <transactionManager type="JDBC"/>
        <!-- 配置数据源-->
        <dataSource type="POOLED">
            <property name="driver" value="${mysql.driver.class}"/>
            <property name="url" value="${mysql.url}"/>
            <property name="username" value="${mysql.user}"/>
            <property name="password" value="${mysql.password}"/>
        </dataSource>
    </environment>
</environments>

注: MyBatis依照例如以下顺序载入properties:
1) 在<properties>标签内定义的属性;
2) .properties文件里定义的属性;
3) 最后读取作为方法參数传递的属性.

---

settings

MyBatis全局配置參数,会影响MyBatis执行时行为(如:开启二级缓存/延迟载入).见MyBatis文档.

---

typeAliases

MyBatis默认支持的类型别名可參考MyBatis文档,我们也能够自己定义别名,但并不推荐,使用PO对象的全限定名能够提高Statement的可读性.

---

typeHandlers

typeHandlers用于Java类型和JDBC类型转换,MyBatis提供了非常多默认的类型处理器(详见MyBatis文档),并且也基本满足日常开发需求,因此一般就不再须要单独定义.

---

mappers

前面已经将SQL语句定义到了mapper文件里,那么<mappers/>属性就是告诉MyBatis到哪里去寻找mapper文件,MyBatis提供了例如以下几种配置方法:

配置	描写叙述
<mapper resource=""/>	使用类路径的资源(Resources/java文件夹下)
<mapper url=""/>	使用全然限定路径
<mapper class=""/>	使用mapper接口类路径
<package name=""/>	注冊指定包下的全部mapper接口

注意:后两种方式要求mapper接口名和mapper映射文件名称称同样,且放在同一个文件夹中(不推荐).

其它关于MyBatis的配置信息可參考MyBatis文档.

---

整合Spring

实现MyBatis与Spring整合之后,能够使用Spring来管理SqlSessionFactory和mapper接口,Spring自己主动使用SqlSessionFactory创建SqlSession,并将实现好DAO接口注冊到Spring容器中, 供@Autowired使用.

---

1. 加入依赖

• 加入Spring支持

<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-core</artifactId>
    <version>${spring.version}</version>
</dependency>
<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-context</artifactId>
    <version>${spring.version}</version>
</dependency>
<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-beans</artifactId>
    <version>${spring.version}</version>
</dependency>
<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-expression</artifactId>
    <version>${spring.version}</version>
</dependency>
<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-aop</artifactId>
    <version>${spring.version}</version>
</dependency>
<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-test</artifactId>
    <version>${spring.version}</version>
</dependency>
<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-jdbc</artifactId>
    <version>${spring.version}</version>
</dependency>
<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-tx</artifactId>
    <version>${spring.version}</version>
</dependency>

• 加入MyBatis-Spring包

<dependency>
    <groupId>org.mybatis</groupId>
    <artifactId>mybatis-spring</artifactId>
    <version>${mybatis-spring.version}</version>
</dependency>

• 加入Hikaricp数据库连接池

<dependency>
    <groupId>com.zaxxer</groupId>
    <artifactId>HikariCP</artifactId>
    <version>${hikaricp.version}</version>
</dependency>

• 不要忘了MySQL数据库驱动

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>${mysql.version}</version>
</dependency>

---

2. 配置文件

• 精简mybatis-configuration.xml
  能够将数据源的配置移到以下的applicationContext-datasource.xml中.

<?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>
    <mappers>
        <mapper resource="mybatis/mapper/UserDAO.xml"/>
    </mappers>
</configuration>

• 定义applicationContext-datasource.xml

<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="classpath:db.properties"/>

    <!-- 配置数据源 -->
    <bean id="hikariConfig" class="com.zaxxer.hikari.HikariConfig">
        <property name="driverClassName" value="${mysql.driver.class}"/>
        <property name="jdbcUrl" value="${mysql.url}"/>
        <property name="username" value="${mysql.user}"/>
        <property name="password" value="${mysql.password}"/>
        <property name="maximumPoolSize" value="5"/>
        <property name="maxLifetime" value="700000"/>
        <property name="idleTimeout" value="600000"/>
        <property name="connectionTimeout" value="10000"/>
        <property name="dataSourceProperties">
            <props>
                <prop key="dataSourceClassName">com.mysql.jdbc.jdbc2.optional.MysqlDataSource</prop>
                <prop key="cachePrepStmts">true</prop>
                <prop key="prepStmtCacheSize">250</prop>
                <prop key="prepStmtCacheSqlLimit">2048</prop>
            </props>
        </property>
    </bean>

    <bean id="dataSource" class="com.zaxxer.hikari.HikariDataSource" destroy-method="close">
        <constructor-arg ref="hikariConfig"/>
    </bean>

    <!-- 配置SqlSessionFactory -->
    <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
        <property name="dataSource" ref="dataSource"/>
        <property name="configLocation" value="classpath:mybatis/mybatis-configuration.xml"/>
    </bean>

    <!-- 依据mapper接口生成代理对象 -->
    <bean id="dao" class="org.mybatis.spring.mapper.MapperFactoryBean">
        <property name="mapperInterface" value="com.fq.mybatis.UserDAO"/>
        <property name="sqlSessionFactory" ref="sqlSessionFactory"/>
    </bean>
</beans>

上面的配置存在一个问题:须要针对每一个mapper配置一个MapperFactoryBean(繁琐),因此这段依据mapper接口生成代理对象的配置可更改例如以下:

<!-- 基于包扫描的mapper配置 -->
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
    <property name="basePackage" value="com.fq.mybatis"/>
    <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"/>
</bean>

附: applicationContext-database.xml完整配置可參考: Git地址

• 定义Spring主配置文件applicationContext.xml
  定义注解驱动及载入静态配置文件datasource:

<?
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:annotation-config/>

    <!-- 载入静态配置文件 -->
    <import resource="applicationContext-datasource.xml"/>
</beans>

• Client

/**
 * @author jifang
 * @since 16/2/22 上午10:20.
 */
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = "classpath:spring/applicationContext.xml")
public class UserDAOClient {

    @Autowired
    private UserDAO dao;

    @Test
    public void client() throws Exception {
        User user = dao.selectUserById(1);
        System.out.println(user);
    }
}

---

缓存

与大多数持久层框架一样,MyBatis也支持一级缓存和二级缓存.

缓存作用是提升系统总体性能(不是提升数据库性能:由于缓存将数据库中的数据存放到内存,下次查询同样内容时直接从内存读取,减轻数据库压力,并且直接从内存中读取数据要比从数据库检索快非常多,因此能够提升系统总体性能).

缓存数据更新:当一个作用域(一级缓存为SqlSession/二级缓存为namespace)进行了C/U/D操作后,默认该作用域下全部缓存都被清空.

---

一级缓存

MyBatis默认开启了一级缓存.一级缓存是基于org.apache.ibatis.cache.impl.PerpetualCache的HashMap本地缓存,其存储作用域为SqlSession,同一个SqlSession几次执行同样SQL,后面的查询会直接从缓存中载入,从而提高查询效率/减轻数据库压力.当SqlSession经flush/close后,该SqlSession中的全部Cache数据被清空.

---

二级缓存

与一级缓存机制相似,MyBatis二级缓存默认也是採用PerpetualCache的HashMap存储,不同在于二级缓存存储作用域为namespace/mapper,并且能够自己定义缓存实现,如Ehcache.

MyBatis默认没有开启二级缓存,须要经过以下步骤才干使用:

• 启用二级缓存(可选)
  其须要在mybatis-configuration.xml的settings全局參数中开启:

<settings>
    <setting name="cacheEnabled" value="true"/>
</settings>

cacheEnabled对此配置文件下的全部cache进行全局性开/关设置(默觉得true).

• 配置缓存策略
  在mapper映射文件里加入<cache/>标签,以指定该namespace开启二级缓存, 并指定缓存策略:

<cache eviction="LRU" flushInterval="60000" size="512" readOnly="true"/>

1) eviction:缓存淘汰算法:

算法	描写叙述	释义
LRU	近期最少使用	移除最长时间不被使用的对象(默认).
FIFO	先进先出	按对象进入缓存的顺序移除.
SOFT	软引用	移除基于垃圾回收器状态和软引用规则的对象.
WEAK	弱引用	更积极地移除基于垃圾收集器状态和弱引用规则的对象.

2) flushInterval:刷新间隔(缓存过期时间),单位为毫秒,MyBatis会每隔一段时间自己主动清空缓存(默认刷新间隔为空, 即永只是期,仅调用语句时刷新).
3) size:引用数目,要记住你缓存的对象的数目和执行环境可用内存资源数目(默认1024).
4) readOnly: 仅仅读.假设为true,则全部同样SQL返回同一对象(因此这些对象不能改动,有助于提高性能,但并发操作同一条数据时,可能不安全);假设为false,则同样SQL后面返回的是cache的clone副本(通过序列化,慢一些但更是安全,因此默认是false).

• 序列化
  PO对象要实现Serializable序列化,由于二级缓存的存储介质不一定仅仅是内存:

public class User implements Serializable {
    //...
}

• Client

@Test
public void cacheClient() throws Exception {
    testCache(factory.openSession());
    testCache(factory.openSession());
    testCache(factory.openSession());
}

private void testCache(SqlSession session) throws Exception {
    UserDAO dao = session.getMapper(UserDAO.class);
    dao.selectUserById(1);
    // 须要将SqlSession关闭才干将数据写入缓存.
    session.close();
}

执行代码, 并观察log输出的命中率(Cache Hit Ratio).

• Statement配置

1) 禁用缓存: 在Statement中设置useCache="false"能够禁用当前select语句的二级缓存(默觉得true:该SQL启用二级缓存).

<select id="selectUserById" parameterType="java.lang.Integer" resultType="com.fq.domain.User" useCache="true">
    SELECT *
    FROM user
    WHERE id = #{id};
</select>

2)刷新缓存: 同一个namespace中,假设还有其它insert/update/delete操作,须要刷新缓存,使用flushCache="true"属性设置(默觉得true刷新缓存).

<insert id="insertUserList" parameterType="java.util.List" flushCache="true">
    INSERT INTO user(name, password) VALUES
    <if test="list != null and list.size != 0">
        <foreach collection="list" item="user" separator=",">
            (#{user.name}, #{user.password})
        </foreach>
    </if>
</insert>

---

整合Ehcache

MyBatis暴露一个org.apache.ibatis.cache.Cache接口出来,通过实现该接口,能够实现各类缓存产品(如Ehcache/Redis/Memcached)与MyBatis的整合(MyBatis的特长操作数据库,缓存管理并非其擅长,因此整合其它缓存产品能够提高系统总体性能).
Ehcache是一个纯Java开发的进程内缓存框架,具有开源/高速/灵活等特点,是Hibernate默认的CacheProvider.使用Ehcache须要在pom.xml中加入例如以下依赖:

<dependency>
    <groupId>net.sf.ehcache</groupId>
    <artifactId>ehcache-core</artifactId>
    <version>2.6.11</version>
</dependency>
<dependency>
    <groupId>org.mybatis.caches</groupId>
    <artifactId>mybatis-ehcache</artifactId>
    <version>1.0.3</version>
</dependency>

• 配置Ehcache
  在Resources文件夹下加入ehcache.xml配置文件

<ehcache>
    <diskStore path="/data/cache"/>
    <defaultCache
            maxElementsInMemory="1000"
            maxElementsOnDisk="10000000"
            eternal="false"
            overflowToDisk="false"
            timeToIdleSeconds="120"
            timeToLiveSeconds="120"
            diskExpiryThreadIntervalSeconds="120"
            memoryStoreEvictionPolicy="LRU">
    </defaultCache>
</ehcache>

属性	描写叙述
diskStore	指定缓存数据在磁盘的存储位置
maxElementsInMemory	在内存中缓存element的最大数目
maxElementsOnDisk	在磁盘上缓存element的最大数目,0表示无穷大
eternal	设定缓存的elements是否永远只是期.true,则缓存的数据始终有效,假设为false那么还要依据timeToIdleSeconds,timeToLiveSeconds推断
overflowToDisk	设定当内存缓存溢出的时候是否将过期的element缓存到磁盘上
timeToIdleSeconds	刷新间隔:缓存数据前后两次訪问时间超过timeToIdleSeconds时,这些数据便会删除(默觉得0,时间间隔无穷大)
timeToLiveSeconds	缓存element的有效生命期(默觉得0,时间无限)
diskSpoolBufferSizeMB	设置DiskStore(磁盘缓存)缓存区大小.默认是30MB.
diskPersistent	在JVM重新启动时是否使用磁盘保存Ehcache数据,默认是false.
diskExpiryThreadIntervalSeconds	磁盘缓存的清理线程执行间隔,默认是120秒.
memoryStoreEvictionPolicy	当内存缓存达到最大,有新的element加入的时候, 移除缓存中element的策略.默认是LRU(近期最少使用),可选的有LFU(最不常使用)和FIFO(先进先出)

• mapper配置ehcache

<cache type="org.mybatis.caches.ehcache.EhcacheCache" eviction="LRU" flushInterval="60000" size="1024"
       readOnly="true"/>

还能够依据需求调整当前namespace的缓存參数:

<cache type="org.mybatis.caches.ehcache.EhcacheCache">
    <property name="timeToIdleSeconds" value="3600"/>
    <property name="timeToLiveSeconds" value="3600"/>
    <!-- 同ehcache參数maxElementsInMemory -->
    <property name="maxEntriesLocalHeap" value="1000"/>
    <!-- 同ehcache參数maxElementsOnDisk -->
    <property name="maxEntriesLocalDisk" value="10000000"/>
    <property name="memoryStoreEvictionPolicy" value="LRU"/>
</cache>

---

二级缓存小结

• 适用场景
  对于查询请求多且对查询结果实时性要求不高的场景,可採用二级缓存减少数据库负担,提高訪问速度(业务场景如:微博/动态/订单信息等).
• 局限
  二级缓存对细粒度级别的缓存实现不好,如”缓存全部的商品信息时,二级缓存就无法实现当一个商品信息变化时仅仅刷新该商品缓存而不刷新全部商品缓存“,由于二级缓存区域以namespace为单位划分,当一个商品发生变化会将全部商品缓存清空,因此解决此类问题须要在上层对数据进行业务划分.