public class DbRequest extends Object
Constructor and Description |
---|
DbRequest()
Constructor
|
Modifier and Type | Method and Description |
---|---|
protected Set<String> |
aggregateUnitDepths(Collection<String> ids,
int relativeDepth)
Aggregate Unit Depths according to parent relative Depth
|
protected Result<MetadataDocument<?>> |
checkObjectGroupStartupRoots(RequestParserMultiple request,
Result<MetadataDocument<?>> defaultStartSet)
Check ObjectGroup at startup against Roots
|
protected Set<String> |
checkUnitAgainstRoots(Set<String> current,
Result<MetadataDocument<?>> defaultStartSet)
Check Unit parents against Roots
|
protected Result<MetadataDocument<?>> |
checkUnitStartupRoots(RequestParserMultiple request,
Result<MetadataDocument<?>> defaultStartSet)
Check Unit at startup against Roots
|
protected Result<MetadataDocument<?>> |
exactDepthUnitQuery(Query realQuery,
Result<MetadataDocument<?>> previous,
int exactDepth,
Integer tenantId,
List<org.elasticsearch.search.sort.SortBuilder> sorts,
int offset,
int limit,
String scrollId,
Integer scrollTimeout)
Execute one Unit Query using exact Depth
|
Result |
execRequest(RequestParserMultiple requestParser,
Result<MetadataDocument<?>> defaultStartSet)
The request should be already analyzed.
|
protected Result<MetadataDocument<?>> |
executeQuery(RequestParserMultiple requestParser,
RequestToAbstract requestToMongodb,
int rank,
Result<MetadataDocument<?>> previous)
Execute one request
|
protected Result<MetadataDocument<?>> |
lastDeleteFilterProjection(DeleteToMongodb requestToMongodb,
Result<MetadataDocument<?>> last)
Finalize the queries with last True Delete
|
protected Result<MetadataDocument<?>> |
lastInsertFilterProjection(InsertToMongodb requestToMongodb,
Result<MetadataDocument<?>> last,
Integer tenantId)
Finalize the queries with last True Insert
|
protected Result<MetadataDocument<?>> |
lastSelectFilterProjection(SelectToMongodb requestToMongodb,
Result<MetadataDocument<?>> last,
boolean checkConsistency)
Finalize the queries with last True Select
|
protected Result<MetadataDocument<?>> |
lastUpdateFilterProjection(UpdateToMongodb requestToMongodb,
Result<MetadataDocument<?>> last,
RequestParserMultiple requestParser)
Finalize the queries with last True Update
|
protected Result<MetadataDocument<?>> |
objectGroupQuery(Query realQuery,
Result<MetadataDocument<?>> previous,
Integer tenantId,
List<org.elasticsearch.search.sort.SortBuilder> sorts,
int offset,
int limit,
String scrollId,
Integer scrollTimeout)
Execute one relative Depth ObjectGroup Query
|
protected Result<MetadataDocument<?>> |
relativeDepthUnitQuery(Query realQuery,
Result<MetadataDocument<?>> previous,
int relativeDepth,
Integer tenantId,
List<org.elasticsearch.search.sort.SortBuilder> sorts,
int offset,
int limit,
String scrollId,
Integer scrollTimeout)
Execute one relative Depth Unit Query
|
protected Result<MetadataDocument<?>> |
sameDepthUnitQuery(Query realQuery,
Result<MetadataDocument<?>> previous,
Integer tenantId,
List<org.elasticsearch.search.sort.SortBuilder> sorts,
int offset,
int limit,
String scrollId,
Integer scrollTimeout)
Execute one relative Depth Unit Query
|
public Result execRequest(RequestParserMultiple requestParser, Result<MetadataDocument<?>> defaultStartSet) throws InstantiationException, IllegalAccessException, MetaDataExecutionException, InvalidParseOperationException, BadRequestException, MetaDataAlreadyExistException, MetaDataNotFoundException, VitamDBException
requestParser
- the RequestParserMultiple to executedefaultStartSet
- the set of id from which the request should start, whatever the roots setInstantiationException
IllegalAccessException
MetaDataExecutionException
- when select/insert/update/delete on metadata collection exception occurredInvalidParseOperationException
- when json data exception occurredMetaDataAlreadyExistException
- when insert metadata exceptionMetaDataNotFoundException
- when metadata not found exceptionBadRequestException
VitamDBException
protected Result<MetadataDocument<?>> checkUnitStartupRoots(RequestParserMultiple request, Result<MetadataDocument<?>> defaultStartSet) throws InvalidParseOperationException
request
- defaultStartSet
- InvalidParseOperationException
protected Result<MetadataDocument<?>> checkObjectGroupStartupRoots(RequestParserMultiple request, Result<MetadataDocument<?>> defaultStartSet) throws InvalidParseOperationException
request
- defaultStartSet
- InvalidParseOperationException
protected Set<String> checkUnitAgainstRoots(Set<String> current, Result<MetadataDocument<?>> defaultStartSet) throws InvalidParseOperationException
current
- set of result iddefaultStartSet
- InvalidParseOperationException
protected Result<MetadataDocument<?>> executeQuery(RequestParserMultiple requestParser, RequestToAbstract requestToMongodb, int rank, Result<MetadataDocument<?>> previous) throws MetaDataExecutionException, InvalidParseOperationException, BadRequestException
requestToMongodb
- rank
- current rank queryprevious
- previous Result from previous level (except in level == 0 where it is the subset of valid roots)MetaDataExecutionException
InvalidParseOperationException
BadRequestException
protected Result<MetadataDocument<?>> exactDepthUnitQuery(Query realQuery, Result<MetadataDocument<?>> previous, int exactDepth, Integer tenantId, List<org.elasticsearch.search.sort.SortBuilder> sorts, int offset, int limit, String scrollId, Integer scrollTimeout) throws InvalidParseOperationException, MetaDataExecutionException, BadRequestException
realQuery
- previous
- exactDepth
- tenantId
- sorts
- offset
- limit
- InvalidParseOperationException
MetaDataExecutionException
BadRequestException
protected Result<MetadataDocument<?>> relativeDepthUnitQuery(Query realQuery, Result<MetadataDocument<?>> previous, int relativeDepth, Integer tenantId, List<org.elasticsearch.search.sort.SortBuilder> sorts, int offset, int limit, String scrollId, Integer scrollTimeout) throws InvalidParseOperationException, MetaDataExecutionException, BadRequestException
realQuery
- previous
- relativeDepth
- tenantId
- sorts
- offset
- limit
- InvalidParseOperationException
MetaDataExecutionException
BadRequestException
protected Set<String> aggregateUnitDepths(Collection<String> ids, int relativeDepth)
ids
- relativeDepth
- protected Result<MetadataDocument<?>> sameDepthUnitQuery(Query realQuery, Result<MetadataDocument<?>> previous, Integer tenantId, List<org.elasticsearch.search.sort.SortBuilder> sorts, int offset, int limit, String scrollId, Integer scrollTimeout) throws InvalidParseOperationException, MetaDataExecutionException, BadRequestException
realQuery
- previous
- tenantId
- sorts
- offset
- limit
- InvalidParseOperationException
MetaDataExecutionException
BadRequestException
protected Result<MetadataDocument<?>> objectGroupQuery(Query realQuery, Result<MetadataDocument<?>> previous, Integer tenantId, List<org.elasticsearch.search.sort.SortBuilder> sorts, int offset, int limit, String scrollId, Integer scrollTimeout) throws InvalidParseOperationException, MetaDataExecutionException, BadRequestException
realQuery
- previous
- units, Note: only immediate Unit parents are allowedtenantId
- sorts
- offset
- limit
- InvalidParseOperationException
MetaDataExecutionException
BadRequestException
protected Result<MetadataDocument<?>> lastSelectFilterProjection(SelectToMongodb requestToMongodb, Result<MetadataDocument<?>> last, boolean checkConsistency) throws InvalidParseOperationException, MetaDataExecutionException, VitamDBException
requestToMongodb
- last
- InvalidParseOperationException
MetaDataExecutionException
VitamDBException
protected Result<MetadataDocument<?>> lastUpdateFilterProjection(UpdateToMongodb requestToMongodb, Result<MetadataDocument<?>> last, RequestParserMultiple requestParser) throws InvalidParseOperationException, MetaDataExecutionException, MetadataInvalidUpdateException
requestToMongodb
- last
- requestParser
- InvalidParseOperationException
MetaDataExecutionException
MetadataInvalidUpdateException
protected Result<MetadataDocument<?>> lastInsertFilterProjection(InsertToMongodb requestToMongodb, Result<MetadataDocument<?>> last, Integer tenantId) throws InvalidParseOperationException, MetaDataAlreadyExistException, MetaDataExecutionException, MetaDataNotFoundException
requestToMongodb
- last
- InvalidParseOperationException
MetaDataAlreadyExistException
MetaDataExecutionException
MetaDataNotFoundException
protected Result<MetadataDocument<?>> lastDeleteFilterProjection(DeleteToMongodb requestToMongodb, Result<MetadataDocument<?>> last) throws InvalidParseOperationException, MetaDataExecutionException
requestToMongodb
- last
- InvalidParseOperationException
MetaDataExecutionException
Copyright © 2018 Vitam. All rights reserved.