ru.bgcrm.util.sql

Class ConnectionPool

java.lang.Object

ru.bgcrm.util.sql.ConnectionPool

public class ConnectionPool
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static int	RETURN_FAKE
static int	RETURN_MASTER
static int	RETURN_NULL
static int	RETURN_SLAVE

Constructor Summary

Constructors

Constructor and Description
ConnectionPool(java.lang.String name, ParameterMap prefs)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	compareAndSetReplicationNotBehindMaster(java.lang.String slaveId, boolean expected, boolean update)
ConnectionSet	getConnectionSet()
ConnectionSet	getConnectionSet(boolean autoCommit)
javax.sql.DataSource	getDataSource()
java.sql.Connection	getDBConnectionFromPool() Возвращает соединение с Master БД из пула.
java.sql.Connection	getDBSlaveConnectionFromPool() Возвращает соединение с Slave БД из пула.
java.sql.Connection	getDBSlaveConnectionFromPool(java.sql.Connection master) Возвращает соединение с Slave БД из пула.
java.sql.Connection	getDBTrashConnectionFromPool(java.lang.String tableName, int retType) Возвращает соединение с мусорной БД если она описана для таблицы в конфиге либо в зависимости от retType.
java.sql.Connection	getDBTrashOrMasterConnectionFromPool(java.lang.String tableName) Возвращение соединения к выделенной "мусорной" либо Master-базе (если треш-база не найдена).
java.sql.Connection	getDBTrashOrSlaveConnectionFromPool(java.lang.String tableName) Возвращение соединения к выделенной "мусорной" либо Slave-базе
int	getMasterActive()
int	getMasterIdle()
int	getMasterMaxActive()
int	getMasterMaxIdle()
float	getMasterPoolLoad() Возвращает отношение числа активных соединений к максимально разрешённому числу соединений Мастер - БД.
java.lang.String	getPoolStackTrace()
java.lang.String	getPoolStatus() Отчет по статусу пулов соединений
int	getSlaveActive(java.lang.String slaveId)
java.util.Set<java.lang.String>	getSlaveBaseId() Возвращает идентификаторы slave баз.
java.sql.Connection	getSlaveConnectionFromPool(java.lang.String poolId) Возвращает соединение с slave базой.
javax.sql.DataSource	getSlaveDataSource()
int	getSlaveIdle(java.lang.String slaveId)
int	getSlaveMaxActive(java.lang.String slaveId)
int	getSlaveMaxIdle(java.lang.String slaveId)
java.util.Set<java.lang.String>	getTrashBaseId() Возвращает идентификаторы trash баз.
java.sql.Connection	getTrashConnectionFromPool(java.lang.String poolId) Возвращает соединение с trash базой.
boolean	isReplicationAvailable(java.lang.String slaveId) Проверяет доступность Slave базы
boolean	isReplicationNotBehindMaster(java.lang.String slaveId) Проверяет есть ли отставание Slave базы
void	setReplicationAvailable(java.lang.String slaveId, boolean available) Установка/Отключение доступности Slave базы
void	setReplicationNotBehindMaster(java.lang.String slaveId, boolean isNotBehind) Включение/Отключение флага отставания Slave базы

Methods inherited from class java.lang.Object

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

Field Detail

RETURN_NULL

public static final int RETURN_NULL

See Also:

Constant Field Values

RETURN_FAKE

public static final int RETURN_FAKE

See Also:

Constant Field Values

RETURN_SLAVE

public static final int RETURN_SLAVE

See Also:

Constant Field Values

RETURN_MASTER

public static final int RETURN_MASTER

See Also:

Constant Field Values

Constructor Detail

ConnectionPool

public ConnectionPool(java.lang.String name,
                      ParameterMap prefs)

Method Detail

getDataSource

public javax.sql.DataSource getDataSource()

getConnectionSet

public ConnectionSet getConnectionSet()

getConnectionSet

public ConnectionSet getConnectionSet(boolean autoCommit)

close

public void close()

getDBConnectionFromPool

public final java.sql.Connection getDBConnectionFromPool()

Возвращает соединение с Master БД из пула.

Returns:

соединение с Master БД либо null в случае недоступности.

getSlaveDataSource

public final javax.sql.DataSource getSlaveDataSource()

getDBSlaveConnectionFromPool

public final java.sql.Connection getDBSlaveConnectionFromPool()

Возвращает соединение с Slave БД из пула. Если Slave БД не определены в конфигурации - возвращает из Master пула.

Returns:

