org.nuxeo.ecm.core.storage.marklogic

Class MarkLogicRepository

java.lang.Object

org.nuxeo.ecm.core.storage.dbs.DBSRepositoryBase

org.nuxeo.ecm.core.storage.marklogic.MarkLogicRepository

All Implemented Interfaces:

LockManager, Repository, DBSRepository

public class MarkLogicRepository
extends DBSRepositoryBase

MarkLogic implementation of a Repository.

Since:

8.3

Nested Class Summary

Nested classes/interfaces inherited from class org.nuxeo.ecm.core.storage.dbs.DBSRepositoryBase

DBSRepositoryBase.BlobFinder, DBSRepositoryBase.DBSSessionInvoker, DBSRepositoryBase.IdType, DBSRepositoryBase.TransactionContext

Field Summary

Fields

Modifier and Type	Field and Description
static String	DB_DEFAULT
protected static String	NOSCROLL_ID
protected List<MarkLogicRangeElementIndexDescriptor>	rangeElementIndexes
protected long	sequenceLastValue Last value used from the in-memory sequence.
protected com.marklogic.xcc.ContentSource	xccContentSource

Fields inherited from class org.nuxeo.ecm.core.storage.dbs.DBSRepositoryBase

blobManager, cm, DEBUG_UUIDS, fulltextConfiguration, idType, lockManager, repositoryName, selfRegisteredLockManager, transactionContexts, TYPE_ROOT

Constructor Summary

Constructors

Constructor and Description
MarkLogicRepository(javax.resource.spi.ConnectionManager cm, MarkLogicRepositoryDescriptor descriptor)

Method Summary

Modifier and Type	Method and Description
void	clearLockManagerCaches() Clears any cache held by the lock manager.
void	closeLockManager() Closes the lock manager and releases resources.
void	createState(State state) Creates a document.
void	createStates(List<State> states) Creates documents.
void	deleteStates(Set<String> ids) Deletes a set of document.
String	generateNewId() Generates a new id for a document.
List<DBSRepositoryBase.IdType>	getAllowedIdTypes() Gets the allowed id types for this DBS repository.
Lock	getLock(String id) Gets the lock on a document.
protected Long	getNextSequenceId()
boolean	hasChild(String parentId, String name, Set<String> ignored) Checks if a document has a child with the given name
protected void	initBlobsPaths()
protected void	initRepository()
void	markReferencedBinaries() Marks the binaries in use by passing them to the binary manager(s)'s GC mark() method.
static com.marklogic.xcc.ContentSource	newMarkLogicContentSource(MarkLogicRepositoryDescriptor descriptor)
PartialList<Map<String,Serializable>>	queryAndFetch(DBSExpressionEvaluator evaluator, OrderByClause orderByClause, boolean distinctDocuments, int limit, int offset, int countUpTo) Queries the repository for documents matching a NXQL query, and returns a projection of the documents.
List<State>	queryKeyValue(String key, Object value, Set<String> ignored) Queries the repository for documents having key = value.
List<State>	queryKeyValue(String key1, Object value1, String key2, Object value2, Set<String> ignored) Queries the repository for documents having key1 = value1 and key2 = value2.
void	queryKeyValueArray(String key, Object value, Set<String> ids, Map<String,String> proxyTargets, Map<String,Object[]> targetProxies) Queries the repository for document ids having value in key (an array).
boolean	queryKeyValuePresence(String key, String value, Set<String> ignored) Queries the repository to check if there are documents having key = value.
State	readChildState(String parentId, String name, Set<String> ignored) Reads the state of a child document.
State	readState(String id) Reads the state of a document.
List<State>	readStates(List<String> ids) Reads the states of several documents.
Lock	removeLock(String id, String owner) Removes the lock from a document.
ScrollResult	scroll(DBSExpressionEvaluator evaluator, int batchSize, int keepAliveInSecond) Executes the given query and returns the first batch of results, next batch must be requested within the keepAliveSeconds delay.
ScrollResult	scroll(String scrollId) Get the next batch of result, the scrollId is part of the previous ScrollResult response.
Lock	setLock(String id, Lock lock) Sets a lock on a document.
void	updateState(String id, State.StateDiff diff) Updates a document.

