Package fr.gouv.vitam.metadata.core

Class MetaDataImpl

java.lang.Object

fr.gouv.vitam.metadata.core.MetaDataImpl

public class MetaDataImpl
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	BINARY_OBJECT_COUNT
static final String	BINARY_OBJECT_SIZE
static final String	FILTER
static final String	LIMIT
static final int	MAX_PRECISION_THRESHOLD
static final String	NESTED_VERSIONS
static final String	OFFSET
static final String	ORIGINATING_AGENCIES
static final String	ORIGINATING_AGENCY
static final String	SNAPSHOT_COLLECTION

Constructor Summary

Constructors

Constructor	Description
MetaDataImpl(MongoDbAccessMetadataImpl mongoDbAccess, int ontologyCacheMaxEntries, int ontologyCacheTimeoutInSeconds, int archiveUnitProfileCacheMaxEntries, int archiveUnitProfileCacheTimeoutInSeconds, int schemaValidatorCacheMaxEntries, int schemaValidatorCacheTimeoutInSeconds, ElasticsearchMetadataIndexManager indexManager)
MetaDataImpl(MongoDbAccessMetadataImpl mongoDbAccess, AdminManagementClientFactory adminManagementClientFactory, IndexationHelper indexationHelper, DbRequest dbRequest, int ontologyCacheMaxEntries, int ontologyCacheTimeoutInSeconds, int archiveUnitProfileCacheMaxEntries, int archiveUnitProfileCacheTimeoutInSeconds, int schemaValidatorCacheMaxEntries, int schemaValidatorCacheTimeoutInSeconds, ElasticsearchMetadataIndexManager indexManager)

Method Summary

Modifier and Type	Method	Description
void	checkStreamObjects(int tenantId, short objectsStreamExecutionLimit)
void	checkStreamUnits(int tenantId, short unitsStreamExecutionLimit)
void	clearESScrollFilter(String scrollId)
List<org.bson.Document>	createAccessionRegisterSymbolic(Integer tenant)
void	deleteObjectGroups(List<String> idList)
void	deleteUnits(List<String> idList)
MongoDbAccessMetadataImpl	getMongoDbAccess()
void	insertObjectGroup(com.fasterxml.jackson.databind.JsonNode objectGroupRequest)
void	insertObjectGroups(List<com.fasterxml.jackson.databind.JsonNode> objectGroupRequest)
void	insertUnits(List<com.fasterxml.jackson.databind.JsonNode> unitRequest)
static MetaDataImpl	newMetadata(MongoDbAccessMetadataImpl mongoDbAccessMetadata, int ontologyCacheMaxEntries, int ontologyCacheTimeoutInSeconds, int archiveUnitProfileCacheMaxEntries, int archiveUnitProfileCacheTimeoutInSeconds, int schemaValidatorCacheMaxEntries, int schemaValidatorCacheTimeoutInSeconds, ElasticsearchMetadataIndexManager indexManager)	Get a new MetaDataImpl instance
void	refreshObjectGroup()
void	refreshUnit()
ReindexationResult	reindex(IndexParameters indexParameters)
MetadataResult	selectObjectGroupById(com.fasterxml.jackson.databind.JsonNode selectQuery, String objectGroupId)
MetadataResult	selectObjectGroupsByQuery(com.fasterxml.jackson.databind.JsonNode selectQuery)
List<ObjectGroupPerOriginatingAgency>	selectOwnAccessionRegisterOnObjectGroupByOperationId(Integer tenant, String operationId)
List<FacetBucket>	selectOwnAccessionRegisterOnUnitByOperationId(String operationId)
MetadataResult	selectUnitsById(com.fasterxml.jackson.databind.JsonNode selectQuery, String unitId)
MetadataResult	selectUnitsByQuery(com.fasterxml.jackson.databind.JsonNode selectQuery)
SwitchIndexResult	switchIndex(String alias, String newIndexName)
void	updateObjectGroupId(com.fasterxml.jackson.databind.JsonNode updateQuery, String objectId, boolean forceUpdate, boolean withRefreshIndex)
void	updateParameterStreamObjects(int tenantId)
void	updateParameterStreamUnits(int tenantId)
UpdateUnit	updateUnitById(com.fasterxml.jackson.databind.JsonNode updateQuery, String unitId, boolean forceUpdate, boolean withRefreshIndex)
List<UpdateUnit>	updateUnits(List<RequestById> bulkRequests, boolean forceUpdate, boolean withRefreshIndex)
RequestResponse<UpdateUnit>	updateUnitsRules(List<String> unitIds, RuleActions ruleActions, Map<String,DurationData> bindRuleToDuration)

Methods inherited from class java.lang.Object

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

Field Details

MAX_PRECISION_THRESHOLD

public static final int MAX_PRECISION_THRESHOLD

See Also:

