MyBatis(1)-DataSource

创建过程

MyBatis主要利用数据源(Data Source)来管理数据库连接,分为:UNPOOLED、POOLED和JNDI,现在主要看下POOLED也就是连接池方式,它的配置如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
<?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,所以要记得在工程里包含这个库。它还可以配置以下一些属性:

1
2
3
4
5
6
7
8
poolMaximumActiveConnections – 在任意时间可以存在的活动(也就是正在使用)连接数量,默认值:10
poolMaximumIdleConnections – 任意时间可能存在的空闲连接数。
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:

1
2
3
4
5
6
7
8
9
10
11
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.");
	}
}

再利用工厂模式(SOLID设计原则与工厂模式)创建PooledDataSource,放入利用Builder模式创建的Environment中,最后存入Configuration

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
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类图如下:

mybatis_uml_1

MyBatis(2)-连接管理

MyBatis(3)-执行流程