diff options
| author | Barry Lind <barry@xythos.com> | 2002-08-14 20:35:40 +0000 |
|---|---|---|
| committer | Barry Lind <barry@xythos.com> | 2002-08-14 20:35:40 +0000 |
| commit | b3dd55c6517a6a9f531a7bab463e9bcf6291aa9b (patch) | |
| tree | e78512bb088ee72bff62abd640335c29cc5965c9 /src/interfaces/jdbc/org/postgresql/xa/ClientConnection.java | |
| parent | 64a0649432408b407e477caf11056b380b5689bd (diff) | |
| download | postgresql-b3dd55c6517a6a9f531a7bab463e9bcf6291aa9b.tar.gz | |
Added support for JDBC3. The driver will now build under JDBC3 (i.e. Java 1.4).
This concludes my changes that restructured the code to support JDBC3.
The jdbc unit tests were also resturctured to allow different tests between
jdbc2 and jdbc3, although currently make check (aka ant test) for JDBC3 just
runs the JDBC2 tests. Of special note the largeobject/PGblob and PGclob
classes have been moved under the jdbc2/jdbc3 specific directories as they
now differ by jdbc version. Also note that this checkin removes the
PostgresqlDataSource and files in the xa directory. A recent checkin has
added new datasource support that replaces the functionality provided by these
classes.
Modified Files:
jdbc/build.xml
jdbc/org/postgresql/jdbc1/AbstractJdbc1DatabaseMetaData.java
jdbc/org/postgresql/jdbc1/AbstractJdbc1ResultSet.java
jdbc/org/postgresql/jdbc1/AbstractJdbc1ResultSetMetaData.java
jdbc/org/postgresql/jdbc1/AbstractJdbc1Statement.java
jdbc/org/postgresql/jdbc2/AbstractJdbc2Connection.java
jdbc/org/postgresql/jdbc2/AbstractJdbc2DatabaseMetaData.java
jdbc/org/postgresql/jdbc2/AbstractJdbc2ResultSet.java
jdbc/org/postgresql/jdbc2/AbstractJdbc2ResultSetMetaData.java
jdbc/org/postgresql/jdbc2/AbstractJdbc2Statement.java
jdbc/org/postgresql/jdbc2/Array.java
jdbc/org/postgresql/jdbc2/Jdbc2CallableStatement.java
jdbc/org/postgresql/jdbc2/Jdbc2Connection.java
jdbc/org/postgresql/jdbc2/Jdbc2DatabaseMetaData.java
jdbc/org/postgresql/jdbc2/Jdbc2PreparedStatement.java
jdbc/org/postgresql/jdbc2/Jdbc2ResultSet.java
jdbc/org/postgresql/jdbc2/Jdbc2ResultSetMetaData.java
jdbc/org/postgresql/jdbc2/Jdbc2Statement.java
jdbc/org/postgresql/test/jdbc2/BatchExecuteTest.java
jdbc/org/postgresql/test/jdbc2/BlobTest.java
jdbc/org/postgresql/test/jdbc2/CallableStmtTest.java
jdbc/org/postgresql/test/jdbc2/ConnectionTest.java
jdbc/org/postgresql/test/jdbc2/DatabaseMetaDataTest.java
jdbc/org/postgresql/test/jdbc2/DateTest.java
jdbc/org/postgresql/test/jdbc2/DriverTest.java
jdbc/org/postgresql/test/jdbc2/JBuilderTest.java
jdbc/org/postgresql/test/jdbc2/MiscTest.java
jdbc/org/postgresql/test/jdbc2/ResultSetTest.java
jdbc/org/postgresql/test/jdbc2/TimeTest.java
jdbc/org/postgresql/test/jdbc2/TimestampTest.java
jdbc/org/postgresql/test/jdbc2/UpdateableResultTest.java
Added Files:
jdbc/org/postgresql/jdbc2/AbstractJdbc2Blob.java
jdbc/org/postgresql/jdbc2/AbstractJdbc2Clob.java
jdbc/org/postgresql/jdbc2/Jdbc2Blob.java
jdbc/org/postgresql/jdbc2/Jdbc2Clob.java
jdbc/org/postgresql/jdbc3/AbstractJdbc3Blob.java
jdbc/org/postgresql/jdbc3/AbstractJdbc3Clob.java
jdbc/org/postgresql/jdbc3/AbstractJdbc3Connection.java
jdbc/org/postgresql/jdbc3/AbstractJdbc3DatabaseMetaData.java
jdbc/org/postgresql/jdbc3/AbstractJdbc3ResultSet.java
jdbc/org/postgresql/jdbc3/AbstractJdbc3Statement.java
jdbc/org/postgresql/jdbc3/Jdbc3Blob.java
jdbc/org/postgresql/jdbc3/Jdbc3CallableStatement.java
jdbc/org/postgresql/jdbc3/Jdbc3Clob.java
jdbc/org/postgresql/jdbc3/Jdbc3Connection.java
jdbc/org/postgresql/jdbc3/Jdbc3DatabaseMetaData.java
jdbc/org/postgresql/jdbc3/Jdbc3PreparedStatement.java
jdbc/org/postgresql/jdbc3/Jdbc3ResultSet.java
jdbc/org/postgresql/jdbc3/Jdbc3ResultSetMetaData.java
jdbc/org/postgresql/jdbc3/Jdbc3Statement.java
jdbc/org/postgresql/test/TestUtil.java
jdbc/org/postgresql/test/jdbc2/Jdbc2TestSuite.java
jdbc/org/postgresql/test/jdbc3/Jdbc3TestSuite.java
Removed Files:
jdbc/org/postgresql/PostgresqlDataSource.java
jdbc/org/postgresql/largeobject/PGblob.java
jdbc/org/postgresql/largeobject/PGclob.java
jdbc/org/postgresql/test/JDBC2Tests.java
jdbc/org/postgresql/xa/ClientConnection.java
jdbc/org/postgresql/xa/TwoPhaseConnection.java
jdbc/org/postgresql/xa/TxConnection.java
jdbc/org/postgresql/xa/XAConnectionImpl.java
jdbc/org/postgresql/xa/XADataSourceImpl.java
Diffstat (limited to 'src/interfaces/jdbc/org/postgresql/xa/ClientConnection.java')
| -rw-r--r-- | src/interfaces/jdbc/org/postgresql/xa/ClientConnection.java | 567 |
1 files changed, 0 insertions, 567 deletions
diff --git a/src/interfaces/jdbc/org/postgresql/xa/ClientConnection.java b/src/interfaces/jdbc/org/postgresql/xa/ClientConnection.java deleted file mode 100644 index dc46c873e8..0000000000 --- a/src/interfaces/jdbc/org/postgresql/xa/ClientConnection.java +++ /dev/null @@ -1,567 +0,0 @@ -/* -* Redistribution and use of this software and associated documentation -* ("Software"), with or without modification, are permitted provided -* that the following conditions are met: -* -* 1. Redistributions of source code must retain copyright -* statements and notices. Redistributions must also contain a -* copy of this document. -* -* 2. Redistributions in binary form must reproduce the -* above copyright notice, this list of conditions and the -* following disclaimer in the documentation and/or other -* materials provided with the distribution. -* -* 3. The name "Exolab" must not be used to endorse or promote -* products derived from this Software without prior written -* permission of Exoffice Technologies. For written permission, -* please contact info@exolab.org. -* -* 4. Products derived from this Software may not be called "Exolab" -* nor may "Exolab" appear in their names without prior written -* permission of Exoffice Technologies. Exolab is a registered -* trademark of Exoffice Technologies. -* -* 5. Due credit should be given to the Exolab Project -* (http://www.exolab.org/). -* -* THIS SOFTWARE IS PROVIDED BY EXOFFICE TECHNOLOGIES AND CONTRIBUTORS -* ``AS IS'' AND ANY EXPRESSED OR IMPLIED WARRANTIES, INCLUDING, BUT -* NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND -* FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL -* EXOFFICE TECHNOLOGIES OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, -* INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES -* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR -* SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) -* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, -* STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) -* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED -* OF THE POSSIBILITY OF SUCH DAMAGE. -* -* Copyright 1999 (C) Exoffice Technologies Inc. All Rights Reserved. -* -* $Id: ClientConnection.java,v 1.4 2001/11/19 23:19:21 momjian Exp $ -*/ - - -package org.postgresql.xa; - - -import java.util.*; -import java.sql.*; - - -/* - * Encapsulates an application's view of an XA/pooled connection. - * The XA connection is managed by the application server through it's - * {@link javax.sql.XAConnection} interface. The underlying JDBC - * connection is a standard JDBC connection. The application's - * JDBC connection gives access to the underlying JDBC connection but - * is managed by the application server. The application is given an - * instance of this class and not the underlying connection directly. - * - * - * @author <a href="arkin@exoffice.com">Assaf Arkin</a> - * @version 1.0 - * @see XAConnectionImpl - * @see XADataSourceImpl - * @see Connection - */ -final class ClientConnection - implements Connection -{ - - - /* - * The pooled XA connection that created this client connection - * and should be used to report closure and fatal errors. - */ - private XAConnectionImpl _xaConn; - - - /* - * This identifier was handed on to use when we were created by - * {@link XAConnection}. If since then the XA connection was asked - * to create another connection or was closed, our identifier will - * no longer be valid and any call to {@link - * XAConnection#getUnderlying} will throw an exception. Previously, - * the XA connection would hold a reference to use and tell us to - * terminate, but that prevented ClientConnection from being - * finalized. - */ - private int _clientId; - - - - - /* - * Construct a new client connection to provide access to the - * underlying JDBC connection (<tt>underlying</tt>) on behalf of - * an XA/pooled connection (<tt>xaConn<tt/>). The pooled connection - * is required to notify of connection closure and fatal errors. - * - * @param xaConn The XA/pooled connection that created this - * client connection - * @param clientId A unique identifier handed to us by - * {@link XAConnection} - * @param underlying The underlying JDBC connection - */ - ClientConnection( XAConnectionImpl xaConn, int clientId ) - { - _xaConn = xaConn; - _clientId = clientId; - } - - - public Statement createStatement() - throws SQLException - { - try - { - return getUnderlying().createStatement(); - } - catch ( SQLException except ) - { - notifyError( except ); - throw except; - } - } - - - public Statement createStatement( int resultSetType, int resultSetConcurrency ) - throws SQLException - { - try - { - return getUnderlying().createStatement( resultSetType, resultSetConcurrency ); - } - catch ( SQLException except ) - { - notifyError( except ); - throw except; - } - } - - - public PreparedStatement prepareStatement( String sql ) - throws SQLException - { - try - { - return getUnderlying().prepareStatement( sql ); - } - catch ( SQLException except ) - { - notifyError( except ); - throw except; - } - } - - - public PreparedStatement prepareStatement( String sql, int resultSetType, int resultSetConcurrency ) - throws SQLException - { - try - { - return getUnderlying().prepareStatement( sql, resultSetType, resultSetConcurrency ); - } - catch ( SQLException except ) - { - notifyError( except ); - throw except; - } - } - - - public CallableStatement prepareCall( String sql ) - throws SQLException - { - try - { - return getUnderlying().prepareCall( sql ); - } - catch ( SQLException except ) - { - notifyError( except ); - throw except; - } - } - - - public CallableStatement prepareCall( String sql, int resultSetType, int resultSetConcurrency ) - throws SQLException - { - try - { - return getUnderlying().prepareCall( sql, resultSetType, resultSetConcurrency ); - } - catch ( SQLException except ) - { - notifyError( except ); - throw except; - } - } - - - public String nativeSQL( String sql ) - throws SQLException - { - try - { - return getUnderlying().nativeSQL( sql ); - } - catch ( SQLException except ) - { - notifyError( except ); - throw except; - } - } - - - public DatabaseMetaData getMetaData() - throws SQLException - { - try - { - return getUnderlying().getMetaData(); - } - catch ( SQLException except ) - { - notifyError( except ); - throw except; - } - } - - - public void setCatalog( String catalog ) - throws SQLException - { - try - { - getUnderlying().setCatalog( catalog ); - } - catch ( SQLException except ) - { - notifyError( except ); - throw except; - } - } - - - public String getCatalog() - throws SQLException - { - try - { - return getUnderlying().getCatalog(); - } - catch ( SQLException except ) - { - notifyError( except ); - throw except; - } - } - - - public SQLWarning getWarnings() - throws SQLException - { - try - { - return getUnderlying().getWarnings(); - } - catch ( SQLException except ) - { - notifyError( except ); - throw except; - } - } - - - public void clearWarnings() - throws SQLException - { - try - { - getUnderlying().clearWarnings(); - } - catch ( SQLException except ) - { - notifyError( except ); - throw except; - } - } - - - public Map getTypeMap() - throws SQLException - { - try - { - return getUnderlying().getTypeMap(); - } - catch ( SQLException except ) - { - notifyError( except ); - throw except; - } - } - - - public void setTypeMap( Map map ) - throws SQLException - { - try - { - getUnderlying().setTypeMap( map ); - } - catch ( SQLException except ) - { - notifyError( except ); - throw except; - } - } - - - public void setAutoCommit( boolean autoCommit ) - throws SQLException - { - // Cannot set auto-commit inside a transaction. - if ( _xaConn.insideGlobalTx() ) - throw new SQLException( "Cannot commit/rollback a connection managed by the transaction manager" ); - try - { - getUnderlying().setAutoCommit( autoCommit ); - } - catch ( SQLException except ) - { - notifyError( except ); - throw except; - } - } - - - public boolean getAutoCommit() - throws SQLException - { - try - { - return getUnderlying().getAutoCommit(); - } - catch ( SQLException except ) - { - notifyError( except ); - throw except; - } - } - - - public void commit() - throws SQLException - { - // Cannot commit directly if we're inside a global transaction. - if ( _xaConn.insideGlobalTx() ) - throw new SQLException( "Cannot commit/rollback a connection managed by the transaction manager" ); - // Cannot commit a read-only transaction. - if ( isReadOnly() ) - throw new SQLException( "Cannot commit/rollback a read-only transaction" ); - - // This only occurs if not inside a local transaction. - try - { - getUnderlying().commit(); - } - catch ( SQLException except ) - { - notifyError( except ); - throw except; - } - } - - - - public void rollback() - throws SQLException - { - // Cannot commit directly if we're inside a global transaction. - if ( _xaConn.insideGlobalTx() ) - throw new SQLException( "Cannot commit/rollback a connection managed by the transaction manager" ); - - // This only occurs if not inside a local transaction. - try - { - getUnderlying().rollback(); - } - catch ( SQLException except ) - { - notifyError( except ); - throw except; - } - } - - - public void setReadOnly( boolean readOnly ) - throws SQLException - { - try - { - getUnderlying().setReadOnly( readOnly ); - } - catch ( SQLException except ) - { - notifyError( except ); - throw except; - } - } - - - public boolean isReadOnly() - throws SQLException - { - try - { - return getUnderlying().isReadOnly(); - } - catch ( SQLException except ) - { - notifyError( except ); - throw except; - } - } - - - public void setTransactionIsolation( int level ) - throws SQLException - { - try - { - getUnderlying().setTransactionIsolation( level ); - } - catch ( SQLException except ) - { - notifyError( except ); - throw except; - } - } - - - public int getTransactionIsolation() - throws SQLException - { - try - { - return getUnderlying().getTransactionIsolation(); - } - catch ( SQLException except ) - { - notifyError( except ); - throw except; - } - } - - - public synchronized void close() - throws SQLException - { - if ( _xaConn == null ) - return; - - // Notify the XA connection that we are no longer going - // to be used. Whether the underlying connection is released, - // held until the transaction terminates, etc is not - // a concern of us. - _xaConn.notifyClose( _clientId ); - _xaConn = null; - } - - - public synchronized boolean isClosed() - { - // Simple way of determining if this connection is closed. - // The actual connection is never closed, it is pooled. - return ( _xaConn == null ); - } - - - /* - * Called by {@link XAConnectionImpl} to terminate this connection - * by dissociating it from the underlying JDBC connection. - * The application would call {@link #close} but {@link - * XAConnectionImpl} cannot, since pooled connection requirements - * will cause an inifinite loop. This method should not attempt - * to notify either a closure or fatal error, but rather throw an - * exception if it fails. - */ - /* Deprecated: see XAConnection._clientId - void terminate() -{ - _xaConn = null; -} - */ - - - protected void finalize() - throws Throwable - { - close(); - } - - - public String toString() - { - try - { - return getUnderlying().toString(); - } - catch ( SQLException except ) - { - return "XAConnection: Connection closed"; - } - } - - - /* - * Called when an exception is thrown by the underlying connection - * to determine whether the exception is critical or not. If the - * exception is critical, notifies the XA connection to forget - * about this connection. - * - * @param except The exception thrown by the underlying - * connection - */ - void notifyError( SQLException except ) - { - if ( _xaConn != null ) - _xaConn.notifyError( _clientId, except ); - } - - - /* - * Called to retrieve the underlying JDBC connection. Actual JDBC - * operations are performed against it. Throws an SQLException if - * this connection has been closed. - */ - Connection getUnderlying() - throws SQLException - { - if ( _xaConn == null ) - throw new SQLException( "This connection has been closed" ); - // Must pass the client identifier so XAConnection can determine - // whether we are still valid. If it tells us we're no longer - // valid, we have little to do. - try - { - return _xaConn.getUnderlying( _clientId ); - } - catch ( SQLException except ) - { - _xaConn = null; - throw except; - } - } - - -} - - - |
