org.mariadb.jdbc

Class MariaDbPooledConnection

java.lang.Object

org.mariadb.jdbc.MariaDbPooledConnection

All Implemented Interfaces:

javax.sql.PooledConnection

Direct Known Subclasses:

MariaXaConnection

public class MariaDbPooledConnection
extends java.lang.Object
implements javax.sql.PooledConnection

Field Summary

Fields

Modifier and Type	Field and Description
private MariaDbConnection	connection
private java.util.List<javax.sql.ConnectionEventListener>	connectionEventListeners
private java.util.concurrent.atomic.AtomicLong	lastUsed
private java.util.List<javax.sql.StatementEventListener>	statementEventListeners

Constructor Summary

Constructors

Constructor and Description
MariaDbPooledConnection(MariaDbConnection connection) Constructor.

Method Summary

Modifier and Type	Method and Description
void	abort(java.util.concurrent.Executor executor) Abort connection.
void	addConnectionEventListener(javax.sql.ConnectionEventListener listener) Registers the given event failover so that it will be notified when an event occurs on this PooledConnection object.
void	addStatementEventListener(javax.sql.StatementEventListener listener) Registers a StatementEventListener with this PooledConnection object.
void	close() Closes the physical connection that this PooledConnection object represents.
void	fireConnectionClosed() Fire Connection close to listening listeners.
void	fireConnectionErrorOccured(java.sql.SQLException ex) Fire connection error to listening listeners.
void	fireStatementClosed(java.sql.Statement st) Fire statement close event to listeners.
void	fireStatementErrorOccured(java.sql.Statement st, java.sql.SQLException ex) Fire statement error to listeners.
MariaDbConnection	getConnection() Creates and returns a Connection object that is a handle for the physical connection that this PooledConnection object represents.
java.util.concurrent.atomic.AtomicLong	getLastUsed() Indicate last time this pool connection has been used.
void	lastUsedToNow() Set last poolConnection use to now.
boolean	noStmtEventListeners() Indicate if there are any registered listener.
void	removeConnectionEventListener(javax.sql.ConnectionEventListener listener) Removes the given event failover from the list of components that will be notified when an event occurs on this PooledConnection object.
void	removeStatementEventListener(javax.sql.StatementEventListener listener) Removes the specified StatementEventListener from the list of components that will be notified when the driver detects that a PreparedStatement has been closed or is invalid.

Methods inherited from class java.lang.Object

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

Field Detail

connection

private final MariaDbConnection connection

connectionEventListeners

private final java.util.List<javax.sql.ConnectionEventListener> connectionEventListeners

statementEventListeners

private final java.util.List<javax.sql.StatementEventListener> statementEventListeners

lastUsed

private final java.util.concurrent.atomic.AtomicLong lastUsed

Constructor Detail

MariaDbPooledConnection

public MariaDbPooledConnection(MariaDbConnection connection)

Constructor.

Parameters:

connection - connection to retrieve connection options

Method Detail

getConnection

public MariaDbConnection getConnection()

Creates and returns a Connection object that is a handle for the physical connection that this PooledConnection object represents. The connection pool manager calls this method when an application has called the method DataSource.getConnection and there are no PooledConnection objects available. See the interface description for more information.

Specified by:

getConnection in interface javax.sql.PooledConnection

Returns:

a Connection object that is a handle to this PooledConnection object

close

public void close()
           throws java.sql.SQLException

Closes the physical connection that this PooledConnection object represents. An application never calls this method directly; it is called by the connection pool module, or manager.
See the interface description for more information.

Specified by:

close in interface javax.sql.PooledConnection

Throws:

java.sql.SQLException - if a database access error occurs

abort

public void abort(java.util.concurrent.Executor executor)
           throws java.sql.SQLException

Abort connection.

Parameters:

executor - executor

Throws:

java.sql.SQLException - if a database access error occurs

addConnectionEventListener

public void addConnectionEventListener(javax.sql.ConnectionEventListener listener)

Registers the given event failover so that it will be notified when an event occurs on this PooledConnection object.

Specified by:

addConnectionEventListener in interface javax.sql.PooledConnection

Parameters:

listener - a component, usually the connection pool manager, that has implemented the ConnectionEventListener interface and wants to be notified when the connection is closed or has an error

See Also:

removeConnectionEventListener(javax.sql.ConnectionEventListener)

removeConnectionEventListener

public void removeConnectionEventListener(javax.sql.ConnectionEventListener listener)

Removes the given event failover from the list of components that will be notified when an event occurs on this PooledConnection object.

Specified by:

removeConnectionEventListener in interface javax.sql.PooledConnection

Parameters:

listener - a component, usually the connection pool manager, that has implemented the ConnectionEventListener interface and been registered with this PooledConnection object as a failover

See Also:

addConnectionEventListener(javax.sql.ConnectionEventListener)

addStatementEventListener

public void addStatementEventListener(javax.sql.StatementEventListener listener)

Registers a StatementEventListener with this PooledConnection object. Components that wish to be notified when PreparedStatements created by the connection are closed or are detected to be invalid may use this method to register a StatementEventListener with this PooledConnection object.

Specified by:

addStatementEventListener in interface javax.sql.PooledConnection

Parameters:

listener - an component which implements the StatementEventListener interface that is to be registered with this PooledConnection object

removeStatementEventListener

public void removeStatementEventListener(javax.sql.StatementEventListener listener)

Removes the specified StatementEventListener from the list of components that will be notified when the driver detects that a PreparedStatement has been closed or is invalid.

Specified by:

removeStatementEventListener in interface javax.sql.PooledConnection

Parameters:

listener - the component which implements the StatementEventListener interface that was previously registered with this PooledConnection object

fireStatementClosed

public void fireStatementClosed(java.sql.Statement st)

Fire statement close event to listeners.

Parameters:

st - statement

fireStatementErrorOccured

public void fireStatementErrorOccured(java.sql.Statement st,
                                      java.sql.SQLException ex)

Fire statement error to listeners.

Parameters:

st - statement

ex - exception

fireConnectionClosed

public void fireConnectionClosed()

Fire Connection close to listening listeners.

fireConnectionErrorOccured

public void fireConnectionErrorOccured(java.sql.SQLException ex)

Fire connection error to listening listeners.

Parameters:

ex - exception

noStmtEventListeners

public boolean noStmtEventListeners()

Indicate if there are any registered listener.

Returns:

true if no listener.

getLastUsed

public java.util.concurrent.atomic.AtomicLong getLastUsed()

Indicate last time this pool connection has been used.

Returns:

current last used time (nano).

lastUsedToNow

public void lastUsedToNow()

Set last poolConnection use to now.