DateSource的创建过程

MyBatis的数据源(Date Source)分为:UNPOOLED、POOLED和JNDI,我们主要看下POOLED也就是连接池方式,它的配置如下:

<?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>  <environments default="development">    <environment id="development">      <transactionManager type="JDBC"/>      <dataSource type="POOLED">        <property name="driver" value="com.mysql.jdbc.Driver"/>        <property name="url" value="${url}"/>        <property name="username" value="${username}"/>        <property name="password" value="${password}"/>      </dataSource>    </environment>  </environments>  <mappers>      <package name="core.mappers"/>  </mappers></configuration>

这里注意,MyBatis底层也是使用MySQL提供的JDBC driver,所以要记得在工程里包含这个库。它还可以配置以下一些属性:

poolMaximumActiveConnections – 在任意时间可以存在的活动(也就是正在使用)连接数量,默认值:10poolMaximumIdleConnections – 任意时间可能存在的空闲连接数。poolMaximumCheckoutTime – 在被强制Roll Back(认为是Overdue)之前,池中连接可以被检出(checked out使用)的时间,默认值:20000 毫秒(即 20 秒)poolTimeToWait – 这是一个底层设置,如果获取连接花费了相当长的时间,连接池会打印状态日志并重新尝试获取一个连接(避免在误配置的情况下一直安静的失败),默认值:20000 毫秒(即 20 秒)。poolMaximumLocalBadConnectionTolerance – 这是一个关于坏连接容忍度的底层设置, 作用于每一个尝试从缓存池获取连接的线程。 如果这个线程获取到的是一个坏的连接,那么这个数据源允许这个线程尝试重新获取一个新的连接,但是这个重新尝试的次数不应该超过 poolMaximumIdleConnections 与 poolMaximumLocalBadConnectionTolerance 之和。 默认值:3 (新增于 3.4.5)poolPingQuery – 发送到数据库的侦测查询,用来检验连接是否正常工作并准备接受请求。默认是“NO PING QUERY SET”,这会导致多数数据库驱动失败时带有一个恰当的错误消息。poolPingEnabled – 是否启用侦测查询。若开启,需要设置 poolPingQuery 属性为一个可执行的 SQL 语句(最好是一个速度非常快的 SQL 语句),默认值:false。poolPingConnectionsNotUsedFor – 配置 poolPingQuery 的频率。可以被设置为和数据库连接超时时间一样,来避免不必要的侦测,默认值:0(即所有连接每一时刻都被侦测 — 当然仅当 poolPingEnabled 为 true 时适用)。

在利用SqlSessionFactoryBuilder创建DefaultSqlSessionFactory时,通过XMLConfigBuilder来读取上面config文件里的内容,看到dataSource的类型为POOLED,则利用反射创建PooledDataSourceFactory:

    private DataSourceFactory dataSourceElement(XNode context) throws Exception {        if (context != null) {            String type = context.getStringAttribute("type");            Properties props = context.getChildrenAsProperties();            DataSourceFactory factory = (DataSourceFactory)this.resolveClass(type).newInstance();            factory.setProperties(props);            return factory;        } else {            throw new BuilderException("Environment declaration requires a DataSourceFactory.");        }    }

再利用工厂模式创建PooledDataSource,放入利用Builder模式创建的Environment中,最后存入Configuration

    private void environmentsElement(XNode context) throws Exception {        if (context != null) {            if (this.environment == null) {                this.environment = context.getStringAttribute("default");            }            Iterator var2 = context.getChildren().iterator();            while(var2.hasNext()) {                XNode child = (XNode)var2.next();                String id = child.getStringAttribute("id");                if (this.isSpecifiedEnvironment(id)) {                    TransactionFactory txFactory = this.transactionManagerElement(child.evalNode("transactionManager"));                    DataSourceFactory dsFactory = this.dataSourceElement(child.evalNode("dataSource"));                    DataSource dataSource = dsFactory.getDataSource();                    Builder environmentBuilder = (new Builder(id)).transactionFactory(txFactory).dataSource(dataSource);                    this.configuration.setEnvironment(environmentBuilder.build());                }            }        }    }

UML类图如下: