org.ontoware.rdf2go.model.impl

Class AbstractModelSetImpl

java.lang.Object

org.ontoware.rdf2go.model.impl.AbstractModelSetImpl

All Implemented Interfaces:

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

Direct Known Subclasses:

DelegatingModelSet, RepositoryModelSet

public abstract class AbstractModelSetImpl
extends Object
implements ModelSet

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AbstractModelSetImpl()

Method Summary

Modifier and Type	Method and Description
void	addAll(Iterator<? extends Statement> statement) For each statement in the iterator, this method creates a Model named statement.getContextURI if needed.
boolean	addModel(Model model) Adds a model to this ModelSet.
void	addModel(Model model, URI contextURI) subclasses should overwrite this for performance reasons
void	addModelSet(ModelSet modelSet) Adds a complete ModelSet to this ModelSet.
BlankNode	addReificationOf(Statement statement) A convenience function for addReficationOf( createBlankNode(), statement );
Resource	addReificationOf(Statement statement, Resource resource) Reifies the statement, whether the statement was present in the model or not.
void	addStatement(URI context, Resource subject, URI predicate, Node object) This method creates a Model named 'contextURI' if needed.
boolean	contains(Statement s)
boolean	containsStatements(UriOrVariable contextURI, ResourceOrVariable subject, UriOrVariable predicate, NodeOrVariable object)
long	countStatements(QuadPattern pattern)
BlankNode	createBlankNode() Create (but do not add) a new blank node
BlankNode	createBlankNode(String internalID) Create a new blank node with the given internal ID.
DatatypeLiteral	createDatatypeLiteral(String literal, URI datatypeURI)
LanguageTagLiteral	createLanguageTagLiteral(String literal, String langugeTag)
PlainLiteral	createPlainLiteral(String literal) Create a new plain literal
Statement	createStatement(Resource subject, URI predicate, Node object) Create a new statement - but DOES NOT add it to the model
Statement	createStatement(URI context, Resource subject, URI predicate, Node object) Creates a statement with a context URI.
URI	createURI(String uriString) Creates an RDF2Go URI.
void	deleteReification(Resource reificationResource) Delete reifications made by this resource.
void	dump() Print the whole content of this ModelSet to System.out.
ClosableIterator<Statement>	findStatements(QuadPattern pattern) Inefficient: Looks into each model and asks to match the triplepattern part of the quad pattern.
ClosableIterator<Statement>	findStatements(UriOrVariable contextURI, ResourceOrVariable subject, UriOrVariable predicate, NodeOrVariable object) Search across all existing models
Collection<Resource>	getAllReificationsOf(Statement statement)
boolean	hasReifications(Statement statement)
boolean	isEmpty() sublcasses should override this method for performance
boolean	isLocked()
boolean	isValidURI(String uriString) CHecks URI for syntax errors.
ClosableIterator<Statement>	iterator() Returns an iterator over a set of elements of type T.
void	lock() Tries to obtain a lock.
URI	newRandomUniqueURI() Implementations are free to choose if their semantics are unique within the this model, the ModelSet, or unique in the universe
void	readFrom(InputStream in, Syntax syntax) Reads assuming the given syntax.
void	readFrom(Reader in, Syntax syntax) Reads assuming the given syntax.
void	removeAll() Removes all models, which is not the same as removing all statements from all models in this ModelSet.
void	removeAll(Iterator<? extends Statement> statement) For each statement in the iterator, the statement is removed form the model named statement.getContext(); If the model named statement.getContext() becomes empty, it remains in the ModelSet.
void	removeStatement(URI context, Resource subject, URI predicate, Node object) Removes the statement (s,p,o) from a model named contextURI.
void	removeStatements(QuadPattern quadPattern) Find all models matching the context of the pattern and remove all matching triple patterms from them
void	removeStatements(UriOrVariable context, ResourceOrVariable subject, UriOrVariable predicate, NodeOrVariable object) Find all models matching the context, and remove all (subject, property ,object)-statements from these model
String	serialize(Syntax syntax) Convenience method to export a ModelSet to a String in a given syntax.
boolean	sparqlAsk(String query) SPARQL ask queries
void	unlock() Removes a lock.
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.
void	writeTo(OutputStream out, Syntax syntax) Write the model to the passed writer, using the passed syntax.
void	writeTo(Writer writer, Syntax syntax) Write the model to the passed writer, using the passed syntax.

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

