com.bigdata.rdf.sail

Class BigdataSailRepositoryConnection

java.lang.Object

org.openrdf.repository.base.RepositoryConnectionBase

org.openrdf.repository.sail.SailRepositoryConnection

com.bigdata.rdf.sail.BigdataSailRepositoryConnection

All Implemented Interfaces:

org.openrdf.repository.RepositoryConnection

public class BigdataSailRepositoryConnection
extends org.openrdf.repository.sail.SailRepositoryConnection

Class with support for a variety of bigdata specific extensions,

Author:

mrpersonick

Field Summary

Fields inherited from class org.openrdf.repository.base.RepositoryConnectionBase

logger

Constructor Summary

Constructors

Constructor and Description
BigdataSailRepositoryConnection(BigdataSailRepository repository, org.openrdf.sail.SailConnection sailConnection)

Method Summary

Methods

Modifier and Type	Method and Description
void	addChangeLog(IChangeLog log) Set the change log on the SAIL connection.
void	commit()
long	commit2() Commit, returning the timestamp associated with the new commit point.
void	computeClosure() Computes the closure of the triple store for RDF(S)+ entailments.
void	flush() Flush the statement buffers.
BigdataSailRepository	getRepository()
BigdataSail.BigdataSailConnection	getSailConnection()
AbstractTripleStore	getTripleStore() Return the backing AbstractTripleStore object.
BigdataValueFactory	getValueFactory()
boolean	hasStatement(org.openrdf.model.Resource s, org.openrdf.model.URI p, org.openrdf.model.Value o, boolean includeInferred, org.openrdf.model.Resource... contexts)
boolean	isReadOnly() Return true if the connection does not permit mutation.
boolean	isUnisolated() Return true if this is the ITx.UNISOLATED connection.
BigdataSailBooleanQuery	prepareBooleanQuery(org.openrdf.query.QueryLanguage ql, String qs, String baseURI)
BigdataSailGraphQuery	prepareGraphQuery(org.openrdf.query.QueryLanguage ql, String qs, String baseURI)
BigdataSailQuery	prepareNativeSPARQLQuery(org.openrdf.query.QueryLanguage ql, String queryStr, String baseURI) Parse a SPARQL query
BigdataSailUpdate	prepareNativeSPARQLUpdate(org.openrdf.query.QueryLanguage ql, String updateStr, String baseURI) Parse a SPARQL UPDATE request.
org.openrdf.repository.sail.SailQuery	prepareQuery(org.openrdf.query.QueryLanguage ql, String qs, String baseURI)
BigdataSailTupleQuery	prepareTupleQuery(org.openrdf.query.QueryLanguage ql, String qs, String baseURI)
org.openrdf.query.Update	prepareUpdate(org.openrdf.query.QueryLanguage ql, String update, String baseURI)
void	removeAllEntailments() Removes all "inferred" statements from the database (does NOT commit the database).
void	removeChangeLog(IChangeLog log) Remove a change log from the SAIL connection.
String	toString()

Methods inherited from class org.openrdf.repository.sail.SailRepositoryConnection

addWithoutCommit, begin, clear, clearNamespaces, close, createRepositoryResult, exportStatements, getContextIDs, getNamespace, getNamespaces, getStatements, isActive, isEmpty, isOpen, removeNamespace, removeWithoutCommit, rollback, setNamespace, size

Methods inherited from class org.openrdf.repository.base.RepositoryConnectionBase

add, add, add, add, add, add, add, add, addWithoutCommit, conditionalCommit, conditionalRollback, export, getParserConfig, hasStatement, isAutoCommit, prepareBooleanQuery, prepareGraphQuery, prepareQuery, prepareTupleQuery, prepareUpdate, remove, remove, remove, remove, removeWithoutCommit, setAutoCommit, setParserConfig, startLocalTransaction

Methods inherited from class java.lang.Object

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

Constructor Detail

BigdataSailRepositoryConnection

public BigdataSailRepositoryConnection(BigdataSailRepository repository,
                               org.openrdf.sail.SailConnection sailConnection)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

getRepository

public BigdataSailRepository getRepository()

Specified by:

getRepository in interface org.openrdf.repository.RepositoryConnection

