Package com.orientechnologies.orient.core.db

Class ODatabasePoolBase<DB extends ODatabaseInternal>

java.lang.Object

java.lang.Thread

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

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

ODatabaseDocumentPool, OObjectDatabasePool

public abstract class ODatabasePoolBase<DB extends ODatabaseInternal>
extends Thread

Database pool base class.

Author:

Luca Garulli (l.garulli--(at)--orientdb.com)

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected ODatabasePoolAbstract<DB>	dbPool
protected final String	url
protected final String	userName
protected final String	userPassword

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ODatabasePoolBase()
protected	ODatabasePoolBase(String iURL, String iUserName, String iUserPassword)

Method Summary

Modifier and Type	Method	Description
DB	acquire()	Acquires a connection from the pool using the configured URL, user-name and user-password.
DB	acquire(String iName, String iUserName, String iUserPassword)	Acquires a connection from the pool.
DB	acquire(String iName, String iUserName, String iUserPassword, Map<String,Object> iOptionalParams)	Acquires a connection from the pool specifying options.
void	close()	Closes the entire pool freeing all the connections.
protected abstract DB	createResource(Object owner, String iDatabaseName, Object... iAdditionalArgs)
int	getAvailableConnections(String name, String userName)	Returns amount of available connections which you can acquire for given source and user name.
int	getConnectionsInCurrentThread(String name, String userName)
int	getCreatedInstances(String name, String userName)
int	getMaxSize()	Returns the maximum size of the pool
Map<String,OReentrantResourcePool<String,DB>>	getPools()	Returns all the configured pools.
void	release(DB iDatabase)	Don't call it directly but use database.close().
void	remove(String iName, String iUser)	Removes a pool by name/user
void	run()
ODatabasePoolBase<DB>	setup()
ODatabasePoolBase<DB>	setup(int iMinSize, int iMaxSize)
ODatabasePoolBase<DB>	setup(int iMinSize, int iMaxSize, long idleTimeout, long timeBetweenEvictionRunsMillis)

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Details

url

protected final String url

userName

protected final String userName

userPassword

protected final String userPassword

dbPool

protected ODatabasePoolAbstract<DB extends ODatabaseInternal> dbPool

Constructor Details

ODatabasePoolBase

protected ODatabasePoolBase()

ODatabasePoolBase

protected ODatabasePoolBase(String iURL,
 String iUserName,
 String iUserPassword)

Method Details

setup

public ODatabasePoolBase<DB> setup()

setup

public ODatabasePoolBase<DB> setup(int iMinSize,
 int iMaxSize)

setup

public ODatabasePoolBase<DB> setup(int iMinSize,
 int iMaxSize,
 long idleTimeout,
 long timeBetweenEvictionRunsMillis)

acquire

public DB acquire()

Acquires a connection from the pool using the configured URL, user-name and user-password. If the pool is empty, then the caller thread will wait for it.

Returns:

A pooled database instance

acquire

public DB acquire(String iName,
 String iUserName,
 String iUserPassword)

Acquires a connection from the pool. If the pool is empty, then the caller thread will wait for it.

Parameters:

iName - Database name

iUserName - User name

iUserPassword - User password

Returns:

A pooled database instance

getAvailableConnections

public int getAvailableConnections(String name,
 String userName)

Returns amount of available connections which you can acquire for given source and user name. Source id is consist of "source name" and "source user name".

Parameters:

name - Source name.

userName - User name which is used to acquire source.

Returns:

amount of available connections which you can acquire for given source and user name.

getCreatedInstances

public int getCreatedInstances(String name,
 String userName)

acquire

public DB acquire(String iName,
 String iUserName,
 String iUserPassword,
 Map<String,Object> iOptionalParams)

Acquires a connection from the pool specifying options. If the pool is empty, then the caller thread will wait for it.

Parameters:

iName - Database name

iUserName - User name

iUserPassword - User password

Returns:

A pooled database instance

getConnectionsInCurrentThread

public int getConnectionsInCurrentThread(String name,
 String userName)

release

public void release(DB iDatabase)

Don't call it directly but use database.close().

Parameters:

iDatabase -

close

public void close()

Closes the entire pool freeing all the connections.

getMaxSize

public int getMaxSize()

Returns the maximum size of the pool

getPools

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

Returns all the configured pools.

remove

public void remove(String iName,
 String iUser)

Removes a pool by name/user

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

createResource

protected abstract DB createResource(Object owner,
 String iDatabaseName,
 Object... iAdditionalArgs)