RepositoryConnectionPool (OpenAnzo 2.5 API)

Overview

Package

Class

Use

Tree

Deprecated

Index

Help

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

org.openanzo.server.repository.rdb
Class RepositoryConnectionPool

java.lang.Object
  org.openanzo.server.repository.rdb.RepositoryConnectionPool

All Implemented Interfaces:: IServerService, RepositoryConnectionPoolMBean

public class RepositoryConnectionPool
extends java.lang.Object
implements RepositoryConnectionPoolMBean, IServerService
extends java.lang.Object
implements RepositoryConnectionPoolMBean, IServerService

Manages a pool of RepositoryConnection objects. Database connections and SQL prepared statements are allocated for each RepositoryConnection according to the ModelServiceProperties.

Author:: Joe Betz

Constructor Summary
`RepositoryConnectionPool(java.util.Properties properties)` Create new ContainerConnectionPool

Method Summary
`RepositoryConnection`	`acquireRepositoryConnection(int type)` Get a repositoryConnection from the pool
`void`	`clearNodeCaches()` Clear the caches in all connections
`void`	`close()` Close the service
`int`	`decrementUsageCount()` Decrement the usage count for the pool
`CacheProvider`	`getCacheProvider()`
`java.lang.String`	`getDatabaseDriver()` Get the database driver's class name
`java.lang.String`	`getDatabasePassword()` Get the password for the database connection
`java.lang.String`	`getDatabaseType()` Get the type of database connection
`java.lang.String`	`getDatabaseUrl()` Get the database JDBC URL
`java.lang.String`	`getDatabaseUserName()` Get the username for the database connection
`boolean`	`getIsStarted()` Determine if the service is started
`int`	`getQueryConnectionInactiveSize()` Get the number of inactive connections in the QUERY connection pool
`int`	`getQueryConnectionInUseSize()` Get the number of connections currently in-use from the QUERY connection pool
`int`	`getQueryConnectionMaxPoolSize()` Get the max size of the QUERY connection pool
`int`	`getQueryConnectionPoolMaxIdle()` Get the max number of idle connections in the QUERY connection pool
`long`	`getQueryConnectionPoolMaxWaitTime()` Get max time to wait for a connection from the QUERY connection pool
`long`	`getQueryConnectionPoolMinIdleTime()` Get minimum time to wait before an idle connection from the QUERY connection pool is destroyed
`int`	`getReadConnectionInactiveSize()` Get the number of inactive connections in the READ connection pool
`int`	`getReadConnectionInUseSize()` Get the number of connections currently in-use from the READ connection pool
`int`	`getReadConnectionMaxPoolSize()` Get the max size of the READ connection pool
`int`	`getReadConnectionPoolMaxIdle()` Get the max number of idle connections in the READ connection pool
`long`	`getReadConnectionPoolMaxWaitTime()` Get max time to wait for a connection from the READ connection pool
`long`	`getReadConnectionPoolMinIdleTime()` Get minimum time to wait before an idle connection from the READ connection pool is destroyed
`int`	`getUsageCount()` Get the current usage count
`int`	`getWriteConnectionInactiveSize()` Get the number of inactive connections in the WRITE connection pool
`int`	`getWriteConnectionInUseSize()` Get the number of connections currently in-use from the WRITE connection pool
`int`	`getWriteConnectionMaxPoolSize()` Get the max size of the WRITE connection pool
`int`	`getWriteConnectionPoolMaxIdle()` Get the max number of idle connections in the WRITE connection pool
`long`	`getWriteConnectionPoolMaxWaitTime()` Get max time to wait for a connection from the WRITE connection pool
`long`	`getWriteConnectionPoolMinIdleTime()` Get minimum time to wait before an idle connection from the WRITE connection pool is destroyed
`int`	`incrementUsageCount()` Increment the usage count for the pool
`void`	`prepareReleaseRepositoryConnections(int connectionsToPrepare)` Acquire and release a number of rw and ro connection
`void`	`purgeAndReset()` Function to purge all connections in pool, and restart using current configuration values
`void`	`registerMBean(javax.management.MBeanServer mbs, javax.management.ObjectName parentObjectName)` Register the service with the server's jmx server
`void`	`registerResetListener(IResetListener listener)` Register IResetListener with ContainerConnectionPool
`void`	`releaseRepositoryConnection(RepositoryConnection connection)` Release a repositoryConnection from the pool
`void`	`reset(java.lang.Long id)` Notify all listeners about a database reset
`void`	`setDatabaseDriver(java.lang.String dbDriver)` Set the database driver's class name
`void`	`setDatabasePassword(java.lang.String password)` Set the password for the database connection
`void`	`setDatabaseType(java.lang.String dbType)` Set the type of database connection
`void`	`setDatabaseUrl(java.lang.String jdbcUrl)` Set the database JDBC URL
`void`	`setDatabaseUserName(java.lang.String userName)` Set the username for the database connection
`void`	`setLiteralIndexer(LiteralIndexer literalIndexer)` Set the literal index which this pool of connections can use
`void`	`setQueryConnectionMaxPoolSize(int size)` Set the max size of the QUERY connection pool
`void`	`setQueryConnectionPoolMaxIdle(int max)` Set the max number of idle connections in the QUERY connection pool
`void`	`setQueryConnectionPoolMaxWaitTime(long maxWait)` Get set the max time to wait for a connection from the QUERY connection pool
`void`	`setQueryConnectionPoolMinIdleTime(long minWait)` Set minimum time to wait before an idle connection from the QUERY connection pool is destroyed
`void`	`setReadConnectionMaxPoolSize(int size)` Set the max size of the READ connection pool
`void`	`setReadConnectionPoolMaxIdle(int max)` Set the max number of idle connections in the READ connection pool
`void`	`setReadConnectionPoolMaxWaitTime(long maxWait)` Get set the max time to wait for a connection from the READ connection pool
`void`	`setReadConnectionPoolMinIdleTime(long minWait)` Set minimum time to wait before an idle connection from the READ connection pool is destroyed
`void`	`setWriteConnectionMaxPoolSize(int size)` Set the max size of the WRITE connection pool
`void`	`setWriteConnectionPoolMaxIdle(int max)` Set the max number of idle connections in the WRITE connection pool
`void`	`setWriteConnectionPoolMaxWaitTime(long maxWait)` Get set the max time to wait for a connection from the WRITE connection pool
`void`	`setWriteConnectionPoolMinIdleTime(long minWait)` Set minimum time to wait before an idle connection from the WRITE connection pool is destroyed
`void`	`start()` Start the service
`void`	`stop()` Stop the service
`void`	`unregisterResetListener(IResetListener listener)` Unregister IResetListener from ContainerConnectionPool

