fr.gouv.vitam.functional.administration.common.server

Class ElasticsearchAccessFunctionalAdmin

java.lang.Object

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

fr.gouv.vitam.functional.administration.common.server.ElasticsearchAccessFunctionalAdmin

All Implemented Interfaces:

DatabaseConnection

public class ElasticsearchAccessFunctionalAdmin
extends ElasticsearchAccess

ElasticSearch model with MongoDB as main database

Field Summary

Fields

Modifier and Type	Field and Description
static String	MAPPING_ACCESSCONTRACT_FILE
static String	MAPPING_ACCESSION_REGISTER_DETAIL_FILE
static String	MAPPING_ACCESSION_REGISTER_SUMMARY_FILE
static String	MAPPING_AGENCIES_FILE
static String	MAPPING_CONTEXT_FILE
static String	MAPPING_FORMAT_FILE
static String	MAPPING_INGESTCONTRACT_FILE
static String	MAPPING_PROFILE_FILE
static String	MAPPING_RULE_FILE
static String	MAPPING_SECURITY_PROFILE_FILE

Fields inherited from class fr.gouv.vitam.common.database.server.elasticsearch.ElasticsearchAccess

client, clusterName, default_builder, nodes

Constructor Summary

Constructors

Constructor and Description
ElasticsearchAccessFunctionalAdmin(String clusterName, List<ElasticsearchNode> nodes)

Method Summary

Modifier and Type	Method and Description
boolean	addIndex(FunctionalAdminCollections collection) Add a type to an index
void	deleteIndex(FunctionalAdminCollections collection) Delete one index
void	refreshIndex(FunctionalAdminCollections collection) refresh an index
protected org.elasticsearch.action.search.SearchResponse	search(FunctionalAdminCollections collection, org.elasticsearch.index.query.QueryBuilder query, org.elasticsearch.index.query.QueryBuilder filter)

Methods inherited from class fr.gouv.vitam.common.database.server.elasticsearch.ElasticsearchAccess

checkConnection, close, createIndexAndAliasIfAliasNotExists, createIndexWithoutAlias, getClient, getClusterName, getInfo, getNodes, getSettings, settings, switchIndex

Methods inherited from class java.lang.Object

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

Field Detail

MAPPING_FORMAT_FILE

public static final String MAPPING_FORMAT_FILE

See Also:

Constant Field Values

MAPPING_RULE_FILE

public static final String MAPPING_RULE_FILE

See Also:

Constant Field Values

MAPPING_INGESTCONTRACT_FILE

public static final String MAPPING_INGESTCONTRACT_FILE

See Also:

Constant Field Values

MAPPING_ACCESSCONTRACT_FILE

public static final String MAPPING_ACCESSCONTRACT_FILE

See Also:

Constant Field Values

MAPPING_AGENCIES_FILE

public static final String MAPPING_AGENCIES_FILE

See Also:

Constant Field Values

MAPPING_PROFILE_FILE

public static final String MAPPING_PROFILE_FILE

See Also:

Constant Field Values

MAPPING_CONTEXT_FILE

public static final String MAPPING_CONTEXT_FILE

See Also:

Constant Field Values

MAPPING_SECURITY_PROFILE_FILE

public static final String MAPPING_SECURITY_PROFILE_FILE

See Also:

Constant Field Values

MAPPING_ACCESSION_REGISTER_SUMMARY_FILE

public static final String MAPPING_ACCESSION_REGISTER_SUMMARY_FILE

See Also:

Constant Field Values

MAPPING_ACCESSION_REGISTER_DETAIL_FILE

public static final String MAPPING_ACCESSION_REGISTER_DETAIL_FILE

See Also:

Constant Field Values

Constructor Detail

ElasticsearchAccessFunctionalAdmin

public ElasticsearchAccessFunctionalAdmin(String clusterName,
                                          List<ElasticsearchNode> nodes)
                                   throws VitamException,
                                          IOException

Parameters:

clusterName -

nodes -

Throws:

VitamException

IOException

Method Detail

deleteIndex

public final void deleteIndex(FunctionalAdminCollections collection)
                       throws ReferentialException

Delete one index

Parameters:

collection -

Throws:

ReferentialException

addIndex

public final boolean addIndex(FunctionalAdminCollections collection)

Add a type to an index

Parameters:

collection -

Returns:

True if ok

refreshIndex

public final void refreshIndex(FunctionalAdminCollections collection)

refresh an index

Parameters:

collection -

search

protected final org.elasticsearch.action.search.SearchResponse search(FunctionalAdminCollections collection,
                                                                      org.elasticsearch.index.query.QueryBuilder query,
                                                                      org.elasticsearch.index.query.QueryBuilder filter)
                                                               throws ReferentialException

Parameters:

collection -

query - as in DSL mode "{ "fieldname" : "value" }" "{ "match" : { "fieldname" : "value" } }" "{ "ids" : { " values" : [list of id] } }"

filter -

Returns:

a structure as ResultInterface

Throws:

ReferentialException