ibatis-2.3.0.677增加对c3p0连接池的支持

 

1,在com.ibatis.sqlmap.engine.datasource包新增类C3P0DataSourceFactory：

 

package com.ibatis.sqlmap.engine.datasource;

import com.ibatis.common.jdbc.C3P0Configuration;
import java.util.Map;
import javax.sql.DataSource;

public class C3P0DataSourceFactory
  implements DataSourceFactory
{
  private DataSource dataSource;

  public void initialize(Map map)
  {
    C3P0Configuration c3p0 = new C3P0Configuration(map);
    this.dataSource = c3p0.getDataSource();
  }

  public DataSource getDataSource() {
    return this.dataSource;
  }
}

 

 

2，在com.ibatis.common.jdbc包新增类C3P0Configuration ,主要作用是加载c3p0的配置文件信息： 

 

package com.ibatis.common.jdbc;

import com.ibatis.common.beans.Probe;
import com.ibatis.common.beans.ProbeFactory;
import com.ibatis.common.exception.NestedRuntimeException;
import com.mchange.v2.c3p0.ComboPooledDataSource;
import java.util.Iterator;
import java.util.Map;
import java.util.Set;
import javax.sql.DataSource;
import org.apache.commons.dbcp.BasicDataSource;

public class C3P0Configuration
{
  private static final Probe PROBE = ProbeFactory.getProbe();
  private static final String ADD_DRIVER_PROPS_PREFIX = "Driver.";
  private static final int ADD_DRIVER_PROPS_PREFIX_LENGTH = "Driver.".length();
  private DataSource dataSource;

  public C3P0Configuration(Map properties)
  {
    try
    {
      this.dataSource = legacyC3P0Configuration(properties);
      if (this.dataSource == null)
        this.dataSource = newDbcpConfiguration(properties);
    } catch (Exception e) {
      throw new NestedRuntimeException("Error initializing C3P0DataSourceFactory.  Cause: " + e, e);
    }
  }

  public DataSource getDataSource() {
    return this.dataSource;
  }

  private BasicDataSource newDbcpConfiguration(Map map) {
    BasicDataSource basicDataSource = new BasicDataSource();
    Iterator props = map.keySet().iterator();
    while (props.hasNext()) {
      String propertyName = (String)props.next();
      if (propertyName.startsWith("Driver.")) {
        String value = (String)map.get(propertyName);
        basicDataSource.addConnectionProperty(propertyName.substring(ADD_DRIVER_PROPS_PREFIX_LENGTH), value);
      } else if (PROBE.hasWritableProperty(basicDataSource, propertyName)) {
        String value = (String)map.get(propertyName);
        Object convertedValue = convertValue(basicDataSource, propertyName, value);
        PROBE.setObject(basicDataSource, propertyName, convertedValue);
      }
    }
    return basicDataSource;
  }

  private Object convertValue(Object object, String propertyName, String value) {
    Object convertedValue = value;
    Class targetType = PROBE.getPropertyTypeForSetter(object, propertyName);
    if ((targetType == Integer.class) || (targetType == Integer.TYPE))
      convertedValue = Integer.valueOf(value);
    else if ((targetType == Long.class) || (targetType == Long.TYPE))
      convertedValue = Long.valueOf(value);
    else if ((targetType == Boolean.class) || (targetType == Boolean.TYPE)) {
      convertedValue = Boolean.valueOf(value);
    }
    return convertedValue;
  }

