weblogic.jdbc.common.internal

Class ConnectionPoolManager

java.lang.Object

weblogic.jdbc.common.internal.ConnectionPoolManager

All Implemented Interfaces:

java.rmi.Remote, weblogic.common.resourcepool.ObjectLifeCycle

public final class ConnectionPoolManager
extends java.lang.Object
implements weblogic.common.resourcepool.ObjectLifeCycle, java.rmi.Remote

Field Summary

Fields

Modifier and Type	Field and Description
private AuthorizationManager	am
private static java.util.HashMap	cpList
private static java.util.HashMap	hacpList
private static weblogic.security.acl.internal.AuthenticatedSubject	KERNELID
private static java.lang.Object	lockObject
private static java.util.HashMap	mpList

Constructor Summary

Constructors

Constructor and Description
ConnectionPoolManager()

Method Summary

Modifier and Type	Method and Description
private static void	addPool(java.util.HashMap poolList, java.lang.String poolName, java.lang.String appName, java.lang.String moduleName, java.lang.String compName, java.lang.Object pool)
static void	addPool(java.lang.String poolName, java.lang.String appName, java.lang.String moduleName, java.lang.String compName, JDBCConnectionPool pool) Add the specified pool to the list of pools.
private static void	checkAndRemoveUnpooledConnection(ConnectionEnv cc, JDBCConnectionPool cp) Checks whether the datasource is configured to disable-pooling.
java.lang.Object	createAndStartPool(JDBCDataSourceBean dsBean, java.lang.String appName, java.lang.String moduleName, java.lang.String compName)
java.lang.Object	createAndStartPool(JDBCDataSourceBean dsBean, java.lang.String appName, java.lang.String moduleName, java.lang.String compName, boolean isMemberDS, boolean isMemberLLR)
java.lang.Object	createAndStartPool(JDBCDataSourceBean dsBean, java.lang.String appName, java.lang.String moduleName, java.lang.String compName, java.lang.ClassLoader classLoader)
java.lang.Object	createAndStartPool(JDBCDataSourceBean dsBean, java.lang.String appName, java.lang.String moduleName, java.lang.String compName, java.lang.ClassLoader classLoader, boolean isMemberDS, boolean isMemberLLR)
void	forceSuspend(boolean shuttingDown)
static java.util.Iterator	getConnectionPools() Returns all the connection pools known to this manager.
static JDBCConnectionPool[]	getConnectionPools(java.lang.String poolName, java.lang.String appName, java.lang.String moduleName, java.lang.String compName) Return the conn pools matching the name specified.
static JDBCConnectionPool	getHAPool(java.lang.String poolName, java.lang.String appName, java.lang.String moduleName, java.lang.String compName)
private static weblogic.security.acl.internal.AuthenticatedSubject	getKernelID()
static java.lang.Object	getLockObject()
static MultiPool	getMultiPool(java.lang.String poolName, java.lang.String applicationName, java.lang.String moduleName, java.lang.String compName)
static java.util.Iterator	getMultiPools() Returns all the multipools known to this manager.
private static java.lang.Object	getPool(java.util.HashMap poolList, java.lang.String poolName, java.lang.String appName, java.lang.String moduleName, java.lang.String compName)
static JDBCConnectionPool	getPool(java.lang.String poolName) Return the specified Connection Pool
static JDBCConnectionPool	getPool(java.lang.String poolName, java.lang.String appName, java.lang.String moduleName, java.lang.String compName)
private static java.util.Collection	getPools(java.util.HashMap poolList)
private static boolean	poolExists(java.util.HashMap poolList, java.lang.String poolName, java.lang.String appName, java.lang.String moduleName, java.lang.String compName)
static boolean	poolExists(java.lang.String poolName, java.lang.String appName, java.lang.String moduleName, java.lang.String compName) Check if the specified Multi Pool or Connection Pool exists
static void	release(ConnectionEnv cc) Release the resource back to the pool
private static java.lang.Object	removePool(java.util.HashMap poolList, java.lang.String poolName, java.lang.String appName, java.lang.String moduleName, java.lang.String compName)
static JDBCConnectionPool	removePool(java.lang.String poolName, java.lang.String appName, java.lang.String moduleName, java.lang.String compName) Remove the specified pool from the list of pools.
static ConnectionEnv	reserve(weblogic.security.acl.internal.AuthenticatedSubject user, java.lang.String poolName, java.lang.String appName, java.lang.String moduleName, java.lang.String compName)
static ConnectionEnv	reserve(weblogic.security.acl.internal.AuthenticatedSubject user, java.lang.String poolName, java.lang.String appName, java.lang.String moduleName, java.lang.String compName, int waitSeconds) Reserve a resource from the specified pool and application.
static ConnectionEnv	reserve(weblogic.security.acl.internal.AuthenticatedSubject user, java.lang.String poolName, java.lang.String appName, java.lang.String moduleName, java.lang.String compName, int waitSeconds, java.util.Properties requestedLabels)
static ConnectionEnv	reserve(weblogic.security.acl.internal.AuthenticatedSubject user, java.lang.String poolName, java.lang.String appName, java.lang.String moduleName, java.lang.String compName, int waitSeconds, java.util.Properties requestedLabels, java.lang.String username, java.lang.String password)
static ConnectionEnv	reserve(weblogic.security.acl.internal.AuthenticatedSubject user, java.lang.String poolName, java.lang.String appName, java.lang.String moduleName, java.lang.String compName, java.util.Properties labels)
static ConnectionEnv	reserve(weblogic.security.acl.internal.AuthenticatedSubject user, java.lang.String poolName, java.lang.String appName, java.lang.String moduleName, java.lang.String compName, java.util.Properties labels, java.lang.String username, java.lang.String password)
static ConnectionEnv	reserve(java.lang.String poolName, java.lang.String appName, java.lang.String moduleName, java.lang.String compName, int waitSeconds)
static ConnectionEnv	reserve(java.lang.String poolName, java.lang.String appName, java.lang.String moduleName, java.lang.String compName, int waitSeconds, java.util.Properties requestedLabels)
static ConnectionEnv	reserve(java.lang.String poolName, java.lang.String appName, java.lang.String moduleName, java.lang.String compName, int waitSeconds, java.util.Properties requestedLabels, java.lang.String username, java.lang.String password)
void	resume()
static void	setDataSource(java.lang.String poolName, java.lang.String applicationName, java.lang.String moduleName, java.lang.String compName, weblogic.jdbc.jta.DataSource ds)
void	shutdown()
void	shutdownAndDestroyPool(JDBCDataSourceBean dsBean, java.lang.String appName, java.lang.String moduleName, java.lang.String compName)
void	shutdownAndDestroyPool(java.lang.String poolName, java.lang.String appName, java.lang.String moduleName, java.lang.String compName)
private void	shutdownAndRemoveConnectionPool(JDBCConnectionPool cp)
private void	shutdownConnectionPool(java.lang.String name, java.lang.String appName, java.lang.String moduleName, java.lang.String compName)
private void	shutdownMultiPool(java.lang.String name, java.lang.String appName, java.lang.String moduleName, java.lang.String compName)
void	start(java.lang.Object unused)
void	suspend(boolean shuttingDown)
private void	validateSharedPoolConfiguration(JDBCDataSourceBean dsBean1, JDBCDataSourceBean dsBean2)
private void	validateStaticSharedPoolConfiguration(JDBCDataSourceBean sharingBean, JDBCDataSourceBean sharedBean)

