C3P0属性设置和数据库连接池的获取-成都快上网建站

C3P0属性设置和数据库连接池的获取

在C3p0构建时,有驱动相关信息及数据库连接池相关的属性设置,及连接的获取,今天我们先来看一下,驱动相关信息及数据库连接池相关的属性设置,在连接的获取。 
从下面几句开始, 

网站建设哪家好,找创新互联!专注于网页设计、网站建设、微信开发、小程序设计、集团企业网站建设等服务项目。为回馈新老客户创新互联还提供了合浦免费建站欢迎大家使用!

Java代码  C3P0属性设置和数据库连接池的获取

  1. cpDSource = new ComboPooledDataSource();  

  2. //设置DriverManagerDataSource驱动相关信息  

  3. cpDSource.setDriverClass(props.getProperty("driver"));  

  4. cpDSource.setJdbcUrl(props.getProperty("url"));  

  5. cpDSource.setUser(props.getProperty("user"));  

  6. cpDSource.setPassword(props.getProperty("password"));  


//AbstractComboPooledDataSource的两个关键内部成员DriverManagerDataSource,WrapperConnectionPoolDataSource 

Java代码下载   C3P0属性设置和数据库连接池的获取

  1. public AbstractComboPooledDataSource(boolean autoregister)  

  2.     {  

  3.         //  

  4.         super(autoregister);  

  5.     //新建驱动数据源管理器  

  6.         dmds = new DriverManagerDataSource();  

  7.     //新建数据库连接池  

  8.         wcpds = new WrapperConnectionPoolDataSource();  

  9.     //设置数据连接池的数据源驱动管理器  

  10.         wcpds.setNestedDataSource(dmds);  

  11.         try  

  12.         {  

  13.             setConnectionPoolDataSource(wcpds);  

  14.         }  

  15.         catch(PropertyVetoException e)  

  16.         {  

  17.             logger.log(MLevel.WARNING, "Hunh??? This can't happen. We haven't set up any listeners to veto the property change yet!", e);  

  18.             throw new RuntimeException((new StringBuilder()).append("Hunh??? This can't happen. We haven't set up any listeners to veto the property change yet! ").append(e).toString());  

  19.         }  

  20.         setUpPropertyEvents();  

  21.     }  

  22. }  

  23. //设置driverClass  

  24. public void setDriverClass(String driverClass)  

  25.         throws PropertyVetoException  

  26.     {  

  27.         dmds.setDriverClass(driverClass);  

  28.     }  

  29.  //设置jdbcUrl  

  30.  public void setJdbcUrl(String jdbcUrl)  

  31.     {  

  32.         if(diff(dmds.getJdbcUrl(), jdbcUrl))  

  33.         {  

  34.             dmds.setJdbcUrl(jdbcUrl);  

  35.             resetPoolManager(false);  

  36.         }  

  37.     }  

  38.    //设置user  

  39.     public void setUser(String user)  

  40.     {  

  41.         if(diff(dmds.getUser(), user))  

  42.         {  

  43.             dmds.setUser(user);  

  44.             resetPoolManager(false);  

  45.         }  

  46.     }  

  47.     //设置password  

  48.     public void setPassword(String password)  

  49.     {  

  50.         if(diff(dmds.getPassword(), password))  

  51.         {  

  52.             dmds.setPassword(password);  

  53.             resetPoolManager(false);  

  54.         }  

  55.     }  


//设置WrapperConnectionPoolDataSource相关属性 

Java代码 下载  C3P0属性设置和数据库连接池的获取

  1. cpDSource.setInitialPoolSize(5);  

  2. cpDSource.setMaxPoolSize(30);  

  3. cpDSource.setMinPoolSize(5);  

  4. cpDSource.setMaxStatements(100);  

  5. cpDSource.setIdleConnectionTestPeriod(60);  

  6. cpDSource.setBreakAfterAcquireFailure(false);  

  7. cpDSource.setAcquireRetryAttempts(30);  

  8. cpDSource.setTestConnectionOnCheckout(false);  


//设置连接失败尝试连接数 

