net.fortytwo.ripple.model.impl.sesame

Class SesameModelConnection

java.lang.Object

net.fortytwo.ripple.model.impl.sesame.SesameModelConnection

All Implemented Interfaces:

ModelConnection

public class SesameModelConnection
extends Object
implements ModelConnection

Field Summary

Fields

Modifier and Type	Field and Description
protected RDFDiffSink	listenerSink
protected SesameModel	model
protected org.openrdf.sail.SailConnection	sailConnection
protected org.openrdf.model.ValueFactory	valueFactory

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SesameModelConnection(SesameModel model, RDFDiffSink listenerSink)

Method Summary

Methods

Modifier and Type	Method and Description
void	add(RippleValue subj, RippleValue pred, RippleValue obj, RippleValue... contexts) Adds one or more RDF statements to the model.
RDFValue	booleanValue(boolean b) Constructs a boolean value.
RippleValue	canonicalValue(RDFValue v) Finds the "canonical" value, in Ripple space, for a given RDF value.
void	close() Closes this connection, releasing its resources and rolling back any uncommitted changes.
void	commit() Commits the current transaction.
long	countStatements(org.openrdf.model.Resource... contexts)
info.aduna.iteration.CloseableIteration<? extends org.openrdf.query.BindingSet,org.openrdf.query.QueryEvaluationException>	evaluate(String query) Evaluates a SPARQL query against the model.
void	finish() Complete any still-executing tasks.
Comparator<RippleValue>	getComparator()
Source<RippleValue>	getContexts()
Model	getModel()
Source<org.openrdf.model.Namespace>	getNamespaces() Retrieves all namespaces defined in this model.
org.openrdf.sail.SailConnection	getSailConnection()
void	getStatements(RDFValue subj, RDFValue pred, RDFValue obj, Sink<org.openrdf.model.Statement> sink) Retrieves all statements in the model matching a given triple pattern.
boolean	internalize(RippleList list) Adds an RDF description of the given list to the model.
RDFValue	languageTaggedValue(String s, String language) Constructs a language-tagged literal value in Ripple space.
RippleList	list()
NumericValue	numericValue(BigDecimal b) Constructs a big-decimal-typed numeric value.
NumericValue	numericValue(double d) Constructs a double-precision numeric value.
NumericValue	numericValue(int i) Constructs an integer-typed numeric value.
NumericValue	numericValue(long l) Constructs a long-integer-typed numeric value.
RDFValue	plainValue(String s) Constructs a plain literal value in Ripple space.
void	query(StatementPatternQuery query, Sink<RippleValue> sink, boolean asynchronous) Issues a triple pattern query over the model.
void	remove(RippleValue subj, RippleValue pred, RippleValue obj, RippleValue... contexts) Removes matching RDF statements from the model.
void	reset(boolean rollback) Returns the ModelConnection to a normal state after an Exception has been thrown.
void	setNamespace(String prefix, String ns, boolean override) Define a namespace prefix.
boolean	toBoolean(RippleValue rv) Attempts to convert a Ripple value to a boolean value.
Date	toDateValue(RippleValue v) Attempts to convert a Ripple value to a date value.
void	toList(RippleValue v, Sink<RippleList> sink) Attempts to convert a Ripple value to a Ripple List.
NumericValue	toNumericValue(RippleValue rv) Attempts to convert a Ripple value to a numeric value.
String	toString(RippleValue v) Attempts to convert a Ripple value to a string value.
RDFValue	typedValue(String s, org.openrdf.model.URI dataType) Constructs a typed RDF literal value.
RDFValue	uriValue(String s) Construct an RDF URI reference.

Methods inherited from class java.lang.Object

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

Field Detail

model

protected final SesameModel model

sailConnection

protected org.openrdf.sail.SailConnection sailConnection

listenerSink

protected final RDFDiffSink listenerSink

valueFactory

protected final org.openrdf.model.ValueFactory valueFactory

