Package org.bgerp.plugin.ai.aixflow.dao
Class FileAixflowTaskDAO
java.lang.Object
ru.bgcrm.dao.CommonDAO
org.bgerp.plugin.ai.aixflow.dao.FileAixflowTaskDAO
DAO for file_aixflow_tasks table.
-
Nested Class Summary
Nested classes/interfaces inherited from class ru.bgcrm.dao.CommonDAO
CommonDAO.ObjectExtractor<T>, CommonDAO.RecordUpdater<T extends Id> -
Field Summary
Fields inherited from class ru.bgcrm.dao.CommonDAO
con, SQL_AND, SQL_DELETE, SQL_DELETE_FROM, SQL_DESC, SQL_DISTINCT, SQL_FROM, SQL_GROUP_BY, SQL_INNER_JOIN, SQL_INSERT_IGNORE_INTO, SQL_INSERT_INTO, SQL_LEFT_JOIN, SQL_LIMIT, SQL_ON_DUP_KEY_UPDATE, SQL_ORDER_BY, SQL_REPLACE, SQL_SELECT, SQL_SELECT_ALL_FROM, SQL_SELECT_COUNT_ROWS, SQL_SET, SQL_UNION_ALL, SQL_UPDATE, SQL_VALUES, SQL_VALUES_1, SQL_VALUES_2, SQL_VALUES_3, SQL_VALUES_4, SQL_VALUES_5, SQL_WHERE -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptioncreate(FileAixflowTask task) booleandelete(int id) getByAnalysisId(String analysisId) getByFileId(int fileId) getById(int id) getByTaskId(String taskId) getPendingOrProcessing(int limit) Returns tasks in pending or processing state for the scheduler poller.booleanincrementRetryCount(String taskId) booleanupdateAnalysisId(String taskId, String analysisId) booleanupdateStatus(String taskId, String status, String result, String errorMessage) Methods inherited from class ru.bgcrm.dao.CommonDAO
deleteById, foundRows, getById, getGroupedIds, getGroupedIds, getIds, getIds, getPageLimit, getPeriodSql, lastInsertId, setPeriodParamValue, setRecordCount, update, updateColumn, updateIds, updateIds, updateOrInsert
-
Constructor Details
-
FileAixflowTaskDAO
-
-
Method Details
-
create
- Throws:
SQLException
-
getById
- Throws:
SQLException
-
getByTaskId
- Throws:
SQLException
-
getByAnalysisId
- Throws:
SQLException
-
getByFileId
- Throws:
SQLException
-
getPendingOrProcessing
Returns tasks in pending or processing state for the scheduler poller.- Throws:
SQLException
-
updateStatus
public boolean updateStatus(String taskId, String status, String result, String errorMessage) throws SQLException - Throws:
SQLException
-
updateAnalysisId
- Throws:
SQLException
-
incrementRetryCount
- Throws:
SQLException
-
delete
- Throws:
SQLException
-