Java代码  C3P0属性设置和数据库连接池的获取

  1. public void setAcquireRetryAttempts(int acquireRetryAttempts)  

  2.     {  

  3.         if(diff(wcpds.getAcquireRetryAttempts(), acquireRetryAttempts))  

  4.         {  

  5.             wcpds.setAcquireRetryAttempts(acquireRetryAttempts);  

  6.             resetPoolManager(false);  

  7.         }  

  8.     }  

  9.    

  10.     public int getAcquireRetryDelay()  

  11.     {  

  12.         return wcpds.getAcquireRetryDelay();  

  13.     }  

  14.   

  15.     public void setAcquireRetryDelay(int acquireRetryDelay)  

  16.     {  

  17.         if(diff(wcpds.getAcquireRetryDelay(), acquireRetryDelay))  

  18.         {  

  19.             wcpds.setAcquireRetryDelay(acquireRetryDelay);  

  20.             resetPoolManager(false);  

  21.         }  

  22.     }  

  23.   

  24.     public boolean isAutoCommitOnClose()  

  25.     {  

  26.         return wcpds.isAutoCommitOnClose();  

  27.     }  

  28.     //设置是否自动提交  

  29.     public void setAutoCommitOnClose(boolean autoCommitOnClose)  

  30.     {  

  31.         if(diff(wcpds.isAutoCommitOnClose(), autoCommitOnClose))  

  32.         {  

  33.             wcpds.setAutoCommitOnClose(autoCommitOnClose);  

  34.             resetPoolManager(false);  

  35.         }  

  36.     }  

  37.       

  38.     public int getInitialPoolSize()  

  39.     {  

  40.         return wcpds.getInitialPoolSize();  

  41.     }  

  42.     //连接池初始化大小  

  43.     public void setInitialPoolSize(int initialPoolSize)  

  44.     {  

  45.         if(diff(wcpds.getInitialPoolSize(), initialPoolSize))  

  46.         {  

  47.             wcpds.setInitialPoolSize(initialPoolSize);  

  48.             resetPoolManager(false);  

  49.         }  

  50.     }  

  51.   下载 

  52.     public int getMaxIdleTime()  

  53.     {  

  54.         return wcpds.getMaxIdleTime();  

  55.     }  

  56.    //maxIdleTime  

  57.     public void setMaxIdleTime(int maxIdleTime)  

  58.     {  

  59.         if(diff(wcpds.getMaxIdleTime(), maxIdleTime))  

  60.         {  

  61.             wcpds.setMaxIdleTime(maxIdleTime);  

  62.             resetPoolManager(false);  

  63.         }  

  64.     }  

  65.     //maxPoolSize  

  66.     public void setMaxPoolSize(int maxPoolSize)  

  67.     {  

  68.         if(diff(wcpds.getMaxPoolSize(), maxPoolSize))  

  69.         {  

  70.             wcpds.setMaxPoolSize(maxPoolSize);  

  71.             resetPoolManager(false);  

  72.         }  

  73.     }  

  74.    //maxStatements  

  75.     public void setMaxStatements(int maxStatements)  

  76.     {  

  77.         if(diff(wcpds.getMaxStatements(), maxStatements))  

  78.         {  

  79.             wcpds.setMaxStatements(maxStatements);  

  80.             resetPoolManager(false);  

  81.         }  

  82.     }  


从上面可以看出cpDSource初始化driver相关属性,是初始化数据源驱动管理器DriverManagerDataSource的属性;初始化poolConnection相关属性,是初始化数据库连接池包装类WrapperConnectionPoolDataSource的属性。 

再看连接的获取,从下面一句开始, 

Java代码  C3P0属性设置和数据库连接池的获取

  1. con = cpDSource.getConnection();  


此方法在ComboPooledDataSource和其父类中都没,追溯到AbstractComboPooledDataSource的 
父类AbstractPoolBackedDataSource 
//AbstractPoolBackedDataSource 

Java代码  C3P0属性设置和数据库连接池的获取

  1. public abstract class AbstractPoolBackedDataSource extends PoolBackedDataSourceBase  

  2.     implements PooledDataSource  

  3. {  

  4.     public Connection getConnection()  

  5.         throws SQLException  

  6.     {  

  7.          //获取数据库连接池管理器  

  8.         PooledConnection pc = getPoolManager().getPool().checkoutPooledConnection();  

  9.     //从数据库连接池,返回数据库连接  

  10.         return pc.getConnection();  

  11.     }  

  12. }  


先看获取数据库连接池管理器 
//获取数据库连接池管理器 
PooledConnection pc = getPoolManager().getPool().checkoutPooledConnection(); 
    
    //获取数据库连接池管理器 
  下载 