Constructor Detail

SesameModelConnection

protected SesameModelConnection(SesameModel model,
                     RDFDiffSink listenerSink)
                         throws RippleException

Throws:

RippleException

Method Detail

getModel

public Model getModel()

Specified by:

getModel in interface ModelConnection

Returns:

the Model of this connection

toList

public void toList(RippleValue v,
          Sink<RippleList> sink)
            throws RippleException

Description copied from interface: ModelConnection

Attempts to convert a Ripple value to a Ripple List.

Specified by:

toList in interface ModelConnection

Parameters:

v - the value to convert. It must be of a type which is convertible to a list, or be the head of an RDF list in the model's RDF knowledge base.

sink - a handler for successfully converted lists

Throws:

RippleException - if conversion fails

list

public RippleList list()

Specified by:

list in interface ModelConnection

Returns:

the empty list, of which there is exactly one in this model

finish

public void finish()
            throws RippleException

Description copied from interface: ModelConnection

Complete any still-executing tasks.

Specified by:

finish in interface ModelConnection

Throws:

RippleException

close

public void close()
           throws RippleException

Description copied from interface: ModelConnection

Closes this connection, releasing its resources and rolling back any uncommitted changes.

Specified by:

close in interface ModelConnection

Throws:

RippleException - if anything goes wrong

reset

public void reset(boolean rollback)
           throws RippleException

Returns the ModelConnection to a normal state after an Exception has been thrown.

Specified by:

reset in interface ModelConnection

Parameters:

rollback - whether to roll back the current transaction

Throws:

RippleException - if anything goes wrong

commit

public void commit()
            throws RippleException

Description copied from interface: ModelConnection

Commits the current transaction.

Specified by:

commit in interface ModelConnection

Throws:

RippleException - if the transaction cannot be committed

getSailConnection

public org.openrdf.sail.SailConnection getSailConnection()

toBoolean

public boolean toBoolean(RippleValue rv)
                  throws RippleException

Description copied from interface: ModelConnection

Attempts to convert a Ripple value to a boolean value.

Specified by:

toBoolean in interface ModelConnection

Parameters:

rv - the value to convert. It must be of a type which is convertible to boolean.

Returns:

the resulting boolean value

Throws:

RippleException - if the value cannot be converted

toNumericValue

public NumericValue toNumericValue(RippleValue rv)
                            throws RippleException

Description copied from interface: ModelConnection

Attempts to convert a Ripple value to a numeric value.

Specified by:

toNumericValue in interface ModelConnection

Parameters:

rv - the value to convert. It must be of a type which is convertible to a number.

Returns:

the resulting numeric value

Throws:

RippleException - if the value cannot be converted

toDateValue

public Date toDateValue(RippleValue v)
                 throws RippleException

Description copied from interface: ModelConnection

Attempts to convert a Ripple value to a date value.

Specified by:

toDateValue in interface ModelConnection

Parameters:

v - the value to convert. It must be of a type which is convertible to a date.

Returns:

the resulting date

Throws:

RippleException - if the value cannot be converted

toString

public String toString(RippleValue v)
                throws RippleException

Description copied from interface: ModelConnection

Attempts to convert a Ripple value to a string value.

Specified by:

toString in interface ModelConnection

Parameters:

v - the value to convert.

Returns:

the string representation of a value. This is not identical to Object.toString(), and may involve a loss of information.

Throws:

RippleException - if conversion fails

add

public void add(RippleValue subj,
       RippleValue pred,
       RippleValue obj,
       RippleValue... contexts)
         throws RippleException

Description copied from interface: ModelConnection

Adds one or more RDF statements to the model.

Specified by:

add in interface ModelConnection

Parameters:

subj - the subject of each statement

pred - the predicate of each statement

obj - the object of each statement

contexts - the graph contexts of the statements, if any. For each non-null context supplied, a statement will be created and placed in the corresponding graph. If a null context is supplied, a statement will be added to the default graph. If no contexts are supplied, a single statement will be added to the default graph.

