Package org.pentaho.di.core.database

Class ConnectionPoolUtil

java.lang.Object

org.pentaho.di.core.database.ConnectionPoolUtil

public class ConnectionPoolUtil
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static String	ACCESS_TO_UNDERLYING_CONNECTION_ALLOWED
static String	DEFAULT_AUTO_COMMIT
static String	DEFAULT_CATALOG
static String	DEFAULT_READ_ONLY
static String	DEFAULT_TRANSACTION_ISOLATION
static int	defaultInitialNrOfConnections
static int	defaultMaximumNrOfConnections
static String	INITIAL_SIZE
static String	LOG_ABANDONED
static String	MAX_ACTIVE
static String	MAX_IDLE
static String	MAX_OPEN_PREPARED_STATEMENTS
static String	MAX_WAIT
static String	MIN_IDLE
static String	POOL_PREPARED_STATEMENTS
static String	REMOVE_ABANDONED
static String	REMOVE_ABANDONED_TIMEOUT
static String	TEST_ON_BORROW
static String	TEST_ON_RETURN
static String	TEST_WHILE_IDLE
static String	TIME_BETWEEN_EVICTION_RUNS_MILLIS
static String	VALIDATION_QUERY

Constructor Summary

Constructors

Constructor	Description
ConnectionPoolUtil()

Method Summary

Modifier and Type	Method	Description
protected static String	buildPoolName(DatabaseMeta dbMeta, String partitionId)
static Connection	getConnection(LogChannelInterface log, DatabaseMeta dbMeta, String partitionId)	Deprecated. (Please use on init the step and then just get the connection when needed)
static DataSource	getDataSource(LogChannelInterface log, DatabaseMeta dbMeta, String partitionId)
static String	getDataSourceName(DatabaseMeta dbMeta, String partitionId)
static boolean	hasOldConfig(DatabaseMeta dbMeta, String partitionId)
static DataSource	removeDataSource(String name)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_AUTO_COMMIT

public static final String DEFAULT_AUTO_COMMIT

See Also:

Constant Field Values

DEFAULT_READ_ONLY

public static final String DEFAULT_READ_ONLY

See Also:

Constant Field Values

DEFAULT_TRANSACTION_ISOLATION

public static final String DEFAULT_TRANSACTION_ISOLATION

See Also:

Constant Field Values

DEFAULT_CATALOG

public static final String DEFAULT_CATALOG

See Also:

Constant Field Values

INITIAL_SIZE

public static final String INITIAL_SIZE

See Also:

Constant Field Values

MAX_ACTIVE

public static final String MAX_ACTIVE

See Also:

Constant Field Values

MAX_IDLE

public static final String MAX_IDLE

See Also:

Constant Field Values

MIN_IDLE

public static final String MIN_IDLE

See Also:

Constant Field Values

MAX_WAIT

public static final String MAX_WAIT

See Also:

Constant Field Values

VALIDATION_QUERY

public static final String VALIDATION_QUERY

See Also:

Constant Field Values

TEST_ON_BORROW

public static final String TEST_ON_BORROW

See Also:

Constant Field Values

TEST_ON_RETURN

public static final String TEST_ON_RETURN

See Also:

Constant Field Values

TEST_WHILE_IDLE

public static final String TEST_WHILE_IDLE

See Also:

Constant Field Values

TIME_BETWEEN_EVICTION_RUNS_MILLIS

public static final String TIME_BETWEEN_EVICTION_RUNS_MILLIS

See Also:

Constant Field Values

POOL_PREPARED_STATEMENTS

public static final String POOL_PREPARED_STATEMENTS

See Also:

Constant Field Values

MAX_OPEN_PREPARED_STATEMENTS

public static final String MAX_OPEN_PREPARED_STATEMENTS

See Also:

Constant Field Values

ACCESS_TO_UNDERLYING_CONNECTION_ALLOWED

public static final String ACCESS_TO_UNDERLYING_CONNECTION_ALLOWED

See Also:

Constant Field Values

REMOVE_ABANDONED

public static final String REMOVE_ABANDONED

See Also:

Constant Field Values

REMOVE_ABANDONED_TIMEOUT

public static final String REMOVE_ABANDONED_TIMEOUT

See Also:

Constant Field Values

LOG_ABANDONED

public static final String LOG_ABANDONED

See Also:

Constant Field Values

defaultInitialNrOfConnections

public static final int defaultInitialNrOfConnections

See Also:

Constant Field Values

defaultMaximumNrOfConnections

public static final int defaultMaximumNrOfConnections

See Also:

Constant Field Values

Constructor Detail

ConnectionPoolUtil

public ConnectionPoolUtil()

Method Detail

getDataSource

public static DataSource getDataSource(LogChannelInterface log,
                                       DatabaseMeta dbMeta,
                                       String partitionId)
                                throws KettleDatabaseException

Throws:

KettleDatabaseException

removeDataSource

public static DataSource removeDataSource(String name)

getConnection

@Deprecated
public static Connection getConnection(LogChannelInterface log,
                                       DatabaseMeta dbMeta,
                                       String partitionId)
                                throws Exception

Deprecated.

(Please use on init the step and then just get the connection when needed)

Throws:

Exception

getDataSourceName

public static String getDataSourceName(DatabaseMeta dbMeta,
                                       String partitionId)

buildPoolName

protected static String buildPoolName(DatabaseMeta dbMeta,
                                      String partitionId)

hasOldConfig

public static boolean hasOldConfig(DatabaseMeta dbMeta,
                                   String partitionId)