org.openrdf.sail.optimistic
Class OptimisticConnection

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

All Implemented Interfaces:

NotifyingSailConnection, SailConnection

Direct Known Subclasses:

OptimisticInferencerConnection

public class OptimisticConnection
extends SailConnectionWrapper
implements NotifyingSailConnection

Ensures every transaction has serializable isolation.

Author:

James Leigh

Constructor Summary

OptimisticConnection(OptimisticSail sail, SailConnection wrappedCon)

Method Summary

void	addConnectionListener(SailConnectionListener listener)
void	addStatement(Resource subj, URI pred, Value obj, Resource... contexts)
void	begin()
void	close()
void	commit()
CloseableIteration<? extends BindingSet,QueryEvaluationException>	evaluate(TupleExpr query, Dataset dataset, BindingSet bindings, boolean inf)
Model	getAddedModel() locked by this
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()
Resource[]	notNull(Resource[] contexts)
void	removeConnectionListener(SailConnectionListener listener)
void	removeStatements(Resource subj, URI pred, Value obj, Resource... contexts)
void	rollback()
long	size(Resource... contexts)

Methods inherited from class org.openrdf.sail.helpers.SailConnectionWrapper

clear, clearNamespaces, getContextIDs, getNamespace, getNamespaces, getWrappedConnection, isOpen, removeNamespace, setNamespace, size

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.openrdf.sail.SailConnection

clear, clearNamespaces, getContextIDs, getNamespace, getNamespaces, isOpen, removeNamespace, setNamespace

Constructor Detail

OptimisticConnection

public OptimisticConnection(OptimisticSail sail,
                            SailConnection wrappedCon)

Method Detail

close

public void close()
           throws SailException

Specified by:

close in interface SailConnection

Overrides:

close in class SailConnectionWrapper

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

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

Overrides:

commit in class SailConnectionWrapper

Throws:

SailException

rollback

public void rollback()
              throws SailException

Specified by:

rollback in interface SailConnection

Overrides:

rollback in class SailConnectionWrapper

Throws:

SailException

addStatement

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

Specified by:

addStatement in interface SailConnection

Overrides:

addStatement in class SailConnectionWrapper

Throws:

SailException

removeStatements

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

Specified by:

removeStatements in interface SailConnection

Overrides:

removeStatements in class SailConnectionWrapper

Throws:

SailException

size

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

Specified by:

size in interface SailConnection

Overrides:

size in class SailConnectionWrapper

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

Overrides:

getStatements in class SailConnectionWrapper

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

Overrides:

evaluate in class SailConnectionWrapper

Throws:

SailException

notNull

public Resource[] notNull(Resource[] contexts)