Throws:

RippleException - if the statement(s) cannot be added

remove

public void remove(RippleValue subj,
          RippleValue pred,
          RippleValue obj,
          RippleValue... contexts)
            throws RippleException

Description copied from interface: ModelConnection

Removes matching RDF statements from the model.

Specified by:

remove in interface ModelConnection

Parameters:

subj - the subject of each matching statement, or null as a wildcard

pred - the predicate of each matching statement, or null as a wildcard

obj - the object of each matching statement, or null as a wildcard

contexts - zero or more graph contexts for matching statements. For each non-null context supplied, matching statements from the corresponding graph will be removed. If a null context is supplied, matching statements from the default context will be removed. If no contexts are supplied, matching statements from all contexts will be removed.

Throws:

RippleException - if matching statements cannot be removed

countStatements

public long countStatements(org.openrdf.model.Resource... contexts)
                     throws RippleException

Throws:

RippleException

getComparator

public Comparator<RippleValue> getComparator()

Specified by:

getComparator in interface ModelConnection

Returns:

the total order of Ripple values in this model

uriValue

public RDFValue uriValue(String s)
                  throws RippleException

Description copied from interface: ModelConnection

Construct an RDF URI reference.

Specified by:

uriValue in interface ModelConnection

Parameters:

s - the URI to convert

Returns:

the resulting RDF value

Throws:

RippleException - if the argument is not a valid URI

canonicalValue

public RippleValue canonicalValue(RDFValue v)

Description copied from interface: ModelConnection

Finds the "canonical" value, in Ripple space, for a given RDF value. Several RDF values may map to the same canonical value. See also SpecialValueMap.

Specified by:

canonicalValue in interface ModelConnection

Parameters:

v - the RDF value to look up

Returns:

the canonical value. Always non-null.

plainValue

public RDFValue plainValue(String s)
                    throws RippleException

Description copied from interface: ModelConnection

Constructs a plain literal value in Ripple space.

Specified by:

plainValue in interface ModelConnection

Parameters:

s - the lexical form of the string

Returns:

the resulting string value

Throws:

RippleException - if the literal cannot be constructed

languageTaggedValue

public RDFValue languageTaggedValue(String s,
                           String language)
                             throws RippleException

Description copied from interface: ModelConnection

Constructs a language-tagged literal value in Ripple space.

Specified by:

languageTaggedValue in interface ModelConnection

Parameters:

s - the label of the literal

language - the language tag of the literal (e.g. "en" or "de")

Returns:

the resulting value

Throws:

RippleException - if the literal cannot be constructed

typedValue

public RDFValue typedValue(String s,
                  org.openrdf.model.URI dataType)
                    throws RippleException

Description copied from interface: ModelConnection

Constructs a typed RDF literal value.

Specified by:

typedValue in interface ModelConnection

Parameters:

s - the label of the literal

dataType - the data type of the value

Returns:

the resulting RDF value

Throws:

RippleException - if the arguments do not define a valid literal

booleanValue

public RDFValue booleanValue(boolean b)
                      throws RippleException

Description copied from interface: ModelConnection

Constructs a boolean value.

Specified by:

booleanValue in interface ModelConnection

Parameters:

b - the primitive value to wrap

Returns:

the resulting RDF value

Throws:

RippleException - if the value cannot be constructed

numericValue

public NumericValue numericValue(int i)
                          throws RippleException

Description copied from interface: ModelConnection

Constructs an integer-typed numeric value.

Specified by:

numericValue in interface ModelConnection

Parameters:

i - the primitive value to wrap

Returns:

the resulting numeric value

Throws:

RippleException - if the value cannot be constructed

numericValue

public NumericValue numericValue(long l)
                          throws RippleException

Description copied from interface: ModelConnection

Constructs a long-integer-typed numeric value.

