Package ru.bitel.bgbilling.server.util

Class DefaultServerSetup

java.lang.Object
ru.bitel.common.ParameterMap
ru.bitel.common.Preferences
ru.bitel.bgbilling.server.util.DefaultServerSetup
Direct Known Subclasses:
Setup
public class DefaultServerSetup extends Preferences
То же что и Preferences, только умеет работать с пулом соединений к базе.

  • Field Details

  • Constructor Details

    • DefaultServerSetup

      public DefaultServerSetup(String bundleName)

    • DefaultServerSetup

      public DefaultServerSetup()

  • Method Details

    • isReplicationEnabled

      @Deprecated public boolean isReplicationEnabled(String slaveId)
      Deprecated.
      Использовать isReplicationNotBehindMaster(String)
      Parameters:
      slaveId -
      Returns:

    • setReplicationEnabled

      @Deprecated public void setReplicationEnabled(String slaveId, boolean enable)
      Deprecated.
      Использовать setReplicationNotBehindMaster(String, boolean)
      Parameters:
      slaveId -
      enable -

    • setReplicationNotBehindMaster

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

    • isReplicationNotBehindMaster

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

    • isReplicationAvailable

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

    • setReplicationAvailable

      public void setReplicationAvailable(String slaveId, boolean available)
      Установка/Отключение доступности Slave базы
      Parameters:
      slaveId - идентификатор Slave базы
      available - true -не доступно; false - доступно

    • getScheduledExecutorService

      public ScheduledExecutorService getScheduledExecutorService()

    • initConnectionPool

      public boolean initConnectionPool()
      Инициализация пулов соединений с мастер и slave базами.

    • initTrashPoolsAndCreateTableOptions

      protected void initTrashPoolsAndCreateTableOptions()
      Инициализация пулов соединений к "мусорным" базам. Загрузка опций создания таблиц.

    • initJNDI

      public void initJNDI()

    • getEnvironment

      public static Context getEnvironment() throws NamingException
      Throws:
      NamingException

    • initMQ

      public Object initMQ()

    • getDBConnectionFromPool

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

    • getDBConnectionFromPool

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

    • getDBSlaveConnectionFromPool

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

    • getDBSlaveConnectionFromPool

      public final Connection getDBSlaveConnectionFromPool(Connection master)
      Возвращает соединение с Slave БД из пула. Если Slave БД не определены в конфигурации - возвращает из Master пула.
      Parameters:
      master - masterConnection
      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:
      коннекшен

    • returnConToPool

      @Deprecated public final void returnConToPool(Connection con)
      Deprecated.
      Возвращает соединение с БД в пул.
      Parameters:
      con -
      See Also:
      • Utils#closeConnection(Connection)

    • getPoolStatus

      public String getPoolStatus()
      Отчет по статусу пулов соединений
      Returns:

    • getMasterPoolLoad

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

    • getPoolStackTrace

      public String getPoolStackTrace()

    • getDBConnection

      public Connection getDBConnection(boolean autoCommit)

    • getDBConnection

      public Connection getDBConnection()
      Возвращает отдельное соединение с Master базой.
      Returns:

    • logConfigure

      public void logConfigure(String log)

    • checkAndCreatePeriodicTableName

      public void checkAndCreatePeriodicTableName(Connection con, String tableName, String createQuery)
      Функция берет имя таблицы(xxxx) из xxxx_mid_yyyyMM и создает ее
      Parameters:
      con -
      tableName -
      createQuery -

    • initLocales

      public void initLocales()