Package org.nuxeo.ecm.core.storage.sql

Class RepositoryImpl

java.lang.Object

org.nuxeo.ecm.core.storage.sql.RepositoryImpl

All Implemented Interfaces:

Repository, Repository, RepositoryManagement

public class RepositoryImpl
extends Object
implements Repository, Repository

Repository implementation, to be extended by backend-specific initialization code.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RepositoryImpl.SessionPathResolver

Field Summary

Fields

Modifier and Type	Field	Description
protected VCSClusterInvalidator	clusterInvalidator
final VCSInvalidationsPropagator	invalidationsPropagator	Propagator of invalidations to all mappers' caches.
protected final io.dropwizard.metrics5.MetricRegistry	registry
protected final RepositoryDescriptor	repositoryDescriptor
boolean	requiresClusterSQL
protected boolean	selfRegisteredLockManager
protected final io.dropwizard.metrics5.Counter	sessionCount
protected SQLInfo	sqlInfo
static final String	TEST_UPGRADE
static final String	TEST_UPGRADE_LAST_CONTRIBUTOR
static final String	TEST_UPGRADE_LOCKS
static final String	TEST_UPGRADE_SYS_CHANGE_TOKEN
static final String	TEST_UPGRADE_VERSIONS
static Map<String,Serializable>	testProps

Fields inherited from interface org.nuxeo.ecm.core.model.Repository

CAPABILITY_QUERY_BLOB_KEYS, CAPABILITY_REPOSITORY

Constructor Summary

Constructors

Constructor	Description
RepositoryImpl(RepositoryDescriptor repositoryDescriptor)

Method Summary

Modifier and Type	Method	Description
int	cleanupDeletedDocuments(int max, Calendar beforeTime)	Cleans up (hard-deletes) any documents that have been soft-deleted in the database.
int	clearCaches()	Clears all the caches.
void	close()	Closes the repository and release all resources.
protected void	closeAllSessions()
protected void	closeSession(SessionImpl session)
protected Mapper	createCachingMapper(Model model, Mapper mapper)
protected VCSClusterInvalidator	createClusterInvalidator()
protected void	createDatabase(String ddlMode)	Creates the necessary structures in the database.
protected void	createDatabaseNoTx(String ddlMode)
protected void	createMetricsGauges()
protected void	createTables(Connection connection, String ddlMode)
protected TableUpgrader	createTableUpgrader(Connection connection, JDBCLogger logger)
protected static Set<String>	findTableNames(DatabaseMetaData metadata, String schemaName)	Finds uppercase table names.
long	getCacheMapperSize()
long	getCachePristineSize()	Evaluate number of elements in hier cache
long	getCacheSelectionSize()	Evaluate number of elements in selection cache
long	getCacheSize()	Evaluate number of elements in all caches
protected Class<? extends CachingMapper>	getCachingMapperClass()
Object	getCapability(String name)	Gets the value of the given capability for this repository.
SessionImpl	getConnection()	Gets a new connection.
FulltextConfiguration	getFulltextConfiguration()	Gets the fulltext configuration.
VCSInvalidationsPropagator	getInvalidationsPropagator()
LockManager	getLockManager()
protected String	getLockManagerName()
Model	getModel()
String	getName()	Gets the repository name.
RepositoryDescriptor	getRepositoryDescriptor()
SQLSession	getSession()
SQLInfo	getSQLInfo()
protected String	getTableName(String origName)
protected void	initClusterInvalidator()
protected void	initLockManager()
protected void	initRepository()
protected void	initRootNode()
boolean	isChangeTokenEnabled()
void	markReferencedBlobs(BiConsumer<String,String> markerCallback)	Marks the blobs in use by passing them to the provided callback (taking the blob key and the repository name).
protected void	prepareClusterInvalidator()
void	processClusterInvalidationsNext()	Makes sure that the next transaction will process cluster invalidations.
protected static void	runWithoutTransaction(Runnable runnable)
void	shutdown()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.nuxeo.ecm.core.model.Repository

getActiveSessionsCount, hasCapability

Field Details

TEST_UPGRADE

public static final String TEST_UPGRADE

See Also:

• Constant Field Values

TEST_UPGRADE_VERSIONS

public static final String TEST_UPGRADE_VERSIONS

See Also:

• Constant Field Values

TEST_UPGRADE_LAST_CONTRIBUTOR

public static final String TEST_UPGRADE_LAST_CONTRIBUTOR

See Also:

• Constant Field Values

TEST_UPGRADE_LOCKS

public static final String TEST_UPGRADE_LOCKS

See Also:

• Constant Field Values

TEST_UPGRADE_SYS_CHANGE_TOKEN

public static final String TEST_UPGRADE_SYS_CHANGE_TOKEN

See Also:

• Constant Field Values

testProps

public static Map<String,Serializable> testProps

repositoryDescriptor

protected final RepositoryDescriptor repositoryDescriptor

registry

protected final io.dropwizard.metrics5.MetricRegistry registry

sessionCount

protected final io.dropwizard.metrics5.Counter sessionCount

selfRegisteredLockManager

protected boolean selfRegisteredLockManager

Since:

7.4 : used to know if the LockManager was provided by this repository or externally