  private ComboPooledDataSource legacyC3P0Configuration(Map map) throws Exception {
    ComboPooledDataSource basicDataSource = null;
    if (map.containsKey("driver")) {
      basicDataSource = new ComboPooledDataSource();
      String driver = (String)map.get("driver");
      String url = (String)map.get("url");
      String username = (String)map.get("username");
      String password = (String)map.get("password");

      String initialPoolSize = (String)map.get("initialPoolSize");
      String maxPoolSize = (String)map.get("maxPoolSize");
      String minPoolSize = (String)map.get("minPoolSize");
      String acquireIncrement = (String)map.get("acquireIncrement");
      String maxIdleTime = (String)map.get("maxIdleTime");
      String maxIdleTimeExcessConnections = (String)map.get("maxIdleTimeExcessConnections");
      String maxConnectionAge = (String)map.get("maxConnectionAge");
      String maxStatements = (String)map.get("maxStatements");
      String maxStatementsPerConnection = (String)map.get("maxStatementsPerConnection");
      String numHelperThreads = (String)map.get("numHelperThreads");
      String automaticTestTable = (String)map.get("automaticTestTable");
      String preferredTestQuery = (String)map.get("preferredTestQuery");
      String checkoutTimeout = (String)map.get("checkoutTimeout");
      String idleConnectionTestPeriod = (String)map.get("idleConnectionTestPeriod");
      String acquireRetryDelay = (String)map.get("acquireRetryDelay");
      String acquireRetryAttempts = (String)map.get("acquireRetryAttempts");
      String testConnectionOnCheckin = (String)map.get("testConnectionOnCheckin");

      basicDataSource.setDriverClass(driver);
      basicDataSource.setJdbcUrl(url);
      basicDataSource.setUser(username);
      basicDataSource.setPassword(password);

      if (notEmpty(automaticTestTable)) {
        basicDataSource.setAutomaticTestTable(automaticTestTable);
      }
      if (notEmpty(acquireRetryDelay)) {
        basicDataSource.setAcquireRetryDelay(Integer.valueOf(acquireRetryDelay).intValue());
      }
      if (notEmpty(testConnectionOnCheckin)) {
        basicDataSource.setTestConnectionOnCheckin(Boolean.valueOf(testConnectionOnCheckin).booleanValue());
      }
      if (notEmpty(acquireRetryAttempts)) {
        basicDataSource.setAcquireRetryAttempts(Integer.valueOf(acquireRetryAttempts).intValue());
      }
      if (notEmpty(preferredTestQuery)) {
        basicDataSource.setPreferredTestQuery(preferredTestQuery);
      }
      if (notEmpty(checkoutTimeout)) {
        basicDataSource.setCheckoutTimeout(Integer.valueOf(checkoutTimeout).intValue());
      }
      if (notEmpty(checkoutTimeout)) {
        basicDataSource.setCheckoutTimeout(Integer.valueOf(checkoutTimeout).intValue());
      }
      if (notEmpty(idleConnectionTestPeriod)) {
        basicDataSource.setIdleConnectionTestPeriod(Integer.valueOf(idleConnectionTestPeriod).intValue());
      }
      if (notEmpty(initialPoolSize)) {
        basicDataSource.setInitialPoolSize(Integer.parseInt(initialPoolSize));
      }
      if (notEmpty(maxPoolSize)) {
        basicDataSource.setMaxPoolSize(Integer.parseInt(maxPoolSize));
      }
      if (notEmpty(minPoolSize)) {
        basicDataSource.setMinPoolSize(Integer.parseInt(minPoolSize));
      }
      if (notEmpty(acquireIncrement)) {
        basicDataSource.setAcquireIncrement(Integer.parseInt(acquireIncrement));
      }
      if (notEmpty(maxIdleTime)) {
        basicDataSource.setMaxIdleTime(Integer.parseInt(maxIdleTime));
      }
      if (notEmpty(maxIdleTimeExcessConnections)) {
        basicDataSource.setMaxIdleTimeExcessConnections(Integer.parseInt(maxIdleTimeExcessConnections));
      }
      if (notEmpty(maxConnectionAge)) {
        basicDataSource.setMaxConnectionAge(Integer.parseInt(maxConnectionAge));
      }
      if (notEmpty(maxStatements)) {
        basicDataSource.setMaxStatements(Integer.parseInt(maxStatements));
      }
      if (notEmpty(maxStatementsPerConnection)) {
        basicDataSource.setMaxStatementsPerConnection(Integer.parseInt(maxStatementsPerConnection));
      }
      if (notEmpty(numHelperThreads)) {
        basicDataSource.setNumHelperThreads(Integer.parseInt(numHelperThreads));
      }
    }
    return basicDataSource;
  }

  private boolean notEmpty(String s) {
    return (s != null) && (s.length() > 0);
  }
}

 

 

 3,在com.ibatis.sqlmap.engine.builder.xml下SqlMapConfigParser类的registerDefaultTypeAliases方法中添加如下代码：

this.vars.typeHandlerFactory.putTypeAlias("C3P0", C3P0DataSourceFactory.class.getName());

 

 

 4，在com.ibatis.common.exception下新增异常处理类，如果没有此包，可以新建，代码见附件Exception.rar(NestedException.class , NestedRuntimeException.class)

 

5, ibatis配置文件如下，注意property中的name必须和下面一致：

<transactionManager type="JDBC">
  <dataSource type="C3P0">
   <property name="driver" value="${driver}" />
   <property name="url" value="${url}" />
   <property name="username" value="${username}" />
   <property name="password" value="${password}" />
   <property name="initialPoolSize" value="10" />
   <property name="maxPoolSize" value="100" />
   <property name="minPoolSize" value="10" />
   <property name="acquireIncrement" value="5" />
   <property name="maxIdleTime" value="3600" />
   <property name="maxIdleTimeExcessConnections" value="1200" />
   <property name="maxConnectionAge" value="27000" />
   <property name="maxStatements" value="200" />
   <property name="maxStatementsPerConnection" value="50" />
   <property name="numHelperThreads" value="10" />
   <property name="idleConnectionTestPeriod"  value="5" />
   <property name="checkoutTimeout" value="30000"/>
   <property name="preferredTestQuery" value="select 1"/>
   <property name="acquireRetryDelay" value="1000"/>
   <property name="acquireRetryAttempts" value="1"/>
   <property name="testConnectionOnCheckin" value="true"/>
   <property name="automaticTestTable" value="c3p0Test"/>
  </dataSource>
 </transactionManager>

 配置中只支持如上属性配置，如果需要加额外属性请在第二步的C3P0Configuration类的legacyC3P0Configuration方法中增加

附件ibatis-2.3.0.677.jar包是已扩展,无需修改

增加c3p0支持包：c3p0-0.9.1.2.jar

 

 

 

PS： 以上只限ibatis-2.3.0.677版本，其他版本按照此方式未必行得通

以下亲测可用

 

PS： 以下只限ibatis-2.3.0.677版本

评论

1 楼 zhh309 2014-11-12  

学习了。