Methods inherited from class java.lang.Object
`equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

Constructor Detail

RepositoryConnectionPool

public RepositoryConnectionPool(java.util.Properties properties)

Create new ContainerConnectionPool

Parameters:: properties - Configuration properties

Method Detail

setLiteralIndexer

public void setLiteralIndexer(LiteralIndexer literalIndexer)

Set the literal index which this pool of connections can use

Parameters:: literalIndexer -

start

public void start()
           throws AnzoException

Description copied from interface: IServerService

Start the service

Specified by:: start in interface IServerService

Throws:: AnzoException

getIsStarted

public boolean getIsStarted()
                     throws AnzoException

Description copied from interface: IServerService

Determine if the service is started

Specified by:: getIsStarted in interface IServerService

Returns:: true if the service is started
Throws:: AnzoException

stop

public void stop()

Description copied from interface: IServerService

Stop the service

Specified by:: stop in interface IServerService

registerMBean

public void registerMBean(javax.management.MBeanServer mbs,
                          javax.management.ObjectName parentObjectName)

Description copied from interface: IServerService

Specified by:: registerMBean in interface IServerService

Parameters:: mbs - the jmx server; parentObjectName - the name under which this object will be registered

clearNodeCaches

public void clearNodeCaches()

Clear the caches in all connections

reset

public void reset(java.lang.Long id)

Notify all listeners about a database reset

Parameters:: id - of server being reset

prepareReleaseRepositoryConnections

public void prepareReleaseRepositoryConnections(int connectionsToPrepare)
                                         throws AnzoException

Acquire and release a number of rw and ro connection

Parameters:: connectionsToPrepare - Number of connections to prepare and release
Throws:: AnzoException

acquireRepositoryConnection

public RepositoryConnection acquireRepositoryConnection(int type)
                                                 throws AnzoException

Get a repositoryConnection from the pool

Parameters:: type - Type of RepositoryConnection to acquire
Returns:: a repositoryConnection from the pool
Throws:: AnzoException

releaseRepositoryConnection

public void releaseRepositoryConnection(RepositoryConnection connection)

Release a repositoryConnection from the pool

Parameters:: connection - RepositoryConnection to release

registerResetListener

public void registerResetListener(IResetListener listener)

Parameters:: listener - Listener to register

unregisterResetListener

public void unregisterResetListener(IResetListener listener)

Unregister IResetListener from ContainerConnectionPool

Parameters:: listener - Listener to unregister

incrementUsageCount

public int incrementUsageCount()

Increment the usage count for the pool

Returns:: incremented usage count

decrementUsageCount

public int decrementUsageCount()

Decrement the usage count for the pool

Returns:: decremented usage count

getUsageCount

public int getUsageCount()

Get the current usage count

Returns:: the current usage count

close

public void close()

Description copied from interface: IServerService

Close the service

Specified by:: close in interface IServerService