Package org.jumpmind.symmetric.service.impl

Class PurgeService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.PurgeService

All Implemented Interfaces:

IPurgeService, IService

public class PurgeService
extends AbstractService
implements IPurgeService

See Also:

• IPurgeService

Field Summary

Fields inherited from class org.jumpmind.symmetric.service.impl.AbstractService

log, parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix

Constructor Summary

Constructors

Constructor	Description
PurgeService(IParameterService parameterService, ISymmetricDialect symmetricDialect, IClusterService clusterService, IDataService dataService, ISequenceService sequenceService, IStatisticManager statisticManager, IExtensionService extensionService, IContextService contextService)

Method Summary

Modifier and Type	Method	Description
protected int	executePurgeDelete(String deleteSql, Object argument)
protected org.jumpmind.symmetric.service.impl.PurgeService.MinMaxDeleteSql	getIdentifierIfUsingExists(org.jumpmind.symmetric.service.impl.PurgeService.MinMaxDeleteSql identifier)
protected String	getIdentifierName(org.jumpmind.symmetric.service.impl.PurgeService.MinMaxDeleteSql identifier)
static long[]	getMinMaxAvoidGaps(long minId, long maxId, List<DataGap> dataGapsExpired)	Takes a range of data_ids that are about to be purged, and modifies the range to go around any expired data gaps that are being watched for data to be committed.
void	purgeAllIncomingEventsForNode(String nodeId)
long	purgeIncoming(boolean force)
long	purgeIncoming(Calendar retentionCutoff, boolean force)
long	purgeOutgoing(boolean force)
long	purgeOutgoing(Calendar retentionCutoff, boolean force)
protected long	purgeOutgoingByRetentionCutoff(Calendar retentionCutoff)
void	purgeStats(boolean force)
protected void	saveContextLastId(org.jumpmind.symmetric.service.impl.PurgeService.MinMaxDeleteSql identifier, long lastId)
protected int	selectIdsAndDelete(String selectSql, String fieldName, String deleteSql)

Methods inherited from class org.jumpmind.symmetric.service.impl.AbstractService

assertNotNull, buildBatchOrderBy, buildBatchParams, buildBatchWhere, buildBatchWhereFromFilter, close, createSqlReplacementTokens, getJdbcTemplate, getParameterService, getSql, getSymmetricDialect, getTablePrefix, getTargetDialect, getTargetPlatform, getTargetPlatform, isCalledFromSymmetricAdminTool, isSet, isStreamClosedByClient, isSymmetricTable, logOnce, maxDate, readAcks, sendAck, setSqlMap, synchronize, toNodeIds, toNodeIds

Methods inherited from class java.lang.Object

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

Constructor Details

PurgeService

public PurgeService(IParameterService parameterService,
 ISymmetricDialect symmetricDialect,
 IClusterService clusterService,
 IDataService dataService,
 ISequenceService sequenceService,
 IStatisticManager statisticManager,
 IExtensionService extensionService,
 IContextService contextService)

Method Details

purgeOutgoing

public long purgeOutgoing(boolean force)

Specified by:

purgeOutgoing in interface IPurgeService

purgeIncoming

public long purgeIncoming(boolean force)

Specified by:

purgeIncoming in interface IPurgeService

purgeOutgoing

public long purgeOutgoing(Calendar retentionCutoff,
 boolean force)

Specified by:

purgeOutgoing in interface IPurgeService

purgeOutgoingByRetentionCutoff

protected long purgeOutgoingByRetentionCutoff(Calendar retentionCutoff)

executePurgeDelete

protected int executePurgeDelete(String deleteSql,
 Object argument)

getIdentifierIfUsingExists

protected org.jumpmind.symmetric.service.impl.PurgeService.MinMaxDeleteSql getIdentifierIfUsingExists(org.jumpmind.symmetric.service.impl.PurgeService.MinMaxDeleteSql identifier)

getIdentifierName

protected String getIdentifierName(org.jumpmind.symmetric.service.impl.PurgeService.MinMaxDeleteSql identifier)

saveContextLastId

protected void saveContextLastId(org.jumpmind.symmetric.service.impl.PurgeService.MinMaxDeleteSql identifier,
 long lastId)

getMinMaxAvoidGaps

public static long[] getMinMaxAvoidGaps(long minId,
 long maxId,
 List<DataGap> dataGapsExpired)

Takes a range of data_ids that are about to be purged, and modifies the range to go around any expired data gaps that are being watched for data to be committed. This allows statistics to be mutually exclusive for purged rows from expired data gaps and purged rows from stranded data.

Parameters:

minId - Min data ID of range

maxId - Max data ID of range

dataGapsExpired - List of expired data gaps to avoid

Returns:

purgeIncoming

public long purgeIncoming(Calendar retentionCutoff,
 boolean force)

Specified by:

purgeIncoming in interface IPurgeService

purgeStats

public void purgeStats(boolean force)

Specified by:

purgeStats in interface IPurgeService

purgeAllIncomingEventsForNode

public void purgeAllIncomingEventsForNode(String nodeId)

Specified by:

purgeAllIncomingEventsForNode in interface IPurgeService

selectIdsAndDelete

protected int selectIdsAndDelete(String selectSql,
 String fieldName,
 String deleteSql)