org.eclipse.lyo.store.internals

Class SparqlStoreImpl

java.lang.Object

org.eclipse.lyo.store.internals.SparqlStoreImpl

All Implemented Interfaces:

Store

public class SparqlStoreImpl
extends Object
implements Store

Store interface implementation that interacts with any SPARQL-based triplestore through a Query and Update endpoints.

Since:

0.14.0

Version:

$version-stub$

Author:

Andrew Berezovskyi (andriib@kth.se)

Field Summary

Fields

Modifier and Type	Field and Description
static int	TRIPLE_LIMIT Could be used to prevent extremely large results

Constructor Summary

Constructors

Constructor and Description
SparqlStoreImpl(JenaQueryExecutor queryExecutor) Initialises the Store with the custom JenaQueryExecutor.
SparqlStoreImpl(String queryEndpoint, String updateEndpoint) Initialises the Store with the endpoints for query and update.
SparqlStoreImpl(String queryEndpoint, String updateEndpoint, String username, String password) Initialises the Store with the endpoints for query and update.

Method Summary

Modifier and Type	Method and Description
<T extends org.eclipse.lyo.oslc4j.core.model.IResource> boolean	appendResources(URI namedGraph, Collection<T> resources) Adds OSLC IResource instances in addition to other instances already present on this named graph into the triplestore.
void	clear(URI namedGraph) Deletes the resources and statements stored under the given named graph from the triplestore.
void	deleteResources(URI namedGraphUri, org.eclipse.lyo.oslc4j.core.model.IResource... resources) Delete all statements whose subject is one of the resources's URis.
void	deleteResources(URI namedGraphUri, URI... subjectUris) Delete all statements whose subject is one of nodeUris
org.apache.jena.rdf.model.Model	getJenaModelForSubject(URI namedGraphUri, URI subject) Retrieve a Jena model for triples under the given subject from the corresponding named graph.
<T extends org.eclipse.lyo.oslc4j.core.model.IResource> T	getResource(URI namedGraphUri, URI resourceUri, Class<T> clazz) Retrieve a single IResource instance specified by the concrete type, unmarshaled from the RDF graph persisted in the triplestore under the given named graph.
<T extends org.eclipse.lyo.oslc4j.core.model.IResource> List<T>	getResources(URI namedGraph, Class<T> clazz) Retrieve the collection of IResource instances specified by the concrete type, unmarshaled from the RDF graph persisted in the triplestore under the given named graph.
<T extends org.eclipse.lyo.oslc4j.core.model.IResource> List<T>	getResources(URI namedGraph, Class<T> clazz, int limit, int offset) Alternative to Store.getResources(URI, Class) with paging on the OSLC resource level.
void	insertJenaModel(URI namedGraph, org.apache.jena.rdf.model.Model model) Insert a jena model into the named graph with corresponding URI.
boolean	insertResources(URI namedGraph, Object... resources) Insert Jena models representations of OSLC IResource instances into the named graph.
Set<String>	keySet() Enumerates all named graph URIs within the dataset.
boolean	namedGraphExists(URI namedGraphUri) Checks if the triplestore has the named graph under the corresponding URI.
<T extends org.eclipse.lyo.oslc4j.core.model.IResource> boolean	putResources(URI uri, Collection<T> resources) Inserts OSLC IResource instances into the triplestore in the designed namedGraph.
void	removeAll() Remove EVERYTHING from the triplestore.
boolean	resourceExists(URI namedGraphUri, URI resourceUri) Checks if a resource with resourceUri exists under the corresponding named graph.
<T extends org.eclipse.lyo.oslc4j.core.model.IResource> boolean	updateResources(URI namedGraphUri, T... resources) Insert Jena models representations of OSLC IResource instances into the named graph.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.lyo.store.Store

appendResource

Field Detail

TRIPLE_LIMIT

public static final int TRIPLE_LIMIT

Could be used to prevent extremely large results

See Also:

Constant Field Values

Constructor Detail

SparqlStoreImpl

public SparqlStoreImpl(String queryEndpoint,
                       String updateEndpoint)

Initialises the Store with the endpoints for query and update. Must be available over HTTP or HTTPS (TLS & cipher support depends on the JDK version) without authentication.

Parameters:

queryEndpoint - SPARQL QUERY endpoint

updateEndpoint - SPARQL UPDATE endpoint

SparqlStoreImpl

public SparqlStoreImpl(String queryEndpoint,
                       String updateEndpoint,
                       String username,
                       String password)

Initialises the Store with the endpoints for query and update. Must be available over HTTP or HTTPS (TLS & cipher support depends on the JDK version) with authentication via username and password combinations. Authentication works with the basic and digest HTTP authentication schemes.

Parameters:

queryEndpoint - SPARQL QUERY endpoint

updateEndpoint - SPARQL UPDATE endpoint

username - Username

password - Password

SparqlStoreImpl

public SparqlStoreImpl(JenaQueryExecutor queryExecutor)

Initialises the Store with the custom JenaQueryExecutor.

Parameters:

queryExecutor - Instance of the JenaQueryExecutor that can run queries and updates.

Method Detail

insertJenaModel

public void insertJenaModel(URI namedGraph,
                            org.apache.jena.rdf.model.Model model)

Description copied from interface: Store

Insert a jena model into the named graph with corresponding URI.

Specified by:

insertJenaModel in interface Store

insertResources

public boolean insertResources(URI namedGraph,
                               Object... resources)
                        throws StoreAccessException

Description copied from interface: Store

Insert Jena models representations of OSLC IResource instances into the named graph. existing statements already present in the named graph are not overridden, nor removed.

Specified by:

insertResources in interface Store

Throws:

StoreAccessException

deleteResources

public void deleteResources(URI namedGraphUri,
                            URI... subjectUris)

Description copied from interface: Store

Delete all statements whose subject is one of nodeUris

Specified by:

deleteResources in interface Store

deleteResources

public void deleteResources(URI namedGraphUri,
                            org.eclipse.lyo.oslc4j.core.model.IResource... resources)

Description copied from interface: Store

Delete all statements whose subject is one of the resources's URis.

Specified by:

deleteResources in interface Store

namedGraphExists

public boolean namedGraphExists(URI namedGraphUri)

Description copied from interface: Store

Checks if the triplestore has the named graph under the corresponding URI.

Specified by:

namedGraphExists in interface Store

Parameters:

namedGraphUri - URI of a named graph that shall be a valid URI and was used before with the put* methods.

Returns:

does the triplestore contain any resources for a given named graph

resourceExists

public boolean resourceExists(URI namedGraphUri,
                              URI resourceUri)

Description copied from interface: Store

Checks if a resource with resourceUri exists under the corresponding named graph.

Specified by:

resourceExists in interface Store

getJenaModelForSubject

public org.apache.jena.rdf.model.Model getJenaModelForSubject(URI namedGraphUri,
                                                              URI subject)
                                                       throws NoSuchElementException,
                                                              StoreAccessException,
                                                              ModelUnmarshallingException

Description copied from interface: Store

Retrieve a Jena model for triples under the given subject from the corresponding named graph.

Specified by:

getJenaModelForSubject in interface Store

Throws:

NoSuchElementException

StoreAccessException

ModelUnmarshallingException

getResources

public <T extends org.eclipse.lyo.oslc4j.core.model.IResource> List<T> getResources(URI namedGraph,
                                                                                    Class<T> clazz)
                                                                             throws StoreAccessException,
                                                                                    ModelUnmarshallingException

Description copied from interface: Store

Retrieve the collection of IResource instances specified by the concrete type, unmarshaled from the RDF graph persisted in the triplestore under the given named graph. The named graph must represent a URI that was previously given to another method call or a Resource about URI if the resource was saved alone.

Specified by:

getResources in interface Store

clazz - Concrete type of the stored resources. Must be correct (correspond to the marshaled type and be a subclass of IResource), otherwise the instantiation from model will not succeed.

Returns:

A collection of IResource instances, unmarshaled from the RDF graph persisted in the triplestore.

Throws:

StoreAccessException - if there was a problem with the triplestore (or the dataset, more broadly).

ModelUnmarshallingException - if the classes cannot be instantiated or another error occurred when working with Jena model.

getResources

public <T extends org.eclipse.lyo.oslc4j.core.model.IResource> List<T> getResources(URI namedGraph,
                                                                                    Class<T> clazz,
                                                                                    int limit,
                                                                                    int offset)
                                                                             throws StoreAccessException,
                                                                                    ModelUnmarshallingException