• Constant Field Values

SNAPSHOT_COLLECTION

public static final String SNAPSHOT_COLLECTION

See Also:

• Constant Field Values

FILTER

public static final String FILTER

See Also:

• Constant Field Values

OFFSET

public static final String OFFSET

See Also:

• Constant Field Values

LIMIT

public static final String LIMIT

See Also:

• Constant Field Values

ORIGINATING_AGENCY

public static final String ORIGINATING_AGENCY

See Also:

• Constant Field Values

ORIGINATING_AGENCIES

public static final String ORIGINATING_AGENCIES

See Also:

• Constant Field Values

NESTED_VERSIONS

public static final String NESTED_VERSIONS

See Also:

• Constant Field Values

BINARY_OBJECT_SIZE

public static final String BINARY_OBJECT_SIZE

See Also:

• Constant Field Values

BINARY_OBJECT_COUNT

public static final String BINARY_OBJECT_COUNT

See Also:

• Constant Field Values

Constructor Details

MetaDataImpl

public MetaDataImpl(MongoDbAccessMetadataImpl mongoDbAccess,
 int ontologyCacheMaxEntries,
 int ontologyCacheTimeoutInSeconds,
 int archiveUnitProfileCacheMaxEntries,
 int archiveUnitProfileCacheTimeoutInSeconds,
 int schemaValidatorCacheMaxEntries,
 int schemaValidatorCacheTimeoutInSeconds,
 ElasticsearchMetadataIndexManager indexManager)

MetaDataImpl

public MetaDataImpl(MongoDbAccessMetadataImpl mongoDbAccess,
 AdminManagementClientFactory adminManagementClientFactory,
 IndexationHelper indexationHelper,
 DbRequest dbRequest,
 int ontologyCacheMaxEntries,
 int ontologyCacheTimeoutInSeconds,
 int archiveUnitProfileCacheMaxEntries,
 int archiveUnitProfileCacheTimeoutInSeconds,
 int schemaValidatorCacheMaxEntries,
 int schemaValidatorCacheTimeoutInSeconds,
 ElasticsearchMetadataIndexManager indexManager)

Method Details

newMetadata

public static MetaDataImpl newMetadata(MongoDbAccessMetadataImpl mongoDbAccessMetadata,
 int ontologyCacheMaxEntries,
 int ontologyCacheTimeoutInSeconds,
 int archiveUnitProfileCacheMaxEntries,
 int archiveUnitProfileCacheTimeoutInSeconds,
 int schemaValidatorCacheMaxEntries,
 int schemaValidatorCacheTimeoutInSeconds,
 ElasticsearchMetadataIndexManager indexManager)

Get a new MetaDataImpl instance

Parameters:

mongoDbAccessMetadata -

indexManager -

Returns:

a new instance of MetaDataImpl

getMongoDbAccess

public MongoDbAccessMetadataImpl getMongoDbAccess()

Returns:

the MongoDbAccessMetadataImpl

insertUnits

public void insertUnits(List<com.fasterxml.jackson.databind.JsonNode> unitRequest)
                 throws InvalidParseOperationException,
MetaDataExecutionException,
MetaDataNotFoundException

Throws:

InvalidParseOperationException

MetaDataExecutionException

MetaDataNotFoundException

deleteUnits

public void deleteUnits(List<String> idList)
                 throws IllegalArgumentException,
MetaDataExecutionException

Throws:

IllegalArgumentException

MetaDataExecutionException

deleteObjectGroups

public void deleteObjectGroups(List<String> idList)
                        throws IllegalArgumentException,
MetaDataExecutionException

Throws:

IllegalArgumentException

MetaDataExecutionException

insertObjectGroup

public void insertObjectGroup(com.fasterxml.jackson.databind.JsonNode objectGroupRequest)
                       throws InvalidParseOperationException,
MetaDataExecutionException

Throws:

InvalidParseOperationException

MetaDataExecutionException

insertObjectGroups

public void insertObjectGroups(List<com.fasterxml.jackson.databind.JsonNode> objectGroupRequest)
                        throws InvalidParseOperationException,
MetaDataExecutionException

Throws:

InvalidParseOperationException

MetaDataExecutionException

selectOwnAccessionRegisterOnUnitByOperationId

public List<FacetBucket> selectOwnAccessionRegisterOnUnitByOperationId(String operationId)
                                                                throws MetaDataExecutionException

Parameters:

operationId - operation id

Returns:

List of FacetBucket

Throws:

MetaDataExecutionException

createAccessionRegisterSymbolic

public List<org.bson.Document> createAccessionRegisterSymbolic(Integer tenant)
                                                        throws MetaDataExecutionException

Throws:

MetaDataExecutionException

selectOwnAccessionRegisterOnObjectGroupByOperationId

