• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

Java DriverAdapterCPDS类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.apache.commons.dbcp.cpdsadapter.DriverAdapterCPDS的典型用法代码示例。如果您正苦于以下问题:Java DriverAdapterCPDS类的具体用法?Java DriverAdapterCPDS怎么用?Java DriverAdapterCPDS使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



DriverAdapterCPDS类属于org.apache.commons.dbcp.cpdsadapter包,在下文中一共展示了DriverAdapterCPDS类的6个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: setUp

import org.apache.commons.dbcp.cpdsadapter.DriverAdapterCPDS; //导入依赖的package包/类
public void setUp() throws Exception {
    super.setUp();
    DriverAdapterCPDS pcds = new DriverAdapterCPDS();
    pcds.setDriver("org.apache.commons.dbcp.TesterDriver");
    pcds.setUrl("jdbc:apache:commons:testdriver");
    pcds.setUser("foo");
    pcds.setPassword("bar");
    pcds.setAccessToUnderlyingConnectionAllowed(true);

    PerUserPoolDataSource tds = new PerUserPoolDataSource();
    tds.setConnectionPoolDataSource(pcds);
    tds.setDefaultMaxActive(getMaxActive());
    tds.setDefaultMaxWait((int)(getMaxWait()));
    tds.setPerUserMaxActive("foo",new Integer(getMaxActive()));
    tds.setPerUserMaxWait("foo",new Integer((int)(getMaxWait())));
    tds.setDefaultTransactionIsolation(
        Connection.TRANSACTION_READ_COMMITTED);

    ds = tds;
}
 
开发者ID:WhiteBearSolutions,项目名称:WBSAirback,代码行数:21,代码来源:TestPerUserPoolDataSource.java


示例2: setUp

import org.apache.commons.dbcp.cpdsadapter.DriverAdapterCPDS; //导入依赖的package包/类
public void setUp() throws Exception {
    super.setUp();
    pcds = new DriverAdapterCPDS();
    pcds.setDriver("org.apache.commons.dbcp.TesterDriver");
    pcds.setUrl("jdbc:apache:commons:testdriver");
    pcds.setUser("foo");
    pcds.setPassword("bar");
    pcds.setPoolPreparedStatements(false);
    pcds.setAccessToUnderlyingConnectionAllowed(true);

    SharedPoolDataSource tds = new SharedPoolDataSource();
    tds.setConnectionPoolDataSource(pcds);
    tds.setMaxActive(getMaxActive());
    tds.setMaxWait((int)(getMaxWait()));
    tds.setDefaultTransactionIsolation(
        Connection.TRANSACTION_READ_COMMITTED);

    ds = tds;
}
 
开发者ID:WhiteBearSolutions,项目名称:WBSAirback,代码行数:20,代码来源:TestSharedPoolDataSource.java


示例3: DbcpResourceFactory

import org.apache.commons.dbcp.cpdsadapter.DriverAdapterCPDS; //导入依赖的package包/类
/**
 * 
 */
public DbcpResourceFactory(final String dataSourceName, 
        final String driverClass, 
        final String url, 
        final String userName, 
        final String password,
        final int maxActive,
        final int maxIdle) throws PoolException{
    try {
       connectionPoolDataSource = AccessController.doPrivileged( new PrivilegedExceptionAction<ConnectionPoolDataSource>() {
            public ConnectionPoolDataSource run() throws Exception {
                //Using the generic connection pool adapter from DBCP, todo, look how to use the connection pool datasource provided by each driver
                DriverAdapterCPDS adapter = new DriverAdapterCPDS();
                adapter.setMaxActive( maxActive );
                adapter.setMaxIdle( maxIdle );
                adapter.setUrl( url );
                adapter.setUser( userName );
                adapter.setPassword( password );
                adapter.setDriver( driverClass );
                SharedPoolDataSource tds = new SharedPoolDataSource();
                tds.setConnectionPoolDataSource( adapter );
                tds.setMaxActive( maxActive );
                
                ds = tds;
                return adapter;
            }
        });
    } catch (Exception e) {
        // "Unable to initialize the shared connection pool DataSource"
        String msg = com.ibm.xsp.extlib.relational.RelationalResourceHandler.getSpecialAudienceString("DbcpPoolDataSource.Unabletoinitializethesharedconnec");//$NON-NLS-1$
        throw new PoolException( e, msg);
    }
}
 
开发者ID:OpenNTF,项目名称:XPagesExtensionLibrary,代码行数:36,代码来源:DbcpResourceFactory.java


示例4: setUp

import org.apache.commons.dbcp.cpdsadapter.DriverAdapterCPDS; //导入依赖的package包/类
public void setUp() throws Exception {
    cpds = new ConnectionPoolDataSourceProxy(new DriverAdapterCPDS());
    DriverAdapterCPDS delegate = (DriverAdapterCPDS) cpds.getDelegate();
    delegate.setDriver("org.apache.commons.dbcp.TesterDriver");
    delegate.setUrl("jdbc:apache:commons:testdriver");
    delegate.setUser("username");
    delegate.setPassword("password");
}
 
开发者ID:WhiteBearSolutions,项目名称:WBSAirback,代码行数:9,代码来源:TestCPDSConnectionFactory.java


示例5: getConnection

