Package org.mariadb.jdbc
Class MariaDbPoolConnection
- java.lang.Object
-
- org.mariadb.jdbc.MariaDbPoolConnection
-
- All Implemented Interfaces:
javax.sql.PooledConnection
,javax.sql.XAConnection
- Direct Known Subclasses:
MariaDbInnerPoolConnection
,MariaDbPoolPinnedConnection
public class MariaDbPoolConnection extends java.lang.Object implements javax.sql.PooledConnection, javax.sql.XAConnection
MariaDB pool connection implementation
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private class
MariaDbPoolConnection.MariaDbXAResource
-
Field Summary
Fields Modifier and Type Field Description private Connection
connection
private java.util.List<javax.sql.ConnectionEventListener>
connectionEventListeners
private java.util.List<javax.sql.StatementEventListener>
statementEventListeners
-
Constructor Summary
Constructors Constructor Description MariaDbPoolConnection(Connection connection)
Constructor.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addConnectionEventListener(javax.sql.ConnectionEventListener listener)
void
addStatementEventListener(javax.sql.StatementEventListener listener)
void
close()
Close underlying connectionvoid
fireConnectionClosed(javax.sql.ConnectionEvent event)
Fire connection close event to registered listeners.void
fireConnectionErrorOccurred(java.sql.SQLException returnEx)
Fire connection error event to registered listeners.void
fireStatementClosed(java.sql.PreparedStatement statement)
Fire statement close event to registered listeners.void
fireStatementErrorOccurred(java.sql.PreparedStatement statement, java.sql.SQLException returnEx)
Fire statement error event to registered listeners.protected static java.lang.String
flagsToString(int flags)
Connection
getConnection()
javax.transaction.xa.XAResource
getXAResource()
protected static javax.transaction.xa.XAException
mapXaException(java.sql.SQLException sqle)
protected void
realClose()
void
removeConnectionEventListener(javax.sql.ConnectionEventListener listener)
void
removeStatementEventListener(javax.sql.StatementEventListener listener)
static java.lang.String
xidToString(javax.transaction.xa.Xid xid)
Create XID string
-
-
-
Field Detail
-
connection
private final Connection connection
-
connectionEventListeners
private final java.util.List<javax.sql.ConnectionEventListener> connectionEventListeners
-
statementEventListeners
private final java.util.List<javax.sql.StatementEventListener> statementEventListeners
-
-
Constructor Detail
-
MariaDbPoolConnection
public MariaDbPoolConnection(Connection connection)
Constructor.- Parameters:
connection
- connection to retrieve connection options
-
-
Method Detail
-
xidToString
public static java.lang.String xidToString(javax.transaction.xa.Xid xid)
Create XID string- Parameters:
xid
- xid value- Returns:
- XID string
-
getConnection
public Connection getConnection()
- Specified by:
getConnection
in interfacejavax.sql.PooledConnection
-
addConnectionEventListener
public void addConnectionEventListener(javax.sql.ConnectionEventListener listener)
- Specified by:
addConnectionEventListener
in interfacejavax.sql.PooledConnection
-
removeConnectionEventListener
public void removeConnectionEventListener(javax.sql.ConnectionEventListener listener)
- Specified by:
removeConnectionEventListener
in interfacejavax.sql.PooledConnection
-
addStatementEventListener
public void addStatementEventListener(javax.sql.StatementEventListener listener)
- Specified by:
addStatementEventListener
in interfacejavax.sql.PooledConnection
-
removeStatementEventListener
public void removeStatementEventListener(javax.sql.StatementEventListener listener)
- Specified by:
removeStatementEventListener
in interfacejavax.sql.PooledConnection
-
fireStatementClosed
public void fireStatementClosed(java.sql.PreparedStatement statement)
Fire statement close event to registered listeners.- Parameters:
statement
- closing statement
-
fireStatementErrorOccurred
public void fireStatementErrorOccurred(java.sql.PreparedStatement statement, java.sql.SQLException returnEx)
Fire statement error event to registered listeners.- Parameters:
statement
- closing statementreturnEx
- exception
-
fireConnectionClosed
public void fireConnectionClosed(javax.sql.ConnectionEvent event)
Fire connection close event to registered listeners.- Parameters:
event
- close connection event
-
fireConnectionErrorOccurred
public void fireConnectionErrorOccurred(java.sql.SQLException returnEx)
Fire connection error event to registered listeners.- Parameters:
returnEx
- exception
-
close
public void close() throws java.sql.SQLException
Close underlying connection- Specified by:
close
in interfacejavax.sql.PooledConnection
- Throws:
java.sql.SQLException
- if close fails
-
realClose
protected void realClose() throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
getXAResource
public javax.transaction.xa.XAResource getXAResource()
- Specified by:
getXAResource
in interfacejavax.sql.XAConnection
-
mapXaException
protected static javax.transaction.xa.XAException mapXaException(java.sql.SQLException sqle)
-
flagsToString
protected static java.lang.String flagsToString(int flags)
-
-