@Component
public final class CorrelationDaoInRDS
extends net.avcompris.commons3.dao.impl.AbstractDaoInRDS
implements net.avcompris.commons3.dao.CorrelationDao
Constructor and Description |
---|
CorrelationDaoInRDS(DataSource dataSource,
String tableName,
net.avcompris.commons3.utils.Clock clock) |
Modifier and Type | Method and Description |
---|---|
void |
addCorrelationId(String correlationId) |
boolean |
isCorrelationIdValid(String correlationId) |
void |
purgeOlderThanSec(int seconds) |
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
@Autowired public CorrelationDaoInRDS(@Value(value="#{rds.dataSource}") DataSource dataSource, @Value(value="#{rds.tableNames.correlations}") String tableName, net.avcompris.commons3.utils.Clock clock)
public boolean isCorrelationIdValid(String correlationId) throws SQLException
isCorrelationIdValid
in interface net.avcompris.commons3.dao.CorrelationDao
SQLException
public void addCorrelationId(String correlationId) throws SQLException, IOException, net.avcompris.commons3.dao.exception.DuplicateEntityException
addCorrelationId
in interface net.avcompris.commons3.dao.CorrelationDao
SQLException
IOException
net.avcompris.commons3.dao.exception.DuplicateEntityException
public void purgeOlderThanSec(int seconds) throws SQLException, IOException
purgeOlderThanSec
in interface net.avcompris.commons3.dao.CorrelationDao
SQLException
IOException
Copyright © 2021 Avantage Compris. All rights reserved.