com.atomikos.jdbc

Class AtomikosNonPoolingDataSourceBean

java.lang.Object

com.atomikos.jdbc.internal.AbstractDataSourceBean

com.atomikos.jdbc.AtomikosDataSourceBean

com.atomikos.jdbc.AtomikosNonPoolingDataSourceBean

All Implemented Interfaces:

ConnectionPoolProperties, com.atomikos.icatch.OrderedLifecycleComponent, InitConnectionCallback, Serializable, Wrapper, Referenceable, CommonDataSource, DataSource

public class AtomikosNonPoolingDataSourceBean
extends AtomikosDataSourceBean

A datasource implementation that still supports XA but does not pool connections. Examples of where this can be useful:

• Testing and Development: When you want to ensure that each test or transaction uses a completely fresh connection.
• Short-lived Applications: For applications that run briefly and don't benefit from connection pooling overhead.
• Resource Constraints: When you want to minimize the number of persistent connections to the database.
• Debugging: When troubleshooting connection-related issues and want to eliminate pooling as a variable.
• Cloud Environments: In serverless or ephemeral environments where maintaining a connection pool is counterproductive.
• Third-party Connection Pooling: When delegating pooling to an external library such as Oracle UCP.

See Also:

Serialized Form

Field Summary

Fields inherited from interface com.atomikos.datasource.pool.ConnectionPoolProperties

DEFAULT_BORROW_CONNECTION_TIMEOUT, DEFAULT_ISOLATION_LEVEL_UNSET, DEFAULT_MAINTENANCE_INTERVAL, DEFAULT_MAX_IDLE_TIME, DEFAULT_MAX_LIFETIME, DEFAULT_POOL_SIZE

Constructor Summary

Constructors

Constructor and Description
AtomikosNonPoolingDataSourceBean()

Method Summary

Modifier and Type	Method and Description
protected void	assertPoolSizeSettings()
protected ConnectionFactory<Connection>	doInit()
Connection	getConnection()
void	setConcurrentConnectionValidation(boolean value) Sets whether or not to use concurrent connection validation.
void	setMaintenanceInterval(int maintenanceInterval) Sets the maintenance interval for the pool maintenance thread.
void	setMaxIdleTime(int maxIdleTime) Sets the maximum amount of seconds that unused excess connections should stay in the pool.
void	setMaxLifetime(int maxLifetime) Sets the maximum amount of seconds that a connection is kept in the pool before it is destroyed automatically.
void	setMaxPoolSize(int maxPoolSize) Sets the maximum pool size.
void	setMinPoolSize(int minPoolSize) Sets the minimum pool size.
void	setPoolSize(int poolSize) Sets both the minimal and maximal pool size.

Methods inherited from class com.atomikos.jdbc.AtomikosDataSourceBean

doClose, getEndExistingXaBranchFlags, getIgnoreJtaTransactions, getJoinExistingXaBranchFlags, getLocalTransactionMode, getPropagateJtaTimeoutToXaResource, getRecycleActiveConnectionsInTransaction, getResumeExistingXaBranchFlags, getStartNewXaBranchFlags, getSupportsTmJoin, getSuspendExistingXaBranchFlags, getXaDataSource, getXaDataSourceClassName, getXaProperties, getXaPropertyNamesToHide, isAssignableFromWrappedVendorClass, printXaProperties, setEndExistingXaBranchFlags, setJoinExistingXaBranchFlags, setLocalTransactionMode, setPropagateJtaTimeoutToXaResource, setRecycleActiveConnectionsInTransaction, setResumeExistingXaBranchFlags, setStartNewXaBranchFlags, setSupportsTmJoin, setSuspendExistingXaBranchFlags, setXaDataSource, setXaDataSourceClassName, setXaProperties, setXaPropertyNamesToHide, unwrapVendorInstance

Methods inherited from class com.atomikos.jdbc.internal.AbstractDataSourceBean

