ibatis框架源码剖析光盘资料

/* * Copyright 2004 Clinton Begin * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package com.ibatis.common.jdbc; import com.ibatis.common.beans.ClassInfo; import com.ibatis.common.resources.Resources; import com.ibatis.common.logging.LogFactory; import com.ibatis.common.logging.Log; import javax.sql.DataSource; import java.io.PrintWriter; import java.lang.reflect.InvocationHandler; import java.lang.reflect.Method; import java.lang.reflect.Proxy; import java.sql.*; import java.util.*; /** * This is a simple, synchronous, thread-safe database connection pool. <p/> * REQUIRED PROPERTIES ------------------- JDBC.Driver JDBC.ConnectionURL * JDBC.Username JDBC.Password <p/> Pool.MaximumActiveConnections * Pool.MaximumIdleConnections Pool.MaximumCheckoutTime Pool.TimeToWait * Pool.PingQuery Pool.PingEnabled Pool.PingConnectionsOlderThan * Pool.PingConnectionsNotUsedFor Pool.QuietMode */ public class SimpleDataSource implements DataSource { private static final Log log = LogFactory.getLog(SimpleDataSource.class); // Required Properties private static final String PROP_JDBC_DRIVER = "JDBC.Driver"; private static final String PROP_JDBC_URL = "JDBC.ConnectionURL"; private static final String PROP_JDBC_USERNAME = "JDBC.Username"; private static final String PROP_JDBC_PASSWORD = "JDBC.Password"; private static final String PROP_JDBC_DEFAULT_AUTOCOMMIT = "JDBC.DefaultAutoCommit"; // Optional Properties private static final String PROP_POOL_MAX_ACTIVE_CONN = "Pool.MaximumActiveConnections"; private static final String PROP_POOL_MAX_IDLE_CONN = "Pool.MaximumIdleConnections"; private static final String PROP_POOL_MAX_CHECKOUT_TIME = "Pool.MaximumCheckoutTime"; private static final String PROP_POOL_TIME_TO_WAIT = "Pool.TimeToWait"; private static final String PROP_POOL_PING_QUERY = "Pool.PingQuery"; private static final String PROP_POOL_PING_CONN_OLDER_THAN = "Pool.PingConnectionsOlderThan"; private static final String PROP_POOL_PING_ENABLED = "Pool.PingEnabled"; private static final String PROP_POOL_PING_CONN_NOT_USED_FOR = "Pool.PingConnectionsNotUsedFor"; private int expectedConnectionTypeCode; // Additional Driver Properties prefix private static final String ADD_DRIVER_PROPS_PREFIX = "Driver."; private static final int ADD_DRIVER_PROPS_PREFIX_LENGTH = ADD_DRIVER_PROPS_PREFIX .length(); // ----- BEGIN: FIELDS LOCKED BY POOL_LOCK ----- // private final Object POOL_LOCK = new Object(); private final Thread POOL_Thread = new Thread(); // 空闲的连接池列表，内部对象为SimplePooledConnection实例化对象 private List idleConnections = new ArrayList(); // 活动的连接池列表，内部对象为SimplePooledConnection实例化对象 private List activeConnections = new ArrayList(); // 请求连接的总数 private long requestCount = 0; // 累计请求时间 private long accumulatedRequestTime = 0; // 累计检查时间 private long accumulatedCheckoutTime = 0; // 统计超时并被被回收的 SimplePooledConnection实例化对象的个数 private long claimedOverdueConnectionCount = 0; // 统计超时并被被回收的 SimplePooledConnection实例化对象的时间 private long accumulatedCheckoutTimeOfOverdueConnections = 0; // 累积为回收SimplePooledConnection实例化对象而等待的时间 private long accumulatedWaitTime = 0; // 累积为回收SimplePooledConnection实例化对象而等待的次数 private long hadToWaitCount = 0; // 空闲池中SimplePooledConnection实例化对象无效的次数 private long badConnectionCount = 0; // ----- END: FIELDS LOCKED BY POOL_LOCK ----- // ----- BEGIN: PROPERTY FIELDS FOR CONFIGURATION ----- // 数据库属性配置信息 private String jdbcDriver; private String jdbcUrl; private String jdbcUsername; private String jdbcPassword; private boolean jdbcDefaultAutoCommit; private Properties driverProps; private boolean useDriverProps; //活动连接池的最大容量 private int poolMaximumActiveConnections; //空闲连接池的最大容量 private int poolMaximumIdleConnections; //连接池的检查时间 private int poolMaximumCheckoutTime; //连接池的等待时间 private int poolTimeToWait; private String poolPingQuery; private boolean poolPingEnabled; private int poolPingConnectionsOlderThan; private int poolPingConnectionsNotUsedFor; // ----- END: PROPERTY FIELDS FOR CONFIGURATION ----- /** * Constructor to allow passing in a map of properties for configuration * * @param props - * the configuration parameters */ public SimpleDataSource(Map props) { initialize(props); } private void initialize(Map props) { try { String prop_pool_ping_query = null; if (props == null) { throw new RuntimeException( "SimpleDataSource: The properties map passed to the initializer was null."); } if (!(props.containsKey(PROP_JDBC_DRIVER) && props.containsKey(PROP_JDBC_URL) && props.containsKey(PROP_JDBC_USERNAME) && props .containsKey(PROP_JDBC_PASSWORD))) { throw new RuntimeException( "SimpleDataSource: Some properties were not set."); } else { jdbcDriver = (String) props.get(PROP_JDBC_DRIVER); jdbcUrl = (String) props.get(PROP_JDBC_URL); jdbcUsername = (String) props.get(PROP_JDBC_USERNAME); jdbcPassword = (String) props.get(PROP_JDBC_PASSWORD); poolMaximumActiveConnections = props .containsKey(PROP_POOL_MAX_ACTIVE_CONN) ? Integer .parseInt((String) props.get(PROP_POOL_MAX_ACTIVE_CONN)) : 10; poolMaximumIdleConnections = props .containsKey(PROP_POOL_MAX_IDLE_CONN) ? Integer .parseInt((String) props.get(PROP_POOL_MAX_IDLE_CONN)) : 5; poolMaximumCheckoutTime = props .containsKey(PROP_POOL_MAX_CHECKOUT_TIME) ? Integer .parseInt((String) props .get(PROP_POOL_MAX_CHECKOUT_TIME)) : 20000; poolTimeToWait = props.containsKey(PROP_POOL_TIME_TO_WAIT) ? Integer .parseInt((String) props.get(PROP_POOL_TIME_TO_WAIT)) : 20000; poolPingEnabled = props.containsKey(PROP_POOL_PING_ENABLED) && Boolean.valueOf( (String) props.get(PROP_POOL_PING_ENABLED)) .booleanValue(); prop_pool_ping_query = (String) props.get(PROP_POOL_PING_QUERY); poolPingQuery = props.containsKey(PROP_POOL_PING_QUERY) ? prop_pool_ping_query : "NO PING QUERY SET"; poolPingConnectionsOlderThan = props .containsKey(PROP_POOL_PING_CONN_OLDER_THAN) ? Integer .parseInt((String) props .get(PROP_POOL_PING_CONN_OLDER_THAN)) : 0; poolPingConnectionsNotUsedFor = props .containsKey(PROP_POOL_PING_CONN_NOT_USED_FOR) ? Integer .parseInt((String) props .get(PROP_POOL_PING_CONN_NOT_USED_FOR)) : 0; jdbcDefaultAutoCommit = props .containsKey(PROP_JDBC_DEFAULT_AUTOCOMMIT) && Boolean.valueOf( (String) props .get(PROP_JDBC_DEFAULT_AUTOCOMMIT)) .booleanValue(); useDriverProps = false; Iterator propIter = props.keySet().iterator(); driverProps = new Properties(); driverProps.put("user", jdbcUsername); driverProps.put("p