fr.gouv.vitam.common.database.api.impl

Class VitamElasticsearchRepository

java.lang.Object

fr.gouv.vitam.common.database.api.impl.VitamElasticsearchRepository

All Implemented Interfaces:

VitamRepository

public class VitamElasticsearchRepository
extends Object
implements VitamRepository

Implementation for Elasticsearch

Field Summary

Fields

Modifier and Type	Field and Description
static String	IDENTIFIER

Constructor Summary

Constructors

Constructor and Description
VitamElasticsearchRepository(org.elasticsearch.client.Client client, String indexName, boolean indexByTenant) VitamElasticsearchRepository Constructor

Method Summary

Modifier and Type	Method and Description
com.mongodb.client.FindIterable<org.bson.Document>	findByFieldsDocuments(Map<String,String> fields, int mongoBatchSize, Integer tenant) Return iterable over document for the given collection for a specific tenant and fields
Optional<org.bson.Document>	findByIdentifier(String identifier) Find by identifier for collections cross tenant
Optional<org.bson.Document>	findByIdentifierAndTenant(String identifier, Integer tenant) find by identifier for all tenant
com.mongodb.client.FindIterable<org.bson.Document>	findDocuments(int mongoBatchSize) Return iterable over document for the given collection
com.mongodb.client.FindIterable<org.bson.Document>	findDocuments(int mongoBatchSize, Integer tenant) Return iterable over document for the given collection for a specific tenant
Optional<org.bson.Document>	getByID(String id, Integer tenant) Get vitam document by id
long	purge() Remove by tenant for collection cross-tenant
long	purge(Integer tenant) Remove by tenant for collection multi-tenant
void	remove(String id, Integer tenant) Remove document by id
void	removeByNameAndTenant(String name, Integer tenant) Remove collection by name and tenant
void	save(org.bson.Document document) Save vitam document
void	save(List<org.bson.Document> documents) Save a list of vitam documents
void	saveLogbook(List<org.bson.Document> documents) Reindex Logbook documents
VitamRepositoryStatus	saveOrUpdate(org.bson.Document document) Save or updatevitam document
void	saveOrUpdate(List<org.bson.Document> documents) Save or update a list of vitam documents
void	saveUnit(List<org.bson.Document> documents) Reindex Unit documents

Methods inherited from class java.lang.Object

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

Field Detail

IDENTIFIER

public static final String IDENTIFIER

See Also:

Constant Field Values

Constructor Detail

VitamElasticsearchRepository

public VitamElasticsearchRepository(org.elasticsearch.client.Client client,
                                    String indexName,
                                    boolean indexByTenant)

VitamElasticsearchRepository Constructor

Parameters:

client - the es client

indexName - the name of the index

indexByTenant - specifies if the index is for a specific tenant or not

Method Detail

save

public void save(org.bson.Document document)
          throws DatabaseException

Description copied from interface: VitamRepository

Save vitam document

Specified by:

save in interface VitamRepository

Parameters:

document - the document to be saved

Throws:

DatabaseException - in case error with database occurs

saveOrUpdate

public VitamRepositoryStatus saveOrUpdate(org.bson.Document document)
                                   throws DatabaseException

Description copied from interface: VitamRepository

Save or updatevitam document

Specified by:

saveOrUpdate in interface VitamRepository

Parameters:

document - the document to be saved

Returns:

status CREATED or UPDATED

Throws:

DatabaseException - in case error with database occurs

save

public void save(List<org.bson.Document> documents)
          throws DatabaseException

Description copied from interface: VitamRepository

Save a list of vitam documents

Specified by:

save in interface VitamRepository

Parameters:

documents - the list of documents to be saved

Throws:

DatabaseException - in case error with database occurs

saveUnit

public void saveUnit(List<org.bson.Document> documents)
              throws DatabaseException

Reindex Unit documents

Parameters:

documents - documents to be reindexed

Throws:

DatabaseException - if the ES insert was in error

saveLogbook

public void saveLogbook(List<org.bson.Document> documents)
                 throws DatabaseException

Reindex Logbook documents

Parameters:

documents - documents to be reindexed

Throws:

DatabaseException - if the ES insert was in error

