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

Class DbRequest

java.lang.Object

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

public class DbRequest
extends Object

DB Request using MongoDB only

Constructor Summary

Constructors

Constructor	Description
DbRequest()

Method Summary

Modifier and Type	Method	Description
protected Set<String>	aggregateUnitDepths(Collection<String> ids, int relativeDepth)	Aggregate Unit Depths according to parent relative Depth
void	clearEsScrollId(String scrollId)
void	deleteObjectGroups(List<String> documentsToDelete)	Delete object groups
void	deleteUnits(List<String> documentsToDelete)	Delete units
protected Result<MetadataDocument<?>>	exactDepthUnitQuery(Query realQuery, Result<MetadataDocument<?>> previous, int exactDepth, Integer tenantId, List<co.elastic.clients.elasticsearch._types.SortOptions> sorts, int offset, int limit, Map<String,co.elastic.clients.elasticsearch._types.aggregations.Aggregation> facets, String scrollId, Integer scrollTimeout, DynamicParserTokens parserTokens, boolean trackTotalHits)	Execute one Unit Query using exact Depth
void	execInsertObjectGroupRequests(List<InsertParserMultiple> requestParsers)	Inserts an object group
void	execInsertUnitRequest(InsertParserMultiple requestParser)	Deprecated.
void	execInsertUnitRequests(List<InsertParserMultiple> requests)	Inserts a unit
Result<MetadataDocument<?>>	execRequest(RequestParserMultiple requestParser, List<OntologyModel> ontologies)	The request should be already analyzed.
UpdatedDocument	execRuleRequest(String documentId, RuleActions ruleActions, Map<String,DurationData> bindRuleToDuration, OntologyValidator ontologyValidator, UnitValidator unitValidator, List<OntologyModel> ontologyModels)	Execute rule action on unit
List<UpdatedDocument>	execUpdateRequest(List<RequestById> bulkRequests, MetadataCollections metadataCollection, OntologyValidator ontologyValidator, UnitValidator unitValidator, List<OntologyModel> ontologyModels, boolean forceUpdate, boolean refreshElasticIndexPostBulkIndexing)
protected Result<MetadataDocument<?>>	executeQuery(RequestParserMultiple requestParser, RequestToAbstract requestToMongodb, int rank, Result<MetadataDocument<?>> previous, DynamicParserTokens parserTokens)	Execute one request
protected Result<MetadataDocument<?>>	lastDeleteFilterProjection(DeleteToMongodb requestToMongodb, Result<MetadataDocument<?>> last)	Finalize the queries with last True Delete
protected Result<MetadataDocument<?>>	lastSelectFilterProjection(SelectToMongodb requestToMongodb, Result<MetadataDocument<?>> last, boolean checkConsistency)	Finalize the queries with last True Select
protected Result<MetadataDocument<?>>	objectGroupQuery(Query realQuery, Result<MetadataDocument<?>> previous, Integer tenantId, List<co.elastic.clients.elasticsearch._types.SortOptions> sorts, int offset, int limit, String scrollId, Integer scrollTimeout, Map<String,co.elastic.clients.elasticsearch._types.aggregations.Aggregation> facets, DynamicParserTokens parserTokens, boolean trackTotalHits)	Execute one relative Depth ObjectGroup Query
protected Result<MetadataDocument<?>>	relativeDepthUnitQuery(Query realQuery, Result<MetadataDocument<?>> previous, int relativeDepth, Integer tenantId, List<co.elastic.clients.elasticsearch._types.SortOptions> sorts, int offset, int limit, Map<String,co.elastic.clients.elasticsearch._types.aggregations.Aggregation> facets, String scrollId, Integer scrollTimeout, DynamicParserTokens parserTokens, boolean trackTotalHits)	Execute one relative Depth Unit Query
protected Result<MetadataDocument<?>>	sameDepthUnitQuery(Query realQuery, Result<MetadataDocument<?>> previous, Integer tenantId, List<co.elastic.clients.elasticsearch._types.SortOptions> sorts, int offset, int limit, Map<String,co.elastic.clients.elasticsearch._types.aggregations.Aggregation> facets, String scrollId, Integer scrollTimeout, DynamicParserTokens parserTokens, boolean trackTotalHits)	Execute one relative Depth Unit Query

Methods inherited from class java.lang.Object

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

Constructor Details

DbRequest

public DbRequest()

Method Details

execRuleRequest