Methods inherited from class java.lang.Object

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

Field Detail

cpList

private static java.util.HashMap cpList

mpList

private static java.util.HashMap mpList

hacpList

private static java.util.HashMap hacpList

lockObject

private static java.lang.Object lockObject

am

private AuthorizationManager am

KERNELID

private static final weblogic.security.acl.internal.AuthenticatedSubject KERNELID

Constructor Detail

ConnectionPoolManager

public ConnectionPoolManager()

Method Detail

getKernelID

private static weblogic.security.acl.internal.AuthenticatedSubject getKernelID()

reserve

public static ConnectionEnv reserve(java.lang.String poolName,
                                    java.lang.String appName,
                                    java.lang.String moduleName,
                                    java.lang.String compName,
                                    int waitSeconds)
                             throws ResourceException,
                                    java.sql.SQLException

Throws:

ResourceException

java.sql.SQLException

reserve

public static ConnectionEnv reserve(java.lang.String poolName,
                                    java.lang.String appName,
                                    java.lang.String moduleName,
                                    java.lang.String compName,
                                    int waitSeconds,
                                    java.util.Properties requestedLabels)
                             throws ResourceException,
                                    java.sql.SQLException

Throws:

ResourceException

java.sql.SQLException

reserve

public static ConnectionEnv reserve(java.lang.String poolName,
                                    java.lang.String appName,
                                    java.lang.String moduleName,
                                    java.lang.String compName,
                                    int waitSeconds,
                                    java.util.Properties requestedLabels,
                                    java.lang.String username,
                                    java.lang.String password)
                             throws ResourceException,
                                    java.sql.SQLException