invalidationsPropagator

public final VCSInvalidationsPropagator invalidationsPropagator

Propagator of invalidations to all mappers' caches.

clusterInvalidator

protected VCSClusterInvalidator clusterInvalidator

requiresClusterSQL

public boolean requiresClusterSQL

sqlInfo

protected SQLInfo sqlInfo

Constructor Details

RepositoryImpl

public RepositoryImpl(RepositoryDescriptor repositoryDescriptor)

Method Details

createMetricsGauges

protected void createMetricsGauges()

createCachingMapper

protected Mapper createCachingMapper(Model model,
 Mapper mapper)

getCachingMapperClass

protected Class<? extends CachingMapper> getCachingMapperClass()

getRepositoryDescriptor

public RepositoryDescriptor getRepositoryDescriptor()

getLockManager

public LockManager getLockManager()

getModel

public Model getModel()

getSQLInfo

public SQLInfo getSQLInfo()

Since:

11.1

getInvalidationsPropagator

public VCSInvalidationsPropagator getInvalidationsPropagator()

isChangeTokenEnabled

public boolean isChangeTokenEnabled()

getSession

public SQLSession getSession()

Specified by:

getSession in interface Repository

getConnection

public SessionImpl getConnection()

Gets a new connection.

Specified by:

getConnection in interface Repository

Returns:

the session

closeSession

protected void closeSession(SessionImpl session)

initRepository

protected void initRepository()

initRootNode

protected void initRootNode()

getLockManagerName

protected String getLockManagerName()

initLockManager

protected void initLockManager()

prepareClusterInvalidator

protected void prepareClusterInvalidator()

createClusterInvalidator

protected VCSClusterInvalidator createClusterInvalidator()

initClusterInvalidator

protected void initClusterInvalidator()

shutdown

public void shutdown()

Specified by:

shutdown in interface Repository

close

public void close()

Description copied from interface: Repository

Closes the repository and release all resources.

Specified by:

close in interface Repository

closeAllSessions

protected void closeAllSessions()

getName

public String getName()

Description copied from interface: RepositoryManagement

Gets the repository name.

Specified by:

getName in interface Repository

Specified by:

getName in interface RepositoryManagement

clearCaches

public int clearCaches()

Description copied from interface: RepositoryManagement

Clears all the caches.

Specified by:

clearCaches in interface RepositoryManagement

Returns:

an indicative count of objects removed

getCacheSize

public long getCacheSize()

Description copied from interface: RepositoryManagement

Evaluate number of elements in all caches

Specified by:

getCacheSize in interface RepositoryManagement

getCacheMapperSize

public long getCacheMapperSize()

getCachePristineSize

public long getCachePristineSize()

Description copied from interface: RepositoryManagement

Evaluate number of elements in hier cache

Specified by:

getCachePristineSize in interface RepositoryManagement

getCacheSelectionSize

public long getCacheSelectionSize()

Description copied from interface: RepositoryManagement

Evaluate number of elements in selection cache

Specified by:

getCacheSelectionSize in interface RepositoryManagement

processClusterInvalidationsNext

public void processClusterInvalidationsNext()

Description copied from interface: RepositoryManagement

Makes sure that the next transaction will process cluster invalidations.

Specified by:

processClusterInvalidationsNext in interface RepositoryManagement

markReferencedBlobs

public void markReferencedBlobs(BiConsumer<String,String> markerCallback)

Description copied from interface: Repository

Marks the blobs in use by passing them to the provided callback (taking the blob key and the repository name).

Specified by:

markReferencedBlobs in interface Repository

cleanupDeletedDocuments

public int cleanupDeletedDocuments(int max,
 Calendar beforeTime)

Description copied from interface: RepositoryManagement

Cleans up (hard-deletes) any documents that have been soft-deleted in the database.

Specified by:

cleanupDeletedDocuments in interface RepositoryManagement

Parameters:

max - the maximum number of documents to delete at a time

beforeTime - the maximum deletion time of the documents to delete

Returns:

the number of documents deleted

getFulltextConfiguration

public FulltextConfiguration getFulltextConfiguration()

Description copied from interface: RepositoryManagement

Gets the fulltext configuration.

Specified by:

getFulltextConfiguration in interface Repository

Specified by:

getFulltextConfiguration in interface RepositoryManagement

getCapability

public Object getCapability(String name)

Description copied from interface: Repository

Gets the value of the given capability for this repository.

Specified by:

getCapability in interface Repository

createDatabase

protected void createDatabase(String ddlMode)

Creates the necessary structures in the database.

Parameters:

ddlMode - the DDL execution mode

createDatabaseNoTx

protected void createDatabaseNoTx(String ddlMode)

getTableName

protected String getTableName(String origName)

createTables

protected void createTables(Connection connection,
 String ddlMode)
                     throws SQLException

Throws:

SQLException

createTableUpgrader

protected TableUpgrader createTableUpgrader(Connection connection,
 JDBCLogger logger)

findTableNames

protected static Set<String> findTableNames(DatabaseMetaData metadata,
 String schemaName)
                                     throws SQLException

Finds uppercase table names.

Throws:

SQLException

runWithoutTransaction

protected static void runWithoutTransaction(Runnable runnable)