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

Class AccessionRegisterMigrationRepository

java.lang.Object

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

public class AccessionRegisterMigrationRepository
extends java.lang.Object

Repository for mongo data migration

Constructor Summary

Constructors

Constructor	Description
AccessionRegisterMigrationRepository()
AccessionRegisterMigrationRepository(VitamRepositoryProvider vitamRepositoryProvider)

Method Summary

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

Throws:

DatabaseException

bulkElasticsearch

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

Throws:

DatabaseException

bulkReplaceAccessionRegisters

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

Replace all accession register (Detail or summary)

Throws:

DatabaseException