Package org.bgerp.app.db.sql.pool

Class ConnectionPool

java.lang.Object
org.bgerp.app.db.sql.pool.ConnectionPool
public class ConnectionPool extends Object

  • Field Details

  • Constructor Details

  • Method Details

    • getDataSource

      public DataSource getDataSource()

    • getConnectionSet

      public ConnectionSet getConnectionSet()

    • getConnectionSet

      public ConnectionSet getConnectionSet(boolean autoCommit)

    • close

      public void close()

    • getDBConnectionFromPool

      public final Connection getDBConnectionFromPool()
      Возвращает соединение с Master БД из пула.
      Returns:
      соединение с Master БД либо null в случае недоступности.

    • getSlaveDataSource

      public final DataSource getSlaveDataSource()

    • getDBSlaveConnectionFromPool

      public final Connection getDBSlaveConnectionFromPool()
      Возвращает соединение с Slave БД из пула. Если Slave БД не определены в конфигурации - возвращает из Master пула.
      Returns:

    • getDBSlaveConnectionFromPool

      public final Connection getDBSlaveConnectionFromPool(Connection master)
      Возвращает соединение с Slave БД из пула. Если Slave БД не определены в конфигурации - возвращает из Master пула.
      Parameters:
      masterOnNull - если false то при отсутсвии slave баз вернет null.
      Returns:

    • getDBTrashConnectionFromPool

      public final Connection getDBTrashConnectionFromPool(String tableName, int retType)
      Возвращает соединение с мусорной БД если она описана для таблицы в конфиге либо в зависимости от retType.
      Parameters:
      tableName - имя таблицы.
      retType - RETURN_FAKE, RETURN_SLAVE либо RETURN_MASTER.
      Returns:
      если не указана конфигурация мусорной БД может быть возвращен коннект к мастер БД, фейковый коннект либо коннект Slave БД.

    • getDBTrashOrMasterConnectionFromPool

      public final Connection getDBTrashOrMasterConnectionFromPool(String tableName)
      Возвращение соединения к выделенной "мусорной" либо Master-базе (если треш-база не найдена).
      Parameters:
      tableName -
      Returns:

    • getDBTrashOrSlaveConnectionFromPool

      public final Connection getDBTrashOrSlaveConnectionFromPool(String tableName)
      Возвращение соединения к выделенной "мусорной" либо Slave-базе
      Parameters:
      tableName -
      Returns:

    • getSlaveConnectionFromPool

      public final Connection getSlaveConnectionFromPool(String poolId)
      Возвращает соединение с slave базой. если неверная база то null со всем вытекающим, так как применяется только при принудительном выборе базы в некоторых специфичных служебных случаях.
      Parameters:
      poolId - - ид базы
      Returns:
      коннекшен

    • getSlaveBaseId

      public final Set<String> getSlaveBaseId()
      Возвращает идентификаторы slave баз.
      Returns:

    • getTrashBaseId

      public final Set<String> getTrashBaseId()
      Возвращает идентификаторы trash баз.
      Returns:

    • getTrashConnectionFromPool

      public final Connection getTrashConnectionFromPool(String poolId)
      Возвращает соединение с trash базой. если неверная база то null со всем вытекающим, так как применяется только при принудительном выборе базы в некоторых специфичных служебных случаях.
      Parameters:
      poolId - - ид базы
      Returns:
      коннекшен

    • poolStatus

      public String poolStatus()
      Returns:
      status text report for connection pools.

    • getDbTrace

      public String getDbTrace()
      Returns:
      pool connections borowing stack traces text report.

    • setReplicationNotBehindMaster

      @Deprecated public void setReplicationNotBehindMaster(String slaveId, boolean isNotBehind)
      Deprecated.
      Включение/Отключение флага отставания Slave базы
      Parameters:
      slaveId - идентификатор Slave базы
      isNotBehind - true - отставание выключено, false - отставание включено

    • isReplicationNotBehindMaster

      @Deprecated public boolean isReplicationNotBehindMaster(String slaveId)
      Deprecated.
      Проверяет есть ли отставание Slave базы
      Parameters:
      slaveId - идентификатор Slave базы
      Returns:

    • isReplicationAvailable

      @Deprecated public boolean isReplicationAvailable(String slaveId)
      Deprecated.
      Проверяет доступность Slave базы
      Parameters:
      slaveId - идентификатор Slave базы
      Returns:
      true - если доступна, false - если не доступна