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

Class MongoDbAccessMetadataImpl

java.lang.Object

fr.gouv.vitam.common.database.server.mongodb.MongoDbAccess

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

All Implemented Interfaces:

DatabaseConnection

public class MongoDbAccessMetadataImpl
extends MongoDbAccess

MongoDbAccess Implement for Admin

Constructor Summary

Constructors

Constructor and Description
MongoDbAccessMetadataImpl(com.mongodb.MongoClient mongoClient, String dbname, boolean recreate, ElasticsearchAccessMetadata esClient, List<Integer> tenants)

Method Summary

Modifier and Type	Method and Description
void	deleteObjectGroupByTenant(Integer... tenantIds) Delete Object Group metadata by Tenant Not check, test feature !
void	deleteUnitByTenant(Integer... tenantIds) Delete Unit metadata by tenant Not check, test feature !
static void	ensureIndex() Ensure that all MongoDB database schema are indexed
protected void	flushOnDisk() Force flush on disk (MongoDB): should not be used
ElasticsearchAccessMetadata	getEsClient()
String	getInfo() Get information on a Database
static com.mongodb.MongoClientOptions	getMongoClientOptions()
static long	getObjectGroupSize()
static long	getUnitSize()
static void	removeIndexBeforeImport() Remove temporarily the MongoDB Index (import optimization?)
static void	resetIndexAfterImport() Reset MongoDB Index (import optimization?)

Methods inherited from class fr.gouv.vitam.common.database.server.mongodb.MongoDbAccess

checkConnection, close, createMongoClient, getMongoAdmin, getMongoClient, getMongoDatabase, setDatabase, setMongoAdmin, setMongoClient, setMongoDatabase

Methods inherited from class java.lang.Object

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

Constructor Detail

MongoDbAccessMetadataImpl

public MongoDbAccessMetadataImpl(com.mongodb.MongoClient mongoClient,
                                 String dbname,
                                 boolean recreate,
                                 ElasticsearchAccessMetadata esClient,
                                 List<Integer> tenants)

Parameters:

mongoClient - MongoClient

dbname - MongoDB database name

recreate - True to recreate the index

esClient - Elasticsearch client

tenants - the tenant list

Method Detail

getMongoClientOptions

public static com.mongodb.MongoClientOptions getMongoClientOptions()

Returns:

The MongoCLientOptions to apply to MongoClient

ensureIndex

public static void ensureIndex()

Ensure that all MongoDB database schema are indexed

removeIndexBeforeImport

public static void removeIndexBeforeImport()

Remove temporarily the MongoDB Index (import optimization?)

resetIndexAfterImport

public static void resetIndexAfterImport()

Reset MongoDB Index (import optimization?)

getInfo

public String getInfo()

Description copied from interface: DatabaseConnection

Get information on a Database

Specified by:

getInfo in interface DatabaseConnection

Overrides:

getInfo in class MongoDbAccess

Returns:

information on the database

getUnitSize

public static long getUnitSize()

Returns:

the current number of Unit

getObjectGroupSize

public static long getObjectGroupSize()

Returns:

the current number of ObjectGroup

flushOnDisk

protected void flushOnDisk()

Force flush on disk (MongoDB): should not be used

getEsClient

public ElasticsearchAccessMetadata getEsClient()

Returns:

the Elasticsearch Acess Metadata client

deleteUnitByTenant

public void deleteUnitByTenant(Integer... tenantIds)
                        throws DatabaseException

Delete Unit metadata by tenant Not check, test feature !

Parameters:

tenantIds - the list of tenants

Throws:

DatabaseException - thrown when error on delete

deleteObjectGroupByTenant

public void deleteObjectGroupByTenant(Integer... tenantIds)
                               throws DatabaseException

Delete Object Group metadata by Tenant Not check, test feature !

Parameters:

tenantIds - the list of tenants

Throws:

DatabaseException - thrown when error on delete