Specified by:

numericValue in interface ModelConnection

Parameters:

l - the primitive value to wrap

Returns:

the resulting numeric value

Throws:

RippleException - if the value cannot be constructed

numericValue

public NumericValue numericValue(double d)
                          throws RippleException

Description copied from interface: ModelConnection

Constructs a double-precision numeric value.

Specified by:

numericValue in interface ModelConnection

Parameters:

d - the primitive value to wrap

Returns:

the resulting numeric value

Throws:

RippleException - if the value cannot be constructed

numericValue

public NumericValue numericValue(BigDecimal b)
                          throws RippleException

Description copied from interface: ModelConnection

Constructs a big-decimal-typed numeric value.

Specified by:

numericValue in interface ModelConnection

Parameters:

b - the primitive value to wrap

Returns:

the resulting numeric value

Throws:

RippleException - if the value cannot be constructed

setNamespace

public void setNamespace(String prefix,
                String ns,
                boolean override)
                  throws RippleException

Description copied from interface: ModelConnection

Define a namespace prefix.

Specified by:

setNamespace in interface ModelConnection

Parameters:

prefix - the namespace prefix

ns - the namespace URI, or null to undefine a prefix

override - whether to override an existing namespace with this prefix, if there is one

Throws:

RippleException - if the namespace cannot be set

query

public void query(StatementPatternQuery query,
         Sink<RippleValue> sink,
         boolean asynchronous)
           throws RippleException

Description copied from interface: ModelConnection

Issues a triple pattern query over the model.

Specified by:

query in interface ModelConnection

Parameters:

query - the query to evaluate

sink - a handler for query results

asynchronous - whether the query should be evaluated in an asynchronous fashion, allowing new threads to be spawned in order to compute results in parallel

Throws:

RippleException - if the query cannot be evaluated

getNamespaces

public Source<org.openrdf.model.Namespace> getNamespaces()
                                                  throws RippleException

Description copied from interface: ModelConnection

Retrieves all namespaces defined in this model.

Specified by:

getNamespaces in interface ModelConnection

Returns:

a source producing all namespaces

Throws:

RippleException - if namespaces cannot be retrieved

getStatements

public void getStatements(RDFValue subj,
                 RDFValue pred,
                 RDFValue obj,
                 Sink<org.openrdf.model.Statement> sink)
                   throws RippleException

Description copied from interface: ModelConnection

Retrieves all statements in the model matching a given triple pattern.

Specified by:

getStatements in interface ModelConnection

Parameters:

subj - the subject of matching statements

pred - the predicate of matching statements

obj - the object of matching statements

sink - a handler for matched statements

Throws:

RippleException - if statements cannot be retrieved

evaluate

public info.aduna.iteration.CloseableIteration<? extends org.openrdf.query.BindingSet,org.openrdf.query.QueryEvaluationException> evaluate(String query)
                                                                                                                                    throws RippleException

Description copied from interface: ModelConnection

Evaluates a SPARQL query against the model.

Specified by:

evaluate in interface ModelConnection

Parameters:

query - the query to evaluate

Returns:

an iterator over all solutios to the query

Throws:

RippleException - if query evaluation fails

getContexts

public Source<RippleValue> getContexts()
                                throws RippleException

Specified by:

getContexts in interface ModelConnection

Returns:

a source producing all graph contexts in this model

Throws:

RippleException - if contexts cannot be retrieved

internalize

public boolean internalize(RippleList list)
                    throws RippleException

Description copied from interface: ModelConnection

Adds an RDF description of the given list to the model. This involves adding all appropriate rdf:type, rdf:first, and rdf:rest statements for the list itself, as well as those of any lists it contains, recursively.

Specified by:

internalize in interface ModelConnection

Parameters:

list - the list to internalize

Returns:

whether the list was internalized successfully. If this operation is unsuccessful, no statements are added to the model.

Throws:

RippleException - if internalization fails