Methods inherited from class org.nuxeo.ecm.core.storage.dbs.DBSRepositoryBase

getActiveSessionsCount, getBlobManager, getFulltextConfiguration, getLockManager, getLockManagerName, getName, getRootId, getSession, getSession, initLockManager, initRoot, isFulltextDisabled, newSession, 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.storage.dbs.DBSRepository

begin, commit, rollback

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

canLockBeRemoved

Field Detail

DB_DEFAULT

public static final String DB_DEFAULT

See Also:

Constant Field Values

NOSCROLL_ID

protected static final String NOSCROLL_ID

See Also:

Constant Field Values

xccContentSource

protected com.marklogic.xcc.ContentSource xccContentSource

sequenceLastValue

protected long sequenceLastValue

Last value used from the in-memory sequence. Used by unit tests.

rangeElementIndexes

protected List<MarkLogicRangeElementIndexDescriptor> rangeElementIndexes

Constructor Detail

MarkLogicRepository

public MarkLogicRepository(javax.resource.spi.ConnectionManager cm,
                           MarkLogicRepositoryDescriptor descriptor)

Method Detail

getAllowedIdTypes

public List<DBSRepositoryBase.IdType> getAllowedIdTypes()

Description copied from class: DBSRepositoryBase

Gets the allowed id types for this DBS repository. The first one is the default.

Specified by:

getAllowedIdTypes in class DBSRepositoryBase

newMarkLogicContentSource

public static com.marklogic.xcc.ContentSource newMarkLogicContentSource(MarkLogicRepositoryDescriptor descriptor)

initRepository

protected void initRepository()

initBlobsPaths

protected void initBlobsPaths()

Specified by:

initBlobsPaths in class DBSRepositoryBase

generateNewId

public String generateNewId()

Description copied from interface: DBSRepository

Generates a new id for a document.

Returns:

the new id

getNextSequenceId

protected Long getNextSequenceId()

readState

public State readState(String id)

Description copied from interface: DBSRepository

Reads the state of a document.

Parameters:

id - the document id

Returns:

the document state, or null if not found

readStates

public List<State> readStates(List<String> ids)

Description copied from interface: DBSRepository

Reads the states of several documents.

The returned states may be in a different order than the ids.

Parameters:

ids - the document ids

Returns:

the document states, an element by be null if not found

createState

public void createState(State state)

Description copied from interface: DBSRepository

Creates a document.

Parameters:

state - the document state

createStates

public void createStates(List<State> states)

Description copied from interface: DBSRepository

Creates documents.

Parameters:

states - the document states

updateState

public void updateState(String id,
                        State.StateDiff diff)

Description copied from interface: DBSRepository

Updates a document.

Parameters:

id - the document id

diff - the diff to apply

deleteStates

public void deleteStates(Set<String> ids)

Description copied from interface: DBSRepository

Deletes a set of document.

Parameters:

ids - the document ids

readChildState

public State readChildState(String parentId,
                            String name,
                            Set<String> ignored)

Description copied from interface: DBSRepository

Reads the state of a child document.

Parameters:

parentId - the parent document id

name - the name of the child

ignored - a set of document ids that should not be considered

Returns:

the state of the child document, or null if not found

hasChild

public boolean hasChild(String parentId,
                        String name,
                        Set<String> ignored)

Description copied from interface: DBSRepository

Checks if a document has a child with the given name

Parameters:

parentId - the parent document id

name - the name of the child

ignored - a set of document ids that should not be considered

Returns:

true if the child exists, false if not

queryKeyValue

public List<State> queryKeyValue(String key,
                                 Object value,
                                 Set<String> ignored)

Description copied from interface: DBSRepository

Queries the repository for documents having key = value.

Parameters:

key - the key

value - the value

ignored - a set of document ids that should not be considered

Returns:

the document states matching the query

queryKeyValue

