Package org.bgerp.plugin.ai.aixflow.dao

Class FileAixflowTaskDAO

java.lang.Object

ru.bgcrm.dao.CommonDAO

org.bgerp.plugin.ai.aixflow.dao.FileAixflowTaskDAO

public class FileAixflowTaskDAO
extends CommonDAO

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

Constructor	Description
FileAixflowTaskDAO(Connection con)

Method Summary

Modifier and Type	Method	Description
FileAixflowTask	create(FileAixflowTask task)
boolean	delete(int id)
FileAixflowTask	getByAnalysisId(String analysisId)
List<FileAixflowTask>	getByFileId(int fileId)
FileAixflowTask	getById(int id)
FileAixflowTask	getByTaskId(String taskId)
List<FileAixflowTask>	getPendingOrProcessing(int limit)	Returns tasks in pending or processing state for the scheduler poller.
boolean	incrementRetryCount(String taskId)
boolean	updateAnalysisId(String taskId, String analysisId)
boolean	updateStatus(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

Methods inherited from class java.lang.Object

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

Constructor Details

FileAixflowTaskDAO

public FileAixflowTaskDAO(Connection con)

Method Details

create

public FileAixflowTask create(FileAixflowTask task)
                       throws SQLException

Throws:

SQLException

getById

public FileAixflowTask getById(int id)
                        throws SQLException

Throws:

SQLException

getByTaskId

public FileAixflowTask getByTaskId(String taskId)
                            throws SQLException

Throws:

SQLException

getByAnalysisId

public FileAixflowTask getByAnalysisId(String analysisId)
                                throws SQLException

Throws:

SQLException

getByFileId

public List<FileAixflowTask> getByFileId(int fileId)
                                  throws SQLException

Throws:

SQLException

getPendingOrProcessing

public List<FileAixflowTask> getPendingOrProcessing(int limit)
                                             throws SQLException

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

public boolean updateAnalysisId(String taskId,
 String analysisId)
                         throws SQLException

Throws:

SQLException

incrementRetryCount

public boolean incrementRetryCount(String taskId)
                            throws SQLException

Throws:

SQLException

delete

public boolean delete(int id)
               throws SQLException

Throws:

SQLException