Package com.atlassian.confluence.impl.incrementalsync.dao

Class HibernateIncrementalSyncSubscriptionDao

java.lang.Object

com.atlassian.confluence.impl.incrementalsync.dao.HibernateIncrementalSyncSubscriptionDao

All Implemented Interfaces:

IncrementalSyncSubscriptionDao

public class HibernateIncrementalSyncSubscriptionDao
extends Object
implements IncrementalSyncSubscriptionDao

Hibernate implementation of IncrementalSyncSubscriptionDao

Since:

9.3.0

Constructor Summary

Constructors

Constructor	Description
HibernateIncrementalSyncSubscriptionDao(org.hibernate.SessionFactory sessionFactory, com.atlassian.core.util.Clock clock)

Method Summary

Modifier and Type	Method	Description
Optional<IncrementalSyncSubscriptionEntity>	getSubscription(long id)	Get an IncrementalSyncSubscriptionEntity using it Id
Collection<IncrementalSyncSubscriptionEntity>	getSubscriptionsByContext(String context)	Get all subscription within a context
Collection<IncrementalSyncSubscriptionEntity>	getSubscriptionsByContext(String context, IncrementalSyncState state)	Get all subscription within a context and state
int	removeAllSubscriptions(String contextKey)	Remove all subscription belong to a context key
int	removeDeletedSubscriptions(String contextKey)	Remove deleted subscription belong to a context key
int	removeExpiredSubscriptions(String contextKey, Instant ttl)	Remove expired subscription belong to a context key
boolean	removeSubscription(long id)
long	store(IncrementalSyncSubscriptionEntity saveSubscription)	Add or update an IncrementalSyncSubscriptionEntity.

Methods inherited from class java.lang.Object

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

Constructor Details

HibernateIncrementalSyncSubscriptionDao

public HibernateIncrementalSyncSubscriptionDao(org.hibernate.SessionFactory sessionFactory,
 com.atlassian.core.util.Clock clock)

Method Details

store

public long store(IncrementalSyncSubscriptionEntity saveSubscription)

Description copied from interface: IncrementalSyncSubscriptionDao

Add or update an IncrementalSyncSubscriptionEntity. This method will update setLastAccessTime

Specified by:

store in interface IncrementalSyncSubscriptionDao

getSubscription

public Optional<IncrementalSyncSubscriptionEntity> getSubscription(long id)

Description copied from interface: IncrementalSyncSubscriptionDao

Get an IncrementalSyncSubscriptionEntity using it Id

Specified by:

getSubscription in interface IncrementalSyncSubscriptionDao

getSubscriptionsByContext

public Collection<IncrementalSyncSubscriptionEntity> getSubscriptionsByContext(String context)

Description copied from interface: IncrementalSyncSubscriptionDao

Get all subscription within a context

Specified by:

getSubscriptionsByContext in interface IncrementalSyncSubscriptionDao

Returns:

getSubscriptionsByContext

public Collection<IncrementalSyncSubscriptionEntity> getSubscriptionsByContext(String context,
 IncrementalSyncState state)

Description copied from interface: IncrementalSyncSubscriptionDao

Get all subscription within a context and state

Specified by:

getSubscriptionsByContext in interface IncrementalSyncSubscriptionDao

Returns:

removeSubscription

public boolean removeSubscription(long id)

Specified by:

removeSubscription in interface IncrementalSyncSubscriptionDao

Returns:

removeAllSubscriptions

public int removeAllSubscriptions(String contextKey)

Description copied from interface: IncrementalSyncSubscriptionDao

Remove all subscription belong to a context key

Specified by:

removeAllSubscriptions in interface IncrementalSyncSubscriptionDao

removeExpiredSubscriptions

public int removeExpiredSubscriptions(String contextKey,
 Instant ttl)

Description copied from interface: IncrementalSyncSubscriptionDao

Remove expired subscription belong to a context key

Specified by:

removeExpiredSubscriptions in interface IncrementalSyncSubscriptionDao

Returns:

removeDeletedSubscriptions

public int removeDeletedSubscriptions(String contextKey)

Description copied from interface: IncrementalSyncSubscriptionDao

Remove deleted subscription belong to a context key

Specified by:

removeDeletedSubscriptions in interface IncrementalSyncSubscriptionDao

Returns: