com.github.paganini2008.devtools.objectpool.dbpool

类 ConnectionObjectFactory

java.lang.Object

com.github.paganini2008.devtools.objectpool.dbpool.ConnectionObjectFactory

所有已实现的接口:

ObjectFactory

public class ConnectionObjectFactory
extends Object
implements ObjectFactory

Build a java.sql.Connection object factory.

从以下版本开始:

2.0.1

作者:

Fred Feng

字段概要

字段

限定符和类型	字段和说明
private Boolean	autoCommit
private ConnectionPool	connectionPool
private Integer	defaultTransactionIsolationLevel
private String	driverClassName
private ExecutorService	executor
private String	jdbcUrl
private String	password
private Integer	statementCacheSize
private String	testSql
private String	user

构造器概要

构造器

构造器和说明
ConnectionObjectFactory(ConnectionPool connectionPool)

方法概要

限定符和类型	方法和说明
protected void	configureConnection(Connection connection)
PooledConnection	createObject() Create object if unavaliable
void	destroyObject(Object connection) Release the pooled object and remove it from the pool.
Boolean	getAutoCommit()
Integer	getDefaultTransactionIsolationLevel()
String	getDriverClassName()
ExecutorService	getExecutor()
String	getJdbcUrl()
String	getPassword()
Integer	getStatementCacheSize()
String	getTestSql()
String	getUser()
void	setAutoCommit(Boolean autoCommit)
void	setDefaultTransactionIsolationLevel(Integer defaultTransactionIsolationLevel) Set default transaction level.
void	setDriverClassName(String driverClassName) Set the DriverClassName if the class exists.
void	setExecutor(ExecutorService executor)
void	setJdbcUrl(String jdbcUrl)
void	setPassword(String password)
void	setStatementCacheSize(Integer statementCacheSize) Set the pooled java.sql.PreparedStatement object cache's size.
void	setTestSql(String testSql) Set a test sql like 'SELECT 1' to testify its availability when borrow a connection object.
void	setUser(String user)
protected void	testSql(Connection connection, String testSql) Execute test sql
boolean	validateObject(Object connection)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 com.github.paganini2008.devtools.objectpool.ObjectFactory

testObject

字段详细资料

user

private String user

password

private String password

driverClassName

private String driverClassName

jdbcUrl

private String jdbcUrl

testSql

private String testSql

autoCommit

private Boolean autoCommit

defaultTransactionIsolationLevel

private Integer defaultTransactionIsolationLevel

statementCacheSize

private Integer statementCacheSize

executor

private ExecutorService executor

connectionPool

private final ConnectionPool connectionPool

构造器详细资料

ConnectionObjectFactory

public ConnectionObjectFactory(ConnectionPool connectionPool)

方法详细资料

setStatementCacheSize

public void setStatementCacheSize(Integer statementCacheSize)

Set the pooled java.sql.PreparedStatement object cache's size.

参数:

statementCacheSize -

getStatementCacheSize

public Integer getStatementCacheSize()

getAutoCommit

public Boolean getAutoCommit()

setAutoCommit

public void setAutoCommit(Boolean autoCommit)

getDefaultTransactionIsolationLevel

public Integer getDefaultTransactionIsolationLevel()

setDefaultTransactionIsolationLevel

public void setDefaultTransactionIsolationLevel(Integer defaultTransactionIsolationLevel)

Set default transaction level.

参数:

defaultTransactionIsolationLevel -

getTestSql

public String getTestSql()

setTestSql

public void setTestSql(String testSql)

Set a test sql like 'SELECT 1' to testify its availability when borrow a connection object.

参数:

testSql -

getUser

public String getUser()

setUser

public void setUser(String user)

getExecutor

public ExecutorService getExecutor()

getPassword

public String getPassword()

setPassword

public void setPassword(String password)

getDriverClassName

public String getDriverClassName()

setDriverClassName

public void setDriverClassName(String driverClassName)

Set the DriverClassName if the class exists.

参数:

driverClassName -

抛出:

SQLException

getJdbcUrl

public String getJdbcUrl()

setJdbcUrl

public void setJdbcUrl(String jdbcUrl)

setExecutor

public void setExecutor(ExecutorService executor)

configureConnection

protected void configureConnection(Connection connection)
                            throws SQLException

抛出:

SQLException

testSql

protected void testSql(Connection connection,
                       String testSql)
                throws SQLException

Execute test sql

参数:

connection -

testSql -

抛出:

SQLException

createObject

public PooledConnection createObject()
                              throws SQLException

从接口复制的说明: ObjectFactory

Create object if unavaliable

指定者:

createObject 在接口中 ObjectFactory

返回:

抛出:

SQLException

validateObject

public boolean validateObject(Object connection)
                       throws SQLException

抛出:

SQLException

destroyObject

public void destroyObject(Object connection)
                   throws SQLException

从接口复制的说明: ObjectFactory

Release the pooled object and remove it from the pool.

指定者:

destroyObject 在接口中 ObjectFactory

抛出:

SQLException