com.orientechnologies.orient.core.db

Class ODatabasePoolAbstract<DB extends ODatabaseInternal>

java.lang.Object

com.orientechnologies.common.concur.lock.OAbstractLock

com.orientechnologies.common.concur.lock.OAdaptiveLock

com.orientechnologies.orient.core.db.ODatabasePoolAbstract<DB>

All Implemented Interfaces:

OLock, OResourcePoolListener<String,DB>, OOrientListener, OOrientShutdownListener

public abstract class ODatabasePoolAbstract<DB extends ODatabaseInternal>
extends OAdaptiveLock
implements OResourcePoolListener<String,DB>, OOrientListener

Field Summary

Fields

Modifier and Type	Field and Description
protected Object	owner

Constructor Summary

Constructors

Constructor and Description
ODatabasePoolAbstract(Object iOwner, int iMinSize, int iMaxSize)
ODatabasePoolAbstract(Object iOwner, int iMinSize, int iMaxSize, int iTimeout, long idleTimeoutMillis, long timeBetweenEvictionRunsMillis)
ODatabasePoolAbstract(Object iOwner, int iMinSize, int iMaxSize, long idleTimeout, long timeBetweenEvictionRunsMillis)

Method Summary

Modifier and Type	Method and Description
DB	acquire(String iURL, String iUserName, String iUserPassword)
DB	acquire(String iURL, String iUserName, String iUserPassword, Map<String,Object> iOptionalParams)
void	close() Closes all the databases.
int	getAvailableConnections(String url, String userName)
int	getConnectionsInCurrentThread(String url, String userName)
int	getCreatedInstances(String url, String userName)
int	getMaxConnections(String url, String userName)
int	getMaxSize()
Map<String,OReentrantResourcePool<String,DB>>	getPools()
void	onShutdown()
void	onStorageRegistered(OStorage iStorage)
void	onStorageUnregistered(OStorage iStorage) Removes from memory the pool associated to the closed storage.
void	release(DB iDatabase)
void	remove(String iPoolName)
void	remove(String iName, String iUser)

Methods inherited from class com.orientechnologies.common.concur.lock.OAdaptiveLock

getUnderlying, isConcurrent, isHeldByCurrentThread, lock, tryAcquireLock, tryAcquireLock, unlock

Methods inherited from class com.orientechnologies.common.concur.lock.OAbstractLock

callInLock

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.orientechnologies.common.concur.resource.OResourcePoolListener

createNewResource, reuseResource

Field Detail

owner

protected Object owner

Constructor Detail

ODatabasePoolAbstract

public ODatabasePoolAbstract(Object iOwner,
                             int iMinSize,
                             int iMaxSize)

ODatabasePoolAbstract

public ODatabasePoolAbstract(Object iOwner,
                             int iMinSize,
                             int iMaxSize,
                             long idleTimeout,
                             long timeBetweenEvictionRunsMillis)

ODatabasePoolAbstract

public ODatabasePoolAbstract(Object iOwner,
                             int iMinSize,
                             int iMaxSize,
                             int iTimeout,
                             long idleTimeoutMillis,
                             long timeBetweenEvictionRunsMillis)

Method Detail

acquire

public DB acquire(String iURL,
                  String iUserName,
                  String iUserPassword)
           throws OLockException

Throws:

OLockException

acquire

public DB acquire(String iURL,
                  String iUserName,
                  String iUserPassword,
                  Map<String,Object> iOptionalParams)
           throws OLockException

Throws:

OLockException

getMaxConnections

public int getMaxConnections(String url,
                             String userName)

getCreatedInstances

public int getCreatedInstances(String url,
                               String userName)

getAvailableConnections

public int getAvailableConnections(String url,
                                   String userName)

getConnectionsInCurrentThread

public int getConnectionsInCurrentThread(String url,
                                         String userName)

release

public void release(DB iDatabase)

getPools

public Map<String,OReentrantResourcePool<String,DB>> getPools()

close

public void close()

Closes all the databases.

Specified by:

close in interface OLock

Overrides:

close in class OAdaptiveLock

remove

public void remove(String iName,
                   String iUser)

remove

public void remove(String iPoolName)

getMaxSize

public int getMaxSize()

onStorageRegistered

public void onStorageRegistered(OStorage iStorage)

Specified by:

onStorageRegistered in interface OOrientListener

onStorageUnregistered

public void onStorageUnregistered(OStorage iStorage)

Removes from memory the pool associated to the closed storage. This avoids pool open against closed storages.

Specified by:

onStorageUnregistered in interface OOrientListener

onShutdown

public void onShutdown()

Specified by:

onShutdown in interface OOrientListener

Specified by:

onShutdown in interface OOrientShutdownListener