Throws:

ResourceException

java.sql.SQLException

reserve

public static ConnectionEnv reserve(weblogic.security.acl.internal.AuthenticatedSubject user,
                                    java.lang.String poolName,
                                    java.lang.String appName,
                                    java.lang.String moduleName,
                                    java.lang.String compName,
                                    int waitSeconds)
                             throws ResourceException,
                                    java.sql.SQLException

Reserve a resource from the specified pool and application.

Parameters:

user -

poolName, - cannot be null

appName - name of application

moduleName - name of application module

compName - name of application component

waitSeconds - -1 : don't wait (non-blocking) >0 : wait for specified # seconds (blocking with timeout) 0 : wait for ever (blocking)

Throws:

ResourceException - if "poolName" is null

java.sql.SQLException

reserve

public static ConnectionEnv reserve(weblogic.security.acl.internal.AuthenticatedSubject user,
                                    java.lang.String poolName,
                                    java.lang.String appName,
                                    java.lang.String moduleName,
                                    java.lang.String compName,
                                    int waitSeconds,
                                    java.util.Properties requestedLabels)
                             throws ResourceException,
                                    java.sql.SQLException

Throws:

ResourceException

java.sql.SQLException

reserve

public static ConnectionEnv reserve(weblogic.security.acl.internal.AuthenticatedSubject user,
                                    java.lang.String poolName,
                                    java.lang.String appName,
                                    java.lang.String moduleName,
                                    java.lang.String compName,
                                    int waitSeconds,
                                    java.util.Properties requestedLabels,
                                    java.lang.String username,
                                    java.lang.String password)
                             throws ResourceException,
                                    java.sql.SQLException

Throws:

ResourceException

java.sql.SQLException

reserve

public static ConnectionEnv reserve(weblogic.security.acl.internal.AuthenticatedSubject user,
                                    java.lang.String poolName,
                                    java.lang.String appName,
                                    java.lang.String moduleName,
                                    java.lang.String compName)
                             throws ResourceException,
                                    java.sql.SQLException

Throws:

ResourceException

java.sql.SQLException

reserve

public static ConnectionEnv reserve(weblogic.security.acl.internal.AuthenticatedSubject user,
                                    java.lang.String poolName,
                                    java.lang.String appName,
                                    java.lang.String moduleName,
                                    java.lang.String compName,
                                    java.util.Properties labels)
                             throws ResourceException,
                                    java.sql.SQLException

Throws:

ResourceException

java.sql.SQLException

reserve

public static ConnectionEnv reserve(weblogic.security.acl.internal.AuthenticatedSubject user,
                                    java.lang.String poolName,
                                    java.lang.String appName,
                                    java.lang.String moduleName,
                                    java.lang.String compName,
                                    java.util.Properties labels,
                                    java.lang.String username,
                                    java.lang.String password)
                             throws ResourceException,
                                    java.sql.SQLException

Throws:

ResourceException

java.sql.SQLException

release

public static void release(ConnectionEnv cc)
                    throws ResourceException

Release the resource back to the pool

Parameters:

resource - to be released

Throws:

ResourceException - if "resource" is null

checkAndRemoveUnpooledConnection

private static void checkAndRemoveUnpooledConnection(ConnectionEnv cc,
                                                     JDBCConnectionPool cp)