import org.apache.commons.dbcp.cpdsadapter.DriverAdapterCPDS; //导入依赖的package包/类
public static Connection getConnection( ServletContext servContext ) throws Exception
{
	if( !loaded )
	{
		String dbdriver = ConfigUtils.get("DBDriver");
		ConfigUtils.clear("DBDriver");
		String dbuser = ConfigUtils.get("DBUser");
		ConfigUtils.clear("DBUser");
		String dbpass = ConfigUtils.get("DBPass");
		ConfigUtils.clear("DBPass");
		String dburl = ConfigUtils.get("DBUrl");
		ConfigUtils.clear("DBUrl");

		try
		{
			DriverAdapterCPDS cpds = new DriverAdapterCPDS();
			cpds.setDriver(dbdriver);
			cpds.setUrl(dburl);
			
			Properties info = new Properties();
			info.put("user", dbuser);
			info.put("password", dbpass);
			cpds.setConnectionProperties(info);
			
			SharedPoolDataSource tds = new SharedPoolDataSource();
			tds.setConnectionPoolDataSource(cpds);
			
			/// TODO: Complete it with other parameters, also, benchmark
			/// Configuring other stuff
			tds.setValidationQuery("SELECT 1 FROM DUAL");
			tds.setTestOnBorrow(true);
			tds.setTestWhileIdle(true);
			tds.setDefaultTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);
			
			String maxwait = ConfigUtils.get("DB.MaxWait");
			String maxtotal = ConfigUtils.get("DB.MaxTotal");
			String minidle = ConfigUtils.get("DB.MinIdle");
			String maxidle = ConfigUtils.get("DB.MaxIdle");
			String waiteviction = ConfigUtils.get("DB.WaitEviction");
			String numtesteviction =  ConfigUtils.get("DB.NumTestEviction");
			/// In case something hasn't been set
			if( maxwait == null ) maxwait = "1000";
			if( maxtotal == null ) maxtotal = "1000";
			if( minidle == null ) minidle = "1";
			if( maxidle == null ) maxidle = "1000";
			if( waiteviction == null ) waiteviction = "60000";
			if( numtesteviction == null ) numtesteviction = "10";
			
			tds.setMaxWait(Integer.decode(maxwait));
			tds.setMaxActive(Integer.decode(maxtotal));
			tds.setMaxIdle(Integer.decode(maxidle));
			tds.setTimeBetweenEvictionRunsMillis(Integer.decode(waiteviction));
			tds.setNumTestsPerEvictionRun(Integer.decode(numtesteviction));
			
			ds = tds;
		}
		catch( Exception e )
		{
			e.printStackTrace();
		}
		loaded = true;
	}
	return ds.getConnection();
}
 
开发者ID:karutaproject,项目名称:karuta-backend,代码行数:65,代码来源:SqlUtils.java


示例6: doTestPoolPreparedStatements

import org.apache.commons.dbcp.cpdsadapter.DriverAdapterCPDS; //导入依赖的package包/类
private void doTestPoolPreparedStatements(PrepareStatementCallback callBack)
throws Exception {
    DriverAdapterCPDS mypcds = new DriverAdapterCPDS();
    DataSource myds = null;
    mypcds.setDriver("org.apache.commons.dbcp.TesterDriver");
    mypcds.setUrl("jdbc:apache:commons:testdriver");
    mypcds.setUser("foo");
    mypcds.setPassword("bar");
    mypcds.setPoolPreparedStatements(true);
    mypcds.setMaxPreparedStatements(10);

    SharedPoolDataSource tds = new SharedPoolDataSource();
    tds.setConnectionPoolDataSource(mypcds);
    tds.setMaxActive(getMaxActive());
    tds.setMaxWait((int)(getMaxWait()));
    tds.setDefaultTransactionIsolation(
        Connection.TRANSACTION_READ_COMMITTED);

    myds = tds;

    Connection conn = ds.getConnection();
    callBack.setConnection(conn);
    PreparedStatement stmt = null;
    ResultSet rset = null;

    assertNotNull(conn);

    stmt = callBack.getPreparedStatement();
    assertNotNull(stmt);
    long l1HashCode = stmt.hashCode();
    rset = stmt.executeQuery();
    assertNotNull(rset);
    assertTrue(rset.next());
    rset.close();
    stmt.close();

    stmt = callBack.getPreparedStatement();
    assertNotNull(stmt);
    long l2HashCode = stmt.hashCode();
    rset = stmt.executeQuery();
    assertNotNull(rset);
    assertTrue(rset.next());
    rset.close();
    stmt.close();

    // statement pooling is not enabled, we should get different statements
    assertTrue(l1HashCode != l2HashCode);
    conn.close();
    conn = null;

    conn = myds.getConnection();
    callBack.setConnection(conn);

    stmt = callBack.getPreparedStatement();
    assertNotNull(stmt);
    long l3HashCode = stmt.hashCode();
    rset = stmt.executeQuery();
    assertNotNull(rset);
    assertTrue(rset.next());
    rset.close();
    stmt.close();

    stmt = callBack.getPreparedStatement();
    assertNotNull(stmt);
    long l4HashCode = stmt.hashCode();
    rset = stmt.executeQuery();
    assertNotNull(rset);
    assertTrue(rset.next());
    rset.close();
    stmt.close();

    // prepared statement pooling is working
    assertTrue(l3HashCode == l4HashCode);
    conn.close();
    conn = null;
}
 
开发者ID:WhiteBearSolutions,项目名称:WBSAirback,代码行数:77,代码来源:TestSharedPoolDataSource.java



注:本文中的org.apache.commons.dbcp.cpdsadapter.DriverAdapterCPDS类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java GZIPResponseStream类代码示例发布时间:2022-05-22
下一篇:
Java ImageUtils类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap