com.bigdata.gom.om

Class ObjectManager

java.lang.Object

com.bigdata.gom.om.ObjectMgrModel

com.bigdata.gom.om.ObjectManager

All Implemented Interfaces:

INativeTransaction, IObjectManager

public class ObjectManager
extends ObjectMgrModel

An IObjectManager for use with an embedded database, including JSP pages running in the same webapp as the NanoSparqlServer and applications that do not expose a public web interface.

Author:

Bryan Thompson

Field Summary

Fields inherited from class com.bigdata.gom.om.ObjectMgrModel

m_maxDirtyListSize, m_valueFactory

Constructor Summary

Constructors

Constructor and Description
ObjectManager(String endpoint, BigdataSailRepository cxn)

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Close the object manager, which terminates its connection with the backing store.
ICloseableIterator<org.openrdf.query.BindingSet>	evaluate(String query)
ICloseableIterator<org.openrdf.model.Statement>	evaluateGraph(String query)
void	execute(String updateStr)
protected void	flushStatements(List<org.openrdf.model.Statement> m_inserts, List<org.openrdf.model.Statement> m_removes) Flush statements to be inserted and removed to the backing store..
BigdataSailRepository	getRepository()
boolean	isPersistent() Return true iff the object manager is backed by some persistence layer.
protected void	materializeWithDescribe(IGPO gpo)
void	setMaxDataListSize(int newValue) This may be used to break ACID and perform incremental eviction of dirty objects to the backing store.

Methods inherited from class com.bigdata.gom.om.ObjectMgrModel

addToDirtyList, beginNativeTransaction, bestEffortIntern, clearCache, commitNativeTransaction, createGPO, encode, getDefaultNameMgr, getDirtyObjectCount, getGPO, getGPO, getGPOs, getID, getNames, getNativeTransactionCounter, getValueFactory, initGPO, initGPOs, internKey, materialize, materializeWithSelect, recall, recallAsGPO, remove, rollbackNativeTransaction, save

Methods inherited from class java.lang.Object

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

Constructor Detail

ObjectManager

public ObjectManager(String endpoint,
             BigdataSailRepository cxn)
              throws org.openrdf.repository.RepositoryException

Parameters:

endpoint - A SPARQL endpoint that may be used to communicate with the database.

cxn - A connection to the database.

Throws:

org.openrdf.repository.RepositoryException

Method Detail

setMaxDataListSize

public void setMaxDataListSize(int newValue)

This may be used to break ACID and perform incremental eviction of dirty objects to the backing store. However, the use of this method is NOT recommended as the updates will become durable incrementally rather than atomically.

Parameters:

newValue - The new maximum dirty list size (default is Integer.MAX_VALUE).

getRepository

public BigdataSailRepository getRepository()

Returns:

direct repository connection

close

public void close()

Description copied from interface: IObjectManager

Close the object manager, which terminates its connection with the backing store. Any open concurrent or nested/native transactions are flushed to the store. The object manager can not be used after it has been closed.

Specified by:

close in interface IObjectManager

Overrides:

close in class ObjectMgrModel

evaluate

public ICloseableIterator<org.openrdf.query.BindingSet> evaluate(String query)

evaluateGraph

public ICloseableIterator<org.openrdf.model.Statement> evaluateGraph(String query)

execute

public void execute(String updateStr)

isPersistent

public boolean isPersistent()

Description copied from interface: IObjectManager

Return true iff the object manager is backed by some persistence layer.

materializeWithDescribe

protected void materializeWithDescribe(IGPO gpo)

Overrides:

materializeWithDescribe in class ObjectMgrModel

flushStatements

protected void flushStatements(List<org.openrdf.model.Statement> m_inserts,
                   List<org.openrdf.model.Statement> m_removes)

Description copied from class: ObjectMgrModel

Flush statements to be inserted and removed to the backing store..

Specified by:

flushStatements in class ObjectMgrModel

Parameters:

m_inserts - The list of statements to be added.

m_removes - The list of statements to be removed.