fr.gouv.vitam.common.database.server.elasticsearch

Class IndexationHelper

java.lang.Object

fr.gouv.vitam.common.database.server.elasticsearch.IndexationHelper

public class IndexationHelper
extends Object

IndexationHelper useful method for indexation

Field Summary

Fields

Modifier and Type	Field and Description
static String	TYPEUNIQUE

Constructor Summary

Constructors

Constructor and Description
IndexationHelper()

Method Summary

Modifier and Type	Method and Description
static IndexationResult	getFullKOResult(IndexParameters indexParameters, String message) Get KO Result for reindexation orders
static IndexationResult	getKOResult(SwitchIndexParameters switchIndexParameters, String message) Get KO Result for switching order
static IndexationResult	reindex(com.mongodb.client.MongoCollection<org.bson.Document> collection, ElasticsearchAccess esClient, List<Integer> tenants, InputStream mapping) reindex a collection on a tenant list with a esmapping file
static void	switchIndex(String aliasName, String newIndex, ElasticsearchAccess esClient) switch index, attach a new index to an existing alias

Methods inherited from class java.lang.Object

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

Field Detail

TYPEUNIQUE

public static final String TYPEUNIQUE

Constructor Detail

IndexationHelper

public IndexationHelper()

Method Detail

reindex

public static IndexationResult reindex(com.mongodb.client.MongoCollection<org.bson.Document> collection,
                                       ElasticsearchAccess esClient,
                                       List<Integer> tenants,
                                       InputStream mapping)
                                throws IOException

reindex a collection on a tenant list with a esmapping file

Parameters:

collection - the collection to be reindexed

esClient - the elastic client to be used to reindex

tenants - the tenant list on which to reindex

mapping - the es mapping as a string

Returns:

the result of the reindexation as a IndexationResult object

Throws:

IOException

switchIndex

public static void switchIndex(String aliasName,
                               String newIndex,
                               ElasticsearchAccess esClient)
                        throws DatabaseException

switch index, attach a new index to an existing alias

Parameters:

aliasName - the name of the alias

newIndex - the new index name to switch on

esClient - the elastic client

Throws:

DatabaseException - if an error occurs

getFullKOResult

public static IndexationResult getFullKOResult(IndexParameters indexParameters,
                                               String message)

Get KO Result for reindexation orders

Parameters:

indexParameters - the index parameter

message - the message to be added

Returns:

the final result as an IndexationResult object

getKOResult

public static IndexationResult getKOResult(SwitchIndexParameters switchIndexParameters,
                                           String message)

Get KO Result for switching order

Parameters:

switchIndexParameters - the switch index parameter

message - the message to be added

Returns:

the final result as an IndexationResult object