org.objectweb.jonas.jdbc_xa
Class ConnectionImpl
java.lang.Object
|
+--org.objectweb.jonas.jdbc_xa.ConnectionImpl
- All Implemented Interfaces:
- java.sql.Connection
- public class ConnectionImpl
- extends java.lang.Object
- implements java.sql.Connection
This class is a wrapper class on a standard java.sql.Connection class.
Its goal is to prevent explicit close of a connection and transaction
management (should be done via XAResource)
- Author:
- Philippe Durieux
Contributor(s):
oe Gittings/Dmitry Melekhov for Sybase pb.
Fields inherited from interface java.sql.Connection |
TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE |
Constructor Summary |
ConnectionImpl(org.objectweb.jonas.jdbc_xa.XAConnectionImpl xac,
java.sql.Connection actual)
|
Method Summary |
void |
clearWarnings()
|
void |
close()
Trigger an event to the listener. |
void |
commit()
In a JDBC-XA driver, Connection.commit is only called if we
are outside a global transaction. |
java.sql.Statement |
createStatement()
|
java.sql.Statement |
createStatement(int resultSetType,
int resultSetConcurrency)
|
java.sql.Statement |
createStatement(int resultSetType,
int resultSetConcurrency,
int resultSetHoldability)
|
boolean |
getAutoCommit()
In a JDBC-XA driver, autocommit is false if we are in a global Tx |
java.lang.String |
getCatalog()
|
java.sql.Connection |
getConnection()
Get the actual connection on database |
int |
getHoldability()
|
java.sql.DatabaseMetaData |
getMetaData()
|
int |
getTransactionIsolation()
|
java.util.Map |
getTypeMap()
|
java.sql.SQLWarning |
getWarnings()
|
boolean |
isClosed()
|
boolean |
isReadOnly()
|
java.lang.String |
nativeSQL(java.lang.String sql)
|
java.sql.CallableStatement |
prepareCall(java.lang.String sql)
|
java.sql.CallableStatement |
prepareCall(java.lang.String sql,
int resultSetType,
int resultSetConcurrency)
|
java.sql.CallableStatement |
prepareCall(java.lang.String sql,
int resultSetType,
int resultSetConcurrency,
int resultSetHoldability)
|
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql)
|
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql,
int autoGeneratedKeys)
|
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql,
int[] columnIndexes)
|
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql,
int resultSetType,
int resultSetConcurrency)
|
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql,
int resultSetType,
int resultSetConcurrency,
int resultSetHoldability)
|
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql,
java.lang.String[] columnNames)
|
void |
releaseSavepoint(java.sql.Savepoint savepoint)
|
void |
rollback()
In a JDBC-XA driver, Connection.rollback is only called if we
are outside a global transaction. |
void |
rollback(java.sql.Savepoint savepoint)
|
void |
setAutoCommit(boolean autoCommit)
In a JDBC-XA driver, autocommit is false if we are in a global Tx |
void |
setCatalog(java.lang.String catalog)
|
void |
setHoldability(int holdability)
|
void |
setReadOnly(boolean readOnly)
|
java.sql.Savepoint |
setSavepoint()
|
java.sql.Savepoint |
setSavepoint(java.lang.String name)
|
void |
setTransactionIsolation(int level)
|
void |
setTypeMap(java.util.Map map)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
actConn
protected java.sql.Connection actConn
xac
protected org.objectweb.jonas.jdbc_xa.XAConnectionImpl xac
autocommit_set
protected boolean autocommit_set
autocommit_unset
protected boolean autocommit_unset
ConnectionImpl
public ConnectionImpl(org.objectweb.jonas.jdbc_xa.XAConnectionImpl xac,
java.sql.Connection actual)
getConnection
public java.sql.Connection getConnection()
- Get the actual connection on database
createStatement
public java.sql.Statement createStatement()
throws java.sql.SQLException
- Specified by:
createStatement
in interface java.sql.Connection
prepareStatement
public java.sql.PreparedStatement prepareStatement(java.lang.String sql)
throws java.sql.SQLException
- Specified by:
prepareStatement
in interface java.sql.Connection
prepareCall
public java.sql.CallableStatement prepareCall(java.lang.String sql)
throws java.sql.SQLException
- Specified by:
prepareCall
in interface java.sql.Connection
nativeSQL
public java.lang.String nativeSQL(java.lang.String sql)
throws java.sql.SQLException
- Specified by:
nativeSQL
in interface java.sql.Connection
isClosed
public boolean isClosed()
throws java.sql.SQLException
- Specified by:
isClosed
in interface java.sql.Connection
getMetaData
public java.sql.DatabaseMetaData getMetaData()
throws java.sql.SQLException
- Specified by:
getMetaData
in interface java.sql.Connection
setReadOnly
public void setReadOnly(boolean readOnly)
throws java.sql.SQLException
- Specified by:
setReadOnly
in interface java.sql.Connection
isReadOnly
public boolean isReadOnly()
throws java.sql.SQLException
- Specified by:
isReadOnly
in interface java.sql.Connection
setCatalog
public void setCatalog(java.lang.String catalog)
throws java.sql.SQLException
- Specified by:
setCatalog
in interface java.sql.Connection
getCatalog
public java.lang.String getCatalog()
throws java.sql.SQLException
- Specified by:
getCatalog
in interface java.sql.Connection
close
public void close()
throws java.sql.SQLException
- Trigger an event to the listener.
- Specified by:
close
in interface java.sql.Connection
setTransactionIsolation
public void setTransactionIsolation(int level)
throws java.sql.SQLException
- Specified by:
setTransactionIsolation
in interface java.sql.Connection
getTransactionIsolation
public int getTransactionIsolation()
throws java.sql.SQLException
- Specified by:
getTransactionIsolation
in interface java.sql.Connection
getWarnings
public java.sql.SQLWarning getWarnings()
throws java.sql.SQLException
- Specified by:
getWarnings
in interface java.sql.Connection
clearWarnings
public void clearWarnings()
throws java.sql.SQLException
- Specified by:
clearWarnings
in interface java.sql.Connection
commit
public void commit()
throws java.sql.SQLException
- In a JDBC-XA driver, Connection.commit is only called if we
are outside a global transaction.
- Specified by:
commit
in interface java.sql.Connection
rollback
public void rollback()
throws java.sql.SQLException
- In a JDBC-XA driver, Connection.rollback is only called if we
are outside a global transaction.
- Specified by:
rollback
in interface java.sql.Connection
setAutoCommit
public void setAutoCommit(boolean autoCommit)
throws java.sql.SQLException
- In a JDBC-XA driver, autocommit is false if we are in a global Tx
- Specified by:
setAutoCommit
in interface java.sql.Connection
getAutoCommit
public boolean getAutoCommit()
throws java.sql.SQLException
- In a JDBC-XA driver, autocommit is false if we are in a global Tx
- Specified by:
getAutoCommit
in interface java.sql.Connection
createStatement
public java.sql.Statement createStatement(int resultSetType,
int resultSetConcurrency)
throws java.sql.SQLException
- Specified by:
createStatement
in interface java.sql.Connection
getTypeMap
public java.util.Map getTypeMap()
throws java.sql.SQLException
- Specified by:
getTypeMap
in interface java.sql.Connection
setTypeMap
public void setTypeMap(java.util.Map map)
throws java.sql.SQLException
- Specified by:
setTypeMap
in interface java.sql.Connection
prepareStatement
public java.sql.PreparedStatement prepareStatement(java.lang.String sql,
int resultSetType,
int resultSetConcurrency)
throws java.sql.SQLException
- Specified by:
prepareStatement
in interface java.sql.Connection
prepareCall
public java.sql.CallableStatement prepareCall(java.lang.String sql,
int resultSetType,
int resultSetConcurrency)
throws java.sql.SQLException
- Specified by:
prepareCall
in interface java.sql.Connection
createStatement
public java.sql.Statement createStatement(int resultSetType,
int resultSetConcurrency,
int resultSetHoldability)
throws java.sql.SQLException
getHoldability
public int getHoldability()
throws java.sql.SQLException
prepareCall
public java.sql.CallableStatement prepareCall(java.lang.String sql,
int resultSetType,
int resultSetConcurrency,
int resultSetHoldability)
throws java.sql.SQLException
prepareStatement
public java.sql.PreparedStatement prepareStatement(java.lang.String sql,
int autoGeneratedKeys)
throws java.sql.SQLException
prepareStatement
public java.sql.PreparedStatement prepareStatement(java.lang.String sql,
int resultSetType,
int resultSetConcurrency,
int resultSetHoldability)
throws java.sql.SQLException
prepareStatement
public java.sql.PreparedStatement prepareStatement(java.lang.String sql,
int[] columnIndexes)
throws java.sql.SQLException
prepareStatement
public java.sql.PreparedStatement prepareStatement(java.lang.String sql,
java.lang.String[] columnNames)
throws java.sql.SQLException
releaseSavepoint
public void releaseSavepoint(java.sql.Savepoint savepoint)
throws java.sql.SQLException
rollback
public void rollback(java.sql.Savepoint savepoint)
throws java.sql.SQLException
setHoldability
public void setHoldability(int holdability)
throws java.sql.SQLException
setSavepoint
public java.sql.Savepoint setSavepoint()
throws java.sql.SQLException
setSavepoint
public java.sql.Savepoint setSavepoint(java.lang.String name)
throws java.sql.SQLException