fr.gouv.vitam.metadata.core.migration

Class DataMigrationRepository

java.lang.Object

fr.gouv.vitam.metadata.core.migration.DataMigrationRepository

public class DataMigrationRepository
extends Object

Repository for mongo data migration

Field Summary

Fields

Modifier and Type	Field and Description
static com.mongodb.BasicDBObject	UNIT_VITAM_GRAPH_PROJECTION

Constructor Summary

Constructors

Constructor and Description
DataMigrationRepository() Constructor

Method Summary

Modifier and Type	Method and Description
void	bulkReplaceUnits(List<Unit> updatedUnits) Replaces all units in unordered bulk mode
void	bulkUpgradeObjectGroups(List<String> objectGroupIds) Replaces all units in unordered bulk mode
Map<String,Unit>	getUnitGraphByIds(Collection<String> unitIds) Returns units graph by Ids
CloseableIterator<List<String>>	selectObjectGroupBulk() Returns all object group ids to migrate by chunks of (at most) BULK_SIZE.
CloseableIterator<List<Unit>>	selectUnitBulkInTopDownHierarchyLevel() Returns all unit ids to migrate sorted by top-down hierarchy level, by chunks of (at most) BULK_SIZE.

Methods inherited from class java.lang.Object

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

Field Detail

UNIT_VITAM_GRAPH_PROJECTION

public static final com.mongodb.BasicDBObject UNIT_VITAM_GRAPH_PROJECTION

Constructor Detail

DataMigrationRepository

public DataMigrationRepository()

Constructor

Method Detail

selectUnitBulkInTopDownHierarchyLevel

public CloseableIterator<List<Unit>> selectUnitBulkInTopDownHierarchyLevel()

Returns all unit ids to migrate sorted by top-down hierarchy level, by chunks of (at most) BULK_SIZE.

getUnitGraphByIds

public Map<String,Unit> getUnitGraphByIds(Collection<String> unitIds)

Returns units graph by Ids

bulkReplaceUnits

public void bulkReplaceUnits(List<Unit> updatedUnits)

Replaces all units in unordered bulk mode

selectObjectGroupBulk

public CloseableIterator<List<String>> selectObjectGroupBulk()

Returns all object group ids to migrate by chunks of (at most) BULK_SIZE.

bulkUpgradeObjectGroups

public void bulkUpgradeObjectGroups(List<String> objectGroupIds)

Replaces all units in unordered bulk mode