public final class JdbcConnectionPool extends java.lang.Object implements javax.sql.DataSource, javax.sql.ConnectionEventListener, JdbcConnectionPoolBackwardsCompat
import java.sql.*; import org.h2.jdbcx.JdbcConnectionPool; public class Test { public static void main(String... args) throws Exception { JdbcConnectionPool cp = JdbcConnectionPool.create( "jdbc:h2:~/test", "sa", "sa"); for (String sql : args) { Connection conn = cp.getConnection(); conn.createStatement().execute(sql); conn.close(); } cp.dispose(); } }
Modifier and Type | Method and Description |
---|---|
void |
connectionClosed(javax.sql.ConnectionEvent event)
INTERNAL
|
void |
connectionErrorOccurred(javax.sql.ConnectionEvent event)
INTERNAL
|
static JdbcConnectionPool |
create(javax.sql.ConnectionPoolDataSource dataSource)
Constructs a new connection pool.
|
static JdbcConnectionPool |
create(java.lang.String url,
java.lang.String user,
java.lang.String password)
Constructs a new connection pool for H2 databases.
|
void |
dispose()
Closes all unused pooled connections.
|
int |
getActiveConnections()
Returns the number of active (open) connections of this pool.
|
java.sql.Connection |
getConnection()
Retrieves a connection from the connection pool.
|
java.sql.Connection |
getConnection(java.lang.String user,
java.lang.String password)
INTERNAL
|
int |
getLoginTimeout()
Gets the maximum time in seconds to wait for a free connection.
|
java.io.PrintWriter |
getLogWriter()
INTERNAL
|
int |
getMaxConnections()
Gets the maximum number of connections to use.
|
java.util.logging.Logger |
getParentLogger()
[Not supported]
|
boolean |
isWrapperFor(java.lang.Class<?> iface)
Checks if unwrap can return an object of this class.
|
void |
setLoginTimeout(int seconds)
Sets the maximum time in seconds to wait for a free connection.
|
void |
setLogWriter(java.io.PrintWriter logWriter)
INTERNAL
|
void |
setMaxConnections(int max)
Sets the maximum number of connections to use from now on.
|
<T> T |
unwrap(java.lang.Class<T> iface)
Return an object of this class if possible.
|
public static JdbcConnectionPool create(javax.sql.ConnectionPoolDataSource dataSource)
dataSource
- the data source to create connectionspublic static JdbcConnectionPool create(java.lang.String url, java.lang.String user, java.lang.String password)
url
- the database URL of the H2 connectionuser
- the user namepassword
- the passwordpublic void setMaxConnections(int max)
max
- the maximum number of connectionspublic int getMaxConnections()
public int getLoginTimeout()
getLoginTimeout
in interface javax.sql.CommonDataSource
public void setLoginTimeout(int seconds)
setLoginTimeout
in interface javax.sql.CommonDataSource
seconds
- the timeout, 0 meaning the defaultpublic void dispose()
public java.sql.Connection getConnection() throws java.sql.SQLException
maxConnections
connections are already in use, the method
waits until a connection becomes available or timeout
seconds elapsed. When the application is finished using the connection,
it must close it in order to return it to the pool.
If no connection becomes available within the given timeout, an exception
with SQL state 08001 and vendor code 8001 is thrown.getConnection
in interface javax.sql.DataSource
java.sql.SQLException
- when a new connection could not be established,
or a timeout occurredpublic java.sql.Connection getConnection(java.lang.String user, java.lang.String password)
getConnection
in interface javax.sql.DataSource
public void connectionClosed(javax.sql.ConnectionEvent event)
connectionClosed
in interface javax.sql.ConnectionEventListener
public void connectionErrorOccurred(javax.sql.ConnectionEvent event)
connectionErrorOccurred
in interface javax.sql.ConnectionEventListener
public int getActiveConnections()
Connection
objects that have been issued by
getConnection() for which Connection.close()
has
not yet been called.public java.io.PrintWriter getLogWriter()
getLogWriter
in interface javax.sql.CommonDataSource
public void setLogWriter(java.io.PrintWriter logWriter)
setLogWriter
in interface javax.sql.CommonDataSource
public <T> T unwrap(java.lang.Class<T> iface) throws java.sql.SQLException
unwrap
in interface java.sql.Wrapper
iface
- the classjava.sql.SQLException
public boolean isWrapperFor(java.lang.Class<?> iface) throws java.sql.SQLException
isWrapperFor
in interface java.sql.Wrapper
iface
- the classjava.sql.SQLException
public java.util.logging.Logger getParentLogger()
getParentLogger
in interface javax.sql.CommonDataSource