public class DbOdcsContextTransactional extends DbContextTransactional
SQL
ERROR_CLOSED_CONNECTION
Constructor and Description |
---|
DbOdcsContextTransactional() |
closeQuietly, commit, rollback, setConnection
close, execute, execute, executeNullsAlllowed, getConnection, select, select
public DbOdcsContextTransactional() throws DbOdcsException
DbOdcsException
public Graph selectOldestEngineWorkingGraph(String engineUuid) throws DbOdcsException
DbOdcsException
public Graph selectOldestEngineQueuedGraph(String engineUuid) throws DbOdcsException
DbOdcsException
public boolean selectResetPipelineRequest(int graphId) throws DbOdcsException
DbOdcsException
public void clearResetPipelineRequest(int graphId) throws DbOdcsException
DbOdcsException
public boolean updateAttachedEngine(int graphId, String engineUuid) throws DbOdcsException
DbOdcsException
public boolean updateEngineState(String engineUuid, String stateDescription) throws DbOdcsException
DbOdcsException
public boolean updateState(int graphId, EnumGraphState newState) throws DbOdcsException
DbOdcsException
public boolean updateStateAndIsInCleanDb(int graphId, EnumGraphState newState, boolean isInCleanDb) throws DbOdcsException
DbOdcsException
public HashSet<String> selectAttachedGraphs(int graphId) throws DbOdcsException
DbOdcsException
public void insertAttachedGraph(int graphId, String name) throws DbOdcsException
DbOdcsException
public void deleteAttachedGraphs(int graphId) throws DbOdcsException
DbOdcsException
public PipelineCommand[] selectPipelineCommands(int pipelineId) throws DbOdcsException
DbOdcsException
public GroupRule[] selectDnRules(int pipelineId) throws DbOdcsException
DbOdcsException
public GroupRule[] selectQaRules(int pipelineId) throws DbOdcsException
DbOdcsException
public GroupRule[] selectOiRules(int pipelineId) throws DbOdcsException
DbOdcsException
public Pipeline selectDefaultPipeline() throws DbOdcsException
DbOdcsException
public String selectErrorMessageFromGraphInError(int graphId) throws DbOdcsException
DbOdcsException
public void insertGraphInError(int graphId, EnumPipelineErrorType type, String message) throws DbOdcsException
DbOdcsException
public void deleteGraphInError(int graphId) throws DbOdcsException
DbOdcsException
public void insertPipelineResult(int graphId, int pipelineId, Integer pipelineAuthorId, boolean isExistingGraph, boolean isSuccess, String errorMessage, Date created) throws DbOdcsException
DbOdcsException
public Credentials selectScraperCredentials(String userName) throws DbOdcsException
DbOdcsException
public int selectEngineId(String uuid) throws DbOdcsException
DbOdcsException
public int selectPipelineId(String label) throws DbOdcsException
DbOdcsException
public String[] selectAllImportingGraphsForEngine(String engineUuid) throws DbOdcsException
DbOdcsException
public boolean isGraphUuidInSystem(String uuid) throws DbOdcsException
DbOdcsException
public void insertImportingGraph(String uuid, String prefix, int pipelineId, int engineId) throws DbOdcsException
DbOdcsException
public void deleteImportingGraph(String uuid) throws DbOdcsException
DbOdcsException
public void updateImportingGraphStateToQueued(String uuid) throws DbOdcsException
DbOdcsException
Copyright © 2013. All Rights Reserved.