Java代码  C3P0属性设置和数据库连接池的获取

  1. private synchronized C3P0PooledConnectionPoolManager getPoolManager()  

  2.        throws SQLException  

  3.    {  

  4.        if(poolManager == null)  

  5.        {  

  6.    //获取数据源数据库连接池  

  7.            ConnectionPoolDataSource cpds = assertCpds();  

  8.     //构建数据库连接池管理器  

  9.            poolManager = new C3P0PooledConnectionPoolManager(cpds, null, null, getNumHelperThreads(), getIdentityToken(), getDataSourceName());  

  10.            if(logger.isLoggable(MLevel.INFO))  

  11.                logger.info((new StringBuilder()).append("Initializing c3p0 pool... ").append(toString(true)).toString());  

  12.        }  

  13.        return poolManager;  

  14.    }  

  15.    //确定数据源数据库连接池  

  16.     private synchronized ConnectionPoolDataSource assertCpds()  

  17.        throws SQLException  

  18.    {  

  19.        if(is_closed)  

  20.            throw new SQLException((new StringBuilder()).append(this).append(" has been closed() -- you can no longer use it.").toString());  

  21.       //获取数据源数据库连接池  

  22. ConnectionPoolDataSource out = getConnectionPoolDataSource();  

  23.        if(out == null)  

  24.            throw new SQLException("Attempted to use an uninitialized PoolBackedDataSource. Please call setConnectionPoolDataSource( ... ) to initialize.");  

  25.        else  

  26.            return out;  

  27.    }  


//PoolBackedDataSourceBase 

Java代码  C3P0属性设置和数据库连接池的获取

  1. public class PoolBackedDataSourceBase extends IdentityTokenResolvable  

  2.     implements Referenceable, Serializable  

  3. {  

  4.    //获取数据源数据库连接池  

  5. public synchronized ConnectionPoolDataSource getConnectionPoolDataSource()  

  6.     {  

  7.         return connectionPoolDataSource;  

  8.     }  

  9.      

  10.     public synchronized void setConnectionPoolDataSource(ConnectionPoolDataSource connectionPoolDataSource)  

  11.         throws PropertyVetoException  

  12.     {  

  13.         ConnectionPoolDataSource oldVal = this.connectionPoolDataSource;  

  14.         if(!eqOrBothNull(oldVal, connectionPoolDataSource))  

  15.             vcs.fireVetoableChange("connectionPoolDataSource", oldVal, connectionPoolDataSource);  

  16.         this.connectionPoolDataSource = connectionPoolDataSource;  

  17.         if(!eqOrBothNull(oldVal, connectionPoolDataSource))  

  18.             pcs.firePropertyChange("connectionPoolDataSource", oldVal, connectionPoolDataSource);  

  19.     }  

  20. }  


这个数据源数据连接池是什么呢?还记得我们前面,有讲过AbstractComboPooledDataSource的构造有这么一段 

Java代码下载   C3P0属性设置和数据库连接池的获取

  1. public AbstractComboPooledDataSource(boolean autoregister)  

  2.     {  

  3.         super(autoregister);  

  4.         dmds = new DriverManagerDataSource();  

  5.         wcpds = new WrapperConnectionPoolDataSource();  

  6.         wcpds.setNestedDataSource(dmds);  

  7.         try  

  8.         {  

  9.         //设置数据源数据库连接池为WrapperConnectionPoolDataSource  

  10.             setConnectionPoolDataSource(wcpds);  

  11.         }  

  12.     }  


现在回到getPoolManager的构建数据库连接池管理器这一句 

Java代码  C3P0属性设置和数据库连接池的获取

  1. poolManager = new C3P0PooledConnectionPoolManager(cpds, null, null, getNumHelperThreads(), getIdentityToken(), getDataSourceName());  


//C3P0PooledConnectionPoolManager 

