Package edu.internet2.middleware.grouper.app.dataProvider

Class GrouperDataProviderLogic

java.lang.Object

edu.internet2.middleware.grouper.app.dataProvider.GrouperDataProviderLogic

public class GrouperDataProviderLogic
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static Map<String,Object>	testingDebugMap	last debug map from the most recent full sync, for testing purposes only.

Constructor Summary

Constructors

Constructor	Description
GrouperDataProviderLogic()

Method Summary

Modifier and Type	Method	Description
static String	dataProviderStemName()
static String	dataProviderSubjectListSyncAllowedGroupName()
static void	deleteOldDataFieldRowHistory(StringBuilder jobMessage, Hib3GrouperLoaderLog hib3GrouploaderLog)	delete old data field and data row history records based on configured retention.
void	setGrouperDataProvider(GrouperDataProvider grouperDataProvider)
void	setGrouperDataProviderSync(GrouperDataProviderSync grouperDataProviderSync)
void	syncFull()	run a full sync for this data provider.
void	syncIncremental()	run an incremental sync for this data provider.
void	syncSubjects(Set<String> subjectIds, Set<String> subjectIdentifiers, Map<String,Set<String>> sourceToSubjectIds, Map<String,Set<String>> sourceToSubjectIdentifiers)	sync specific subjects for this data provider (e.g. from a web service call).

Methods inherited from class java.lang.Object

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

Field Details

testingDebugMap

public static Map<String,Object> testingDebugMap

last debug map from the most recent full sync, for testing purposes only. set at the end of syncFull() so tests can inspect accumulated counts and change examples.

Constructor Details

GrouperDataProviderLogic

public GrouperDataProviderLogic()

Method Details

setGrouperDataProviderSync

public void setGrouperDataProviderSync(GrouperDataProviderSync grouperDataProviderSync)

setGrouperDataProvider

public void setGrouperDataProvider(GrouperDataProvider grouperDataProvider)

dataProviderStemName

public static String dataProviderStemName()

Returns:

the stem name

dataProviderSubjectListSyncAllowedGroupName

public static String dataProviderSubjectListSyncAllowedGroupName()

Returns:

the group name

syncFull

public void syncFull()

run a full sync for this data provider. retrieves distinct subject ids from all source queries and from grouper, unions them into one sorted list, and processes in batches of configurable size. each batch loads source data and grouper data for that range, compares, and writes changes. after all batches, any missed subject ids are processed as a straggler pass.

syncIncremental

public void syncIncremental()

run an incremental sync for this data provider. queries the change log to find subjects that changed since the last sync, then loads and processes only those subjects.

syncSubjects

public void syncSubjects(Set<String> subjectIds,
 Set<String> subjectIdentifiers,
 Map<String,Set<String>> sourceToSubjectIds,
 Map<String,Set<String>> sourceToSubjectIdentifiers)

sync specific subjects for this data provider (e.g. from a web service call). loads config and then delegates to the incremental sync logic for the given subjects.

Parameters:

subjectIds - subject ids to sync (no source specified)

subjectIdentifiers - subject identifiers to sync (no source specified)

sourceToSubjectIds - subject ids keyed by source id

sourceToSubjectIdentifiers - subject identifiers keyed by source id

deleteOldDataFieldRowHistory

public static void deleteOldDataFieldRowHistory(StringBuilder jobMessage,
 Hib3GrouperLoaderLog hib3GrouploaderLog)

delete old data field and data row history records based on configured retention. called from OTHER_JOB_cleanLogs (GrouperDaemonDeleteOldRecords)

Parameters:

jobMessage -

hib3GrouploaderLog -