close, containsModel, getDefaultModel, getModel, getModels, getModelURIs, getUnderlyingModelSetImplementation, isOpen, open, removeModel, size

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

queryConstruct, querySelect, sparqlConstruct, sparqlDescribe, sparqlSelect

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

readFrom, readFrom, readFrom, readFrom, writeTo, writeTo

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

createQuadPattern

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

addStatement, removeStatement

Methods inherited from interface java.lang.Iterable

forEach, spliterator

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

commit, setAutocommit

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

getNamespace, getNamespaces, removeNamespace, setNamespace

Constructor Detail

AbstractModelSetImpl

public AbstractModelSetImpl()

Method Detail

dump

public void dump()

Description copied from interface: ModelSet

Print the whole content of this ModelSet to System.out.

Specified by:

dump in interface ModelSet

removeAll

public void removeAll()
               throws ModelRuntimeException

Description copied from interface: ModelSet

Removes all models, which is not the same as removing all statements from all models in this ModelSet.

Specified by:

removeAll in interface ModelSet

Throws:

ModelRuntimeException

createStatement

public Statement createStatement(URI context,
                                 Resource subject,
                                 URI predicate,
                                 Node object)

Description copied from interface: ModelSet

Creates a statement with a context URI.

Specified by:

createStatement in interface ModelSet

Returns:

the newly created statement (quad), which is not yet added to any model

readFrom

public void readFrom(Reader in,
                     Syntax syntax)
              throws IOException,
                     ModelRuntimeException,
                     SyntaxNotSupportedException

Description copied from interface: ModelSetIO

Reads assuming the given syntax. Encoding defaults to UTF8.

Specified by:

readFrom in interface ModelSetIO

Parameters:

in - the input to read

syntax - syntax to use

Throws:

IOException - on IOErrors

ModelRuntimeException - on RDF serialisation errors or model errors

SyntaxNotSupportedException - if adapter can't handle the given syntax

readFrom

public void readFrom(InputStream in,
                     Syntax syntax)
              throws IOException,
                     ModelRuntimeException,
                     SyntaxNotSupportedException

Description copied from interface: ModelSetIO

Reads assuming the given syntax. Encoding defaults to UTF8.

Specified by:

readFrom in interface ModelSetIO

syntax - syntax to use

Throws:

IOException - on IOErrors

ModelRuntimeException - on RDF serialisation errors or model errors

SyntaxNotSupportedException - if adapter can't handle the given syntax

writeTo

public void writeTo(Writer writer,
                    Syntax syntax)
             throws IOException,
                    ModelRuntimeException,
                    SyntaxNotSupportedException

Description copied from interface: ModelSetIO

Write the model to the passed writer, using the passed syntax.

Specified by:

writeTo in interface ModelSetIO

Parameters:

writer - the output to write to

syntax - syntax to use

Throws:

IOException - on IOErrors

ModelRuntimeException - on RDF serialization errors or model errors

SyntaxNotSupportedException - if adapter can't handle the given syntax

writeTo

public void writeTo(OutputStream out,
                    Syntax syntax)
             throws IOException,
                    ModelRuntimeException,
                    SyntaxNotSupportedException

Description copied from interface: ModelSetIO

Write the model to the passed writer, using the passed syntax.

Specified by:

writeTo in interface ModelSetIO

Parameters:

out - the output to write to

syntax - syntax to use

