org.ontoware.rdf2go.model.impl

Class NotifyingModelSetLayer

java.lang.Object

org.ontoware.rdf2go.model.impl.AbstractModelSetImpl

org.ontoware.rdf2go.model.impl.DelegatingModelSet

org.ontoware.rdf2go.model.impl.NotifyingModelSetLayer

All Implemented Interfaces:

Serializable, Iterable<Statement>, ClosableIterable<Statement>, Commitable, FindableModelSet, Lockable, ModelSet, ModelSetAddRemove, ModelSetIO, ModelValueFactory, NamespaceSupport, NotifyingModelSet, ReificationSupport, Sparqlable

public class NotifyingModelSetLayer
extends DelegatingModelSet
implements NotifyingModelSet

Adds notifying capabilites to existing models. Reads from streams and readers are not detectable.

Author:

voelkel

See Also:

Serialized Form

Field Summary

Fields inherited from class org.ontoware.rdf2go.model.impl.DelegatingModelSet

baseModelSet

Constructor Summary

Constructors

Constructor and Description
NotifyingModelSetLayer(ModelSet modelset)

Method Summary

Modifier and Type	Method and Description
boolean	addModel(Model model) Adds a model to this ModelSet.
void	addModelSetChangedListener(ModelChangedListener listener)
void	addModelSetChangedListener(ModelChangedListener listener, QuadPattern pattern)
void	addStatement(Statement statement) This method creates a Model named statement.getContextURI if needed.
Model	getDefaultModel() The default model is used when the ModelSet is loaded from a serialisation that has no context.
Model	getModel(URI contextURI) Get the Model with the passed URI.
ClosableIterator<Model>	getModels()
void	removeModelSetChangedListener(ModelChangedListener listener)
void	removeStatement(Statement statement) Removes the statement (s,p,o) from a model named statement.getContext().
void	update(DiffReader diff) Apply the changes given by this diff in one atomic operation Implementations must check that all statements to be removed are still in the Model.

Methods inherited from class org.ontoware.rdf2go.model.impl.DelegatingModelSet

addModel, addModelSet, addReificationOf, addReificationOf, close, commit, containsModel, containsStatements, createBlankNode, createQuadPattern, createURI, deleteReification, findStatements, getAllReificationsOf, getDelegatedModelSet, getModelURIs, getNamespace, getNamespaces, getUnderlyingModelImplementation, getUnderlyingModelSetImplementation, hasReifications, isEmpty, isOpen, open, queryConstruct, querySelect, readFrom, readFrom, readFrom, readFrom, readFrom, readFrom, removeModel, removeNamespace, setAutocommit, setNamespace, size, sparqlAsk, sparqlConstruct, sparqlDescribe, sparqlSelect, writeTo, writeTo, writeTo, writeTo

Methods inherited from class org.ontoware.rdf2go.model.impl.AbstractModelSetImpl

addAll, addStatement, contains, countStatements, createBlankNode, createDatatypeLiteral, createLanguageTagLiteral, createPlainLiteral, createStatement, createStatement, dump, findStatements, isLocked, isValidURI, iterator, lock, newRandomUniqueURI, removeAll, removeAll, removeStatement, removeStatements, removeStatements, serialize, unlock

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.ontoware.rdf2go.model.ModelSet

createStatement, dump, removeAll

Methods inherited from interface org.ontoware.rdf2go.model.ModelSetIO

serialize

Methods inherited from interface org.ontoware.rdf2go.model.FindableModelSet

contains, countStatements, findStatements

Methods inherited from interface org.ontoware.rdf2go.model.ModelSetAddRemove

addAll, addStatement, removeAll, removeStatement, removeStatements, removeStatements

Methods inherited from interface org.ontoware.aifbcommons.collection.ClosableIterable

iterator

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Methods inherited from interface org.ontoware.rdf2go.model.Lockable

isLocked, lock, unlock

Methods inherited from interface org.ontoware.rdf2go.model.ModelValueFactory

createBlankNode, createDatatypeLiteral, createLanguageTagLiteral, createPlainLiteral, createStatement, isValidURI, newRandomUniqueURI

Constructor Detail

NotifyingModelSetLayer

public NotifyingModelSetLayer(ModelSet modelset)

Method Detail

