Class PoolingManagedDataSource
- java.lang.Object
-
- org.apache.commons.dbcp2.PoolingDataSource
-
- org.pentaho.platform.plugin.action.kettle.PoolingManagedDataSource
-
- All Implemented Interfaces:
AutoCloseable
,Wrapper
,CommonDataSource
,DataSource
,org.pentaho.di.core.database.CachedManagedDataSourceInterface
public class PoolingManagedDataSource extends org.apache.commons.dbcp2.PoolingDataSource implements org.pentaho.di.core.database.CachedManagedDataSourceInterface
-
-
Constructor Summary
Constructors Constructor Description PoolingManagedDataSource(org.pentaho.database.model.IDatabaseConnection databaseConnection, org.pentaho.database.IDatabaseDialect dialect)
-
Method Summary
All Methods Instance Methods Concrete Methods 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.dbcp2.PoolingDataSource
close, getConnection, getConnection, getLoginTimeout, getLogWriter, getPool, isAccessToUnderlyingConnectionAllowed, isWrapperFor, setAccessToUnderlyingConnectionAllowed, setLoginTimeout, setLogWriter, 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
-
-
-
-
Method Detail
-
isExpired
public boolean isExpired()
- Specified by:
isExpired
in interfaceorg.pentaho.di.core.database.CachedManagedDataSourceInterface
-
tryInvalidateDataSource
public void tryInvalidateDataSource(String invalidatedBy)
- Specified by:
tryInvalidateDataSource
in interfaceorg.pentaho.di.core.database.CachedManagedDataSourceInterface
-
getParentLogger
public Logger getParentLogger() throws SQLFeatureNotSupportedException
- Specified by:
getParentLogger
in interfaceCommonDataSource
- Overrides:
getParentLogger
in classorg.apache.commons.dbcp2.PoolingDataSource
- Throws:
SQLFeatureNotSupportedException
-
addInUseBy
public void addInUseBy(String ownerName)
- Specified by:
addInUseBy
in interfaceorg.pentaho.di.core.database.CachedManagedDataSourceInterface
-
removeInUseBy
public void removeInUseBy(String invalidatedBy)
- Specified by:
removeInUseBy
in interfaceorg.pentaho.di.core.database.CachedManagedDataSourceInterface
-
setHash
public void setHash(String poolConfig)
- Specified by:
setHash
in interfaceorg.pentaho.di.core.database.CachedManagedDataSourceInterface
-
getHash
public String getHash()
- Specified by:
getHash
in interfaceorg.pentaho.di.core.database.CachedManagedDataSourceInterface
-
hasSameConfig
public boolean hasSameConfig(String poolConfigHash)
-
isInUse
public boolean isInUse()
- Specified by:
isInUse
in interfaceorg.pentaho.di.core.database.CachedManagedDataSourceInterface
-
setInUseBy
public void setInUseBy(List<String> ownerList)
- Specified by:
setInUseBy
in interfaceorg.pentaho.di.core.database.CachedManagedDataSourceInterface
-
expire
public void expire()
- Specified by:
expire
in interfaceorg.pentaho.di.core.database.CachedManagedDataSourceInterface
-
-