public UpdatedDocument execRuleRequest(String documentId,
 RuleActions ruleActions,
 Map<String,DurationData> bindRuleToDuration,
 OntologyValidator ontologyValidator,
 UnitValidator unitValidator,
 List<OntologyModel> ontologyModels)
                                throws InvalidParseOperationException,
MetaDataExecutionException,
InvalidCreateOperationException,
MetaDataNotFoundException,
MetadataValidationException

Execute rule action on unit

Parameters:

ontologyModels -

documentId - the unitId

ruleActions - the list of ruleAction (by category)

Throws:

InvalidParseOperationException

MetaDataExecutionException

InvalidCreateOperationException

MetaDataNotFoundException

MetadataValidationException

execRequest

public Result<MetadataDocument<?>> execRequest(RequestParserMultiple requestParser,
 List<OntologyModel> ontologies)
                                        throws MetaDataExecutionException,
InvalidParseOperationException,
BadRequestException,
VitamDBException

The request should be already analyzed.

Parameters:

requestParser - the RequestParserMultiple to execute

Returns:

the Result

Throws:

MetaDataExecutionException - when select/update/delete on metadata collection exception occurred

InvalidParseOperationException - when json data exception occurred

BadRequestException

VitamDBException

execUpdateRequest

public List<UpdatedDocument> execUpdateRequest(List<RequestById> bulkRequests,
 MetadataCollections metadataCollection,
 OntologyValidator ontologyValidator,
 UnitValidator unitValidator,
 List<OntologyModel> ontologyModels,
 boolean forceUpdate,
 boolean refreshElasticIndexPostBulkIndexing)
                                        throws MetaDataExecutionException,
InvalidParseOperationException,
MetaDataNotFoundException

Throws:

MetaDataExecutionException

InvalidParseOperationException

MetaDataNotFoundException

executeQuery

protected Result<MetadataDocument<?>> executeQuery(RequestParserMultiple requestParser,
 RequestToAbstract requestToMongodb,
 int rank,
 Result<MetadataDocument<?>> previous,
 DynamicParserTokens parserTokens)
                                            throws MetaDataExecutionException,
InvalidParseOperationException,
BadRequestException

Execute one request

Parameters:

requestToMongodb -

rank - current rank query

previous - previous Result from previous level (except in level == 0 where it is the subset of valid roots)

Returns:

the new Result from this request

Throws:

MetaDataExecutionException

InvalidParseOperationException

BadRequestException

exactDepthUnitQuery

protected Result<MetadataDocument<?>> exactDepthUnitQuery(Query realQuery,
 Result<MetadataDocument<?>> previous,
 int exactDepth,
 Integer tenantId,
 List<co.elastic.clients.elasticsearch._types.SortOptions> sorts,
 int offset,
 int limit,
 Map<String,co.elastic.clients.elasticsearch._types.aggregations.Aggregation> facets,
 String scrollId,
 Integer scrollTimeout,
 DynamicParserTokens parserTokens,
 boolean trackTotalHits)
                                                   throws InvalidParseOperationException,
MetaDataExecutionException,
BadRequestException

Execute one Unit Query using exact Depth

Parameters:

realQuery -

previous -

exactDepth -

tenantId -

sorts -

offset -

limit -

facets -

trackTotalHits -

Returns:

the associated Result

Throws:

InvalidParseOperationException

MetaDataExecutionException

BadRequestException

relativeDepthUnitQuery

protected Result<MetadataDocument<?>> relativeDepthUnitQuery(Query realQuery,
 Result<MetadataDocument<?>> previous,
 int relativeDepth,
 Integer tenantId,
 List<co.elastic.clients.elasticsearch._types.SortOptions> sorts,
 int offset,
 int limit,
 Map<String,co.elastic.clients.elasticsearch._types.aggregations.Aggregation> facets,
 String scrollId,
 Integer scrollTimeout,
 DynamicParserTokens parserTokens,
 boolean trackTotalHits)
                                                      throws InvalidParseOperationException,
MetaDataExecutionException,
BadRequestException

Execute one relative Depth Unit Query

Parameters:

realQuery -

previous -

relativeDepth -

tenantId -

sorts -

offset -

limit -

facets -

trackTotalHits -

Returns:

the associated Result

Throws:

InvalidParseOperationException

MetaDataExecutionException

BadRequestException

aggregateUnitDepths

protected Set<String> aggregateUnitDepths(Collection<String> ids,
 int relativeDepth)

Aggregate Unit Depths according to parent relative Depth