addModelSetChangedListener

public void addModelSetChangedListener(ModelChangedListener listener)

Specified by:

addModelSetChangedListener in interface NotifyingModelSet

addModelSetChangedListener

public void addModelSetChangedListener(ModelChangedListener listener,
                                       QuadPattern pattern)

Specified by:

addModelSetChangedListener in interface NotifyingModelSet

Parameters:

listener - to be notified on matching events

pattern - all add or remove statement events matching the pattern will be send to the listener. Updates are always send.

removeModelSetChangedListener

public void removeModelSetChangedListener(ModelChangedListener listener)

Specified by:

removeModelSetChangedListener in interface NotifyingModelSet

addModel

public boolean addModel(Model model)

Description copied from interface: ModelSet

Adds a model to this ModelSet. Creating the named-graph if needed, adding the triples to it if not. Same semantics as: ModelSet.getModel(model.getContextUri).add(model). Note: This method might be much quicker than addAll(model.iterator()) depending on the implementation.

Specified by:

addModel in interface ModelSet

Overrides:

addModel in class DelegatingModelSet

Returns:

true if successful

addStatement

public void addStatement(Statement statement)
                  throws ModelRuntimeException

Description copied from interface: ModelSetAddRemove

This method creates a Model named statement.getContextURI if needed. Then the statement (s,p,o) is inserted into that model.

Specified by:

addStatement in interface ModelSetAddRemove

Overrides:

addStatement in class DelegatingModelSet

Throws:

ModelRuntimeException - if any internal (I/O related) exception occurs

getDefaultModel

public Model getDefaultModel()

Description copied from interface: ModelSet

The default model is used when the ModelSet is loaded from a serialisation that has no context. The default model has a context of 'null'

Specified by:

getDefaultModel in interface ModelSet

Overrides:

getDefaultModel in class DelegatingModelSet

Returns:

the default model. It has to be isOpen() == true.

getModel

public Model getModel(URI contextURI)

Description copied from interface: ModelSet

Get the Model with the passed URI. If the model does not exist yet, an empty model will be created and returned. This method will throw an Exception when ModelSet.isOpen() is false. Note that the returned model is tied to this ModelSet. Any changes in the model will be reflected here, closing this ModelSet will close the returned Model. To avoid side-effects, closing the returned Model will NOT close this ModelSet. Closing the returned model will not affect objects returned by previous calls to this method, hence this method should always return a new copy of the Model object to allow callers to close() a returned model.

Specified by:

getModel in interface ModelSet

Overrides:

getModel in class DelegatingModelSet

Parameters:

contextURI - the URI of the context. This is the same as the name of the named graph.

Returns:

the model identified by this context. May have a size of 0, if no data was added to it yet. Never returns null. The returned model has isOpen() == true. Closing the returned model will not close this dataset and is optional.

getModels

public ClosableIterator<Model> getModels()

Specified by:

getModels in interface ModelSet

Overrides:

getModels in class DelegatingModelSet

Returns:

an Interator over all models within this ModelSet. Some models might be empty. Since 4.4.10: Each model has to be isOpen() == true. For some implementations: While you read the iterator you may not WRITE to the models.

removeStatement

public void removeStatement(Statement statement)
                     throws ModelRuntimeException

Description copied from interface: ModelSetAddRemove

Removes the statement (s,p,o) from a model named statement.getContext(). If the model named statement.getContext() becomes empty, it remains in the ModelSet.

Specified by:

removeStatement in interface ModelSetAddRemove

Overrides:

removeStatement in class DelegatingModelSet

Parameters:

statement - a Statement

Throws:

ModelRuntimeException - if any internal (I/O related) exception occurs

update

public void update(DiffReader diff)
            throws ModelRuntimeException

Description copied from interface: ModelSetAddRemove

Apply the changes given by this diff in one atomic operation Implementations must check that all statements to be removed are still in the Model. Otherwise an exception is thrown. First all triples to be removed are removed, then triples to be added are added. In this modelset, this means (s,p,o) is removed from the graph named c, for all statements (c,s,p,o). Note: Models becoming empty are not removed.

Specified by:

update in interface ModelSetAddRemove

Overrides:

update in class DelegatingModelSet

Throws:

ModelRuntimeException - if the ModelSet is locked