close, getBorrowConnectionTimeout, getConcurrentConnectionValidation, getConnection, getConnectionValidationInterval, getDefaultIsolationLevel, getFailOnInitIfDatabaseDown, getInitConnectionSql, getLoginTimeout, getLogWriter, getMaintenanceInterval, getMaxIdleTime, getMaxLifetime, getMaxPoolSize, getMinPoolSize, getNetworkTimeout, getParentLogger, getReference, getTestQuery, getUniqueResourceName, getUseDriverBasedConnectionValidation, hasInitConnectionSQL, init, intializeVendorConnection, isWrapperFor, poolAvailableSize, poolTotalSize, refreshPool, setBorrowConnectionTimeout, setConnectionValidationInterval, setDefaultIsolationLevel, setFailOnInitIfDatabaseDown, setInitConnectionSql, setLoginTimeout, setLogWriter, setNetworkTimeout, setTestQuery, setUniqueResourceName, setUseDriverBasedConnectionValidation, throwAtomikosSQLException, throwAtomikosSQLException, toString, unwrap

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.sql.DataSource

getConnection

Methods inherited from interface javax.sql.CommonDataSource

getLoginTimeout, getLogWriter, getParentLogger, setLoginTimeout, setLogWriter

Methods inherited from interface java.sql.Wrapper

isWrapperFor, unwrap

Constructor Detail

AtomikosNonPoolingDataSourceBean

public AtomikosNonPoolingDataSourceBean()

Method Detail

getConnection

public Connection getConnection()
                         throws SQLException

Specified by:

getConnection in interface DataSource

Overrides:

getConnection in class AbstractDataSourceBean

Throws:

SQLException

doInit

protected ConnectionFactory<Connection> doInit()
                                        throws Exception

Overrides:

doInit in class AtomikosDataSourceBean

Throws:

Exception

setMaxPoolSize

public void setMaxPoolSize(int maxPoolSize)

Description copied from class: AbstractDataSourceBean

Sets the maximum pool size. The amount of pooled connections won't go above this value. Optional, defaults to 1.

Overrides:

setMaxPoolSize in class AbstractDataSourceBean

setMinPoolSize

public void setMinPoolSize(int minPoolSize)

Description copied from class: AbstractDataSourceBean

Sets the minimum pool size. The amount of pooled connections won't go below that value. The pool will open this amount of connections during initialization. Optional, defaults to 1.

Overrides:

setMinPoolSize in class AbstractDataSourceBean

setMaintenanceInterval

public void setMaintenanceInterval(int maintenanceInterval)

Description copied from class: AbstractDataSourceBean

Sets the maintenance interval for the pool maintenance thread. Optional.

Overrides:

setMaintenanceInterval in class AbstractDataSourceBean

Parameters:

maintenanceInterval - The interval in seconds. If not set or not positive then the pool's default (60 secs) will be used.

setPoolSize

public void setPoolSize(int poolSize)

Description copied from class: AbstractDataSourceBean

Sets both the minimal and maximal pool size. Required if the maxPoolSize is not set. Overrides any minPoolSize or maxPoolSize settings you might have configured before!

Overrides:

setPoolSize in class AbstractDataSourceBean

setConcurrentConnectionValidation

public void setConcurrentConnectionValidation(boolean value)

Description copied from class: AbstractDataSourceBean

Sets whether or not to use concurrent connection validation. Optional, defaults to true.

Overrides:

setConcurrentConnectionValidation in class AbstractDataSourceBean

setMaxIdleTime

public void setMaxIdleTime(int maxIdleTime)

Description copied from class: AbstractDataSourceBean

Sets the maximum amount of seconds that unused excess connections should stay in the pool. Optional. Note: excess connections are connections that are created above the minPoolSize limit.

Overrides:

setMaxIdleTime in class AbstractDataSourceBean

Parameters:

maxIdleTime - The preferred idle time for unused excess connections. Note that this value is only an indication; the pool will check regularly as indicated by the maintenanceInteval property. The default is 60 seconds.

setMaxLifetime

public void setMaxLifetime(int maxLifetime)

Description copied from class: AbstractDataSourceBean

Sets the maximum amount of seconds that a connection is kept in the pool before it is destroyed automatically. Optional, defaults to 0 (no limit).

Overrides:

setMaxLifetime in class AbstractDataSourceBean

assertPoolSizeSettings

protected void assertPoolSizeSettings()
                               throws AtomikosSQLException

Overrides:

assertPoolSizeSettings in class AbstractDataSourceBean

Throws:

AtomikosSQLException