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​(java.lang.String bundleName)

    • DefaultServerSetup

      public DefaultServerSetup()

  • Method Details

    • isReplicationEnabled

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

    • setReplicationEnabled

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

    • 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:

    • 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 - доступно

    • getScheduledExecutorService

      public java.util.concurrent.ScheduledExecutorService getScheduledExecutorService()

    • initConnectionPool

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

    • initTrashPoolsAndCreateTableOptions

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

    • initJNDI

      public void initJNDI()

    • getEnvironment

      public static javax.naming.Context getEnvironment() throws javax.naming.NamingException
      Throws:
      javax.naming.NamingException

    • initMQ

      public void initMQ()

    • getDBConnectionFromPool

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

    • getDBConnectionFromPool

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

    • 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:
      коннекшен

    • returnConToPool

      @Deprecated public final void returnConToPool​(java.sql.Connection con)
      Deprecated.
      Возвращает соединение с БД в пул.
      Parameters:
      con -

    • getPoolStatus

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

    • getMasterPoolLoad

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

    • getPoolStackTrace

      public java.lang.String getPoolStackTrace()

    • getDBConnection

      public java.sql.Connection getDBConnection​(boolean autoCommit)

    • getDBConnection

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

    • logConfigure

      public void logConfigure​(java.lang.String log)

    • checkAndCreatePeriodicTableName

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

    • initLocales

      public void initLocales()