本文整理汇总了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;未经允许,请勿转载。 |
请发表评论