Throws:

IOException - on IOErrors

ModelRuntimeException - on RDF serialization errors or model errors

SyntaxNotSupportedException - if adapter can't handle the given syntax

serialize

public String serialize(Syntax syntax)
                 throws SyntaxNotSupportedException

Description copied from interface: ModelSetIO

Convenience method to export a ModelSet to a String in a given syntax.

Specified by:

serialize in interface ModelSetIO

Returns:

a String, containing the ModelSet content in the given syntax.

Throws:

SyntaxNotSupportedException - if the syntax is not supported

containsStatements

public boolean containsStatements(UriOrVariable contextURI,
                                  ResourceOrVariable subject,
                                  UriOrVariable predicate,
                                  NodeOrVariable object)
                           throws ModelRuntimeException

Specified by:

containsStatements in interface FindableModelSet

Returns:

true, if a Model named 'contextURI' contains the statement (s,p,o)

Throws:

ModelRuntimeException

addStatement

public void addStatement(URI context,
                         Resource subject,
                         URI predicate,
                         Node object)
                  throws ModelRuntimeException

Description copied from interface: ModelSetAddRemove

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

Specified by:

addStatement in interface ModelSetAddRemove

Parameters:

context - a URI or null

subject - a Resource (URI or BlankNode)

object - a Node

Throws:

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

addAll

public void addAll(Iterator<? extends Statement> statement)
            throws ModelRuntimeException

Description copied from interface: ModelSetAddRemove

For each statement in the iterator, this method creates a Model named statement.getContextURI if needed. Then the statement (s,p,o) is inserted into that model.

Specified by:

addAll in interface ModelSetAddRemove

Throws:

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

removeStatement

public void removeStatement(URI context,
                            Resource subject,
                            URI predicate,
                            Node object)
                     throws ModelRuntimeException

Description copied from interface: ModelSetAddRemove

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

Specified by:

removeStatement in interface ModelSetAddRemove

subject - a Resource (URI or BlankNode)

object - a Node

Throws:

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

removeAll

public void removeAll(Iterator<? extends Statement> statement)
               throws ModelRuntimeException

Description copied from interface: ModelSetAddRemove

For each statement in the iterator, the statement is removed form the model named statement.getContext(); If the model named statement.getContext() becomes empty, it remains in the ModelSet.

Specified by:

removeAll in interface ModelSetAddRemove

Throws:

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

removeStatements

public void removeStatements(QuadPattern quadPattern)
                      throws ModelRuntimeException

Description copied from interface: ModelSetAddRemove

Find all models matching the context of the pattern and remove all matching triple patterms from them

Specified by:

removeStatements in interface ModelSetAddRemove

Throws:

ModelRuntimeException

removeStatements

public void removeStatements(UriOrVariable context,
                             ResourceOrVariable subject,
                             UriOrVariable predicate,
                             NodeOrVariable object)
                      throws ModelRuntimeException

Description copied from interface: ModelSetAddRemove

Find all models matching the context, and remove all (subject, property ,object)-statements from these model

Specified by:

removeStatements in interface ModelSetAddRemove

Throws:

ModelRuntimeException

createBlankNode

public BlankNode createBlankNode()

Description copied from interface: ModelValueFactory

Create (but do not add) a new blank node

Specified by:

createBlankNode in interface ModelValueFactory

Returns:

a new blank node

createBlankNode

public BlankNode createBlankNode(String internalID)

Description copied from interface: ModelValueFactory

Create a new blank node with the given internal ID. The id should be one returned from BlankNode.getInternalID().

Specified by:

createBlankNode in interface ModelValueFactory

Returns:

a BlankNode with the given internal ID.

createURI

public URI createURI(String uriString)
              throws ModelRuntimeException

Description copied from interface: ModelSet

Creates an RDF2Go URI. This allows a user to create a model via 'getModel( URI )'.

Specified by:

