Package edu.internet2.middleware.grouper.sqlCache

Class SqlCacheMembershipDao

java.lang.Object

edu.internet2.middleware.grouper.sqlCache.SqlCacheMembershipDao

public class SqlCacheMembershipDao
extends Object

dao for sql cache memberships

Constructor Summary

Constructors

Constructor	Description
SqlCacheMembershipDao()

Method Summary

Modifier and Type	Method	Description
static void	delete(SqlCacheMembership sqlCacheMembership)
static int	deleteSqlCacheMembershipsBySqlCacheGroupInternalId(Long sqlCacheGroupInternalId, Connection connection)
static int	deleteSqlCacheMembershipsIfCacheable(Collection<MultiKey> ownerIdFieldNameSourceIdSubjectIdsEndedMicros, Connection connection)	Things to delete from sql cache memberships.
static int	insertSqlCacheMembershipsIfCacheable(Collection<MultiKey> ownerIdFieldNameSourceIdSubjectIdStartedMicros, Connection connection)	things to add to sql cache memberships.
static SqlCacheMembership	retrieveByCacheGroupInternalIdAndMemberInternalId(Long cacheGroupInternalId, Long memberInternalId)	select grouper sync by id
static Map<MultiKey,SqlCacheMembership>	retrieveByCacheGroupInternalIdsMemberInternalIds(Collection<MultiKey> cacheGroupInternalIdsMemberInternalIds, Connection connection)	select caches by cache group internal ids and member internal ids
static Set<Long>	retrieveSqlCacheGroupIdsCachedInHistory(Set<Long> sqlCacheGroupIds, Connection connection)
static boolean	store(SqlCacheMembership sqlCacheMembership)
static int	store(Collection<SqlCacheMembership> sqlCacheMemberships)
static int	store(Collection<SqlCacheMembership> sqlCacheMemberships, Connection connection, boolean isInsert, boolean retryBatchStoreFailures, boolean ignoreRetriedBatchStoreFailures)

Methods inherited from class java.lang.Object

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

Constructor Details

SqlCacheMembershipDao

public SqlCacheMembershipDao()

Method Details

store

public static boolean store(SqlCacheMembership sqlCacheMembership)

Parameters:

connectionName -

Returns:

true if changed

retrieveByCacheGroupInternalIdAndMemberInternalId

public static SqlCacheMembership retrieveByCacheGroupInternalIdAndMemberInternalId(Long cacheGroupInternalId,
 Long memberInternalId)

select grouper sync by id

Parameters:

theConnectionName -

id -

Returns:

the sync

delete

public static void delete(SqlCacheMembership sqlCacheMembership)

Parameters:

sqlCacheMembership -

insertSqlCacheMembershipsIfCacheable

public static int insertSqlCacheMembershipsIfCacheable(Collection<MultiKey> ownerIdFieldNameSourceIdSubjectIdStartedMicros,
 Connection connection)

things to add to sql cache memberships. 5 fields in multikey: ownerId, fieldName, sourceId, subjectId, microsSince1970whenMembershipStarted (Long)

Parameters:

ownerIdFieldNameSourceIdSubjectIdStartedMicros -

connection - optionally pass connection to use

Returns:

number of cache membership inserts

deleteSqlCacheMembershipsIfCacheable

public static int deleteSqlCacheMembershipsIfCacheable(Collection<MultiKey> ownerIdFieldNameSourceIdSubjectIdsEndedMicros,
 Connection connection)

Things to delete from sql cache memberships. Also possibly add to history if cachable. 5 fields in multikey: ownerId, fieldName, sourceId, subjectId, microsSince1970whenMembershipEnded (Long)

Parameters:

ownerIdFieldNameSourceIdSubjectIdStartedMillis -

connection - optionally pass connection to use

Returns:

number of cache membership deletes

deleteSqlCacheMembershipsBySqlCacheGroupInternalId

public static int deleteSqlCacheMembershipsBySqlCacheGroupInternalId(Long sqlCacheGroupInternalId,
 Connection connection)

Parameters:

sqlCacheGroupInternalId -

connection - optionally pass connection to use

Returns:

number of changes

store

public static int store(Collection<SqlCacheMembership> sqlCacheMemberships)

Parameters:

sqlCacheMemberships -

Returns:

number of changes

store

public static int store(Collection<SqlCacheMembership> sqlCacheMemberships,
 Connection connection,
 boolean isInsert,
 boolean retryBatchStoreFailures,
 boolean ignoreRetriedBatchStoreFailures)

Parameters:

sqlCacheMemberships -

connection - optionally pass connection to use

isInsert -

Returns:

number of changes

retrieveByCacheGroupInternalIdsMemberInternalIds

public static Map<MultiKey,SqlCacheMembership> retrieveByCacheGroupInternalIdsMemberInternalIds(Collection<MultiKey> cacheGroupInternalIdsMemberInternalIds,
 Connection connection)

select caches by cache group internal ids and member internal ids

Parameters:

cacheGroupInternalIdsMemberInternalIds -

connection -

Returns:

the caches if they exist

retrieveSqlCacheGroupIdsCachedInHistory

public static Set<Long> retrieveSqlCacheGroupIdsCachedInHistory(Set<Long> sqlCacheGroupIds,
 Connection connection)

Parameters:

sqlCacheGroupIds -

connection -

Returns:

sqlCacheGroupIds being cached in history