public List<ObjectGroupPerOriginatingAgency> selectOwnAccessionRegisterOnObjectGroupByOperationId(Integer tenant,
 String operationId)
                                                                                           throws MetaDataExecutionException

Throws:

MetaDataExecutionException

selectUnitsByQuery

public MetadataResult selectUnitsByQuery(com.fasterxml.jackson.databind.JsonNode selectQuery)
                                  throws MetaDataExecutionException,
InvalidParseOperationException,
MetaDataDocumentSizeException,
MetaDataNotFoundException,
BadRequestException,
VitamDBException

Throws:

MetaDataExecutionException

InvalidParseOperationException

MetaDataDocumentSizeException

MetaDataNotFoundException

BadRequestException

VitamDBException

selectObjectGroupsByQuery

public MetadataResult selectObjectGroupsByQuery(com.fasterxml.jackson.databind.JsonNode selectQuery)
                                         throws MetaDataExecutionException,
InvalidParseOperationException,
MetaDataDocumentSizeException,
MetaDataNotFoundException,
BadRequestException,
VitamDBException

Throws:

MetaDataExecutionException

InvalidParseOperationException

MetaDataDocumentSizeException

MetaDataNotFoundException

BadRequestException

VitamDBException

selectUnitsById

public MetadataResult selectUnitsById(com.fasterxml.jackson.databind.JsonNode selectQuery,
 String unitId)
                               throws InvalidParseOperationException,
MetaDataExecutionException,
MetaDataDocumentSizeException,
MetaDataNotFoundException,
BadRequestException,
VitamDBException

Throws:

InvalidParseOperationException

MetaDataExecutionException

MetaDataDocumentSizeException

MetaDataNotFoundException

BadRequestException

VitamDBException

selectObjectGroupById

public MetadataResult selectObjectGroupById(com.fasterxml.jackson.databind.JsonNode selectQuery,
 String objectGroupId)
                                     throws InvalidParseOperationException,
MetaDataDocumentSizeException,
MetaDataExecutionException,
MetaDataNotFoundException,
BadRequestException,
VitamDBException

Throws:

InvalidParseOperationException

MetaDataDocumentSizeException

MetaDataExecutionException

MetaDataNotFoundException

BadRequestException

VitamDBException

updateObjectGroupId

public void updateObjectGroupId(com.fasterxml.jackson.databind.JsonNode updateQuery,
 String objectId,
 boolean forceUpdate,
 boolean withRefreshIndex)
                         throws InvalidParseOperationException,
MetaDataExecutionException,
MetaDataNotFoundException,
MetadataValidationException

Throws:

InvalidParseOperationException

MetaDataExecutionException

MetaDataNotFoundException

MetadataValidationException

updateUnits

public List<UpdateUnit> updateUnits(List<RequestById> bulkRequests,
 boolean forceUpdate,
 boolean withRefreshIndex)
                             throws InvalidParseOperationException

Throws:

InvalidParseOperationException

updateUnitsRules

public RequestResponse<UpdateUnit> updateUnitsRules(List<String> unitIds,
 RuleActions ruleActions,
 Map<String,DurationData> bindRuleToDuration)

updateUnitById

public UpdateUnit updateUnitById(com.fasterxml.jackson.databind.JsonNode updateQuery,
 String unitId,
 boolean forceUpdate,
 boolean withRefreshIndex)
                          throws MetaDataNotFoundException,
InvalidParseOperationException,
MetaDataExecutionException,
MetadataValidationException

Throws:

MetaDataNotFoundException

InvalidParseOperationException

MetaDataExecutionException

MetadataValidationException

refreshUnit

public void refreshUnit()
                 throws IllegalArgumentException,
VitamThreadAccessException,
MetaDataExecutionException

Throws:

IllegalArgumentException

VitamThreadAccessException

MetaDataExecutionException

refreshObjectGroup

public void refreshObjectGroup()
                        throws IllegalArgumentException,
VitamThreadAccessException,
MetaDataExecutionException

Throws:

IllegalArgumentException

VitamThreadAccessException

MetaDataExecutionException

reindex

public ReindexationResult reindex(IndexParameters indexParameters)

switchIndex

public SwitchIndexResult switchIndex(String alias,
 String newIndexName)
                              throws DatabaseException

Throws:

DatabaseException

checkStreamUnits

public void checkStreamUnits(int tenantId,
 short unitsStreamExecutionLimit)
                      throws MetaDataException

Throws:

MetaDataException

checkStreamObjects

public void checkStreamObjects(int tenantId,
 short objectsStreamExecutionLimit)
                        throws MetaDataException

Throws:

MetaDataException

updateParameterStreamUnits

public void updateParameterStreamUnits(int tenantId)

updateParameterStreamObjects

public void updateParameterStreamObjects(int tenantId)

clearESScrollFilter

public void clearESScrollFilter(String scrollId)