org.openrdf.sail.optimistic
Class OptimisticConnection

java.lang.Object
  org.openrdf.sail.optimistic.OptimisticConnection

All Implemented Interfaces:

NotifyingSailConnection, SailConnection

Direct Known Subclasses:

OptimisticInferencerConnection

public class OptimisticConnection
extends Object
implements NotifyingSailConnection

Optionally enforces snapshot and serializable isolation.

Author:

James Leigh

Constructor Summary

OptimisticConnection(OptimisticSail sail, SailConnection delegate)

Method Summary

void	addConnectionListener(SailConnectionListener listener)
void	addStatement(Resource subj, URI pred, Value obj, Resource... contexts)
void	begin()
void	clear(Resource... contexts)
void	clearNamespaces()
void	close()
void	commit()
CloseableIteration<? extends BindingSet,QueryEvaluationException>	evaluate(TupleExpr query, Dataset dataset, BindingSet bindings, boolean inf)
Model	getAddedModel() locked by this
CloseableIteration<? extends Resource,SailException>	getContextIDs()
String	getNamespace(String prefix)
CloseableIteration<? extends Namespace,SailException>	getNamespaces()
Set<EvaluateOperation>	getReadOperations() locked by this
Model	getRemovedModel() locked by this
CloseableIteration<? extends Statement,SailException>	getStatements(Resource subj, URI pred, Value obj, boolean inf, Resource... contexts)
boolean	isAutoCommit()
boolean	isOpen()
boolean	isSerializable()
boolean	isSnapshot()
void	removeConnectionListener(SailConnectionListener listener)
void	removeNamespace(String prefix)
void	removeStatements(Resource subj, URI pred, Value obj, Resource... contexts)
void	rollback()
void	setNamespace(String prefix, String name)
void	setSerializable(boolean serializable)
void	setSnapshot(boolean snapshot)
long	size(Resource... contexts)

Methods inherited from class java.lang.Object

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

Constructor Detail

OptimisticConnection

public OptimisticConnection(OptimisticSail sail,
                            SailConnection delegate)

Method Detail

isSnapshot

public boolean isSnapshot()

setSnapshot

public void setSnapshot(boolean snapshot)

isSerializable

public boolean isSerializable()

setSerializable

public void setSerializable(boolean serializable)

close

public void close()
           throws SailException

Specified by:

close in interface SailConnection

Throws:

SailException

getAddedModel

public Model getAddedModel()

locked by this

getRemovedModel

public Model getRemovedModel()

locked by this

getReadOperations

public Set<EvaluateOperation> getReadOperations()

locked by this

addConnectionListener

public void addConnectionListener(SailConnectionListener listener)

Specified by:

addConnectionListener in interface NotifyingSailConnection

removeConnectionListener

public void removeConnectionListener(SailConnectionListener listener)

Specified by:

removeConnectionListener in interface NotifyingSailConnection

isOpen

public boolean isOpen()
               throws SailException

Specified by:

isOpen in interface SailConnection

Throws:

SailException

isAutoCommit

public boolean isAutoCommit()
                     throws SailException

Throws:

SailException

begin

public void begin()
           throws SailException

Throws:

SailException

commit

public void commit()
            throws SailException

Specified by:

commit in interface SailConnection

Throws:

SailException

rollback

public void rollback()
              throws SailException

Specified by:

rollback in interface SailConnection

Throws:

SailException

clear

public void clear(Resource... contexts)
           throws SailException

Specified by:

clear in interface SailConnection

Throws:

SailException

getContextIDs

public CloseableIteration<? extends Resource,SailException> getContextIDs()
                                                                   throws SailException

Specified by:

getContextIDs in interface SailConnection

Throws:

SailException

clearNamespaces

public void clearNamespaces()
                     throws SailException

Specified by:

clearNamespaces in interface SailConnection

Throws:

SailException

removeNamespace

public void removeNamespace(String prefix)
                     throws SailException

Specified by:

removeNamespace in interface SailConnection

Throws:

SailException

setNamespace

public void setNamespace(String prefix,
                         String name)
                  throws SailException

Specified by:

setNamespace in interface SailConnection

Throws:

SailException

getNamespace

public String getNamespace(String prefix)
                    throws SailException

Specified by:

getNamespace in interface SailConnection

Throws:

SailException

getNamespaces

public CloseableIteration<? extends Namespace,SailException> getNamespaces()
                                                                    throws SailException

Specified by:

getNamespaces in interface SailConnection

Throws:

SailException

addStatement

public void addStatement(Resource subj,
                         URI pred,
                         Value obj,
                         Resource... contexts)
                  throws SailException

Specified by:

addStatement in interface SailConnection

Throws:

SailException

removeStatements

public void removeStatements(Resource subj,
                             URI pred,
                             Value obj,
                             Resource... contexts)
                      throws SailException

Specified by:

removeStatements in interface SailConnection

Throws:

SailException

size

public long size(Resource... contexts)
          throws SailException

Specified by:

size in interface SailConnection

Throws:

SailException

getStatements

public CloseableIteration<? extends Statement,SailException> getStatements(Resource subj,
                                                                           URI pred,
                                                                           Value obj,
                                                                           boolean inf,
                                                                           Resource... contexts)
                                                                    throws SailException

Specified by:

getStatements in interface SailConnection

Throws:

SailException

evaluate

public CloseableIteration<? extends BindingSet,QueryEvaluationException> evaluate(TupleExpr query,
                                                                                  Dataset dataset,
                                                                                  BindingSet bindings,
                                                                                  boolean inf)
                                                                           throws SailException

Specified by:

evaluate in interface SailConnection

Throws:

SailException