Package org.pentaho.platform.plugin.action.kettle

Class PoolingManagedDataSource

java.lang.Object

org.apache.commons.dbcp.PoolingDataSource

org.pentaho.platform.plugin.action.kettle.PoolingManagedDataSource

All Implemented Interfaces:

Wrapper, CommonDataSource, DataSource, org.pentaho.di.core.database.CachedManagedDataSourceInterface

public class PoolingManagedDataSource
extends org.apache.commons.dbcp.PoolingDataSource
implements org.pentaho.di.core.database.CachedManagedDataSourceInterface

Field Summary

Fields inherited from class org.apache.commons.dbcp.PoolingDataSource

_logWriter, _pool

Constructor Summary

Constructors

Constructor	Description
PoolingManagedDataSource(org.pentaho.database.model.IDatabaseConnection databaseConnection, org.pentaho.database.IDatabaseDialect dialect)

Method Summary

Modifier and Type	Method	Description
void	addInUseBy(String ownerName)
void	expire()
String	getHash()
Logger	getParentLogger()
boolean	hasSameConfig(String poolConfigHash)
boolean	isExpired()
boolean	isInUse()
void	removeInUseBy(String invalidatedBy)
void	setHash(String poolConfig)
void	setInUseBy(List<String> ownerList)
void	tryInvalidateDataSource(String invalidatedBy)

Methods inherited from class org.apache.commons.dbcp.PoolingDataSource

getConnection, getConnection, getLoginTimeout, getLogWriter, isAccessToUnderlyingConnectionAllowed, isWrapperFor, setAccessToUnderlyingConnectionAllowed, setLoginTimeout, setLogWriter, setPool, unwrap

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.sql.CommonDataSource

createShardingKeyBuilder

Methods inherited from interface javax.sql.DataSource

createConnectionBuilder, getConnection, getConnection, getLoginTimeout, getLogWriter, setLoginTimeout, setLogWriter

Methods inherited from interface java.sql.Wrapper

isWrapperFor, unwrap

Constructor Detail

PoolingManagedDataSource

public PoolingManagedDataSource(org.pentaho.database.model.IDatabaseConnection databaseConnection,
                                org.pentaho.database.IDatabaseDialect dialect)
                         throws Exception

Throws:

Exception

Method Detail

isExpired

public boolean isExpired()

Specified by:

isExpired in interface org.pentaho.di.core.database.CachedManagedDataSourceInterface

tryInvalidateDataSource

public void tryInvalidateDataSource(String invalidatedBy)

Specified by:

tryInvalidateDataSource in interface org.pentaho.di.core.database.CachedManagedDataSourceInterface

getParentLogger

public Logger getParentLogger()
                       throws SQLFeatureNotSupportedException

Specified by:

getParentLogger in interface CommonDataSource

Throws:

SQLFeatureNotSupportedException

addInUseBy

public void addInUseBy(String ownerName)

Specified by:

addInUseBy in interface org.pentaho.di.core.database.CachedManagedDataSourceInterface

removeInUseBy

public void removeInUseBy(String invalidatedBy)

Specified by:

removeInUseBy in interface org.pentaho.di.core.database.CachedManagedDataSourceInterface

setHash

public void setHash(String poolConfig)

Specified by:

setHash in interface org.pentaho.di.core.database.CachedManagedDataSourceInterface

getHash

public String getHash()

Specified by:

getHash in interface org.pentaho.di.core.database.CachedManagedDataSourceInterface

hasSameConfig

public boolean hasSameConfig(String poolConfigHash)

isInUse

public boolean isInUse()

Specified by:

isInUse in interface org.pentaho.di.core.database.CachedManagedDataSourceInterface

setInUseBy

public void setInUseBy(List<String> ownerList)

Specified by:

setInUseBy in interface org.pentaho.di.core.database.CachedManagedDataSourceInterface

expire

public void expire()

Specified by:

expire in interface org.pentaho.di.core.database.CachedManagedDataSourceInterface