Java代码  C3P0属性设置和数据库连接池的获取

  1. public final class C3P0PooledConnectionPoolManager  

  2. {  

  3.     private static final boolean POOL_EVENT_SUPPORT = false;  

  4.     private static final CoalesceChecker COALESCE_CHECKER;  

  5.     static final Coalescer COALESCER;  

  6.     static final int DFLT_NUM_TASK_THREADS_PER_DATA_SOURCE = 3;  

  7.     ThreadPoolAsynchronousRunner taskRunner;//  

  8.     ThreadPoolAsynchronousRunner deferredStatementDestroyer;  

  9.     Timer timer;  

  10.     ResourcePoolFactory rpfact;  

  11.     Map authsToPools;  

  12.     final ConnectionPoolDataSource cpds;  

  13.     final Map propNamesToReadMethods;  

  14.     final Map flatPropertyOverrides;  

  15.     final Map userOverrides;  

  16.     final DbAuth defaultAuth;  

  17.     final String parentDataSourceIdentityToken;  

  18.     final String parentDataSourceName;  

  19.     int num_task_threads;  

  20.     static   

  21.     {  

  22.         COALESCE_CHECKER = IdentityTokenizedCoalesceChecker.INSTANCE;  

  23.         COALESCER = CoalescerFactory.createCoalescer(COALESCE_CHECKER, true, false);  

  24.     }  

  25.     //初始化C3P0PooledConnectionPoolManager,cpds为WrapperConnectionPoolDataSource  

  26.     public C3P0PooledConnectionPoolManager(ConnectionPoolDataSource cpds, Map flatPropertyOverrides, Map forceUserOverrides, int num_task_threads, String parentDataSourceIdentityToken, String parentDataSourceName)  

  27.         throws SQLException  

  28.     {  

  29.         //任务线程数  

  30.         this.num_task_threads = 3;  

  31.         try  

  32.         {  

  33.             this.cpds = cpds;//初始化数据库连接池  

  34.             this.flatPropertyOverrides = flatPropertyOverrides;  

  35.             this.num_task_threads = num_task_threads;  

  36.             this.parentDataSourceIdentityToken = parentDataSourceIdentityToken;  

  37.             this.parentDataSourceName = parentDataSourceName;  

  38.             DbAuth auth = null;  

  39.             if(flatPropertyOverrides != null)  

  40.             {  

  41.                 String overrideUser = (String)flatPropertyOverrides.get("overrideDefaultUser");  

  42.                 String overridePassword = (String)flatPropertyOverrides.get("overrideDefaultPassword");  

  43.                 if(overrideUser == null)  

  44.                 {  

  45.                     overrideUser = (String)flatPropertyOverrides.get("user");  

  46.                     overridePassword = (String)flatPropertyOverrides.get("password");  

  47.                 }  

  48.                 if(overrideUser != null)  

  49.                     auth = new DbAuth(overrideUser, overridePassword);  

  50.             }  

  51.             if(auth == null)  

  52.             //初始化数据库验证  

  53.                 auth = C3P0ImplUtils.findAuth(cpds);  

  54.             defaultAuth = auth;  

  55.             Map tmp = new HashMap();  

  56.             BeanInfo bi = Introspector.getBeanInfo(cpds.getClass());  

  57.             PropertyDescriptor pds[] = bi.getPropertyDescriptors();  

  58.             PropertyDescriptor pd = null;  

  59.             int i = 0;  

  60.             for(int len = pds.length; i < len; i++)  

  61.             {  下载 

  62.                 pd = pds[i];  

  63.                 String name = pd.getName();  

  64.                 Method m = pd.getReadMethod();  

  65.                 if(m != null)  

  66.                     tmp.put(name, m);  

  67.             }  

  68.   

  69.             propNamesToReadMethods = tmp;  

  70.             if(forceUserOverrides == null)  

  71.             {  

  72.                 Method uom = (Method)propNamesToReadMethods.get("userOverridesAsString");  

  73.                 if(uom != null)  

  74.                 {  

  75.                     String uoas = (String)uom.invoke(cpds, (Object[])null);  

  76.                     Map uo = C3P0ImplUtils.parseUserOverridesAsString(uoas);  

  77.                     userOverrides = uo;  

  78.                 } else  

  79.                 {  

  80.                     userOverrides = Collections.EMPTY_MAP;  

  81.                 }  

  82.             } else  

  83.             {  

  84.                 userOverrides = forceUserOverrides;  

  85.             }  

  86.   

  87.             poolsInit();  

  88.         }  

  89.         catch(Exception e)  

  90.         {  

  91.             logger.log(MLevel.FINE, null, e);  

  92.             throw SqlUtils.toSQLException(e);  

  93.         }  

  94.     }  

  95. }  

  96. //连接池初始化  

  97. private void poolsInit()  

  98.     {  

  99.         boolean privilege_spawned_threads = getPrivilegeSpawnedThreads();  

  100.         String contextClassLoaderSource = getContextClassLoaderSource();  

  101.         class _cls1ContextClassLoaderPoolsInitThread extends Thread  

  102.         {  

  103.   

  104.             public void run()  

  105.             {  

  106.             //  

  107.                 maybePrivilegedPoolsInit(privilege_spawned_threads);  

  108.             }  

  109.   

  110.             final boolean val$privilege_spawned_threads;  

  111.             final C3P0PooledConnectionPoolManager this$0;  

  112.   

  113.             _cls1ContextClassLoaderPoolsInitThread(boolean flag)  

  114.             {  

  115.                 this.this$0 = C3P0PooledConnectionPoolManager.this;  

  116.                 privilege_spawned_threads = flag;  

  117.                 super();  

  118.                 setContextClassLoader(ccl);  

  119.             }  

  120.         }  

  121.   

  122.         try  

  123.         {  

  124.             if("library".equalsIgnoreCase(contextClassLoaderSource))  

  125.             {  

  126.             //  

  127.                 Thread t = new _cls1ContextClassLoaderPoolsInitThread(privilege_spawned_threads);  

  128.                 t.start();  

  129.                 t.join();  

  130.             } else  

  131.             if("none".equalsIgnoreCase(contextClassLoaderSource))  

  132.             {  

  133.                 Thread t = new _cls1ContextClassLoaderPoolsInitThread(privilege_spawned_threads);  

  134.                 t.start();  

  135.                 t.join();  

  136.             } else  

  137.             {  

  138.                 if(logger.isLoggable(MLevel.WARNING) && !"caller".equalsIgnoreCase(contextClassLoaderSource))  

  139.                     logger.log(MLevel.WARNING, (new StringBuilder()).append("Unknown contextClassLoaderSource: ").append(contextClassLoaderSource).append(" -- should be 'caller', 'library', or 'none'. Using default value 'caller'.").toString());  

  140.                 maybePrivilegedPoolsInit(privilege_spawned_threads);  

  141.             }  

  142.         }  

  143.     }  

  144.   

  145.  private void maybePrivilegedPoolsInit(boolean privilege_spawned_threads)  

  146.     {  

  147.         if(privilege_spawned_threads)  

  148.         {  

  149.             PrivilegedAction privilegedPoolsInit = new PrivilegedAction() {  

  150.   

  151.                 public Void run()  

  152.                 {  

  153.             //委托给_poolsInit  

  154.                     _poolsInit();  

  155.                     return null;  

  156.                 }  

  157.   

  158.                 public volatile Object run()  

  159.                 {  

  160.                     return run();  

  161.                 }  

  162.   

  163.                 final C3P0PooledConnectionPoolManager this$0;  

  164.   

  165.               

  166.             {  

  167.                 this.this$0 = C3P0PooledConnectionPoolManager.this;  

  168.                 super();  

  169.             }  

  170.             };  

  171.             AccessController.doPrivileged(privilegedPoolsInit);  

  172.         } else  

  173.         {  

  174.             _poolsInit();  

  175.         }  

  176.     }  

  177.     //终于找个了poolsInit的关键,初始化定时任务调度器,及死锁检测线程,及延时死锁检测线程  

  178.     private synchronized void _poolsInit()  

  179.     {  

  180.         String idStr = idString();  

  181.         timer = new Timer((new StringBuilder()).append(idStr).append("-AdminTaskTimer").toString(), true);  

  182.         int matt = getMaxAdministrativeTaskTime();  

  183.     //创建任务线程调度器  

  184.         taskRunner = createTaskRunner(num_task_threads, matt, timer, (new StringBuilder()).append(idStr).append("-HelperThread").toString());  

  185.         int num_deferred_close_threads = getStatementCacheNumDeferredCloseThreads();  

  186.         if(num_deferred_close_threads > 0)  

  187.             deferredStatementDestroyer = createTaskRunner(num_deferred_close_threads, matt, timer, (new StringBuilder()).append(idStr).append("-DeferredStatementDestroyerThread").toString());  

  188.         else  

  189.             deferredStatementDestroyer = null;  

  190.         rpfact = BasicResourcePoolFactory.createNoEventSupportInstance(taskRunner, timer);  

  191.         authsToPools = new HashMap();  

  192.     }  


从上面可以看出getPoolManager()实际上,是初始化数据库连接池管理器C3P0PooledConnectionPoolManager,初始化C3P0PooledConnectionPoolManager的


文章标题:C3P0属性设置和数据库连接池的获取
文章来源:http://kswjz.com/article/jdocgs.html
扫二维码与项目经理沟通

我们在微信上24小时期待你的声音

解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流