org.nuxeo.ecm.core.storage.mem

Class MemRepository

java.lang.Object

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

org.nuxeo.ecm.core.storage.mem.MemRepository

All Implemented Interfaces:

Repository, DBSRepository

public class MemRepository
extends DBSRepositoryBase

In-memory implementation of a Repository.

Internally, the repository is a map from id to document object.

A document object is a JSON-like document stored as a Map recursively containing the data, see DBSDocument for the description of the document.

Since:

5.9.4

Nested Class Summary

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

DBSRepositoryBase.DBSSessionInvoker, DBSRepositoryBase.TransactionContext

Field Summary

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

transactionContexts, TYPE_ROOT

Constructor Summary

Constructors

Constructor and Description
MemRepository(String repositoryName)

Method Summary

Methods

Modifier and Type	Method and Description
static Serializable	applyDiff(Serializable value, State.ListDiff listDiff) Applies a State.ListDiff onto an array or List, and returns the resulting value.
static void	applyDiff(State state, State.StateDiff stateDiff) Applies a State.StateDiff in-place onto a base State.
void	createState(State state) Creates a document.
void	deleteStates(Set<String> ids) Deletes a set of document.
String	generateNewId() Generates a new id for a document.
boolean	hasChild(String parentId, String name, Set<String> ignored) Checks if a document has a child with the given name
PartialList<State>	queryAndFetch(Expression expression, DBSExpressionEvaluator evaluator, OrderByClause orderByClause, int limit, int offset, int countUpTo, boolean deepCopy, boolean fulltextScore) Queries the repository for documents matching a query.
List<State>	queryKeyValue(String key, String value, Set<String> ignored) Queries the repository for documents having key = value.
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.
void	shutdown()
void	updateState(String id, State.StateDiff diff) Updates a document.

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

getActiveSessionsCount, getBlobManager, getName, getRootId, getSession, initRoot, isFulltextDisabled, newBinaryManager

Methods inherited from class java.lang.Object

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

Constructor Detail

MemRepository

public MemRepository(String repositoryName)

Method Detail

shutdown

public void shutdown()

Specified by:

shutdown in interface Repository

Overrides:

shutdown in class DBSRepositoryBase

generateNewId

public String generateNewId()

Description copied from interface: DBSRepository

Generates a new id for a document.

Returns:

the new id

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)
                 throws DocumentException

Description copied from interface: DBSRepository

Creates a document.

Parameters:

state - the document state

Throws:

DocumentException - if the document already exists

updateState

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

Description copied from interface: DBSRepository

Updates a document.

Parameters:

id - the document id

diff - the diff to apply

Throws:

DocumentException - if the document does not exist

deleteStates

public void deleteStates(Set<String> ids)
                  throws DocumentException

Description copied from interface: DBSRepository

Deletes a set of document.

Parameters:

ids - the document ids

Throws:

DocumentException

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,
                        String 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

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<State> queryAndFetch(Expression expression,
                               DBSExpressionEvaluator evaluator,
                               OrderByClause orderByClause,
                               int limit,
                               int offset,
                               int countUpTo,
                               boolean deepCopy,
                               boolean fulltextScore)

Description copied from interface: DBSRepository

Queries the repository for documents matching a query.

Parameters:

expression - the query expression

evaluator - the map-based evaluator for the query

orderByClause - an ORDER BY clause

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.

deepCopy - whether returned state should be a copy

fulltextScore - whether returned state should include the fulltext score

Returns:

a partial list containing the limited documents required, and the total size according to countUpTo

applyDiff

public static void applyDiff(State state,
             State.StateDiff stateDiff)

Applies a State.StateDiff in-place onto a base State.

Uses thread-safe datastructures.

applyDiff

public static Serializable applyDiff(Serializable value,
                     State.ListDiff listDiff)

Applies a State.ListDiff onto an array or List, and returns the resulting value.

Uses thread-safe datastructures.