fr.gouv.vitam.functional.administration.migration.r7r8

Class AccessionRegisterMigrationRepository

java.lang.Object

fr.gouv.vitam.functional.administration.migration.r7r8.AccessionRegisterMigrationRepository

public class AccessionRegisterMigrationRepository
extends Object

Repository for mongo data migration

Constructor Summary

Constructors

Constructor and Description
AccessionRegisterMigrationRepository()
AccessionRegisterMigrationRepository(VitamRepositoryProvider vitamRepositoryProvider)

Method Summary

Modifier and Type	Method and Description
void	bulkElasticsearch(FunctionalAdminCollections functionalAdminCollections, List<org.bson.Document> collection)
void	bulkMongo(FunctionalAdminCollections functionalAdminCollections, List<com.mongodb.client.model.WriteModel<org.bson.Document>> collection)
void	bulkReplaceAccessionRegisters(List<org.bson.Document> updatedDocuments, FunctionalAdminCollections functionalAdminCollections) Replace all accession register (Detail or summary)
void	purgeElasticsearch(FunctionalAdminCollections functionalAdminCollections)
void	purgeMongo(FunctionalAdminCollections functionalAdminCollections)
CloseableIterator<List<org.bson.Document>>	selectAccessionRegistesBulk(FunctionalAdminCollections collection) Returns all AccessionRegister to migrate, 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

Constructor Detail

AccessionRegisterMigrationRepository

public AccessionRegisterMigrationRepository()

AccessionRegisterMigrationRepository

public AccessionRegisterMigrationRepository(VitamRepositoryProvider vitamRepositoryProvider)

Method Detail

selectAccessionRegistesBulk

public CloseableIterator<List<org.bson.Document>> selectAccessionRegistesBulk(FunctionalAdminCollections collection)

Returns all AccessionRegister to migrate, by chunks of (at most) BULK_SIZE.

purgeMongo

public void purgeMongo(FunctionalAdminCollections functionalAdminCollections)

purgeElasticsearch

public void purgeElasticsearch(FunctionalAdminCollections functionalAdminCollections)

bulkMongo

public void bulkMongo(FunctionalAdminCollections functionalAdminCollections,
                      List<com.mongodb.client.model.WriteModel<org.bson.Document>> collection)
               throws DatabaseException

Throws:

DatabaseException

bulkElasticsearch

public void bulkElasticsearch(FunctionalAdminCollections functionalAdminCollections,
                              List<org.bson.Document> collection)
                       throws DatabaseException

Throws:

DatabaseException

bulkReplaceAccessionRegisters

public void bulkReplaceAccessionRegisters(List<org.bson.Document> updatedDocuments,
                                          FunctionalAdminCollections functionalAdminCollections)
                                   throws DatabaseException

Replace all accession register (Detail or summary)

Throws:

DatabaseException