ExtendedConnectionDataSourceProxy (Spring Batch 4.3.7 API)

java.lang.Object
- org.springframework.batch.item.database.ExtendedConnectionDataSourceProxy

All Implemented Interfaces:

java.sql.Wrapper, javax.sql.CommonDataSource, javax.sql.DataSource, org.springframework.beans.factory.InitializingBean, org.springframework.jdbc.datasource.SmartDataSource
```
public class ExtendedConnectionDataSourceProxy
extends java.lang.Object
implements org.springframework.jdbc.datasource.SmartDataSource, org.springframework.beans.factory.InitializingBean
```
Implementation of SmartDataSource that is capable of keeping a single JDBC Connection which is NOT closed after each use even if Connection.close() is called. The connection can be kept open over multiple transactions when used together with any of Spring's PlatformTransactionManager implementations.
Loosely based on the SingleConnectionDataSource implementation in Spring Core. Intended to be used with the JdbcCursorItemReader to provide a connection that remains open across transaction boundaries, It remains open for the life of the cursor, and can be shared with the main transaction of the rest of the step processing.
Once close suppression has been turned on for a connection, it will be returned for the first getConnection() call. Any subsequent calls to getConnection() will retrieve a new connection from the wrapped DataSource until the DataSourceUtils queries whether the connection should be closed or not by calling shouldClose(Connection) for the close-suppressed Connection. At that point the cycle starts over again, and the next getConnection() call will have the Connection that is being close-suppressed returned. This allows the use of the close-suppressed Connection to be the main Connection for an extended data access process. The close suppression is turned off by calling stopCloseSuppression(Connection).
This class is not multi-threading capable.
The connection returned will be a close-suppressing proxy instead of the physical Connection. Be aware that you will not be able to cast this to a native OracleConnection or the like anymore; you'd be required to use Wrapper.unwrap(Class).

Since:

2.0

Author:

Thomas Risberg

See Also:

getConnection(), Connection.close(), DataSourceUtils.releaseConnection(java.sql.Connection, javax.sql.DataSource), Wrapper.unwrap(Class)

Constructor Summary

Constructors
Constructor and Description
`ExtendedConnectionDataSourceProxy()` No arg constructor for use when configured using JavaBean style.
`ExtendedConnectionDataSourceProxy(javax.sql.DataSource dataSource)` Constructor that takes as a parameter with the `DataSource` to be wrapped.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`afterPropertiesSet()`
`protected java.sql.Connection`	`getCloseSuppressingConnectionProxy(java.sql.Connection target)` Wrap the given Connection with a proxy that delegates every method call to it but suppresses close calls.
`java.sql.Connection`	`getConnection()`
`java.sql.Connection`	`getConnection(java.lang.String username, java.lang.String password)`
`int`	`getLoginTimeout()`
`java.io.PrintWriter`	`getLogWriter()`
`java.util.logging.Logger`	`getParentLogger()` Added due to JDK 7 compatibility.
`boolean`	`isCloseSuppressionActive(java.sql.Connection connection)` Return the status of close suppression being activated for a given `Connection`
`boolean`	`isWrapperFor(java.lang.Class<?> iface)` Performs only a 'shallow' non-recursive check of self's and delegate's class to retain Java 5 compatibility.
`void`	`setDataSource(javax.sql.DataSource dataSource)` Setter for the `DataSource` that is to be wrapped.
`void`	`setLoginTimeout(int seconds)`
`void`	`setLogWriter(java.io.PrintWriter out)`
`boolean`	`shouldClose(java.sql.Connection connection)`
`void`	`startCloseSuppression(java.sql.Connection connection)`
`void`	`stopCloseSuppression(java.sql.Connection connection)`
`<T> T`	`unwrap(java.lang.Class<T> iface)` Returns either self or delegate (in this order) if one of them can be cast to supplied parameter class.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - ExtendedConnectionDataSourceProxy
```
public ExtendedConnectionDataSourceProxy()
```
    No arg constructor for use when configured using JavaBean style.
  - ExtendedConnectionDataSourceProxy
```
public ExtendedConnectionDataSourceProxy(javax.sql.DataSource dataSource)
```
    Constructor that takes as a parameter with the DataSource to be wrapped.
    
    Parameters:
    
    dataSource - DataSource to be used
- Method Detail
  - setDataSource
```
public void setDataSource(javax.sql.DataSource dataSource)
```
    Setter for the DataSource that is to be wrapped.
    
    Parameters:
    
    dataSource - the DataSource
  - shouldClose