getDBSlaveConnectionFromPool

public final java.sql.Connection getDBSlaveConnectionFromPool(java.sql.Connection master)

Возвращает соединение с Slave БД из пула. Если Slave БД не определены в конфигурации - возвращает из Master пула.

Parameters:

masterOnNull - если false то при отсутсвии slave баз вернет null.

Returns:

getDBTrashConnectionFromPool

public final java.sql.Connection getDBTrashConnectionFromPool(java.lang.String tableName,
                                                              int retType)

Возвращает соединение с мусорной БД если она описана для таблицы в конфиге либо в зависимости от retType.

Parameters:

tableName - имя таблицы.

retType - RETURN_FAKE, RETURN_SLAVE либо RETURN_MASTER.

Returns:

если не указана конфигурация мусорной БД может быть возвращен коннект к мастер БД, фейковый коннект либо коннект Slave БД.

getDBTrashOrMasterConnectionFromPool

public final java.sql.Connection getDBTrashOrMasterConnectionFromPool(java.lang.String tableName)

Возвращение соединения к выделенной "мусорной" либо Master-базе (если треш-база не найдена).

Parameters:

tableName -

Returns:

getDBTrashOrSlaveConnectionFromPool

public final java.sql.Connection getDBTrashOrSlaveConnectionFromPool(java.lang.String tableName)

Возвращение соединения к выделенной "мусорной" либо Slave-базе

Parameters:

tableName -

Returns:

getSlaveConnectionFromPool

public final java.sql.Connection getSlaveConnectionFromPool(java.lang.String poolId)

Возвращает соединение с slave базой. если неверная база то null со всем вытекающим, так как применяется только при принудительном выборе базы в некоторых специфичных служебных случаях.

Parameters:

poolId - - ид базы

Returns:

коннекшен

getSlaveBaseId

public final java.util.Set<java.lang.String> getSlaveBaseId()

Возвращает идентификаторы slave баз.

Returns:

getTrashBaseId

public final java.util.Set<java.lang.String> getTrashBaseId()

Возвращает идентификаторы trash баз.

Returns:

getTrashConnectionFromPool

public final java.sql.Connection getTrashConnectionFromPool(java.lang.String poolId)

Возвращает соединение с trash базой. если неверная база то null со всем вытекающим, так как применяется только при принудительном выборе базы в некоторых специфичных служебных случаях.

Parameters:

poolId - - ид базы

Returns:

коннекшен

getPoolStatus

public java.lang.String getPoolStatus()

Отчет по статусу пулов соединений

Returns:

getMasterActive

public int getMasterActive()

getMasterMaxActive

public int getMasterMaxActive()

getMasterIdle

public int getMasterIdle()

getMasterMaxIdle

public int getMasterMaxIdle()

getSlaveActive

public int getSlaveActive(java.lang.String slaveId)

getSlaveMaxActive

public int getSlaveMaxActive(java.lang.String slaveId)

getSlaveIdle

public int getSlaveIdle(java.lang.String slaveId)

getSlaveMaxIdle

public int getSlaveMaxIdle(java.lang.String slaveId)

getMasterPoolLoad

public float getMasterPoolLoad()

Возвращает отношение числа активных соединений к максимально разрешённому числу соединений Мастер - БД.

Returns:

getPoolStackTrace

public java.lang.String getPoolStackTrace()

setReplicationNotBehindMaster

public void setReplicationNotBehindMaster(java.lang.String slaveId,
                                          boolean isNotBehind)

Включение/Отключение флага отставания Slave базы

Parameters:

slaveId - идентификатор Slave базы

isNotBehind - true - отставание выключено, false - отставание включено

isReplicationNotBehindMaster

public boolean isReplicationNotBehindMaster(java.lang.String slaveId)

Проверяет есть ли отставание Slave базы

Parameters:

slaveId - идентификатор Slave базы

Returns:

compareAndSetReplicationNotBehindMaster

public boolean compareAndSetReplicationNotBehindMaster(java.lang.String slaveId,
                                                       boolean expected,
                                                       boolean update)

isReplicationAvailable

public boolean isReplicationAvailable(java.lang.String slaveId)

Проверяет доступность Slave базы

Parameters:

slaveId - идентификатор Slave базы

Returns:

true - если доступна, false - если не доступна

setReplicationAvailable

public void setReplicationAvailable(java.lang.String slaveId,
                                    boolean available)

Установка/Отключение доступности Slave базы

Parameters:

slaveId - идентификатор Slave базы

available - true -не доступно; false - доступно