createURI in interface ModelSet

Specified by:

createURI in interface ModelValueFactory

Returns:

an RDF2Go URI

Throws:

ModelRuntimeException - if URI has not a valid URI format - according to the adapter

isValidURI

public boolean isValidURI(String uriString)

Description copied from interface: ModelValueFactory

CHecks URI for syntax errors.

Specified by:

isValidURI in interface ModelValueFactory

Returns:

true if the URI is valid for the given implementation

createPlainLiteral

public PlainLiteral createPlainLiteral(String literal)

Description copied from interface: ModelValueFactory

Create a new plain literal

Specified by:

createPlainLiteral in interface ModelValueFactory

Returns:

a PlainLiteral

createLanguageTagLiteral

public LanguageTagLiteral createLanguageTagLiteral(String literal,
                                                   String langugeTag)
                                            throws ModelRuntimeException

Specified by:

createLanguageTagLiteral in interface ModelValueFactory

Returns:

a LanguageTagLiteral

Throws:

ModelRuntimeException - e.g. if the language tag is malformed

createDatatypeLiteral

public DatatypeLiteral createDatatypeLiteral(String literal,
                                             URI datatypeURI)
                                      throws ModelRuntimeException

Specified by:

createDatatypeLiteral in interface ModelValueFactory

Returns:

a DatatypeLiteral

Throws:

ModelRuntimeException - e.g. if the datatype URI causes problems

createStatement

public Statement createStatement(Resource subject,
                                 URI predicate,
                                 Node object)

Description copied from interface: ModelValueFactory

Create a new statement - but DOES NOT add it to the model

Specified by:

createStatement in interface ModelValueFactory

Returns:

a Statement

newRandomUniqueURI

public URI newRandomUniqueURI()

Description copied from interface: ModelValueFactory

Implementations are free to choose if their semantics are unique within the this model, the ModelSet, or unique in the universe

Specified by:

newRandomUniqueURI in interface ModelValueFactory

Returns:

a new, unique URI

isLocked

public boolean isLocked()

Specified by:

isLocked in interface Lockable

Returns:

true if a lock is active

lock

public void lock()
          throws LockException

Description copied from interface: Lockable

Tries to obtain a lock.

Specified by:

lock in interface Lockable

Throws:

LockException - if already locked

unlock

public void unlock()

Description copied from interface: Lockable

Removes a lock. If no lock was set, nothing happens.

Specified by:

unlock in interface Lockable

contains

public boolean contains(Statement s)
                 throws ModelRuntimeException

Specified by:

contains in interface FindableModelSet

Parameters:

s - a Statement

Returns:

true if the modelset contains a model with context s.getContext() which contains the statement s. If the context is null, the default graph is checked.

Throws:

ModelRuntimeException

countStatements

public long countStatements(QuadPattern pattern)
                     throws ModelRuntimeException

Specified by:

countStatements in interface FindableModelSet

Returns:

the number of statements matchingthe pattern. This is for all graphs matching the context of the pattern (this is none, one or all graphs). In matching graphs the number of matching statements is accumulated and returned.

Throws:

ModelRuntimeException

findStatements

public ClosableIterator<Statement> findStatements(QuadPattern pattern)
                                           throws ModelRuntimeException

Inefficient: Looks into each model and asks to match the triplepattern part of the quad pattern.

Specified by:

findStatements in interface FindableModelSet

Returns:

all statements matching the quad pattern

Throws:

ModelRuntimeException

findStatements

public ClosableIterator<Statement> findStatements(UriOrVariable contextURI,
                                                  ResourceOrVariable subject,
                                                  UriOrVariable predicate,
                                                  NodeOrVariable object)
                                           throws ModelRuntimeException

Description copied from interface: FindableModelSet

Search across all existing models

Specified by:

findStatements in interface FindableModelSet

Returns:

all matching statements in all models

Throws:

ModelRuntimeException