Checks whether the datasource is configured to disable-pooling.
If configured, destroy the connnection.
This is useful in the case of "proxy-datasources" where they are not supposed to pool connections from various underlying datasources

getConnectionPools

public static java.util.Iterator getConnectionPools()

Returns all the connection pools known to this manager.

getMultiPools

public static java.util.Iterator getMultiPools()

Returns all the multipools known to this manager.

getLockObject

public static java.lang.Object getLockObject()

getConnectionPools

public static JDBCConnectionPool[] getConnectionPools(java.lang.String poolName,
                                                      java.lang.String appName,
                                                      java.lang.String moduleName,
                                                      java.lang.String compName)
                                               throws ResourceException

Return the conn pools matching the name specified. If 'poolName' is a conn pool, array will contain just one index. if 'poolName' is a MultiPool, array will contain all the conn pools underlying that MP.

Parameters:

poolName, - cannot be null

appName -

Throws:

ResourceException - if "poolName" is null or pool(s) not found.

getMultiPool

public static MultiPool getMultiPool(java.lang.String poolName,
                                     java.lang.String applicationName,
                                     java.lang.String moduleName,
                                     java.lang.String compName)
                              throws ResourceException

Throws:

ResourceException

getPool

public static JDBCConnectionPool getPool(java.lang.String poolName)
                                  throws ResourceException

Return the specified Connection Pool

Parameters:

poolName, - cannot be null

Throws:

ResourceException - if "poolName" is null

getPool

public static JDBCConnectionPool getPool(java.lang.String poolName,
                                         java.lang.String appName,
                                         java.lang.String moduleName,
                                         java.lang.String compName)
                                  throws ResourceException

Throws:

ResourceException

getHAPool

public static JDBCConnectionPool getHAPool(java.lang.String poolName,
                                           java.lang.String appName,
                                           java.lang.String moduleName,
                                           java.lang.String compName)
                                    throws ResourceException

Throws:

ResourceException

poolExists

public static boolean poolExists(java.lang.String poolName,
                                 java.lang.String appName,
                                 java.lang.String moduleName,
                                 java.lang.String compName)
                          throws ResourceException

Check if the specified Multi Pool or Connection Pool exists

Parameters:

poolName, - cannot be null

appName -

moduleName -

compName -

Throws:

ResourceException - if "poolName" is null

addPool

public static void addPool(java.lang.String poolName,
                           java.lang.String appName,
                           java.lang.String moduleName,
                           java.lang.String compName,
                           JDBCConnectionPool pool)
                    throws ResourceException

Add the specified pool to the list of pools.

Parameters:

poolName, - cannot be null

appName -

moduleName -

compName -

pool - pool to add to list

Throws:

ResourceException - if "poolName" is null

removePool

public static JDBCConnectionPool removePool(java.lang.String poolName,
                                            java.lang.String appName,
                                            java.lang.String moduleName,
                                            java.lang.String compName)
                                     throws ResourceException

Remove the specified pool from the list of pools.

Parameters:

poolName, - cannot be null

appName -

moduleName -

compName -

Throws:

ResourceException - if "poolName" is null

start

public void start(java.lang.Object unused)
           throws ResourceException

Specified by:

start in interface weblogic.common.resourcepool.ObjectLifeCycle

Throws:

ResourceException

resume

public void resume()
            throws ResourceException

Specified by:

resume in interface weblogic.common.resourcepool.ObjectLifeCycle

Throws:

ResourceException

suspend

public void suspend(boolean shuttingDown)
             throws ResourceException

Specified by:

suspend in interface weblogic.common.resourcepool.ObjectLifeCycle

Throws:

ResourceException

forceSuspend

public void forceSuspend(boolean shuttingDown)
                  throws ResourceException

Specified by:

forceSuspend in interface weblogic.common.resourcepool.ObjectLifeCycle

Throws:

ResourceException

shutdown

public void shutdown()
              throws ResourceException

Specified by:

shutdown in interface weblogic.common.resourcepool.ObjectLifeCycle

Throws:

ResourceException

createAndStartPool

public java.lang.Object createAndStartPool(JDBCDataSourceBean dsBean,
                                           java.lang.String appName,
                                           java.lang.String moduleName,
                                           java.lang.String compName)
                                    throws ResourceException