saveOrUpdate

public void saveOrUpdate(List<org.bson.Document> documents)
                  throws DatabaseException

Description copied from interface: VitamRepository

Save or update a list of vitam documents

Specified by:

saveOrUpdate in interface VitamRepository

Parameters:

documents - the list of document to be saved orupdated

Throws:

DatabaseException - in case error with database occurs

remove

public void remove(String id,
                   Integer tenant)
            throws DatabaseException

Description copied from interface: VitamRepository

Remove document by id

Specified by:

remove in interface VitamRepository

Parameters:

id - the id of the document to be removed

tenant - the tenant of the document to be removed

Throws:

DatabaseException - in case error with database occurs

removeByNameAndTenant

public void removeByNameAndTenant(String name,
                                  Integer tenant)
                           throws DatabaseException

Description copied from interface: VitamRepository

Remove collection by name and tenant

Specified by:

removeByNameAndTenant in interface VitamRepository

Parameters:

name - the name of the collection to be removed

tenant - the tenant of the collection to be removed

Throws:

DatabaseException - in case error with database occurs

purge

public long purge(Integer tenant)
           throws DatabaseException

Description copied from interface: VitamRepository

Remove by tenant for collection multi-tenant

Specified by:

purge in interface VitamRepository

Parameters:

tenant - the tenant

Returns:

the number of deleted documents

Throws:

DatabaseException - in case error with database occurs

purge

public long purge()
           throws DatabaseException

Description copied from interface: VitamRepository

Remove by tenant for collection cross-tenant

Specified by:

purge in interface VitamRepository

Returns:

number of purged documents

Throws:

DatabaseException - in case error with database occurs

getByID

public Optional<org.bson.Document> getByID(String id,
                                           Integer tenant)
                                    throws DatabaseException

Description copied from interface: VitamRepository

Get vitam document by id

Specified by:

getByID in interface VitamRepository

Parameters:

id - the document id

tenant - the tenant of the document

Returns:

the document if found

Throws:

DatabaseException - in case error with database occurs

findByIdentifierAndTenant

public Optional<org.bson.Document> findByIdentifierAndTenant(String identifier,
                                                             Integer tenant)
                                                      throws DatabaseException

Description copied from interface: VitamRepository

find by identifier for all tenant

Specified by:

findByIdentifierAndTenant in interface VitamRepository

Parameters:

identifier - the identifier of the document

tenant - the tenant of the document

Returns:

the document if found

Throws:

DatabaseException - in case error with database occurs

findByIdentifier

public Optional<org.bson.Document> findByIdentifier(String identifier)
                                             throws DatabaseException

Description copied from interface: VitamRepository

Find by identifier for collections cross tenant

Specified by:

findByIdentifier in interface VitamRepository

Parameters:

identifier - the identifier of the document

Returns:

the document if found

Throws:

DatabaseException - in case error with database occurs

findByFieldsDocuments

public com.mongodb.client.FindIterable<org.bson.Document> findByFieldsDocuments(Map<String,String> fields,
                                                                                int mongoBatchSize,
                                                                                Integer tenant)

Description copied from interface: VitamRepository

Return iterable over document for the given collection for a specific tenant and fields

Specified by:

findByFieldsDocuments in interface VitamRepository

Parameters:

fields - list of fields for filter

mongoBatchSize - mongoBatchSize

tenant - tenant id

Returns:

iterable over document for the given collection

findDocuments

public com.mongodb.client.FindIterable<org.bson.Document> findDocuments(int mongoBatchSize,
                                                                        Integer tenant)

Description copied from interface: VitamRepository

Return iterable over document for the given collection for a specific tenant

Specified by:

findDocuments in interface VitamRepository

Parameters:

mongoBatchSize - mongoBatchSize

tenant - tenant id

Returns:

iterable over document for the given collection

findDocuments

public com.mongodb.client.FindIterable<org.bson.Document> findDocuments(int mongoBatchSize)

Description copied from interface: VitamRepository

Return iterable over document for the given collection

Specified by:

findDocuments in interface VitamRepository

Parameters:

mongoBatchSize - mongoBatchSize

Returns:

iterable over document for the given collection