Package ru.bitel.bgbilling.kernel.task.server.dao

Class RunTaskDataDao

java.lang.Object
ru.bitel.bgbilling.kernel.base.server.logger.BGLogger
ru.bitel.bgbilling.common.dao.AbstractDaoConstant
ru.bitel.bgbilling.kernel.task.server.dao.RunTaskDataDao
public class RunTaskDataDao extends ru.bitel.bgbilling.common.dao.AbstractDaoConstant

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    class 
    RunTaskDataDao.PeriodicTaskRun
    Deprecated.

  • Field Summary

    Fields inherited from class ru.bitel.bgbilling.common.dao.AbstractDaoConstant

    con, ERROR, fields, moduleId, SQL_ALL, SQL_AND, SQL_DELETE, SQL_DISTINCT, SQL_EQ, SQL_EQCS, SQL_FROM, SQL_GROUP, SQL_IN, SQL_INSERT, SQL_JOIN, SQL_LEFT_JOIN, SQL_LIMIT, SQL_NOT_IN, SQL_ON, SQL_ORDER, SQL_SELECT, SQL_SET, SQL_UPDATE, SQL_VALUES, SQL_WHERE, tableName

  • Constructor Summary

    Constructors
    Constructor
    Description
    RunTaskDataDao(Connection con)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    addTask(RunTask task)
    Добавить задание, пишется в БД
    void
    clearCurrentPeriodic()
    Очистка таблицы с текущими запущенными задачами планировщика.
    List<RunTaskDataDao.PeriodicTaskRun>
    getCurrentPeriodic()
    Deprecated.
    RunTask
    getNextTask()
    Выбирает следующий (первый с минимальным id) RunTask к исполнению.
    List<RunTask>
    getNextTasks()
    Выбирает все следующие готовые к выполнению RunTask-и.
    int
    getTaskCount()
     
    List<TaskData>
    getTaskDataForReload()
    Все текущие задачи к исполнению(?).
    List<RunningTask>
    getTasks()
    Deprecated.
    void
    removeTask(int id)
    Deprecated.

    Methods inherited from class ru.bitel.bgbilling.common.dao.AbstractDaoConstant

    getPeriod, getPlaceholders, getSQLOrder, getSQLOrderFields, getTableName, psSetDate, psSetDateOrNull, psSetInt, psSetIntOrNull, psSetPeriod, psSetString, psSetStringOrNull, psSetTimestampOrNull, queryAndIn, setStatementParam, sqlDelete, sqlDeleteBatch, sqlInsert, sqlInsertBatch, sqlInsertGetId, sqlInsertGetLongId, sqlInsertOnDuplicateKeyUpdate, sqlInsertSelect, sqlInsertUpdateById, sqlSelectCountAsInt, sqlUpdate, sqlUpdateBatch

    Methods inherited from class ru.bitel.bgbilling.kernel.base.server.logger.BGLogger

    error, error, error, getLogger, logError, logError, warn

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • RunTaskDataDao

      public RunTaskDataDao(Connection con)

  • Method Details

    • addTask

      public void addTask(RunTask task)
      Добавить задание, пишется в БД
      Parameters:
      task - объект RunTask

    • removeTask

      @Deprecated public void removeTask(int id) throws SQLException
      Deprecated.
      Использовать
      invalid @link 
      {@link SchedulerManager.deleteCurrentRunTask( int taskId )
      }
      Parameters:
      id -
      Throws:
      SQLException

    • getCurrentPeriodic

      @Deprecated public List<RunTaskDataDao.PeriodicTaskRun> getCurrentPeriodic()
      Deprecated.
      Использовать
      invalid @link 
      {@link SchedulerManager.getPeriodicTasks()
      }

    • getTaskCount

      public int getTaskCount()

    • getTasks

      @Deprecated public List<RunningTask> getTasks()
      Deprecated.
      Использовать
      invalid @link 
      {@link SchedulerManager.getRunningTaskList()
      }

    • getNextTask

      public RunTask getNextTask() throws Exception
      Выбирает следующий (первый с минимальным id) RunTask к исполнению. Если записи следующей нет, то вернётся null. Если есть, но не смогли мы прочитать корректный объект, то запись с битым объектом удаляется и возвращается также null (и выводится в лог запись с ошибкой). Помечает задачу как начавшуюся. Старый метод, заменён методом getNextTasks.
      Returns:
      прочитанный из БД объект RunTask, или null, если нету больше в БД записей, или же при чтении текущего произошла ошибка.
      Throws:
      SQLException - ошибка БД.
      Exception

    • getNextTasks

      public List<RunTask> getNextTasks() throws SQLException
      Выбирает все следующие готовые к выполнению RunTask-и. Сортировка по возрастанию id. Может вернуться пустой список (не null). Помечает вернутые задачи как начавшиеся. Поддерживает ключи задач для схлопывания (таковые удаляются из очереди) и незапуска параллельно (таковые оставляются до следующей проверки).
      Throws:
      SQLException

    • clearCurrentPeriodic

      public void clearCurrentPeriodic() throws SQLException
      Очистка таблицы с текущими запущенными задачами планировщика. Вызывается при старте таск экзекутера.
      Throws:
      SQLException

    • getTaskDataForReload

      public List<TaskData> getTaskDataForReload() throws Exception
      Все текущие задачи к исполнению(?). Вызывается при reloadTasks(). В случае, если в системе отсутствует экземпляр модуля и/или выключен плагин, то задачи этого модуля и/и плагина не учитываются
      Returns:
      список готовых объектов TaskData.
      Throws:
      Exception