Throws:

ResourceException

createAndStartPool

public java.lang.Object createAndStartPool(JDBCDataSourceBean dsBean,
                                           java.lang.String appName,
                                           java.lang.String moduleName,
                                           java.lang.String compName,
                                           java.lang.ClassLoader classLoader)
                                    throws ResourceException

Throws:

ResourceException

createAndStartPool

public java.lang.Object createAndStartPool(JDBCDataSourceBean dsBean,
                                           java.lang.String appName,
                                           java.lang.String moduleName,
                                           java.lang.String compName,
                                           boolean isMemberDS,
                                           boolean isMemberLLR)
                                    throws ResourceException

Throws:

ResourceException

createAndStartPool

public java.lang.Object createAndStartPool(JDBCDataSourceBean dsBean,
                                           java.lang.String appName,
                                           java.lang.String moduleName,
                                           java.lang.String compName,
                                           java.lang.ClassLoader classLoader,
                                           boolean isMemberDS,
                                           boolean isMemberLLR)
                                    throws ResourceException

Throws:

ResourceException

shutdownAndDestroyPool

public void shutdownAndDestroyPool(JDBCDataSourceBean dsBean,
                                   java.lang.String appName,
                                   java.lang.String moduleName,
                                   java.lang.String compName)
                            throws ResourceException

Throws:

ResourceException

shutdownAndDestroyPool

public void shutdownAndDestroyPool(java.lang.String poolName,
                                   java.lang.String appName,
                                   java.lang.String moduleName,
                                   java.lang.String compName)
                            throws ResourceException

Throws:

ResourceException

shutdownMultiPool

private void shutdownMultiPool(java.lang.String name,
                               java.lang.String appName,
                               java.lang.String moduleName,
                               java.lang.String compName)
                        throws ResourceException

Throws:

ResourceException

shutdownConnectionPool

private void shutdownConnectionPool(java.lang.String name,
                                    java.lang.String appName,
                                    java.lang.String moduleName,
                                    java.lang.String compName)
                             throws ResourceException

Throws:

ResourceException

shutdownAndRemoveConnectionPool

private void shutdownAndRemoveConnectionPool(JDBCConnectionPool cp)
                                      throws ResourceException

Throws:

ResourceException

addPool

private static void addPool(java.util.HashMap poolList,
                            java.lang.String poolName,
                            java.lang.String appName,
                            java.lang.String moduleName,
                            java.lang.String compName,
                            java.lang.Object pool)
                     throws ResourceException

Throws:

ResourceException

removePool

private static java.lang.Object removePool(java.util.HashMap poolList,
                                           java.lang.String poolName,
                                           java.lang.String appName,
                                           java.lang.String moduleName,
                                           java.lang.String compName)
                                    throws ResourceException

Throws:

ResourceException

getPool

private static java.lang.Object getPool(java.util.HashMap poolList,
                                        java.lang.String poolName,
                                        java.lang.String appName,
                                        java.lang.String moduleName,
                                        java.lang.String compName)
                                 throws ResourceException

Throws:

ResourceException

poolExists

private static boolean poolExists(java.util.HashMap poolList,
                                  java.lang.String poolName,
                                  java.lang.String appName,
                                  java.lang.String moduleName,
                                  java.lang.String compName)
                           throws ResourceException

Throws:

ResourceException

getPools

private static java.util.Collection getPools(java.util.HashMap poolList)

setDataSource

public static void setDataSource(java.lang.String poolName,
                                 java.lang.String applicationName,
                                 java.lang.String moduleName,
                                 java.lang.String compName,
                                 weblogic.jdbc.jta.DataSource ds)
                          throws ResourceException

Throws:

ResourceException

validateStaticSharedPoolConfiguration

private void validateStaticSharedPoolConfiguration(JDBCDataSourceBean sharingBean,
                                                   JDBCDataSourceBean sharedBean)
                                            throws ResourceException

Throws:

ResourceException

validateSharedPoolConfiguration

private void validateSharedPoolConfiguration(JDBCDataSourceBean dsBean1,
                                             JDBCDataSourceBean dsBean2)
                                      throws ResourceException

Throws:

ResourceException