```
public boolean shouldClose(java.sql.Connection connection)
```
    Specified by:
    
    shouldClose in interface org.springframework.jdbc.datasource.SmartDataSource
    
    See Also:
    
    SmartDataSource
  - isCloseSuppressionActive
```
public boolean isCloseSuppressionActive(java.sql.Connection connection)
```
    Return the status of close suppression being activated for a given Connection
    
    Parameters:
    
    connection - the Connection that the close suppression status is requested for
    
    Returns:
    
    true or false
  - startCloseSuppression
```
public void startCloseSuppression(java.sql.Connection connection)
```
    Parameters:
    
    connection - the Connection that close suppression is requested for
  - stopCloseSuppression
```
public void stopCloseSuppression(java.sql.Connection connection)
```
    Parameters:
    
    connection - the Connection that close suppression should be turned off for
  - getConnection
```
public java.sql.Connection getConnection()
                                  throws java.sql.SQLException
```
    Specified by:
    
    getConnection in interface javax.sql.DataSource
    
    Throws:
    
    java.sql.SQLException
  - getConnection
```
public java.sql.Connection getConnection(java.lang.String username,
                                         java.lang.String password)
                                  throws java.sql.SQLException
```
    Specified by:
    
    getConnection in interface javax.sql.DataSource
    
    Throws:
    
    java.sql.SQLException
  - getLogWriter
```
public java.io.PrintWriter getLogWriter()
                                 throws java.sql.SQLException
```
    Specified by:
    
    getLogWriter in interface javax.sql.CommonDataSource
    
    Throws:
    
    java.sql.SQLException
  - getLoginTimeout
```
public int getLoginTimeout()
                    throws java.sql.SQLException
```
    Specified by:
    
    getLoginTimeout in interface javax.sql.CommonDataSource
    
    Throws:
    
    java.sql.SQLException
  - setLogWriter
```
public void setLogWriter(java.io.PrintWriter out)
                  throws java.sql.SQLException
```
    Specified by:
    
    setLogWriter in interface javax.sql.CommonDataSource
    
    Throws:
    
    java.sql.SQLException
  - setLoginTimeout
```
public void setLoginTimeout(int seconds)
                     throws java.sql.SQLException
```
    Specified by:
    
    setLoginTimeout in interface javax.sql.CommonDataSource
    
    Throws:
    
    java.sql.SQLException
  - getCloseSuppressingConnectionProxy
```
protected java.sql.Connection getCloseSuppressingConnectionProxy(java.sql.Connection target)
```
    Wrap the given Connection with a proxy that delegates every method call to it but suppresses close calls.
    
    Parameters:
    
    target - the original Connection to wrap
    
    Returns:
    
    the wrapped Connection
  - isWrapperFor
```
public boolean isWrapperFor(java.lang.Class<?> iface)
                     throws java.sql.SQLException
```
    Performs only a 'shallow' non-recursive check of self's and delegate's class to retain Java 5 compatibility.
    
    Specified by:
    
    isWrapperFor in interface java.sql.Wrapper
    
    Throws:
    
    java.sql.SQLException
  - unwrap
```
public <T> T unwrap(java.lang.Class<T> iface)
             throws java.sql.SQLException
```
    Returns either self or delegate (in this order) if one of them can be cast to supplied parameter class. Does *not* support recursive unwrapping of the delegate to retain Java 5 compatibility.
    
    Specified by:
    
    unwrap in interface java.sql.Wrapper
    
    Throws:
    
    java.sql.SQLException
  - afterPropertiesSet
```
public void afterPropertiesSet()
                        throws java.lang.Exception
```
    Specified by:
    
    afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean
    
    Throws:
    
    java.lang.Exception
  - getParentLogger
```
public java.util.logging.Logger getParentLogger()
                                         throws java.sql.SQLFeatureNotSupportedException
```
    Added due to JDK 7 compatibility.
    
    Specified by:
    
    getParentLogger in interface javax.sql.CommonDataSource
    
    Throws:
    
    java.sql.SQLFeatureNotSupportedException

Class ExtendedConnectionDataSourceProxy

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

ExtendedConnectionDataSourceProxy

ExtendedConnectionDataSourceProxy

Method Detail

setDataSource

shouldClose

isCloseSuppressionActive

startCloseSuppression

stopCloseSuppression

getConnection

getConnection

getLogWriter

getLoginTimeout

setLogWriter

setLoginTimeout

getCloseSuppressingConnectionProxy

isWrapperFor

unwrap

afterPropertiesSet

getParentLogger