|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.derby.jdbc.EmbedPooledConnection
class EmbedPooledConnection
A PooledConnection object is a connection object that provides hooks for connection pool management.
This is Derby's implementation of a PooledConnection for use in the following environments:
Field Summary | |
---|---|
private int |
connectionId
The id for this connection. |
private java.lang.String |
connString
the connection string |
(package private) BrokeredConnection |
currentConnectionHandle
|
(package private) ReferenceableDataSource |
dataSource
|
(package private) int |
defaultIsolationLevel
|
private boolean |
defaultReadOnly
|
private int |
eventIterators
The number of iterators going through the list of connection event listeners at the current time. |
private java.util.ArrayList |
eventListener
The list of ConnectionEventListener s. |
private static int |
idCounter
Static counter for connection ids |
protected boolean |
isActive
|
private java.lang.String |
password
|
(package private) EmbedConnection |
realConnection
|
private boolean |
requestPassword
True if the password was passed in on the connection request, false if it came from the data source property. |
private java.lang.String |
username
|
Constructor Summary | |
---|---|
EmbedPooledConnection(ReferenceableDataSource ds,
java.lang.String u,
java.lang.String p,
boolean requestPassword)
|
Method Summary | |
---|---|
void |
addConnectionEventListener(javax.sql.ConnectionEventListener listener)
Add an event listener. |
(package private) void |
checkActive()
|
void |
checkAutoCommit(boolean autoCommit)
Allow control over setting auto commit mode. |
void |
checkClose()
Check if the brokered connection can be closed. |
void |
checkCommit()
Allow control over calling commit. |
int |
checkHoldCursors(int holdability,
boolean downgrade)
Are held cursors allowed. |
void |
checkRollback()
Allow control over calling rollback. |
void |
checkSavepoint()
Allow control over creating a Savepoint (JDBC 3.0) |
void |
close()
Close the Pooled connection. |
private void |
closeCurrentConnectionHandle()
In this case the Listeners are *not* notified. |
boolean |
closingConnection()
Close called on BrokeredConnection. |
private void |
fireConnectionEventListeners(java.sql.SQLException exception)
Fire all the ConnectionEventListener s registered. |
java.sql.Connection |
getConnection()
Create an object handle for a database connection. |
LanguageConnectionContext |
getLanguageConnection()
|
(package private) java.sql.Connection |
getNewCurrentConnectionHandle()
|
(package private) java.lang.String |
getPassword()
|
EngineConnection |
getRealConnection()
Return the real JDBC connection for the brokered connection. |
(package private) java.lang.String |
getUsername()
|
boolean |
isInGlobalTransaction()
Is this a global transaction |
boolean |
isIsolationLevelSetUsingSQLorJDBC()
Returns true if isolation level has been set using either JDBC api or SQL |
private int |
nextId()
|
void |
notifyError(java.sql.SQLException exception)
|
void |
notifyException(java.sql.SQLException sqle)
Notify the control class that a SQLException was thrown during a call on one of the brokered connection's methods. |
void |
onStatementClose(java.sql.PreparedStatement statement)
Dummy implementation for the actual methods found in org.apache.derby.jdbc.EmbedPooledConnection40 |
void |
onStatementErrorOccurred(java.sql.PreparedStatement statement,
java.sql.SQLException sqle)
Dummy implementation for the actual methods found in org.apache.derby.jdbc.EmbedPooledConnection40 |
(package private) void |
openRealConnection()
|
void |
removeConnectionEventListener(javax.sql.ConnectionEventListener listener)
Remove an event listener. |
void |
resetIsolationLevelFlag()
Reset the isolation level flag used to keep state in BrokeredConnection. |
(package private) void |
resetRealConnection()
|
java.lang.String |
toString()
Get the string representation of this pooled connection. |
java.sql.CallableStatement |
wrapStatement(java.sql.CallableStatement cs,
java.lang.String sql)
Call the setBrokeredConnectionControl method inside the EmbedCallableStatement class to set the BrokeredConnectionControl variable to this instance of EmbedPooledConnection This will then be used to call the onStatementErrorOccurred and onStatementClose events when the corresponding events occur on the CallableStatement |
java.sql.PreparedStatement |
wrapStatement(java.sql.PreparedStatement ps,
java.lang.String sql,
java.lang.Object generatedKeys)
Call the setBrokeredConnectionControl method inside the EmbedPreparedStatement class to set the BrokeredConnectionControl variable to this instance of EmbedPooledConnection This will then be used to call the onStatementErrorOccurred and onStatementClose events when the corresponding events occur on the PreparedStatement |
java.sql.Statement |
wrapStatement(java.sql.Statement s)
No need to wrap statements for PooledConnections. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface javax.sql.PooledConnection |
---|
addStatementEventListener, removeStatementEventListener |
Field Detail |
---|
private static int idCounter
private int connectionId
private java.lang.String connString
private java.util.ArrayList eventListener
ConnectionEventListener
s. It is initially null
and will be initialized lazily when the first listener is added.
private int eventIterators
EmbedConnection realConnection
int defaultIsolationLevel
private boolean defaultReadOnly
BrokeredConnection currentConnectionHandle
final ReferenceableDataSource dataSource
private final java.lang.String username
private final java.lang.String password
private final boolean requestPassword
protected boolean isActive
Constructor Detail |
---|
EmbedPooledConnection(ReferenceableDataSource ds, java.lang.String u, java.lang.String p, boolean requestPassword) throws java.sql.SQLException
java.sql.SQLException
Method Detail |
---|
private int nextId()
java.lang.String getUsername()
java.lang.String getPassword()
public java.sql.Connection getConnection() throws java.sql.SQLException
getConnection
in interface javax.sql.PooledConnection
java.sql.SQLException
- - if a database-access error occurs.final void openRealConnection() throws java.sql.SQLException
java.sql.SQLException
final java.sql.Connection getNewCurrentConnectionHandle()
private void closeCurrentConnectionHandle() throws java.sql.SQLException
java.sql.SQLException
void resetRealConnection() throws java.sql.SQLException
java.sql.SQLException
public void close() throws java.sql.SQLException
close
in interface javax.sql.PooledConnection
java.sql.SQLException
- - if a database-access error occurs.public final void addConnectionEventListener(javax.sql.ConnectionEventListener listener)
addConnectionEventListener
in interface javax.sql.PooledConnection
public final void removeConnectionEventListener(javax.sql.ConnectionEventListener listener)
removeConnectionEventListener
in interface javax.sql.PooledConnection
public EngineConnection getRealConnection() throws java.sql.SQLException
BrokeredConnectionControl
getRealConnection
in interface BrokeredConnectionControl
java.sql.SQLException
public LanguageConnectionContext getLanguageConnection() throws java.sql.SQLException
java.sql.SQLException
public void notifyError(java.sql.SQLException exception)
private void fireConnectionEventListeners(java.sql.SQLException exception)
ConnectionEventListener
s registered. Callers must
synchronize on this
to prevent others from modifying the list of
listeners.
exception
- the exception that caused the event, or null
if
it is a close eventfinal void checkActive() throws java.sql.SQLException
java.sql.SQLException
public boolean isIsolationLevelSetUsingSQLorJDBC() throws java.sql.SQLException
isIsolationLevelSetUsingSQLorJDBC
in interface BrokeredConnectionControl
java.sql.SQLException
public void resetIsolationLevelFlag() throws java.sql.SQLException
resetIsolationLevelFlag
in interface BrokeredConnectionControl
java.sql.SQLException
public boolean isInGlobalTransaction()
BrokeredConnectionControl
isInGlobalTransaction
in interface BrokeredConnectionControl
BrokeredConnectionControl.isInGlobalTransaction()
public void notifyException(java.sql.SQLException sqle)
notifyException
in interface BrokeredConnectionControl
public void checkAutoCommit(boolean autoCommit) throws java.sql.SQLException
checkAutoCommit
in interface BrokeredConnectionControl
java.sql.SQLException
public int checkHoldCursors(int holdability, boolean downgrade) throws java.sql.SQLException
checkHoldCursors
in interface BrokeredConnectionControl
downgrade
- true to downgrade the holdability,
false to throw an exception.
java.sql.SQLException
public void checkSavepoint() throws java.sql.SQLException
checkSavepoint
in interface BrokeredConnectionControl
java.sql.SQLException
public void checkRollback() throws java.sql.SQLException
checkRollback
in interface BrokeredConnectionControl
java.sql.SQLException
public void checkCommit() throws java.sql.SQLException
checkCommit
in interface BrokeredConnectionControl
java.sql.SQLException
public void checkClose() throws java.sql.SQLException
BrokeredConnectionControl
checkClose
in interface BrokeredConnectionControl
java.sql.SQLException
- if it is not allowed to call close on the brokered
connectionBrokeredConnectionControl.checkClose()
public boolean closingConnection() throws java.sql.SQLException
closingConnection
in interface BrokeredConnectionControl
java.sql.SQLException
public java.sql.Statement wrapStatement(java.sql.Statement s) throws java.sql.SQLException
wrapStatement
in interface BrokeredConnectionControl
java.sql.SQLException
public java.sql.PreparedStatement wrapStatement(java.sql.PreparedStatement ps, java.lang.String sql, java.lang.Object generatedKeys) throws java.sql.SQLException
wrapStatement
in interface BrokeredConnectionControl
ps
- PreparedStatment to be wrappedsql
- StringgeneratedKeys
- Object
java.sql.SQLException
public java.sql.CallableStatement wrapStatement(java.sql.CallableStatement cs, java.lang.String sql) throws java.sql.SQLException
wrapStatement
in interface BrokeredConnectionControl
cs
- CallableStatment to be wrappedsql
- String
java.sql.SQLException
public java.lang.String toString()
toString
in class java.lang.Object
public void onStatementClose(java.sql.PreparedStatement statement)
onStatementClose
in interface BrokeredConnectionControl
statement
- PreparedStatementpublic void onStatementErrorOccurred(java.sql.PreparedStatement statement, java.sql.SQLException sqle)
onStatementErrorOccurred
in interface BrokeredConnectionControl
statement
- PreparedStatementsqle
- SQLException
|
Built on Thu 2010-12-23 20:49:13+0000, from revision ??? | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |