fr.gouv.vitam.logbook.common.server.database.collections

Class LogbookElasticsearchAccess

java.lang.Object

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

fr.gouv.vitam.logbook.common.server.database.collections.LogbookElasticsearchAccess

All Implemented Interfaces:

DatabaseConnection

public class LogbookElasticsearchAccess
extends ElasticsearchAccess

ElasticSearch model with MongoDB as main database with management of index and index entries

Field Summary

Fields

Modifier and Type	Field and Description
static String	MAPPING_LOGBOOK_OPERATION_FILE

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

client, clusterName, default_builder, nodes

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
boolean	addIndex(LogbookCollections collection, Integer tenantId) Add a type to an index
boolean	deleteIndex(LogbookCollections collection, Integer tenantId) Delete an index
void	refreshIndex(LogbookCollections collection, Integer tenantId) Refresh an index
org.elasticsearch.action.search.SearchResponse	search(LogbookCollections collection, Integer tenantId, org.elasticsearch.index.query.QueryBuilder query, org.elasticsearch.index.query.QueryBuilder filter, List<org.elasticsearch.search.sort.SortBuilder> sorts, int offset, int limit) Search entries in the ElasticSearch index.

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_LOGBOOK_OPERATION_FILE

public static final String MAPPING_LOGBOOK_OPERATION_FILE

See Also:

Constant Field Values

Constructor Detail

LogbookElasticsearchAccess

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

Parameters:

clusterName - cluster name

nodes - elasticsearch node

Throws:

VitamException - if elasticsearch nodes list is empty/null

IOException

Method Detail

deleteIndex

public final boolean deleteIndex(LogbookCollections collection,
                                 Integer tenantId)

Delete an index

Parameters:

collection - collection of index

tenantId - tenant Id

Returns:

True if deleted

addIndex

public final boolean addIndex(LogbookCollections collection,
                              Integer tenantId)

Add a type to an index

Parameters:

collection - collection of index

tenantId - tenant Id

Returns:

True if added

refreshIndex

public final void refreshIndex(LogbookCollections collection,
                               Integer tenantId)

Refresh an index

Parameters:

collection - collection of index

tenantId - tenant Id

search

public final org.elasticsearch.action.search.SearchResponse search(LogbookCollections collection,
                                                                   Integer tenantId,
                                                                   org.elasticsearch.index.query.QueryBuilder query,
                                                                   org.elasticsearch.index.query.QueryBuilder filter,
                                                                   List<org.elasticsearch.search.sort.SortBuilder> sorts,
                                                                   int offset,
                                                                   int limit)
                                                            throws LogbookException

Search entries in the ElasticSearch index.

Parameters:

collection - collection of index

tenantId - tenant Id

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

filter - the filter

sorts - the list of sort

offset - the offset

limit - the limit

Returns:

a structure as SearchResponse

Throws:

LogbookException - thrown of an error occurred while executing the request