public class RDF4JProtocolSession extends SPARQLProtocolSession
SPARQLProtocolSession subclass which extends the standard SPARQL 1.1 Protocol with additional
functionality, as documented in the RDF4J REST API.DEFAULT_MAXIMUM_URL_LENGTH, MAXIMUM_URL_LENGTH, MAXIMUM_URL_LENGTH_PARAM, UTF8| Constructor and Description |
|---|
RDF4JProtocolSession(org.apache.http.client.HttpClient client,
ScheduledExecutorService executor) |
| Modifier and Type | Method and Description |
|---|---|
void |
addData(InputStream contents,
String baseURI,
RDFFormat dataFormat,
Resource... contexts) |
void |
beginTransaction(IsolationLevel isolationLevel) |
void |
beginTransaction(TransactionSetting... transactionSettings) |
protected void |
checkRepositoryURL() |
protected void |
checkServerURL() |
void |
clearNamespaces() |
void |
close() |
void |
commitTransaction() |
void |
createRepository(RepositoryConfig config)
Create a new repository.
|
void |
deleteRepository(String repositoryID) |
TupleQueryResult |
getContextIDs() |
void |
getContextIDs(TupleQueryResultHandler handler) |
String |
getNamespace(String prefix) |
TupleQueryResult |
getNamespaces() |
void |
getNamespaces(TupleQueryResultHandler handler) |
protected org.apache.http.client.methods.HttpUriRequest |
getQueryMethod(QueryLanguage ql,
String query,
String baseURI,
Dataset dataset,
boolean includeInferred,
int maxQueryTime,
Binding... bindings) |
protected List<org.apache.http.NameValuePair> |
getQueryMethodParameters(QueryLanguage ql,
String query,
String baseURI,
Dataset dataset,
boolean includeInferred,
int maxQueryTime,
Binding... bindings) |
void |
getRepositoryConfig(StatementCollector statementCollector)
Retrieve configuration of the current repository and send it to the supplied
StatementCollector |
TupleQueryResult |
getRepositoryList() |
void |
getRepositoryList(TupleQueryResultHandler handler) |
String |
getRepositoryURL() |
String |
getServerProtocol() |
String |
getServerURL() |
void |
getStatements(Resource subj,
IRI pred,
Value obj,
boolean includeInferred,
RDFHandler handler,
Resource... contexts) |
protected org.apache.http.client.methods.HttpUriRequest |
getUpdateMethod(QueryLanguage ql,
String update,
String baseURI,
Dataset dataset,
boolean includeInferred,
int maxExecutionTime,
Binding... bindings) |
protected List<org.apache.http.NameValuePair> |
getUpdateMethodParameters(QueryLanguage ql,
String update,
String baseURI,
Dataset dataset,
boolean includeInferred,
int maxQueryTime,
Binding... bindings) |
String |
getUpdateURL() |
void |
removeData(InputStream contents,
String baseURI,
RDFFormat dataFormat,
Resource... contexts) |
void |
removeNamespacePrefix(String prefix) |
void |
rollbackTransaction() |
void |
sendTransaction(Iterable<? extends TransactionOperation> txn)
Deprecated.
since 2.8.0
|
void |
setNamespacePrefix(String prefix,
String name) |
void |
setRepository(String repositoryURL) |
void |
setServerURL(String serverURL) |
void |
setUsernameAndPassword(String username,
String password)
Set the username and password for authentication with the remote server.
|
long |
size(Resource... contexts) |
void |
updateRepository(RepositoryConfig config)
Update the config of an existing repository.
|
protected void |
upload(org.apache.http.HttpEntity reqEntity,
String baseURI,
boolean overwrite,
boolean preserveNodeIds,
Protocol.Action action,
Resource... contexts) |
protected void |
upload(InputStream contents,
String baseURI,
RDFFormat dataFormat,
boolean overwrite,
boolean preserveNodeIds,
Protocol.Action action,
Resource... contexts) |
void |
upload(InputStream contents,
String baseURI,
RDFFormat dataFormat,
boolean overwrite,
boolean preserveNodeIds,
Resource... contexts) |
protected void |
upload(Reader contents,
String baseURI,
RDFFormat dataFormat,
boolean overwrite,
boolean preserveNodeIds,
Protocol.Action action,
Resource... contexts) |
void |
upload(Reader contents,
String baseURI,
RDFFormat dataFormat,
boolean overwrite,
boolean preserveNodeIds,
Resource... contexts) |
execute, executeNoContent, executeOK, getAdditionalHttpHeaders, getBackgroundTupleQueryResult, getBoolean, getConnectionTimeout, getErrorInfo, getHttpClient, getParserConfig, getPreferredBooleanQueryResultFormat, getPreferredRDFFormat, getPreferredTupleQueryResultFormat, getQueryURL, getRDF, getRDFBackground, getResponseMIMEType, getTupleQueryResult, getUpdateMethod, getUpdateMethodParameters, getValueFactory, sendBooleanQuery, sendBooleanQuery, sendGraphQuery, sendGraphQuery, sendGraphQuery, sendGraphQuery, sendTupleQuery, sendTupleQuery, sendTupleQuery, sendUpdate, sendUpdate, setAdditionalHttpHeaders, setConnectionTimeout, setHttpClient, setParserConfig, setPreferredBooleanQueryResultFormat, setPreferredRDFFormat, setPreferredTupleQueryResultFormat, setQueryURL, setUpdateURL, setUsernameAndPasswordForUrl, setValueFactory, shouldUsePostpublic RDF4JProtocolSession(org.apache.http.client.HttpClient client,
ScheduledExecutorService executor)
public void setServerURL(String serverURL)
public String getServerURL()
public String getRepositoryURL()
public void setRepository(String repositoryURL)
protected void checkRepositoryURL()
protected void checkServerURL()
public String getUpdateURL()
getUpdateURL in class SPARQLProtocolSessionpublic void close()
close in interface AutoCloseableclose in class SPARQLProtocolSessionpublic TupleQueryResult getRepositoryList() throws IOException, RepositoryException, UnauthorizedException, QueryInterruptedException
public void getRepositoryList(TupleQueryResultHandler handler) throws IOException, TupleQueryResultHandlerException, RepositoryException, UnauthorizedException, QueryInterruptedException
public String getServerProtocol() throws IOException, RepositoryException, UnauthorizedException
public long size(Resource... contexts) throws IOException, RepositoryException, UnauthorizedException
public void createRepository(RepositoryConfig config) throws IOException, RepositoryException
config - the repository configurationIOExceptionRepositoryExceptionpublic void updateRepository(RepositoryConfig config) throws IOException, RepositoryException
config - the repository configurationIOExceptionRepositoryExceptionpublic void deleteRepository(String repositoryID) throws IOException, RepositoryException
IOExceptionRepositoryExceptionpublic void getRepositoryConfig(StatementCollector statementCollector) throws UnauthorizedException, QueryInterruptedException, RDFHandlerException, RepositoryException, IOException
StatementCollectorstatementCollector - receiver of the repository config informationIOExceptionRepositoryExceptionRDFHandlerExceptionQueryInterruptedExceptionUnauthorizedExceptionpublic TupleQueryResult getNamespaces() throws IOException, RepositoryException, UnauthorizedException, QueryInterruptedException
public void getNamespaces(TupleQueryResultHandler handler) throws IOException, TupleQueryResultHandlerException, RepositoryException, UnauthorizedException, QueryInterruptedException
public String getNamespace(String prefix) throws IOException, RepositoryException, UnauthorizedException
public void setNamespacePrefix(String prefix, String name) throws IOException, RepositoryException, UnauthorizedException
public void removeNamespacePrefix(String prefix) throws IOException, RepositoryException, UnauthorizedException
public void clearNamespaces()
throws IOException,
RepositoryException,
UnauthorizedException
public TupleQueryResult getContextIDs() throws IOException, RepositoryException, UnauthorizedException, QueryInterruptedException
public void getContextIDs(TupleQueryResultHandler handler) throws IOException, TupleQueryResultHandlerException, RepositoryException, UnauthorizedException, QueryInterruptedException
public void getStatements(Resource subj, IRI pred, Value obj, boolean includeInferred, RDFHandler handler, Resource... contexts) throws IOException, RDFHandlerException, RepositoryException, UnauthorizedException, QueryInterruptedException
public void beginTransaction(IsolationLevel isolationLevel) throws RDF4JException, IOException, UnauthorizedException
public void beginTransaction(TransactionSetting... transactionSettings) throws RDF4JException, IOException, UnauthorizedException
public void commitTransaction()
throws RDF4JException,
IOException,
UnauthorizedException
public void rollbackTransaction()
throws RDF4JException,
IOException,
UnauthorizedException
@Deprecated public void sendTransaction(Iterable<? extends TransactionOperation> txn) throws IOException, RepositoryException, UnauthorizedException
txn - IOExceptionRepositoryExceptionUnauthorizedExceptionpublic void addData(InputStream contents, String baseURI, RDFFormat dataFormat, Resource... contexts) throws UnauthorizedException, RDFParseException, RepositoryException, IOException
public void removeData(InputStream contents, String baseURI, RDFFormat dataFormat, Resource... contexts) throws UnauthorizedException, RDFParseException, RepositoryException, IOException
public void upload(InputStream contents, String baseURI, RDFFormat dataFormat, boolean overwrite, boolean preserveNodeIds, Resource... contexts) throws IOException, RDFParseException, RepositoryException, UnauthorizedException
protected void upload(InputStream contents, String baseURI, RDFFormat dataFormat, boolean overwrite, boolean preserveNodeIds, Protocol.Action action, Resource... contexts) throws IOException, RDFParseException, RepositoryException, UnauthorizedException
public void upload(Reader contents, String baseURI, RDFFormat dataFormat, boolean overwrite, boolean preserveNodeIds, Resource... contexts) throws UnauthorizedException, RDFParseException, RepositoryException, IOException
protected org.apache.http.client.methods.HttpUriRequest getQueryMethod(QueryLanguage ql, String query, String baseURI, Dataset dataset, boolean includeInferred, int maxQueryTime, Binding... bindings)
getQueryMethod in class SPARQLProtocolSessionprotected org.apache.http.client.methods.HttpUriRequest getUpdateMethod(QueryLanguage ql, String update, String baseURI, Dataset dataset, boolean includeInferred, int maxExecutionTime, Binding... bindings)
getUpdateMethod in class SPARQLProtocolSessionprotected void upload(Reader contents, String baseURI, RDFFormat dataFormat, boolean overwrite, boolean preserveNodeIds, Protocol.Action action, Resource... contexts) throws IOException, RDFParseException, RepositoryException, UnauthorizedException
protected void upload(org.apache.http.HttpEntity reqEntity,
String baseURI,
boolean overwrite,
boolean preserveNodeIds,
Protocol.Action action,
Resource... contexts)
throws IOException,
RDFParseException,
RepositoryException,
UnauthorizedException
public void setUsernameAndPassword(String username, String password)
SPARQLProtocolSessionsetUsernameAndPassword in class SPARQLProtocolSessionusername - the usernamepassword - the passwordprotected List<org.apache.http.NameValuePair> getQueryMethodParameters(QueryLanguage ql, String query, String baseURI, Dataset dataset, boolean includeInferred, int maxQueryTime, Binding... bindings)
getQueryMethodParameters in class SPARQLProtocolSessionprotected List<org.apache.http.NameValuePair> getUpdateMethodParameters(QueryLanguage ql, String update, String baseURI, Dataset dataset, boolean includeInferred, int maxQueryTime, Binding... bindings)
getUpdateMethodParameters in class SPARQLProtocolSessionCopyright © 2015-2020 Eclipse Foundation. All Rights Reserved.