Description copied from interface: Store

Alternative to Store.getResources(URI, Class) with paging on the OSLC resource level.

Specified by:

getResources in interface Store

Parameters:

namedGraph - URI of a named graph under which resources were stored

clazz - class of the resources being retrieved

limit - paging limit

offset - paging offset

Returns:

list of OSLC resources, size is less or equal to 'limit'

Throws:

StoreAccessException - if there was a problem with the triplestore (or the dataset, more broadly).

ModelUnmarshallingException - if the classes cannot be instantiated or another error occurred when working with Jena model.

getResource

public <T extends org.eclipse.lyo.oslc4j.core.model.IResource> T getResource(URI namedGraphUri,
                                                                             URI resourceUri,
                                                                             Class<T> clazz)
                                                                      throws NoSuchElementException,
                                                                             StoreAccessException,
                                                                             ModelUnmarshallingException

Description copied from interface: Store

Retrieve a single IResource instance specified by the concrete type, unmarshaled from the RDF graph persisted in the triplestore under the given named graph. namedGraph must represent a URI that was previously given to another call.

Specified by:

getResource in interface Store

Parameters:

namedGraphUri - URI of a named graph under which resources were stored

clazz - Java class of the stored resources.

Returns:

An IResource instance, unmarshaled from the RDF graph persisted in the triplestore.

Throws:

NoSuchElementException - if the resource is not present under a given named graph URI or if the named graph itself contains no resources (effectively missing).

StoreAccessException - if there was a problem with the triplestore (or the dataset, more broadly).

ModelUnmarshallingException - if the classes cannot be instantiated or another error occurred when working with Jena model.

updateResources

public <T extends org.eclipse.lyo.oslc4j.core.model.IResource> boolean updateResources(URI namedGraphUri,
                                                                                       T... resources)
                                                                                throws StoreAccessException

Description copied from interface: Store

Insert Jena models representations of OSLC IResource instances into the named graph. Any existing model representations of these instances are overridden. other existing statements in the named graph are not overridden, nor removed.

Specified by:

updateResources in interface Store

Throws:

StoreAccessException

putResources

public <T extends org.eclipse.lyo.oslc4j.core.model.IResource> boolean putResources(URI uri,
                                                                                    Collection<T> resources)
                                                                             throws StoreAccessException

Description copied from interface: Store

Inserts OSLC IResource instances into the triplestore in the designed namedGraph.

Any previously stored resource(s) and/or statements will be overwritten.

Specified by:

putResources in interface Store

Parameters:

uri - A unique URI that is used as a named graph to which resources are appended

resources - A collection of IResource instances

Returns:

Operation success

Throws:

StoreAccessException - if the operation can't be performed

appendResources

public <T extends org.eclipse.lyo.oslc4j.core.model.IResource> boolean appendResources(URI namedGraph,
                                                                                       Collection<T> resources)
                                                                                throws StoreAccessException

Description copied from interface: Store

Adds OSLC IResource instances in addition to other instances already present on this named graph into the triplestore. Jena models representing existing and added resource arrays will be combined.

Specified by:

appendResources in interface Store

Parameters:

namedGraph - A unique URI that is used as a named graph to which resources are appended

resources - A collection of IResource instances

Returns:

Operation success

Throws:

StoreAccessException - if the operation can't be performed

clear

public void clear(URI namedGraph)

Description copied from interface: Store

Deletes the resources and statements stored under the given named graph from the triplestore.

May delete the containing named graph, many triplestores will delete the named graph automatically as well as soon as it doesn't contain any triples.

Specified by:

clear in interface Store

keySet

public Set<String> keySet()

Description copied from interface: Store

Enumerates all named graph URIs within the dataset.

If the dataset was not manipulated by other means than via this interface, it can be assumed that all URIs in the set are valid keys.

Specified by:

keySet in interface Store

Returns:

The set of all named graph URIs, may contain URIs that are not valid keys if the dataset was manipulated directly.

removeAll

public void removeAll()

Description copied from interface: Store

Remove EVERYTHING from the triplestore.

Specified by:

removeAll in interface Store