iterator

public ClosableIterator<Statement> iterator()

Description copied from interface: ClosableIterable

Returns an iterator over a set of elements of type T.

Specified by:

iterator in interface Iterable<Statement>

Specified by:

iterator in interface ClosableIterable<Statement>

Returns:

an Iterator.

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

Returns:

true if successful

addModelSet

public void addModelSet(ModelSet modelSet)

Description copied from interface: ModelSet

Adds a complete ModelSet to this ModelSet. Context URIs in the Statements of the modelSet are respected.

Specified by:

addModelSet in interface ModelSet

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

Throws:

ModelRuntimeException - if the ModelSet is locked

isEmpty

public boolean isEmpty()

sublcasses should override this method for performance

Specified by:

isEmpty in interface ModelSet

Returns:

true if all models in this ModelSet contain zero statements. This method might be faster than calling size() == 0 on each model. Note: This method can return isEmpty == true, even if the ModelSet contains a number of models.

sparqlAsk

public boolean sparqlAsk(String query)
                  throws ModelRuntimeException,
                         MalformedQueryException

Description copied from interface: Sparqlable

SPARQL ask queries

Specified by:

sparqlAsk in interface Sparqlable

Parameters:

query - a SPARQL AKS query

Returns:

the query result as true or false

Throws:

ModelRuntimeException - if the execution throws an exception

MalformedQueryException - if the query is not a valid SPARQL ASK query

addReificationOf

public BlankNode addReificationOf(Statement statement)

Description copied from interface: ReificationSupport

A convenience function for addReficationOf( createBlankNode(), statement );

Specified by:

addReificationOf in interface ReificationSupport

Returns:

a new BlankNode which holds the reification of the given statement.

addReificationOf

public Resource addReificationOf(Statement statement,
                                 Resource resource)

Description copied from interface: ReificationSupport

Reifies the statement, whether the statement was present in the model or not. The statement itself is never added to the model, but it might have been in the model before this method call. This method creates only triples like (resource )rdf:subject s; rdf:predicate p; rdf:object o. Where s,p, and o are taken from the given statement. Adds the following statements, as defined in @see http://www.w3.org/TR/rdf-mt/#Reif

 (resource) rdf:type       rdf:Statement .
 (resource) rdf:subject   (statement.getSubject()) .
 (resource) rdf:predicate (statement.getPredicate()) .
 (resource) rdf:object    (statement.getObject()) .
 

Specified by:

addReificationOf in interface ReificationSupport

Parameters:

statement - which will be reified

resource - used to represent the reified statement

Returns:

the given resource

hasReifications

public boolean hasReifications(Statement statement)

Specified by:

hasReifications in interface ReificationSupport

Returns:

true if the model contains results to the query

 ?reificationResource rdf:type      rdf:Statement . 
 ?reificationResource rdf:subject   ?s .
 ?reificationResource rdf:predicate ?p .
 ?reificationResource rdf:object    ?o .
 

getAllReificationsOf

public Collection<Resource> getAllReificationsOf(Statement statement)

Specified by:

getAllReificationsOf in interface ReificationSupport

Returns:

a collection which contains all resources that are a reification of the given statement.

deleteReification

public void deleteReification(Resource reificationResource)

Description copied from interface: ReificationSupport

Delete reifications made by this resource. More technically, this method will remove the following patterns:

 (reificationResource) rdf:type      rdf:Statement . 
 (reificationResource) rdf:subject   * .
 (reificationResource) rdf:predicate * .
 (reificationResource) rdf:object    * .
 

Note that one resource might have been used in several reifications. Although semantic nonsense, this can happen. This method cleans up also these cases. Note that this method deletes the reification from all contexts.

Specified by:

deleteReification in interface ReificationSupport

addModel

public void addModel(Model model,
                     URI contextURI)

subclasses should overwrite this for performance reasons

Specified by:

addModel in interface ModelSet