Overrides:

getRepository in class org.openrdf.repository.base.RepositoryConnectionBase

getSailConnection

public BigdataSail.BigdataSailConnection getSailConnection()

Overrides:

getSailConnection in class org.openrdf.repository.sail.SailRepositoryConnection

getValueFactory

public BigdataValueFactory getValueFactory()

Specified by:

getValueFactory in interface org.openrdf.repository.RepositoryConnection

Overrides:

getValueFactory in class org.openrdf.repository.base.RepositoryConnectionBase

hasStatement

public boolean hasStatement(org.openrdf.model.Resource s,
                   org.openrdf.model.URI p,
                   org.openrdf.model.Value o,
                   boolean includeInferred,
                   org.openrdf.model.Resource... contexts)
                     throws org.openrdf.repository.RepositoryException

This code path is optimized for cases where isolatable indices are not in use and where inferences can not appear.

Specified by:

hasStatement in interface org.openrdf.repository.RepositoryConnection

Overrides:

hasStatement in class org.openrdf.repository.base.RepositoryConnectionBase

Throws:

org.openrdf.repository.RepositoryException

See Also:

Optimize hasStatement() TODO This should be using {@link BigdataSailConnection#hasStatement(Resource, URI, Value, boolean, Resource...)} for improved performance. See #1178.

prepareGraphQuery

public BigdataSailGraphQuery prepareGraphQuery(org.openrdf.query.QueryLanguage ql,
                                      String qs,
                                      String baseURI)
                                        throws org.openrdf.query.MalformedQueryException

Specified by:

prepareGraphQuery in interface org.openrdf.repository.RepositoryConnection

Overrides:

prepareGraphQuery in class org.openrdf.repository.sail.SailRepositoryConnection

Throws:

org.openrdf.query.MalformedQueryException

prepareTupleQuery

public BigdataSailTupleQuery prepareTupleQuery(org.openrdf.query.QueryLanguage ql,
                                      String qs,
                                      String baseURI)
                                        throws org.openrdf.query.MalformedQueryException

Specified by:

prepareTupleQuery in interface org.openrdf.repository.RepositoryConnection

Overrides:

prepareTupleQuery in class org.openrdf.repository.sail.SailRepositoryConnection

Throws:

org.openrdf.query.MalformedQueryException

prepareBooleanQuery

public BigdataSailBooleanQuery prepareBooleanQuery(org.openrdf.query.QueryLanguage ql,
                                          String qs,
                                          String baseURI)
                                            throws org.openrdf.query.MalformedQueryException

Specified by:

prepareBooleanQuery in interface org.openrdf.repository.RepositoryConnection

Overrides:

prepareBooleanQuery in class org.openrdf.repository.sail.SailRepositoryConnection

Throws:

org.openrdf.query.MalformedQueryException

prepareQuery

public org.openrdf.repository.sail.SailQuery prepareQuery(org.openrdf.query.QueryLanguage ql,
                                                 String qs,
                                                 String baseURI)
                                                   throws org.openrdf.query.MalformedQueryException

Specified by:

prepareQuery in interface org.openrdf.repository.RepositoryConnection

Overrides:

prepareQuery in class org.openrdf.repository.sail.SailRepositoryConnection

Throws:

org.openrdf.query.MalformedQueryException

prepareUpdate

public org.openrdf.query.Update prepareUpdate(org.openrdf.query.QueryLanguage ql,
                                     String update,
                                     String baseURI)
                                       throws org.openrdf.repository.RepositoryException,
                                              org.openrdf.query.MalformedQueryException

Specified by:

prepareUpdate in interface org.openrdf.repository.RepositoryConnection

Overrides:

prepareUpdate in class org.openrdf.repository.sail.SailRepositoryConnection

Throws:

org.openrdf.repository.RepositoryException

org.openrdf.query.MalformedQueryException

See Also:

SPARQL 1.1 Update

prepareNativeSPARQLQuery

public BigdataSailQuery prepareNativeSPARQLQuery(org.openrdf.query.QueryLanguage ql,
                                        String queryStr,
                                        String baseURI)
                                          throws org.openrdf.query.MalformedQueryException

Parse a SPARQL query

Parameters:

ql - The QueryLanguage.

queryStr - The query.

baseURI - The base URI.

Returns:

An object wrapping the bigdata AST model for that query.

Throws:

org.openrdf.query.MalformedQueryException

UnsupportedOperationException - if the query language is not SPARQL.

prepareNativeSPARQLUpdate

public BigdataSailUpdate prepareNativeSPARQLUpdate(org.openrdf.query.QueryLanguage ql,
                                          String updateStr,
                                          String baseURI)
                                            throws org.openrdf.query.MalformedQueryException

Parse a SPARQL UPDATE request.

Parameters:

ql - The QueryLanguage.

updateStr - The update request.

baseURI - The base URI.

Returns:

An object wrapping the bigdata AST model for that request.

Throws:

org.openrdf.query.MalformedQueryException

UnsupportedOperationException - if the QueryLanguage is not SPARQL.

isReadOnly

public final boolean isReadOnly()

Return true if the connection does not permit mutation.

isUnisolated

public final boolean isUnisolated()

Return true if this is the ITx.UNISOLATED connection.

commit2

public long commit2()
             throws org.openrdf.repository.RepositoryException

Commit, returning the timestamp associated with the new commit point.

Note: auto-commit is an EXTREMELY bad idea. Performance will be terrible. The database will swell to an outrageous size. TURN OFF AUTO COMMIT.

Returns:

The timestamp associated with the new commit point. This will be 0L if the write set was empty such that nothing was committed.

Throws:

org.openrdf.repository.RepositoryException

See Also:

BigdataSail.Options.ALLOW_AUTO_COMMIT

commit

public void commit()
            throws org.openrdf.repository.RepositoryException

Note: auto-commit is an EXTREMELY bad idea. Performance will be terrible. The database will swell to an outrageous size. TURN OFF AUTO COMMIT.

Specified by:

commit in interface org.openrdf.repository.RepositoryConnection

Overrides:

commit in class org.openrdf.repository.sail.SailRepositoryConnection

Throws:

org.openrdf.repository.RepositoryException

See Also:

BigdataSail.Options.ALLOW_AUTO_COMMIT

flush

public void flush()
           throws org.openrdf.repository.RepositoryException

Flush the statement buffers. The BigdataSail.BigdataSailConnection heavily buffers assertions and retractions. Either a flush() or a commit() is required before executing any operations directly against the backing AbstractTripleStore so that the buffered assertions or retractions will be written onto the KB and become visible to other methods. This is not a transaction issue -- just a buffer issue. The public methods on the BigdataSail.BigdataSailConnection all flush the buffers before performing any queries against the underlying AbstractTripleStore.

Throws:

org.openrdf.repository.RepositoryException

getTripleStore

public AbstractTripleStore getTripleStore()

Return the backing AbstractTripleStore object. Caution MUST be used when accessing this object as the access goes around the SAIL API.

computeClosure

public void computeClosure()
                    throws org.openrdf.repository.RepositoryException

Computes the closure of the triple store for RDF(S)+ entailments.

This computes the closure of the database. This can be used if you do NOT enable truth maintenance and choose instead to load up all of your data first and then compute the closure of the database. Note that some rules may be computed by eager closure while others are computed at query time.

Note: If there are already entailments in the database AND you have retracted statements since the last time the closure was computed then you MUST delete all entailments from the database before re-computing the closure.

Note: This method does NOT commit the database. See AbstractTripleStore.commit() and getTripleStore().

Throws:

org.openrdf.repository.RepositoryException

See Also:

removeAllEntailments()

removeAllEntailments

public void removeAllEntailments()
                          throws org.openrdf.sail.SailException,
                                 org.openrdf.repository.RepositoryException

Removes all "inferred" statements from the database (does NOT commit the database).

Throws:

org.openrdf.repository.RepositoryException

org.openrdf.sail.SailException

addChangeLog

public void addChangeLog(IChangeLog log)

Set the change log on the SAIL connection. See IChangeLog and IChangeRecord.

Parameters:

log - the change log

removeChangeLog

public void removeChangeLog(IChangeLog log)

Remove a change log from the SAIL connection. See IChangeLog and IChangeRecord.

Parameters:

log - the change log