Parameters:

ids -

relativeDepth -

Returns:

the aggregate set of multi level parents for this relativeDepth

sameDepthUnitQuery

protected Result<MetadataDocument<?>> sameDepthUnitQuery(Query realQuery,
 Result<MetadataDocument<?>> previous,
 Integer tenantId,
 List<co.elastic.clients.elasticsearch._types.SortOptions> sorts,
 int offset,
 int limit,
 Map<String,co.elastic.clients.elasticsearch._types.aggregations.Aggregation> facets,
 String scrollId,
 Integer scrollTimeout,
 DynamicParserTokens parserTokens,
 boolean trackTotalHits)
                                                  throws InvalidParseOperationException,
MetaDataExecutionException,
BadRequestException

Execute one relative Depth Unit Query

Parameters:

realQuery -

previous -

tenantId -

sorts -

offset -

limit -

facets -

trackTotalHits -

Returns:

the associated Result

Throws:

InvalidParseOperationException

MetaDataExecutionException

BadRequestException

objectGroupQuery

protected Result<MetadataDocument<?>> objectGroupQuery(Query realQuery,
 Result<MetadataDocument<?>> previous,
 Integer tenantId,
 List<co.elastic.clients.elasticsearch._types.SortOptions> sorts,
 int offset,
 int limit,
 String scrollId,
 Integer scrollTimeout,
 Map<String,co.elastic.clients.elasticsearch._types.aggregations.Aggregation> facets,
 DynamicParserTokens parserTokens,
 boolean trackTotalHits)
                                                throws InvalidParseOperationException,
MetaDataExecutionException,
BadRequestException

Execute one relative Depth ObjectGroup Query

Parameters:

realQuery -

previous - units, Note: only immediate Unit parents are allowed

tenantId -

sorts -

offset -

limit -

trackTotalHits -

Returns:

the associated Result

Throws:

InvalidParseOperationException

MetaDataExecutionException

BadRequestException

lastSelectFilterProjection

protected Result<MetadataDocument<?>> lastSelectFilterProjection(SelectToMongodb requestToMongodb,
 Result<MetadataDocument<?>> last,
 boolean checkConsistency)
                                                          throws InvalidParseOperationException,
VitamDBException

Finalize the queries with last True Select

Parameters:

requestToMongodb -

last -

Returns:

the final Result

Throws:

InvalidParseOperationException

VitamDBException

execInsertUnitRequest

@Deprecated
public void execInsertUnitRequest(InsertParserMultiple requestParser)
                           throws MetaDataExecutionException,
MetaDataNotFoundException

Deprecated.

Inserts a unit

Parameters:

requestParser - the InsertParserMultiple to execute

Throws:

MetaDataExecutionException - when insert on metadata collection exception occurred

MetaDataNotFoundException - when metadata not found exception

execInsertObjectGroupRequests

public void execInsertObjectGroupRequests(List<InsertParserMultiple> requestParsers)
                                   throws MetaDataExecutionException,
InvalidParseOperationException

Inserts an object group

Parameters:

requestParsers - the list of InsertParserMultiple to execute

Throws:

MetaDataExecutionException - when insert on metadata collection exception occurred

InvalidParseOperationException - when json data exception occurred

MetaDataAlreadyExistException - when insert metadata exception

lastDeleteFilterProjection

protected Result<MetadataDocument<?>> lastDeleteFilterProjection(DeleteToMongodb requestToMongodb,
 Result<MetadataDocument<?>> last)
                                                          throws MetaDataExecutionException

Finalize the queries with last True Delete

Parameters:

requestToMongodb -

last -

Returns:

the final Result

Throws:

InvalidParseOperationException

MetaDataExecutionException

execInsertUnitRequests

public void execInsertUnitRequests(List<InsertParserMultiple> requests)
                            throws MetaDataExecutionException,
MetaDataNotFoundException

Inserts a unit

Parameters:

requests - list of unit insert requests

Throws:

MetaDataExecutionException - when insert on metadata collection exception occurred

MetaDataNotFoundException - when metadata not found exception

deleteUnits

public void deleteUnits(List<String> documentsToDelete)
                 throws MetaDataExecutionException

Delete units

Throws:

MetaDataExecutionException

deleteObjectGroups

public void deleteObjectGroups(List<String> documentsToDelete)
                        throws MetaDataExecutionException

Delete object groups

Throws:

MetaDataExecutionException

clearEsScrollId

public void clearEsScrollId(String scrollId)