Package fr.gouv.vitam.metadata.core.database.collections

Class ElasticsearchAccessMetadata

java.lang.Object

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

fr.gouv.vitam.metadata.core.database.collections.ElasticsearchAccessMetadata

All Implemented Interfaces:

DatabaseConnection

public class ElasticsearchAccessMetadata
extends ElasticsearchAccess

ElasticSearch model with MongoDB as main database

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	MAPPING_OBJECT_GROUP_FILE
static java.lang.String	MAPPING_UNIT_FILE

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

clusterName, DEFAULT_LIMIT_SCROLL, DEFAULT_SCROLL_TIMEOUT, nodes, SCROLL_ACTIVATE_KEYWORD

Constructor Summary

Constructors

Constructor	Description
ElasticsearchAccessMetadata(java.lang.String clusterName, java.util.List<ElasticsearchNode> nodes)

Method Summary

Modifier and Type	Method	Description
java.util.Map<java.lang.String,java.lang.String>	addIndex(MetadataCollections collection, java.lang.Integer tenantId)	Add a type to an index
org.elasticsearch.action.search.SearchResponse	basicSearch(MetadataCollections collection, java.lang.Integer tenantId, java.util.List<org.elasticsearch.search.aggregations.AggregationBuilder> aggregations, org.elasticsearch.index.query.QueryBuilder query)	Makes a search request on elasticsearch on a collection with aggregations and a query
void	deleteBulkOGEntriesIndexes(java.util.List<java.lang.String> ids, java.lang.Integer tenantId)
void	deleteBulkUnitsEntriesIndexes(java.util.List<java.lang.String> ids, java.lang.Integer tenantId)
void	insertFullDocument(MetadataCollections collection, java.lang.Integer tenantId, java.lang.String id, MetadataDocument doc)	Insert one element
void	insertFullDocuments(MetadataCollections collection, java.lang.Integer tenantId, java.util.Collection<? extends MetadataDocument> documents)
protected Result	search(MetadataCollections collection, java.lang.Integer tenantId, org.elasticsearch.index.query.QueryBuilder query, java.util.List<org.elasticsearch.search.sort.SortBuilder> sorts, int offset, java.lang.Integer limit, java.util.List<org.elasticsearch.search.aggregations.AggregationBuilder> facets, java.lang.String scrollId, java.lang.Integer scrollTimeout)
void	updateFullDocument(MetadataCollections collection, java.lang.Integer tenantId, java.lang.String id, MetadataDocument metadataDocument)	Update one element fully

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

checkConnection, clearScroll, close, createIndex, createIndex, createIndexAndAliasIfAliasNotExists, createIndexAndAliasIfAliasNotExists, createIndexWithoutAlias, delete, deleteIndex, deleteIndexByAlias, existsAlias, existsIndex, getAlias, getClient, getClusterName, getInfo, getNodes, indexEntries, indexEntry, purgeIndex, purgeIndex, refreshIndex, search, search, search, search, switchAliasIndex, switchIndex, updateEntry

Methods inherited from class java.lang.Object

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

Field Detail

MAPPING_UNIT_FILE

public static final java.lang.String MAPPING_UNIT_FILE

See Also:

Constant Field Values

MAPPING_OBJECT_GROUP_FILE

public static final java.lang.String MAPPING_OBJECT_GROUP_FILE

See Also:

Constant Field Values

Constructor Detail

ElasticsearchAccessMetadata

public ElasticsearchAccessMetadata(java.lang.String clusterName,
                                   java.util.List<ElasticsearchNode> nodes)
                            throws VitamException,
                                   java.io.IOException

Parameters:

clusterName - cluster name

nodes - list of elasticsearch node

Throws:

VitamException - if nodes list is empty

java.io.IOException

Method Detail

addIndex

public final java.util.Map<java.lang.String,java.lang.String> addIndex(MetadataCollections collection,
                                                                             java.lang.Integer tenantId)

Add a type to an index

Parameters:

collection - the working metadata collection

tenantId - the tenant for operation

Returns:

key aliasName value indexName or empty

search

protected final Result search(MetadataCollections collection,
                              java.lang.Integer tenantId,
                              org.elasticsearch.index.query.QueryBuilder query,
                              java.util.List<org.elasticsearch.search.sort.SortBuilder> sorts,
                              int offset,
                              java.lang.Integer limit,
                              java.util.List<org.elasticsearch.search.aggregations.AggregationBuilder> facets,
                              java.lang.String scrollId,
                              java.lang.Integer scrollTimeout)
                       throws MetaDataExecutionException,
                              BadRequestException

Parameters:

collection -

tenantId -

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

sorts - the list of sort

facets - the list of facet

Returns:

a structure as ResultInterface

Throws:

MetaDataExecutionException

BadRequestException

basicSearch

public org.elasticsearch.action.search.SearchResponse basicSearch(MetadataCollections collection,
                                                                  java.lang.Integer tenantId,
                                                                  java.util.List<org.elasticsearch.search.aggregations.AggregationBuilder> aggregations,
                                                                  org.elasticsearch.index.query.QueryBuilder query)
                                                           throws MetaDataExecutionException

Makes a search request on elasticsearch on a collection with aggregations and a query

Parameters:

collection - on which the request is made

tenantId - on which the request is made

aggregations - elasticsearch

query - elasticsearch

Returns:

the elasticsearch SearchResponse

Throws:

MetaDataExecutionException

insertFullDocument

public void insertFullDocument(MetadataCollections collection,
                               java.lang.Integer tenantId,
                               java.lang.String id,
                               MetadataDocument doc)
                        throws MetaDataExecutionException

Insert one element

Parameters:

collection -

tenantId -

id -

doc - full document to insert

Throws:

MetaDataExecutionException

insertFullDocuments

public void insertFullDocuments(MetadataCollections collection,
                                java.lang.Integer tenantId,
                                java.util.Collection<? extends MetadataDocument> documents)
                         throws MetaDataExecutionException

Throws:

MetaDataExecutionException

updateFullDocument

public void updateFullDocument(MetadataCollections collection,
                               java.lang.Integer tenantId,
                               java.lang.String id,
                               MetadataDocument metadataDocument)
                        throws MetaDataExecutionException

Update one element fully

Parameters:

collection -

tenantId -

id -

metadataDocument - full document to update

Throws:

MetaDataExecutionException

deleteBulkOGEntriesIndexes

public void deleteBulkOGEntriesIndexes(java.util.List<java.lang.String> ids,
                                       java.lang.Integer tenantId)
                                throws MetaDataExecutionException

Throws:

MetaDataExecutionException

deleteBulkUnitsEntriesIndexes

public void deleteBulkUnitsEntriesIndexes(java.util.List<java.lang.String> ids,
                                          java.lang.Integer tenantId)
                                   throws MetaDataExecutionException

Throws:

MetaDataExecutionException