public class JobsDAOImpl extends AbstractDAO<eu.dnetlib.domain.functionality.validator.StoredJob> implements JobsDAO
datasource, logger
Constructor and Description |
---|
JobsDAOImpl() |
Modifier and Type | Method and Description |
---|---|
int |
deleteOld(String date,
String period,
String jobType) |
int |
deleteUncompletedJobs() |
eu.dnetlib.domain.functionality.validator.StoredJob |
get(int id) |
protected PreparedStatement |
getDeleteStatement(int id,
Connection con) |
protected PreparedStatement |
getInsertStatement(eu.dnetlib.domain.functionality.validator.StoredJob t,
Connection con) |
boolean |
getJobError(int jobId)
Deprecated.
|
List<eu.dnetlib.domain.functionality.validator.StoredJob> |
getJobs(String userName,
String jobType,
Integer offset,
Integer limit,
String dateFrom,
String dateTo) |
List<eu.dnetlib.domain.functionality.validator.StoredJob> |
getJobs(String userName,
String jobType,
Integer offset,
Integer limit,
String dateFrom,
String dateTo,
String validationStatus) |
int |
getJobsTotalNumber(String userName,
String jobType) |
int |
getJobsTotalNumber(String userName,
String jobType,
String validationStatus) |
eu.dnetlib.domain.functionality.validator.StoredJob |
getJobSummary(int jobId,
String groupby) |
List<eu.dnetlib.domain.functionality.validator.StoredJob> |
getJobSummary(List<String> baseUrls,
int size) |
protected int |
getLastId() |
Map<String,Integer> |
getScoresPerGroupBy(int jobId) |
List<eu.dnetlib.domain.functionality.validator.StoredJob> |
getUncompletedJobs() |
protected PreparedStatement |
getUpdateStatement(eu.dnetlib.domain.functionality.validator.StoredJob t,
Connection con) |
List<String> |
getValidationErrors(int jobId,
int ruleId) |
void |
importOldJobs() |
Integer |
save(eu.dnetlib.domain.functionality.validator.StoredJob job) |
int |
setJobFinished(int jobId,
Map<String,Map<Integer,RuleStatus>> scoreMapPerGroupBy,
String error,
Boolean failed,
int objsValidated,
String validationType) |
void |
setStatus(int jobId,
String status,
int recordsTested,
String validationType) |
void |
setTotalJobFinished(int jobId,
String error,
Boolean failed) |
closeConnection, delete, getConnection, getDatasource, setDatasource
public Integer save(eu.dnetlib.domain.functionality.validator.StoredJob job) throws DaoException
save
in interface DAO<eu.dnetlib.domain.functionality.validator.StoredJob>
save
in class AbstractDAO<eu.dnetlib.domain.functionality.validator.StoredJob>
DaoException
protected PreparedStatement getDeleteStatement(int id, Connection con) throws SQLException
getDeleteStatement
in class AbstractDAO<eu.dnetlib.domain.functionality.validator.StoredJob>
SQLException
public eu.dnetlib.domain.functionality.validator.StoredJob get(int id) throws DaoException
get
in interface DAO<eu.dnetlib.domain.functionality.validator.StoredJob>
DaoException
public void importOldJobs() throws DaoException
importOldJobs
in interface JobsDAO
DaoException
public List<eu.dnetlib.domain.functionality.validator.StoredJob> getJobs(String userName, String jobType, Integer offset, Integer limit, String dateFrom, String dateTo) throws DaoException
getJobs
in interface JobsDAO
DaoException
public List<eu.dnetlib.domain.functionality.validator.StoredJob> getJobs(String userName, String jobType, Integer offset, Integer limit, String dateFrom, String dateTo, String validationStatus) throws DaoException
getJobs
in interface JobsDAO
DaoException
public int getJobsTotalNumber(String userName, String jobType) throws DaoException
getJobsTotalNumber
in interface JobsDAO
DaoException
public int getJobsTotalNumber(String userName, String jobType, String validationStatus) throws DaoException
getJobsTotalNumber
in interface JobsDAO
DaoException
public void setTotalJobFinished(int jobId, String error, Boolean failed) throws DaoException
setTotalJobFinished
in interface JobsDAO
DaoException
public int setJobFinished(int jobId, Map<String,Map<Integer,RuleStatus>> scoreMapPerGroupBy, String error, Boolean failed, int objsValidated, String validationType) throws DaoException
setJobFinished
in interface JobsDAO
DaoException
@Deprecated public boolean getJobError(int jobId) throws DaoException
DaoException
protected int getLastId() throws DaoException
getLastId
in class AbstractDAO<eu.dnetlib.domain.functionality.validator.StoredJob>
DaoException
public int deleteOld(String date, String period, String jobType) throws DaoException
deleteOld
in interface JobsDAO
DaoException
public void setStatus(int jobId, String status, int recordsTested, String validationType) throws DaoException
setStatus
in interface JobsDAO
DaoException
public eu.dnetlib.domain.functionality.validator.StoredJob getJobSummary(int jobId, String groupby) throws DaoException
getJobSummary
in interface JobsDAO
DaoException
public List<eu.dnetlib.domain.functionality.validator.StoredJob> getJobSummary(List<String> baseUrls, int size) throws DaoException
getJobSummary
in interface JobsDAO
DaoException
public List<String> getValidationErrors(int jobId, int ruleId) throws DaoException
DaoException
public List<eu.dnetlib.domain.functionality.validator.StoredJob> getUncompletedJobs() throws DaoException
getUncompletedJobs
in interface JobsDAO
DaoException
public int deleteUncompletedJobs() throws DaoException
deleteUncompletedJobs
in interface JobsDAO
DaoException
public Map<String,Integer> getScoresPerGroupBy(int jobId) throws DaoException
DaoException
protected PreparedStatement getUpdateStatement(eu.dnetlib.domain.functionality.validator.StoredJob t, Connection con) throws SQLException
getUpdateStatement
in class AbstractDAO<eu.dnetlib.domain.functionality.validator.StoredJob>
SQLException
protected PreparedStatement getInsertStatement(eu.dnetlib.domain.functionality.validator.StoredJob t, Connection con) throws SQLException
getInsertStatement
in class AbstractDAO<eu.dnetlib.domain.functionality.validator.StoredJob>
SQLException
Copyright © 2023. All rights reserved.