public class TasksDAOimpl extends AbstractDAO<TaskStored> implements TasksDAO
datasource, logger
Constructor and Description |
---|
TasksDAOimpl() |
Modifier and Type | Method and Description |
---|---|
void |
cleanTasks(int jobId) |
TaskStored |
get(int id) |
protected PreparedStatement |
getDeleteStatement(int id,
Connection con) |
List<String> |
getDistinctTasksOfJob(int jobId) |
List<TaskStored> |
getFinishedTasks(int jobId,
int ruleId) |
protected PreparedStatement |
getInsertStatement(TaskStored t,
Connection con) |
protected int |
getLastId() |
List<TaskStored> |
getTasksOfJob(int id) |
protected PreparedStatement |
getUpdateStatement(TaskStored t,
Connection con) |
List<String> |
getValidationErrors(int jobId,
int ruleId) |
void |
saveTasks(List<TaskStored> tasks,
List<String> groupBy_values) |
void |
saveTasks(Map<Integer,RuleStatus> scoreMapPerRule) |
void |
saveTasksBatch(List<TaskStored> tasks,
Map<String,List<String>> groupByMap) |
closeConnection, delete, getConnection, getDatasource, save, setDatasource
protected PreparedStatement getUpdateStatement(TaskStored t, Connection con) throws SQLException
getUpdateStatement
in class AbstractDAO<TaskStored>
SQLException
protected PreparedStatement getInsertStatement(TaskStored t, Connection con) throws SQLException
getInsertStatement
in class AbstractDAO<TaskStored>
SQLException
protected PreparedStatement getDeleteStatement(int id, Connection con) throws SQLException
getDeleteStatement
in class AbstractDAO<TaskStored>
SQLException
public List<TaskStored> getTasksOfJob(int id) throws DaoException
getTasksOfJob
in interface TasksDAO
DaoException
public TaskStored get(int id)
get
in interface DAO<TaskStored>
public List<String> getValidationErrors(int jobId, int ruleId) throws DaoException
getValidationErrors
in interface TasksDAO
DaoException
public List<String> getDistinctTasksOfJob(int jobId) throws DaoException
getDistinctTasksOfJob
in interface TasksDAO
DaoException
public List<TaskStored> getFinishedTasks(int jobId, int ruleId) throws DaoException
getFinishedTasks
in interface TasksDAO
DaoException
public void saveTasksBatch(List<TaskStored> tasks, Map<String,List<String>> groupByMap) throws DaoException
saveTasksBatch
in interface TasksDAO
DaoException
public void saveTasks(List<TaskStored> tasks, List<String> groupBy_values) throws DaoException
saveTasks
in interface TasksDAO
DaoException
public void saveTasks(Map<Integer,RuleStatus> scoreMapPerRule) throws DaoException
saveTasks
in interface TasksDAO
DaoException
protected int getLastId() throws DaoException
getLastId
in class AbstractDAO<TaskStored>
DaoException
public void cleanTasks(int jobId) throws DaoException
cleanTasks
in interface TasksDAO
DaoException
Copyright © 2023. All rights reserved.