net.avcompris.status.dao.impl

Class CorrelationDaoInRDS

java.lang.Object

net.avcompris.commons3.dao.impl.AbstractDao

net.avcompris.commons3.dao.impl.AbstractDaoInRDS

net.avcompris.status.dao.impl.CorrelationDaoInRDS

All Implemented Interfaces:

net.avcompris.commons3.dao.CorrelationDao

@Component
public final class CorrelationDaoInRDS
extends net.avcompris.commons3.dao.impl.AbstractDaoInRDS
implements net.avcompris.commons3.dao.CorrelationDao

Nested Class Summary

Nested classes/interfaces inherited from class net.avcompris.commons3.dao.impl.AbstractDao

net.avcompris.commons3.dao.impl.AbstractDao.Action<T>

Field Summary

Fields inherited from class net.avcompris.commons3.dao.impl.AbstractDaoInRDS

PSQL_FOREIGN_ENTITY_VIOLATION, PSQL_UNIQUE_VIOLATION, SCHEMA_VERSION_COLUMN_NAME, tableName

Fields inherited from class net.avcompris.commons3.dao.impl.AbstractDao

clock

Constructor Summary

Constructors

Constructor and Description
CorrelationDaoInRDS(DataSource dataSource, String tableName, net.avcompris.commons3.utils.Clock clock)

Method Summary

Modifier and Type	Method and Description
void	addCorrelationId(String correlationId)
boolean	isCorrelationIdValid(String correlationId)
void	purgeOlderThanSec(int seconds)

Methods inherited from class net.avcompris.commons3.dao.impl.AbstractDaoInRDS

getBoolean, getBoolean, getBytes, getBytes, getConnection, getDateTime, getDateTime, getEnum, getEnum, getInt, getInt, getInteger, getInteger, getLong, getLong, getString, getString, isPSQLForeignEntityViolation, isPSQLUniqueViolation, joinRefIds, setBinaryStream, setBoolean, setBytes, setDateTime, setDouble, setInt, setInteger, setLong, setObject, setString, toSQLLimitClause, toSQLOrderByDirective

Methods inherited from class net.avcompris.commons3.dao.impl.AbstractDao

retryUntil, retryUntil

Methods inherited from class java.lang.Object

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

Constructor Detail

CorrelationDaoInRDS

@Autowired
public CorrelationDaoInRDS(@Value(value="#{rds.dataSource}")
                                      DataSource dataSource,
                                      @Value(value="#{rds.tableNames.correlations}")
                                      String tableName,
                                      net.avcompris.commons3.utils.Clock clock)

Method Detail

isCorrelationIdValid

public boolean isCorrelationIdValid(String correlationId)
                             throws SQLException

Specified by:

isCorrelationIdValid in interface net.avcompris.commons3.dao.CorrelationDao

Throws:

SQLException

addCorrelationId

public void addCorrelationId(String correlationId)
                      throws SQLException,
                             IOException,
                             net.avcompris.commons3.dao.exception.DuplicateEntityException

Specified by:

addCorrelationId in interface net.avcompris.commons3.dao.CorrelationDao

Throws:

SQLException

IOException

net.avcompris.commons3.dao.exception.DuplicateEntityException

purgeOlderThanSec

public void purgeOlderThanSec(int seconds)
                       throws SQLException,
                              IOException

Specified by:

purgeOlderThanSec in interface net.avcompris.commons3.dao.CorrelationDao

Throws:

SQLException

IOException