public class BigdataSailRemoteRepositoryConnection extends Object implements org.openrdf.repository.RepositoryConnection
RemoteRepository. This provides SAIL API based client access
to a bigdata remote NanoSparqlServer.
Repository or
RepositoryConnection. Therefore a namespace DOES NOT need to be
configured for isolatable indices in order to create and manipulate
transactions, but it DOES need to be configured with isolatable indices in
order for you to WRITE on the namespace using a transaction.RemoteTransactionManager,
BigdataSail.Options.ISOLATABLE_INDICES,
Support read/write
transactions in the REST API,
BigdataSailRemoteRepositoryConnection should implement interface methods
FIXME (***) #698 Fix all the Query objects (TupleQuery, GraphQuery,
BooleanQuery) to support the various possible operations on them, such
as setting a binding.| Constructor and Description |
|---|
BigdataSailRemoteRepositoryConnection(BigdataSailRemoteRepository repo) |
| Modifier and Type | Method and Description |
|---|---|
void |
add(File input,
String baseURI,
org.openrdf.rio.RDFFormat format,
org.openrdf.model.Resource... c)
TODO support baseURI
|
void |
add(InputStream input,
String baseURI,
org.openrdf.rio.RDFFormat format,
org.openrdf.model.Resource... c)
TODO support baseURI
|
void |
add(Iterable<? extends org.openrdf.model.Statement> stmts,
org.openrdf.model.Resource... c) |
<E extends Exception> |
add(info.aduna.iteration.Iteration<? extends org.openrdf.model.Statement,E> stmts,
org.openrdf.model.Resource... c) |
void |
add(Reader input,
String baseURI,
org.openrdf.rio.RDFFormat format,
org.openrdf.model.Resource... c)
TODO support baseURI
|
void |
add(org.openrdf.model.Resource s,
org.openrdf.model.URI p,
org.openrdf.model.Value o,
org.openrdf.model.Resource... c) |
void |
add(org.openrdf.model.Statement stmt,
org.openrdf.model.Resource... c)
single statement updates not recommended for performance
reasons.
|
void |
add(URL input,
String baseURI,
org.openrdf.rio.RDFFormat format,
org.openrdf.model.Resource... c)
TODO support baseURI
|
void |
begin() |
void |
beginReadOnly()
Begin a read-only transaction.
|
void |
beginReadOnly(long timestamp)
Begin a read-only transaction that reads against the most recent committed
state whose commit timestamp is less than or equal to timestamp.
|
void |
clear(org.openrdf.model.Resource... c) |
void |
clearNamespaces() |
void |
close() |
void |
commit() |
long |
count(org.openrdf.model.Resource s,
org.openrdf.model.URI p,
org.openrdf.model.Value o,
org.openrdf.model.Resource... c)
Report the fast range count (aka ESTCARD) associated with the specified
access path.
|
void |
export(org.openrdf.rio.RDFHandler handler,
org.openrdf.model.Resource... c) |
void |
exportStatements(org.openrdf.model.Resource s,
org.openrdf.model.URI p,
org.openrdf.model.Value o,
boolean includeInferred,
org.openrdf.rio.RDFHandler handler,
org.openrdf.model.Resource... c) |
org.openrdf.repository.RepositoryResult<org.openrdf.model.Resource> |
getContextIDs() |
String |
getNamespace(String arg0) |
org.openrdf.repository.RepositoryResult<org.openrdf.model.Namespace> |
getNamespaces() |
org.openrdf.rio.ParserConfig |
getParserConfig() |
org.openrdf.repository.Repository |
getRepository() |
protected RemoteRepository |
getRepositoryForConnection()
Return a
RemoteRepository for this connection. |
org.openrdf.repository.RepositoryResult<org.openrdf.model.Statement> |
getStatements(org.openrdf.model.Resource s,
org.openrdf.model.URI p,
org.openrdf.model.Value o,
boolean includeInferred,
org.openrdf.model.Resource... c) |
org.openrdf.model.ValueFactory |
getValueFactory() |
boolean |
hasStatement(org.openrdf.model.Resource s,
org.openrdf.model.URI p,
org.openrdf.model.Value o,
boolean includeInferred,
org.openrdf.model.Resource... c) |
boolean |
hasStatement(org.openrdf.model.Statement s,
boolean includeInferred,
org.openrdf.model.Resource... c) |
boolean |
isActive() |
boolean |
isAutoCommit()
Deprecated.
|
boolean |
isEmpty() |
boolean |
isOpen() |
org.openrdf.query.BooleanQuery |
prepareBooleanQuery(org.openrdf.query.QueryLanguage ql,
String query) |
org.openrdf.query.BooleanQuery |
prepareBooleanQuery(org.openrdf.query.QueryLanguage ql,
String query,
String baseURI) |
org.openrdf.query.GraphQuery |
prepareGraphQuery(org.openrdf.query.QueryLanguage ql,
String query) |
org.openrdf.query.GraphQuery |
prepareGraphQuery(org.openrdf.query.QueryLanguage ql,
String query,
String baseURI) |
org.openrdf.query.Query |
prepareQuery(org.openrdf.query.QueryLanguage ql,
String query) |
org.openrdf.query.Query |
prepareQuery(org.openrdf.query.QueryLanguage ql,
String query,
String baseURI) |
org.openrdf.query.TupleQuery |
prepareTupleQuery(org.openrdf.query.QueryLanguage ql,
String query) |
org.openrdf.query.TupleQuery |
prepareTupleQuery(org.openrdf.query.QueryLanguage ql,
String query,
String baseURI) |
org.openrdf.query.Update |
prepareUpdate(org.openrdf.query.QueryLanguage ql,
String query) |
org.openrdf.query.Update |
prepareUpdate(org.openrdf.query.QueryLanguage ql,
String query,
String baseURI) |
void |
remove(Iterable<? extends org.openrdf.model.Statement> stmts,
org.openrdf.model.Resource... c) |
<E extends Exception> |
remove(info.aduna.iteration.Iteration<? extends org.openrdf.model.Statement,E> stmts,
org.openrdf.model.Resource... c) |
void |
remove(org.openrdf.model.Resource s,
org.openrdf.model.URI p,
org.openrdf.model.Value o,
org.openrdf.model.Resource... c) |
void |
remove(org.openrdf.model.Statement stmt,
org.openrdf.model.Resource... c)
single statement updates not recommended for performance
reasons.
|
void |
removeNamespace(String arg0) |
void |
rollback() |
void |
setAutoCommit(boolean autoCommit)
Deprecated.
|
void |
setNamespace(String arg0,
String arg1) |
void |
setParserConfig(org.openrdf.rio.ParserConfig arg0) |
long |
size(org.openrdf.model.Resource... c) |
public BigdataSailRemoteRepositoryConnection(BigdataSailRemoteRepository repo)
protected RemoteRepository getRepositoryForConnection()
RemoteRepository for this connection.RemoteRepositoryManager#newpublic long count(org.openrdf.model.Resource s,
org.openrdf.model.URI p,
org.openrdf.model.Value o,
org.openrdf.model.Resource... c)
throws org.openrdf.repository.RepositoryException
org.openrdf.repository.RepositoryExceptionpublic org.openrdf.repository.RepositoryResult<org.openrdf.model.Statement> getStatements(org.openrdf.model.Resource s,
org.openrdf.model.URI p,
org.openrdf.model.Value o,
boolean includeInferred,
org.openrdf.model.Resource... c)
throws org.openrdf.repository.RepositoryException
getStatements in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionpublic boolean hasStatement(org.openrdf.model.Resource s,
org.openrdf.model.URI p,
org.openrdf.model.Value o,
boolean includeInferred,
org.openrdf.model.Resource... c)
throws org.openrdf.repository.RepositoryException
hasStatement in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionpublic org.openrdf.query.BooleanQuery prepareBooleanQuery(org.openrdf.query.QueryLanguage ql,
String query,
String baseURI)
throws org.openrdf.repository.RepositoryException,
org.openrdf.query.MalformedQueryException
prepareBooleanQuery in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionorg.openrdf.query.MalformedQueryExceptionpublic org.openrdf.query.BooleanQuery prepareBooleanQuery(org.openrdf.query.QueryLanguage ql,
String query)
throws org.openrdf.repository.RepositoryException,
org.openrdf.query.MalformedQueryException
prepareBooleanQuery in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionorg.openrdf.query.MalformedQueryExceptionpublic org.openrdf.query.GraphQuery prepareGraphQuery(org.openrdf.query.QueryLanguage ql,
String query,
String baseURI)
throws org.openrdf.repository.RepositoryException,
org.openrdf.query.MalformedQueryException
prepareGraphQuery in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionorg.openrdf.query.MalformedQueryExceptionpublic org.openrdf.query.GraphQuery prepareGraphQuery(org.openrdf.query.QueryLanguage ql,
String query)
throws org.openrdf.repository.RepositoryException,
org.openrdf.query.MalformedQueryException
prepareGraphQuery in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionorg.openrdf.query.MalformedQueryExceptionpublic org.openrdf.query.Query prepareQuery(org.openrdf.query.QueryLanguage ql,
String query)
throws org.openrdf.repository.RepositoryException,
org.openrdf.query.MalformedQueryException
prepareQuery in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionorg.openrdf.query.MalformedQueryExceptionpublic org.openrdf.query.Query prepareQuery(org.openrdf.query.QueryLanguage ql,
String query,
String baseURI)
throws org.openrdf.repository.RepositoryException,
org.openrdf.query.MalformedQueryException
prepareQuery in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionorg.openrdf.query.MalformedQueryExceptionpublic org.openrdf.query.TupleQuery prepareTupleQuery(org.openrdf.query.QueryLanguage ql,
String query,
String baseURI)
throws org.openrdf.repository.RepositoryException,
org.openrdf.query.MalformedQueryException
prepareTupleQuery in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionorg.openrdf.query.MalformedQueryExceptionpublic org.openrdf.query.TupleQuery prepareTupleQuery(org.openrdf.query.QueryLanguage ql,
String query)
throws org.openrdf.repository.RepositoryException,
org.openrdf.query.MalformedQueryException
prepareTupleQuery in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionorg.openrdf.query.MalformedQueryExceptionpublic boolean hasStatement(org.openrdf.model.Statement s,
boolean includeInferred,
org.openrdf.model.Resource... c)
throws org.openrdf.repository.RepositoryException
hasStatement in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionpublic <E extends Exception> void add(info.aduna.iteration.Iteration<? extends org.openrdf.model.Statement,E> stmts, org.openrdf.model.Resource... c) throws org.openrdf.repository.RepositoryException, E extends Exception
add in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionE extends Exceptionpublic void add(org.openrdf.model.Resource s,
org.openrdf.model.URI p,
org.openrdf.model.Value o,
org.openrdf.model.Resource... c)
throws org.openrdf.repository.RepositoryException
add in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionpublic void add(org.openrdf.model.Statement stmt,
org.openrdf.model.Resource... c)
throws org.openrdf.repository.RepositoryException
add in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionpublic void add(Iterable<? extends org.openrdf.model.Statement> stmts, org.openrdf.model.Resource... c) throws org.openrdf.repository.RepositoryException
add in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionpublic void add(Reader input, String baseURI, org.openrdf.rio.RDFFormat format, org.openrdf.model.Resource... c) throws IOException, org.openrdf.rio.RDFParseException, org.openrdf.repository.RepositoryException
add in interface org.openrdf.repository.RepositoryConnectionIOExceptionorg.openrdf.rio.RDFParseExceptionorg.openrdf.repository.RepositoryExceptionpublic void add(URL input, String baseURI, org.openrdf.rio.RDFFormat format, org.openrdf.model.Resource... c) throws IOException, org.openrdf.rio.RDFParseException, org.openrdf.repository.RepositoryException
add in interface org.openrdf.repository.RepositoryConnectionIOExceptionorg.openrdf.rio.RDFParseExceptionorg.openrdf.repository.RepositoryExceptionpublic void add(File input, String baseURI, org.openrdf.rio.RDFFormat format, org.openrdf.model.Resource... c) throws IOException, org.openrdf.rio.RDFParseException, org.openrdf.repository.RepositoryException
add in interface org.openrdf.repository.RepositoryConnectionIOExceptionorg.openrdf.rio.RDFParseExceptionorg.openrdf.repository.RepositoryExceptionpublic void add(InputStream input, String baseURI, org.openrdf.rio.RDFFormat format, org.openrdf.model.Resource... c) throws IOException, org.openrdf.rio.RDFParseException, org.openrdf.repository.RepositoryException
add in interface org.openrdf.repository.RepositoryConnectionIOExceptionorg.openrdf.rio.RDFParseExceptionorg.openrdf.repository.RepositoryExceptionpublic <E extends Exception> void remove(info.aduna.iteration.Iteration<? extends org.openrdf.model.Statement,E> stmts, org.openrdf.model.Resource... c) throws org.openrdf.repository.RepositoryException, E extends Exception
remove in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionE extends Exceptionpublic void remove(org.openrdf.model.Statement stmt,
org.openrdf.model.Resource... c)
throws org.openrdf.repository.RepositoryException
remove in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionpublic void remove(Iterable<? extends org.openrdf.model.Statement> stmts, org.openrdf.model.Resource... c) throws org.openrdf.repository.RepositoryException
remove in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionpublic void remove(org.openrdf.model.Resource s,
org.openrdf.model.URI p,
org.openrdf.model.Value o,
org.openrdf.model.Resource... c)
throws org.openrdf.repository.RepositoryException
remove in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionpublic org.openrdf.repository.Repository getRepository()
getRepository in interface org.openrdf.repository.RepositoryConnectionpublic org.openrdf.repository.RepositoryResult<org.openrdf.model.Resource> getContextIDs()
throws org.openrdf.repository.RepositoryException
getContextIDs in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionpublic boolean isEmpty()
throws org.openrdf.repository.RepositoryException
This uses the HASSTMT REST API method to do the minimum amount of work on the server.
isEmpty in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionpublic long size(org.openrdf.model.Resource... c)
throws org.openrdf.repository.RepositoryException
size in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionpublic void clear(org.openrdf.model.Resource... c)
throws org.openrdf.repository.RepositoryException
clear in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionpublic void export(org.openrdf.rio.RDFHandler handler,
org.openrdf.model.Resource... c)
throws org.openrdf.repository.RepositoryException,
org.openrdf.rio.RDFHandlerException
export in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionorg.openrdf.rio.RDFHandlerExceptionpublic void exportStatements(org.openrdf.model.Resource s,
org.openrdf.model.URI p,
org.openrdf.model.Value o,
boolean includeInferred,
org.openrdf.rio.RDFHandler handler,
org.openrdf.model.Resource... c)
throws org.openrdf.repository.RepositoryException,
org.openrdf.rio.RDFHandlerException
exportStatements in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionorg.openrdf.rio.RDFHandlerExceptionpublic org.openrdf.query.Update prepareUpdate(org.openrdf.query.QueryLanguage ql,
String query)
throws org.openrdf.repository.RepositoryException,
org.openrdf.query.MalformedQueryException
prepareUpdate in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionorg.openrdf.query.MalformedQueryExceptionpublic org.openrdf.query.Update prepareUpdate(org.openrdf.query.QueryLanguage ql,
String query,
String baseURI)
throws org.openrdf.repository.RepositoryException,
org.openrdf.query.MalformedQueryException
prepareUpdate in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionorg.openrdf.query.MalformedQueryExceptionpublic void setNamespace(String arg0, String arg1) throws org.openrdf.repository.RepositoryException
setNamespace in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionpublic String getNamespace(String arg0) throws org.openrdf.repository.RepositoryException
getNamespace in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionpublic org.openrdf.repository.RepositoryResult<org.openrdf.model.Namespace> getNamespaces()
throws org.openrdf.repository.RepositoryException
getNamespaces in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionpublic void removeNamespace(String arg0) throws org.openrdf.repository.RepositoryException
removeNamespace in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionpublic void clearNamespaces()
throws org.openrdf.repository.RepositoryException
clearNamespaces in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionpublic void setParserConfig(org.openrdf.rio.ParserConfig arg0)
setParserConfig in interface org.openrdf.repository.RepositoryConnectionpublic org.openrdf.rio.ParserConfig getParserConfig()
getParserConfig in interface org.openrdf.repository.RepositoryConnectionpublic org.openrdf.model.ValueFactory getValueFactory()
getValueFactory in interface org.openrdf.repository.RepositoryConnectionpublic boolean isOpen()
throws org.openrdf.repository.RepositoryException
isOpen in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryException@Deprecated public boolean isAutoCommit() throws org.openrdf.repository.RepositoryException
Note: This is deprecated in openrdf since 2.7.x. The semantics are that a connection without an active transaction is in "auto-commit" mode.
isAutoCommit in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryException@Deprecated public void setAutoCommit(boolean autoCommit) throws org.openrdf.repository.RepositoryException
Note: This is deprecated in openrdf since 2.7.x. The semantics are that a connection without an active transaction is in "auto-commit" mode. If there is an open transaction and auto-commit is disabled, the open transaction is committed. This is per the openrdf API.
setAutoCommit in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionpublic void close()
throws org.openrdf.repository.RepositoryException
close in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionpublic boolean isActive()
throws org.openrdf.repository.UnknownTransactionStateException,
org.openrdf.repository.RepositoryException
isActive in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.UnknownTransactionStateExceptionorg.openrdf.repository.RepositoryExceptionpublic void begin()
throws org.openrdf.repository.RepositoryException
begin in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionpublic void beginReadOnly()
throws org.openrdf.repository.RepositoryException
org.openrdf.repository.RepositoryExceptionpublic void beginReadOnly(long timestamp)
throws org.openrdf.repository.RepositoryException
Note: Since all read operations have snapshot isolation, this is only
necessary when multiple read operations need to read on the same commit
point.
TODO While the ability to do read-only operations against a specified
timestamp without a transaction exists, it is not exposed by this
interface nor can be accomplished using RemoteRepository since
that interface also lacks mechanisms (e.g.,
prepareTupleQuery(String:query,long:commitTime)) to express this request.
org.openrdf.repository.RepositoryExceptionpublic void commit()
throws org.openrdf.repository.RepositoryException
commit in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionpublic void rollback()
throws org.openrdf.repository.RepositoryException
rollback in interface org.openrdf.repository.RepositoryConnectionorg.openrdf.repository.RepositoryExceptionCopyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.