public List<State> queryKeyValue(String key1,
                                 Object value1,
                                 String key2,
                                 Object value2,
                                 Set<String> ignored)

Description copied from interface: DBSRepository

Queries the repository for documents having key1 = value1 and key2 = value2.

Parameters:

key1 - the first key

value1 - the first value

key2 - the second key

value2 - the second value

ignored - a set of document ids that should not be considered

Returns:

the document states matching the query

queryKeyValueArray

public void queryKeyValueArray(String key,
                               Object value,
                               Set<String> ids,
                               Map<String,String> proxyTargets,
                               Map<String,Object[]> targetProxies)

Description copied from interface: DBSRepository

Queries the repository for document ids having value in key (an array).

Parameters:

key - the key

value - the value

ids - the set which receives the documents ids

proxyTargets - returns a map of proxy to target among the documents found

targetProxies - returns a map of target to proxies among the document found

queryKeyValuePresence

public boolean queryKeyValuePresence(String key,
                                     String value,
                                     Set<String> ignored)

Description copied from interface: DBSRepository

Queries the repository to check if there are documents having key = value.

Parameters:

key - the key

value - the value

ignored - a set of document ids that should not be considered

Returns:

true if the query matches at least one document, false if the query matches nothing

queryAndFetch

public PartialList<Map<String,Serializable>> queryAndFetch(DBSExpressionEvaluator evaluator,
                                                           OrderByClause orderByClause,
                                                           boolean distinctDocuments,
                                                           int limit,
                                                           int offset,
                                                           int countUpTo)

Description copied from interface: DBSRepository

Queries the repository for documents matching a NXQL query, and returns a projection of the documents.

Parameters:

evaluator - the map-based evaluator for the query

orderByClause - an ORDER BY clause

distinctDocuments - true if the projection should return a maximum of one row per document

limit - the limit on the number of documents to return

offset - the offset in the list of documents to return

countUpTo - if -1, count the total size without offset/limit.
If 0, don't count the total size, set it to -1 .
If n, count the total number if there are less than n documents otherwise set the total size to -2.

Returns:

a partial list of maps containing the NXQL projections requested, and the total size according to countUpTo

scroll

public ScrollResult scroll(DBSExpressionEvaluator evaluator,
                           int batchSize,
                           int keepAliveInSecond)

Description copied from interface: DBSRepository

Executes the given query and returns the first batch of results, next batch must be requested within the keepAliveSeconds delay.

scroll

public ScrollResult scroll(String scrollId)

Description copied from interface: DBSRepository

Get the next batch of result, the scrollId is part of the previous ScrollResult response.

getLock

public Lock getLock(String id)

Description copied from interface: LockManager

Gets the lock on a document.

If the document does not exist, null is returned.

Parameters:

id - the document id

Returns:

the existing lock, or null when there is no lock

setLock

public Lock setLock(String id,
                    Lock lock)

Description copied from interface: LockManager

Sets a lock on a document.

If the document is already locked, returns its existing lock status (there is no re-locking, LockManager.removeLock(java.lang.String, java.lang.String) must be called first).

Parameters:

id - the document id

lock - the lock to set

Returns:

null if locking succeeded, or the existing lock if locking failed

removeLock

public Lock removeLock(String id,
                       String owner)

Description copied from interface: LockManager

Removes the lock from a document.

The previous lock is returned.

If owner is null then the lock is unconditionally removed.

If owner is not null, it must match the existing lock owner for the lock to be removed. If it doesn't match, the returned lock will return true for Lock.getFailed().

Parameters:

id - the document id

Returns:

the previous lock (may be null), with a failed flag if locking failed

closeLockManager

public void closeLockManager()

Description copied from interface: LockManager

Closes the lock manager and releases resources.

clearLockManagerCaches

public void clearLockManagerCaches()

Description copied from interface: LockManager

Clears any cache held by the lock manager.

markReferencedBinaries

public void markReferencedBinaries()

Description copied from interface: Repository

Marks the binaries in use by passing them to the binary manager(s)'s GC mark() method.