AGRepositoryConnection (agraph-java-client 2.1.1-SNAPSHOT API)

java.lang.Object
- org.eclipse.rdf4j.repository.base.AbstractRepositoryConnection
- - com.franz.agraph.repository.AGRepositoryConnection

All Implemented Interfaces:

AutoCloseable, RepositoryConnection
```
public class AGRepositoryConnection
extends AbstractRepositoryConnection
implements RepositoryConnection, AutoCloseable
```
Implements the Sesame RepositoryConnection interface for AllegroGraph.
By default, a connection is in autoCommit mode. Connections in this mode are said to be shared. Multiple shared connections may be serviced by the same server back-end process and they have no associated state, thus they do not support some functionality such as multi-step transactions and datatype mappings.

Full functionality is offered by dedicated sessions at the cost of higher server resource requirements.

Note that concurrent access to the same connection object of either kind is explicitly forbidden. The client must perform its own synchronization to ensure non-concurrent access. This is typically achieved by employing connection pooling (see AGConnPool) and having exactly one thread that uses each connection.

Dedicated Session Overview

Sessions with AllegroGraph server are used for ACID transactions and also for server code in InitFile and Scripts. See more documentation for Sessions in the AllegroGraph HTTP Protocol and ACID transactions in the AllegroGraph Server documentation.

Operations such as setAutoCommit, addRules, and registerSNAGenerator will spawn a dedicated session (simply session, from now on) in order to perform their duties. Adds and deletes during a session must be committed or rolled back.

To conserve resources, the server will drop a session when its idle lifetime is exceeded. To avoid this, the client periodically sends a ping message to the server. This automated behavior can be controlled by changing the executor used to schedule maintenance tasks. This can be done either in the AGServer.setExecutor(ScheduledExecutorService) server} object or when creating a new connection with AGRepository.getConnection(ScheduledExecutorService).

A session should be closed when finished.

InitFiles and Scripts are loaded into the server only for sessions. See Scripting in HTTP Protocol and search for "InitFile" in WebView for how to create initFiles.

Starting a session causes http requests to use a new port, which may cause an exception if the client can not access it. See Session Port Setup.

Methods that start a session if not already started:
Methods that affect a session in use:
Methods to configure a session before it is started:
Data-type and Predicate Mapping

For more details, see the HTTP Protocol docs for Type Mappings and the Lisp reference for Data-type and Predicate Mapping.

Methods for type mappings:
Since:

v4.0

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

class AGRepositoryConnection.AttributeDefinition
Builder class for defining a new attribute definition.

Nested Classes
Modifier and Type	Class and Description
`class`	`AGRepositoryConnection.AttributeDefinition` Builder class for defining a new attribute definition.

Field Summary

Fields
Modifier and Type	Field and Description
`static int`	`DEFAULT_ADD_STATEMENT_BUFFER_SIZE`
`static String`	`PROP_ADD_STATEMENT_BUFFER_MAX_SIZE`
`static String`	`PROP_STREAM_RESULTS`
`static String`	`PROP_USE_ADD_STATEMENT_BUFFER`

Constructor Summary

Constructors
Constructor and Description
`AGRepositoryConnection(AGRepository repository, AGHttpRepoClient client)`
`AGRepositoryConnection(AGVirtualRepository repository, AGHttpRepoClient client)`

Method Summary

All Methods Instance Methods Concrete Methods Deprecated Methods
Modifier and Type	Method and Description
`void`	`add(File file, String baseURI, RDFFormat dataFormat, org.json.JSONObject attributes, Resource... contexts)` Adds RDF data from the specified file to a specific contexts in the repository.
`void`	`add(File file, String baseURI, RDFFormat dataFormat, Resource... contexts)` Adds RDF data from the specified file to a specific contexts in the repository.
`void`	`add(InputStream in, String baseURI, RDFFormat dataFormat, org.json.JSONObject attributes, Resource... contexts)` Adds RDF data from an InputStream to the repository, optionally to one or more named contexts.
`void`	`add(InputStream in, String baseURI, RDFFormat dataFormat, Resource... contexts)` Adds RDF data from an InputStream to the repository, optionally to one or more named contexts.
`void`	`add(Iterable<? extends Statement> statements, org.json.JSONObject attributes, Resource... contexts)`
`void`	`add(Iterable<? extends Statement> statements, Resource... contexts)`
`<E extends Exception> void`	`add(Iteration<? extends Statement,E> statementIter, org.json.JSONObject attributes, Resource... contexts)`
`<E extends Exception> void`	`add(Iteration<? extends Statement,E> statementIter, Resource... contexts)`
`void`	`add(Reader reader, String baseURI, RDFFormat dataFormat, org.json.JSONObject attributes, Resource... contexts)` Adds RDF data from a Reader to the repository, optionally to one or more named contexts.
`void`	`add(Reader reader, String baseURI, RDFFormat dataFormat, Resource... contexts)` Adds RDF data from a Reader to the repository, optionally to one or more named contexts.
`void`	`add(Resource subject, IRI predicate, Value object, org.json.JSONObject attributes, Resource... contexts)`
`void`	`add(Resource subject, IRI predicate, Value object, Resource... contexts)` Adds a statement with the specified subject, predicate and object to this repository, optionally to one or more named contexts.
`void`	`add(Statement st, org.json.JSONObject attributes, Resource... contexts)`
`void`	`add(Statement st, Resource... contexts)`
`void`	`add(URL url, String baseURI, RDFFormat dataFormat, org.json.JSONObject attributes, Resource... contexts)` Adds the RDF data that can be found at the specified URL to the repository, optionally to one or more named contexts.
`void`	`add(URL url, String baseURI, RDFFormat dataFormat, Resource... contexts)` Adds the RDF data that can be found at the specified URL to the repository, optionally to one or more named contexts.
`void`	`addIndex(String type)` Adds the given index to the list of actively managed indices.
`void`	`addRules(InputStream rulestream)` Adds Prolog rules to be used on this connection.
`void`	`addRules(String rules)` Adds Prolog rules to be used on this connection.
`void`	`addSessionLoadScript(String scriptName)` Adds a 'script' for a dedicated session spawned by this connection.
`void`	`begin()` Begins a transaction requiring `commit()` or `rollback()` to be called to end the transaction.
`Object`	`callStoredProc(String functionName, String moduleName, Object... args)` Deprecated. The stored proc feature and API are experimental, and subject to change in a future release.
`void`	`clear(Resource... contexts)` Removes all statement(s) within the specified contexts.
`void`	`clearAttributes()` Deletes all attribute definitions from the repository.
`void`	`clearMappings()` Deletes all user-defined predicate and datatype mappings for this connection, and reestablishes the automatic mappings for primitive datatypes.
`void`	`clearMappings(boolean includeAutoEncodedPrimitiveTypes)` Deletes all predicate and user-defined datatype mappings for this connection.
`void`	`clearNamespaces()`
`void`	`close()` Closes the session if there is one started.
`void`	`commit()` Commit the current transaction.
`void`	`commit(TransactionSettings transactionSettings)` Commit the current transaction.
`void`	`commit(Xid xid)` Finalize a previously prepared two phase commit (2PC).
`void`	`createFreetextIndex(String indexName, AGFreetextIndexConfig config)` Creates a freetext index with the given name and configuration.
`void`	`createFreetextIndex(String name, IRI[] predicates)` Deprecated.
`<E> RepositoryResult<E>`	`createRepositoryResult(Iterable<? extends E> elements)` Creates a RepositoryResult for the supplied element set.
`void`	`deleteAttributeDefinition(String name)` Delete an existing triple attribute definition.
`void`	`deleteDatatypeMapping(IRI datatype)` Deletes any datatype mapping associated with the given datatype.
`void`	`deleteDuplicates(String comparisonMode)` Deletes all duplicates from the store.
`void`	`deleteFreetextIndex(String indexName)` Deletes the freetext index of the specified name.
`long`	`deleteMaterialized()` Deletes materialized statements from the default graph.
`long`	`deleteMaterialized(AGMaterializer materializer)` Deletes materialized statements.
`long`	`deleteMaterialized(Resource inferredGraph)` Deletes materialized statements from given graph.
`void`	`deletePredicateMapping(IRI predicate)` Deletes any predicate mapping associated with the given predicate.
`void`	`deleteSpinFunction(String uri)`
`void`	`deleteSpinMagicProperty(String uri)`
`void`	`deleteStaticAttributeFilter()` Delete the static attribute filter defined on this repository.
`void`	`disableTripleCache()` Disables the spogi triple cache.
`void`	`downloadStatements(File file, RDFFormat format, Resource subj, IRI pred, Value obj, boolean includeInferred, Resource... contexts)` Downloads statements matching given pattern to a file.
`void`	`downloadStatements(File file, RDFFormat format, String ids)` Downloads statements with given ids to a file.
`void`	`downloadStatements(File file, Resource subj, IRI pred, Value obj, boolean includeInferred, Resource... contexts)` Downloads statements matching given pattern to a file.
`void`	`downloadStatements(File file, String mimeType, Resource subj, IRI pred, Value obj, boolean includeInferred, Resource... contexts)` Downloads statements matching given pattern to a file.
`void`	`downloadStatements(File file, String mimeType, String ids)` Downloads statements with given ids to a file.
`void`	`downloadStatements(String file, RDFFormat format, Resource subj, IRI pred, Value obj, boolean includeInferred, Resource... contexts)` Downloads statements matching given pattern to a file.
`void`	`downloadStatements(String file, RDFFormat format, String ids)` Downloads statements with given ids to a file.
`void`	`downloadStatements(String file, Resource subj, IRI pred, Value obj, boolean includeInferred, Resource... contexts)` Downloads statements matching given pattern to a file.
`void`	`downloadStatements(String file, String mimeType, Resource subj, IRI pred, Value obj, boolean includeInferred, Resource... contexts)` Downloads statements matching given pattern to a file.
`void`	`downloadStatements(String file, String mimeType, String ids)` Downloads statements with given ids to a file.
`void`	`dropIndex(String type)` Drops the given index from the list of actively managed indices.
`void`	`enableTripleCache(long size)` Enables the spogi cache in this repository.
`String`	`evalInServer(InputStream stream)` Evaluates a Lisp form on the server, and returns the result as a String.
`String`	`evalInServer(String lispForm)` Evaluates a Lisp form on the server, and returns the result as a String.
`void`	`exportStatements(RDFHandler handler, String... ids)`
`void`	`exportStatements(Resource subj, IRI pred, Value obj, boolean includeInferred, RDFHandler handler, Resource... contexts)`
`int`	`getAddStatementBufferMaxSize()`
`org.json.JSONArray`	`getAttributeDefinition(String name)` Return the definition of the attribute named by NAME.
`org.json.JSONArray`	`getAttributeDefinitions()` Return a list of all attributes defined for the current connection.
`RepositoryResult<Resource>`	`getContextIDs()`
`String[]`	`getDatatypeMappings()` Gets the datatype mappings defined for this connection.
`RepositoryResult<Statement>`	`getDuplicateStatements(String comparisonMode)` Returns all duplicates from the store.
`AGFreetextIndexConfig`	`getFreetextIndexConfig(String indexName)` Gets the configuration of the specified free text index.
`String[]`	`getFreetextIndices()` Deprecated.
`String[]`	`getFreetextPredicates(String index)` Deprecated.
`RepositoryResult<Statement>`	`getGeoHaversine(IRI type, IRI predicate, float lat, float lon, float radius, String unit, int limit, boolean infer)`
`String[]`	`getGeoTypes()`
`String`	`getNamespace(String prefix)`
`RepositoryResult<Namespace>`	`getNamespaces()`
`int`	`getNumBufferedAddStatements()`
`String[]`	`getPredicateMappings()` Gets the predicate mappings defined for this connection.
`Xid[]`	`getPreparedTransactions()`
`AGAbstractRepository`	`getRepository()`
`AGServer`	`getServer()`
`int`	`getSessionLifetime()` Returns the lifetime for a dedicated session spawned by this connection.
`String`	`getSpinFunction(String uri)`
`String`	`getSpinMagicProperty(String uri)`
`RepositoryResult<Statement>`	`getStatements(Resource subj, IRI pred, Value obj, boolean includeInferred, Resource... contexts)`
`RepositoryResult<Statement>`	`getStatements(String... ids)` Returns statements having the specified ids.
`RepositoryResult<Statement>`	`getStatementsInBox(IRI type, IRI predicate, float xmin, float xmax, float ymin, float ymax, int limit, boolean infer)`
`RepositoryResult<Statement>`	`getStatementsInCircle(IRI type, IRI predicate, float x, float y, float radius, int limit, boolean infer)`
`RepositoryResult<Statement>`	`getStatementsInPolygon(IRI type, IRI predicate, IRI polygon, int limit, boolean infer)`
`String`	`getStaticAttributeFilter()` Fetch the string representation of the static attribute filter defined on this repository
`long`	`getStoreID()` Returns the store ID
`long`	`getTripleCacheSize()` Returns the size of the spogi cache.
`int`	`getUploadCommitPeriod()` Gets the commit period used within large add/load operations.
`String`	`getUserAttributes()`
`AGValueFactory`	`getValueFactory()`
`XAResource`	`getXAResource()`
`boolean`	`isActive()` Indicates if a transaction is currently active on the connection.
`boolean`	`isAddStatementBufferEnabled()`
`boolean`	`isAutoCommit()` Deprecated. since release 2.7.0. Use isActive() instead.
`boolean`	`isStreamResults()` If true, automatically use `AGStreamTupleQuery`.
`boolean`	`isUseAddStatementBuffer()`
`List<AGFormattedNamespace>`	`listEncodableNamespaces()` Returns a list of the registered encodable namespaces.
`List<String>`	`listFreetextIndices()` Lists the freetext indices that have been defined for this repository.
`List<String>`	`listIndices()` Returns a list of actively managed indices for this repository.
`List<AGSpinFunction>`	`listSpinFunctions()`
`List<AGSpinMagicProperty>`	`listSpinMagicProperties()`
`List<String>`	`listValidIndices()` Returns a list of all possible index types for this repository.
`void`	`load(IRI source, String baseURI, RDFFormat dataFormat, org.json.JSONObject attributes, Resource... contexts)` Instructs the server to fetch and load data from the specified URI.
`void`	`load(IRI source, String baseURI, RDFFormat dataFormat, Resource... contexts)` Instructs the server to fetch and load data from the specified URI.
`void`	`load(String absoluteServerPath, String baseURI, RDFFormat dataFormat, org.json.JSONObject attributes, Resource... contexts)` Instructs the server to load data from the specified server-side path.
`void`	`load(String absoluteServerPath, String baseURI, RDFFormat dataFormat, Resource... contexts)` Instructs the server to load data from the specified server-side path.
`long`	`materialize(AGMaterializer materializer)` Materializes inferred statements (generates and adds them to the store).
`void`	`optimizeIndices(Boolean wait)`
`void`	`optimizeIndices(Boolean wait, int level)` Instruct the server to optimize the indices for this store.
`void`	`ping()` Instructs the server to extend the life of this connection's dedicated session, if it is using one.
`AGBooleanQuery`	`prepareBooleanQuery(QueryLanguage ql, String queryString)`
`AGBooleanQuery`	`prepareBooleanQuery(QueryLanguage ql, String queryString, String baseURI)`
`void`	`prepareCommit(Xid xid)` Asks the server to prepare a commit for later finalization/rollback.
`AGGraphQuery`	`prepareGraphQuery(QueryLanguage ql, String queryString)`
`AGGraphQuery`	`prepareGraphQuery(QueryLanguage ql, String queryString, String baseURI)`
`AGHttpRepoClient`	`prepareHttpRepoClient()` This is the method to call, in this or other classes, if you want to do HTTP interaction with the repository.
`AGQuery`	`prepareQuery(QueryLanguage ql, String queryString, String baseURI)` Prepares a `AGQuery` for evaluation on this repository.
`AGTupleQuery`	`prepareTupleQuery(QueryLanguage ql, String queryString)`
`AGTupleQuery`	`prepareTupleQuery(QueryLanguage ql, String queryString, String baseURI)`
`AGUpdate`	`prepareUpdate(QueryLanguage ql, String queryString)`
`AGUpdate`	`prepareUpdate(QueryLanguage ql, String queryString, String baseURI)`
`void`	`putSpinFunction(AGSpinFunction fn)`
`void`	`putSpinMagicProperty(AGSpinMagicProperty fn)`
`IRI`	`registerCartesianType(float stripWidth, float xmin, float xmax, float ymin, float ymax)` Registers a cartesian geospatial subtype.
`void`	`registerDatatypeMapping(IRI datatype, IRI primtype)` Registers a datatype mapping from the datatype to a primitive datatype.
`void`	`registerEncodableNamespace(String namespace, String format)` Registers an encodable namespace having the specified format.
`void`	`registerEncodableNamespaces(Iterable<? extends AGFormattedNamespace> formattedNamespaces)` Registers multiple formatted namespaces in a single request.
`void`	`registerPolygon(IRI polygon, List<Literal> points)` Registers a polygon.
`void`	`registerPredicateMapping(IRI predicate, IRI primtype)` Registers a predicate mapping from the predicate to a primitive datatype.
`void`	`registerSNAGenerator(String generator, List<IRI> objectOfs, List<IRI> subjectOfs, List<IRI> undirecteds, String query)` See Social network analysis Lisp documentation and SNA generator registration.
`void`	`registerSNANeighborMatrix(String matrix, String generator, List<IRI> group, int depth)`
`IRI`	`registerSphericalType(float stripWidth, String unit)`
`IRI`	`registerSphericalType(float stripWidth, String unit, float latmin, float lonmin, float latmax, float lonmax)` Registers a spherical geospatial subtype.
`void`	`remove(Iterable<? extends Statement> statements, Resource... contexts)`
`<E extends Exception> void`	`remove(Iteration<? extends Statement,E> statements, Resource... contexts)`
`void`	`remove(Resource subject, IRI predicate, Value object, Resource... contexts)` Removes the statement(s) with the specified subject, predicate and object from the repository, optionally restricted to the specified contexts.
`void`	`remove(Statement st, Resource... contexts)`
`void`	`removeNamespace(String prefix)`
`void`	`rollback()` Roll back the current transaction (discard all changes made since last commit).
`void`	`rollback(Xid xid)` Aborts a previously prepared commit.
`void`	`sendRDFTransaction(InputStream rdftransaction)` Executes an application/x-rdftransaction.
`void`	`sendRDFTransaction(InputStream rdftransaction, org.json.JSONObject attributes)` send an RDFTransaction, including attributes.
`void`	`setAddStatementBufferEnabled(boolean enabled)` Enable or disable the use of the addStatementBuffer.
`void`	`setAddStatementBufferMaxSize(int size)` Set the maximum size of the addStatementBuffer.
`void`	`setAutoCommit(boolean autoCommit)` Deprecated. As of release 2.7.0, use begin() instead.
`void`	`setMasqueradeAsUser(String user)` Sets the AG user for X-Masquerade-As-User requests.
`void`	`setNamespace(String prefix, String name)`
`void`	`setPool(AGConnPool pool)` Sets the connection pool this object will be returned to on close.
`void`	`setSessionLifetime(int lifetimeInSeconds)` Sets the 'lifetime' for a dedicated session spawned by this connection.
`void`	`setSessionLoadInitFile(boolean loadInitFile)` Sets the 'loadInitFile' flag for a dedicated session spawned by this connection.
`void`	`setStaticAttributeFilter(String filter)` Establish a static attribute filter on the current repository.
`void`	`setStreamResults(boolean streamResults)` Set to true to automatically use `AGStreamTupleQuery` for `prepareTupleQuery(QueryLanguage, String, String)`.
`void`	`setTransactionSettings(TransactionSettings transactionSettings)` Configure distributed transaction behavior.
`void`	`setUploadCommitPeriod(int period)` Sets the commit period to use within large add/load operations.
`void`	`setUserAttributes(org.json.JSONObject value)`
`void`	`setUserAttributes(String value)`
`long`	`size(Resource... contexts)`
`InputStream`	`streamStatements(RDFFormat format, Resource subj, IRI pred, Value obj, boolean includeInferred, Resource... contexts)` Returns statements matching given pattern as an InputStream.
`InputStream`	`streamStatements(RDFFormat format, String... ids)` Returns statements with given ids as an InputStream.
`InputStream`	`streamStatements(Resource subj, IRI pred, Value obj, boolean includeInferred, Resource... contexts)` Returns statements matching given pattern as an InputStream.
`InputStream`	`streamStatements(String mimeType, Resource subj, IRI pred, Value obj, boolean includeInferred, Resource... contexts)` Returns statements matching given pattern as an InputStream.
`InputStream`	`streamStatements(String mimeType, String... ids)` Returns statements with given ids as an InputStream.
`String`	`toString()`
`Ctx`	`transactionSettingsCtx(TransactionSettings transactionSettings)` A 'context manager' for temporarily changing transaction settings.
`void`	`unregisterEncodableNamespace(String namespace)` Unregisters the specified encodable namespace.
`void`	`warmup()` Asks the server to read store's internal data structures into memory.
`void`	`warmup(WarmupConfig config)` Asks the server to read store's internal data structures into memory.

Methods inherited from class org.eclipse.rdf4j.repository.base.AbstractRepositoryConnection
begin, export, getIsolationLevel, getParserConfig, hasStatement, hasStatement, isEmpty, isOpen, prepareQuery, setIsolationLevel, setParserConfig

Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.eclipse.rdf4j.repository.RepositoryConnection
add, begin, export, getIsolationLevel, getParserConfig, getStatements, getStatements, hasStatement, hasStatement, hasStatement, isEmpty, isOpen, prepareBooleanQuery, prepareGraphQuery, prepareQuery, prepareQuery, prepareTupleQuery, prepareUpdate, remove, setIsolationLevel, setParserConfig

- Field Detail
  - PROP_STREAM_RESULTS
```
public static final String PROP_STREAM_RESULTS
```
    See Also:
    
    Constant Field Values
  - PROP_USE_ADD_STATEMENT_BUFFER
```
public static final String PROP_USE_ADD_STATEMENT_BUFFER
```
    See Also:
    
    Constant Field Values
  - PROP_ADD_STATEMENT_BUFFER_MAX_SIZE
```
public static final String PROP_ADD_STATEMENT_BUFFER_MAX_SIZE
```
    See Also:
    
    Constant Field Values
  - DEFAULT_ADD_STATEMENT_BUFFER_SIZE
```
public static final int DEFAULT_ADD_STATEMENT_BUFFER_SIZE
```
    See Also:
    
    Constant Field Values
- Constructor Detail
  - AGRepositoryConnection
```
public AGRepositoryConnection(AGRepository repository,
                              AGHttpRepoClient client)
```
    Parameters:
    
    repository - a repository name
    
    client - the HTTP client through which requests on this connection will be made
    
    See Also:
    
    AGRepository.getConnection(), AGVirtualRepository.getConnection()
  - AGRepositoryConnection
```
public AGRepositoryConnection(AGVirtualRepository repository,
                              AGHttpRepoClient client)
```
- Method Detail
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object
  - getRepository
```
public AGAbstractRepository getRepository()
```
    Specified by:
    
    getRepository in interface RepositoryConnection
    
    Overrides:
    
    getRepository in class AbstractRepositoryConnection
  - getServer
```
public AGServer getServer()
```
    Returns:
    
    the AGServer object associated with this connection
  - prepareHttpRepoClient
```
public AGHttpRepoClient prepareHttpRepoClient()
```
    This is the method to call, in this or other classes, if you want to do HTTP interaction with the repository. As a side effect (what the "prepare" stands for) any buffered statements are sent over.
    
    Returns:
    
    the AGHttpRepoclient used by this connection (after the addStatementBuffer is cleared)
  - isAddStatementBufferEnabled
```
public boolean isAddStatementBufferEnabled()
```
    Returns:
    
    whether the addStatementBuffer is in principle enabled (by the PROP_USE_ADD_STATEMENT_BUFFER property or a call to setAddStatementBufferEnabled).
  - setAddStatementBufferEnabled
```
public void setAddStatementBufferEnabled(boolean enabled)
```
    Enable or disable the use of the addStatementBuffer. This can be called within an active transaction and will affect (speed up) the rest of the transaction. When called in autocommit mode, it has no immediate effect, but in a subsequent transaction the buffer functionality will be used.
    The buffer can also be enabled by setting property PROP_USE_ADD_STATEMENT_BUFFER.
    
    Parameters:
    
    enabled - whether to enable buffering
  - isUseAddStatementBuffer
```
public boolean isUseAddStatementBuffer()
```
    Returns:
    
    whether the addStatementBuffer is actually used right now for the connection.
  - getAddStatementBufferMaxSize
```
public int getAddStatementBufferMaxSize()
```
  - setAddStatementBufferMaxSize
```
public void setAddStatementBufferMaxSize(int size)
```
    Set the maximum size of the addStatementBuffer.
    This size can also be set by using property PROP_ADD_STATEMENT_BUFFER_MAX_SIZE.
    
    Parameters:
    
    size - new maximum buffer size
  - getNumBufferedAddStatements
```
public int getNumBufferedAddStatements()
```
    Returns:
    
    the number of buffered statements to be added
  - getValueFactory
```
public AGValueFactory getValueFactory()
```
    Specified by:
    
    getValueFactory in interface RepositoryConnection
    
    Overrides:
    
    getValueFactory in class AbstractRepositoryConnection
  - add
```
public void add(Iterable<? extends Statement> statements,
                Resource... contexts)
         throws RepositoryException
```
    Specified by:
    
    add in interface RepositoryConnection
    
    Overrides:
    
    add in class AbstractRepositoryConnection
    
    Throws:
    
    RepositoryException
  - add
```
public void add(Iterable<? extends Statement> statements,
                org.json.JSONObject attributes,
                Resource... contexts)
         throws RepositoryException
```
    Throws:
    
    RepositoryException
  - add
```
public <E extends Exception> void add(Iteration<? extends Statement,E> statementIter,
                                      Resource... contexts)
                               throws RepositoryException,
                                      E extends Exception
```
    Specified by:
    
    add in interface RepositoryConnection
    
    Overrides:
    
    add in class AbstractRepositoryConnection
    
    Throws:
    
    RepositoryException
    
    E extends Exception
  - add
```
public <E extends Exception> void add(Iteration<? extends Statement,E> statementIter,
                                      org.json.JSONObject attributes,
                                      Resource... contexts)
                               throws RepositoryException,
                                      E extends Exception
```
    Throws:
    
    RepositoryException
    
    E extends Exception
  - add
```
public void add(File file,
                String baseURI,
                RDFFormat dataFormat,
                Resource... contexts)
         throws IOException,
                RDFParseException,
                RepositoryException
```
    Adds RDF data from the specified file to a specific contexts in the repository.
    
    Specified by:
    
    add in interface RepositoryConnection
    
    Overrides:
    
    add in class AbstractRepositoryConnection
    
    Parameters:
    
    file - a file containing RDF data
    
    baseURI - the base URI against which any relative URIs in the data are resolved. This defaults to the value of file.toURI() if the value is set to null
    
    dataFormat - the serialization format of the data
    
    contexts - the contexts to add the data to. Note that this parameter is a vararg and as such is optional. If no contexts are specified, the data is added to any context specified in the actual data file, or if the data contains no context, it is added to the default context. If one or more contexts are specified the data is added to these contexts, ignoring any context information in the data itself
    
    Throws:
    
    IOException - if an I/O error occurred while reading from the file
    
    UnsupportedRDFormatException - if no parser is available for the specified RDF format
    
    RDFParseException - if an error occurred while parsing the RDF data
    
    RepositoryException - if the data could not be added to the repository, for example because the repository is not writable
  - add
```
public void add(File file,
                String baseURI,
                RDFFormat dataFormat,
                org.json.JSONObject attributes,
                Resource... contexts)
         throws IOException,
                RDFParseException,
                RepositoryException
```
    Adds RDF data from the specified file to a specific contexts in the repository.
    
    Parameters:
    
    file - a file containing RDF data
    
    baseURI - the base URI against which any relative URIs in the data are resolved. This defaults to the value of file.toURI() if the value is set to null
    
    dataFormat - the serialization format of the data
    
    attributes - a JSONObject of attribute bindings that will be added to each statement imported from `file'. For RDFFormats that support the specification of attributes (like NQX) these attributes will be applied to statements that do not already specify attributes
    
    contexts - the contexts to add the data to. Note that this parameter is a vararg and as such is optional. If no contexts are specified, the data is added to any context specified in the actual data file, or if the data contains no context, it is added to the default context. If one or more contexts are specified the data is added to these contexts, ignoring any context information in the data itself
    
    Throws:
    
    IOException - if an I/O error occurred while reading from the file
    
    UnsupportedRDFormatException - if no parser is available for the specified RDF format
    
    RDFParseException - if an error occurred while parsing the RDF data
    
    RepositoryException - if the data could not be added to the repository, for example because the repository is not writable
  - add
```
public void add(URL url,
                String baseURI,
                RDFFormat dataFormat,
                Resource... contexts)
         throws IOException,
                RDFParseException,
                RepositoryException
```
    Adds the RDF data that can be found at the specified URL to the repository, optionally to one or more named contexts.
    
    Specified by:
    
    add in interface RepositoryConnection
    
    Overrides:
    
    add in class AbstractRepositoryConnection
    
    Parameters:
    
    url - the URL of the RDF data
    
    baseURI - the base URI against which any relative URIs in the data are resolved. This defaults to the value of url.toExternalForm() if the value is set to null
    
    dataFormat - the serialization format of the data
    
    contexts - the contexts to add the data to. If one or more contexts are specified the data is added to these contexts, ignoring any context information in the data itself
    
    Throws:
    
    IOException - if an I/O error occurred while reading from the URL
    
    UnsupportedRDFormatException - if no parser is available for the specified RDF format
    
    RDFParseException - if an error occurred while parsing the RDF data
    
    RepositoryException - if the data could not be added to the repository, for example because the repository is not writable
  - add
```
public void add(URL url,
                String baseURI,
                RDFFormat dataFormat,
                org.json.JSONObject attributes,
                Resource... contexts)
         throws IOException,
                RDFParseException,
                RepositoryException
```
    Adds the RDF data that can be found at the specified URL to the repository, optionally to one or more named contexts.
    
    Parameters:
    
    url - the URL of the RDF data
    
    baseURI - the base URI against which any relative URIs in the data are resolved. This defaults to the value of url.toExternalForm() if the value is set to null
    
    dataFormat - the serialization format of the data
    
    attributes - a JSONObject of attribute bindings that will be added to each statement imported from `url'. For RDFFormats that support the specification of attributes (like NQX) these attributes will be applied to statements that do not already specify attributes
    
    contexts - the contexts to add the data to. If one or more contexts are specified the data is added to these contexts, ignoring any context information in the data itself
    
    Throws:
    
    IOException - if an I/O error occurred while reading from the URL
    
    UnsupportedRDFormatException - if no parser is available for the specified RDF format
    
    RDFParseException - if an error occurred while parsing the RDF data
    
    RepositoryException - if the data could not be added to the repository, for example because the repository is not writable
  - add
```
public void add(InputStream in,
                String baseURI,
                RDFFormat dataFormat,
                Resource... contexts)
         throws IOException,
                RDFParseException,
                RepositoryException
```
    Adds RDF data from an InputStream to the repository, optionally to one or more named contexts.
    
    Specified by:
    
    add in interface RepositoryConnection
    
    Overrides:
    
    add in class AbstractRepositoryConnection
    
    Parameters:
    
    in - an InputStream from which RDF data can be read
    
    baseURI - the base URI against which any relative URIs in the data are resolved
    
    dataFormat - the serialization format of the data
    
    contexts - the contexts to add the data to. If one or more contexts are supplied the method ignores contextual information in the actual data. If no contexts are supplied the contextual information in the input stream is used, if no context information is available the data is added without any context
    
    Throws:
    
    IOException - if an I/O error occurred while reading from the input stream
    
    UnsupportedRDFormatException - if no parser is available for the specified RDF format
    
    RDFParseException - if an error occurred while parsing the RDF data
    
    RepositoryException - if the data could not be added to the repository, for example because the repository is not writable
  - add
```
public void add(InputStream in,
                String baseURI,
                RDFFormat dataFormat,
                org.json.JSONObject attributes,
                Resource... contexts)
         throws IOException,
                RDFParseException,
                RepositoryException
```
    Adds RDF data from an InputStream to the repository, optionally to one or more named contexts.
    
    Parameters:
    
    in - an InputStream from which RDF data can be read
    
    baseURI - the base URI against which any relative URIs in the data are resolved
    
    dataFormat - the serialization format of the data
    
    attributes - a JSONObject of attribute bindings that will be added to each statement imported from `in'. For RDFFormats that support the specification of attributes (like NQX) these attributes will be applied to statements that do not already specify attributes
    
    contexts - the contexts to add the data to. If one or more contexts are supplied the method ignores contextual information in the actual data. If no contexts are supplied the contextual information in the input stream is used, if no context information is available the data is added without any context
    
    Throws:
    
    IOException - if an I/O error occurred while reading from the input stream
    
    UnsupportedRDFormatException - if no parser is available for the specified RDF format
    
    RDFParseException - if an error occurred while parsing the RDF data
    
    RepositoryException - if the data could not be added to the repository, for example because the repository is not writable
  - add
```
public void add(Reader reader,
                String baseURI,
                RDFFormat dataFormat,
                Resource... contexts)
         throws IOException,
                RDFParseException,
                RepositoryException
```
    Adds RDF data from a Reader to the repository, optionally to one or more named contexts. Note: using a Reader to upload byte-based data means that you have to be careful not to destroy the data's character encoding by enforcing a default character encoding upon the bytes. If possible, adding such data using an InputStream is to be preferred.
    
    Specified by:
    
    add in interface RepositoryConnection
    
    Overrides:
    
    add in class AbstractRepositoryConnection
    
    Parameters:
    
    reader - a Reader from which RDF data can be read
    
    baseURI - the base URI against which any relative URIs in the data are resolved
    
    dataFormat - the serialization format of the data
    
    contexts - he contexts to add the data to. If one or more contexts are specified the data is added to these contexts, ignoring any context information in the data itself
    
    Throws:
    
    IOException - if an I/O error occurred while reading from the reader
    
    UnsupportedRDFormatException - if no parser is available for the specified RDF format
    
    RDFParseException - if an error occurred while parsing the RDF data
    
    RepositoryException - if the data could not be added to the repository, for example because the repository is not writable
  - add
```
public void add(Reader reader,
                String baseURI,
                RDFFormat dataFormat,
                org.json.JSONObject attributes,
                Resource... contexts)
         throws IOException,
                RDFParseException,
                RepositoryException
```
    Adds RDF data from a Reader to the repository, optionally to one or more named contexts. Note: using a Reader to upload byte-based data means that you have to be careful not to destroy the data's character encoding by enforcing a default character encoding upon the bytes. If possible, adding such data using an InputStream is to be preferred.
    
    Parameters:
    
    reader - a Reader from which RDF data can be read
    
    baseURI - the base URI against which any relative URIs in the data are resolved
    
    dataFormat - the serialization format of the data
    
    attributes - a JSONObject of attribute bindings that will be added to each statement imported from `reader'. For RDFFormats that support the specification of attributes (like NQX) these attributes will be applied to statements that do not already specify attributes
    
    contexts - the contexts to add the data to. If one or more contexts are specified the data is added to these contexts, ignoring any context information in the data itself
    
    Throws:
    
    IOException - if an I/O error occurred while reading from the reader
    
    UnsupportedRDFormatException - if no parser is available for the specified RDF format
    
    RDFParseException - if an error occurred while parsing the RDF data
    
    RepositoryException - if the data could not be added to the repository, for example because the repository is not writable
  - add
```
public void add(Resource subject,
                IRI predicate,
                Value object,
                Resource... contexts)
         throws RepositoryException
```
    Adds a statement with the specified subject, predicate and object to this repository, optionally to one or more named contexts.
    
    Specified by:
    
    add in interface RepositoryConnection
    
    Overrides:
    
    add in class AbstractRepositoryConnection
    
    Parameters:
    
    subject - the statement's subject
    
    predicate - the statement's predicate
    
    object - the statement's object
    
    contexts - the contexts to add the data to. Note that this parameter is a vararg and as such is optional. If the data contains no context, it is added to the default context. If one or more contexts are specified the data is added to these contexts, ignoring any context information in the data itself
    
    Throws:
    
    RepositoryException - if the data could not be added to the repository, for example because the repository is not writable
  - add
```
public void add(Resource subject,
                IRI predicate,
                Value object,
                org.json.JSONObject attributes,
                Resource... contexts)
         throws RepositoryException
```
    Throws:
    
    RepositoryException
  - remove
```
public void remove(Resource subject,
                   IRI predicate,
                   Value object,
                   Resource... contexts)
            throws RepositoryException
```
    Removes the statement(s) with the specified subject, predicate and object from the repository, optionally restricted to the specified contexts.
    
    Specified by:
    
    remove in interface RepositoryConnection
    
    Overrides:
    
    remove in class AbstractRepositoryConnection
    
    Parameters:
    
    subject - the statement's subject, or null for a wildcard
    
    predicate - the statement's predicate, or null for a wildcard
    
    object - the statement's object, or null for a wildcard
    
    contexts - the context(s) to remove the data from. Note that this parameter is a vararg and as such is optional. If no contexts are supplied the method operates on the entire repository
    
    Throws:
    
    RepositoryException - if the statement(s) could not be removed from the repository, for example because the repository is not writable
  - remove
```
public void remove(Statement st,
                   Resource... contexts)
            throws RepositoryException
```
    Specified by:
    
    remove in interface RepositoryConnection
    
    Overrides:
    
    remove in class AbstractRepositoryConnection
    
    Throws:
    
    RepositoryException
  - add
```
public void add(Statement st,
                Resource... contexts)
         throws RepositoryException
```
    Specified by:
    
    add in interface RepositoryConnection
    
    Overrides:
    
    add in class AbstractRepositoryConnection
    
    Throws:
    
    RepositoryException
  - add
```
public void add(Statement st,
                org.json.JSONObject attributes,
                Resource... contexts)
         throws RepositoryException
```
    Throws:
    
    RepositoryException
  - remove
```
public void remove(Iterable<? extends Statement> statements,
                   Resource... contexts)
            throws RepositoryException
```
    Specified by:
    
    remove in interface RepositoryConnection
    
    Overrides:
    
    remove in class AbstractRepositoryConnection
    
    Throws:
    
    RepositoryException
  - remove
```
public <E extends Exception> void remove(Iteration<? extends Statement,E> statements,
                                         Resource... contexts)
                                  throws RepositoryException,
                                         E extends Exception
```
    Specified by:
    
    remove in interface RepositoryConnection
    
    Overrides:
    
    remove in class AbstractRepositoryConnection
    
    Throws:
    
    RepositoryException
    
    E extends Exception
  - isAutoCommit
```
public boolean isAutoCommit()
                     throws RepositoryException
```
    Deprecated. since release 2.7.0. Use isActive() instead.
    
    Specified by:
    
    isAutoCommit in interface RepositoryConnection
    
    Overrides:
    
    isAutoCommit in class AbstractRepositoryConnection
    
    Throws:
    
    RepositoryException
    
    See Also:
    
    setAutoCommit(boolean)
  - setAutoCommit
```
public void setAutoCommit(boolean autoCommit)
                   throws RepositoryException
```
    Deprecated. As of release 2.7.0, use begin() instead.
    
    Setting autoCommit to false creates a dedicated server session which supports ACID transactions. Setting to true will create a dedicated server session.
    See session overview and POST session for more details.
    Starting a session causes http requests to use a new port, which may cause an exception if the client can not access it. See Session Port Setup.
    
    Specified by:
    
    setAutoCommit in interface RepositoryConnection
    
    Overrides:
    
    setAutoCommit in class AbstractRepositoryConnection
    
    Throws:
    
    RepositoryException
  - getXAResource
```
public XAResource getXAResource()
```
    Returns:
    
    an XAResource suitable for passing to a transaction manager to allow this connection to participate in an XA/2PC distributed transaction.
  - prepareCommit
```
public void prepareCommit(Xid xid)
```
    Asks the server to prepare a commit for later finalization/rollback.
    
    Parameters:
    
    xid - The transaction id to assign to the prepared commit
  - commit
```
public void commit()
            throws RepositoryException
```
    Commit the current transaction. See session overview and POST commit for more details.
    
    Specified by:
    
    commit in interface RepositoryConnection
    
    Throws:
    
    RepositoryException
  - commit
```
public void commit(Xid xid)
```
    Finalize a previously prepared two phase commit (2PC).
    
    Parameters:
    
    xid - The XID of the prepared transaction to be finalized
  - commit
```
public void commit(TransactionSettings transactionSettings)
            throws RepositoryException
```
    Commit the current transaction.
    See session overview and POST commit for more details.
    
    Parameters:
    
    transactionSettings - Distributed transaction settings to be used by this commit.
    
    Throws:
    
    RepositoryException
  - rollback
```
public void rollback()
              throws RepositoryException
```
    Roll back the current transaction (discard all changes made since last commit). See session overview and POST rollback for more details.
    
    Specified by:
    
    rollback in interface RepositoryConnection
    
    Throws:
    
    RepositoryException
  - rollback
```
public void rollback(Xid xid)
```
    Aborts a previously prepared commit.
    
    Parameters:
    
    xid - The transaction id of the prepared commit to abort.
  - getPreparedTransactions
```
public Xid[] getPreparedTransactions()
                              throws org.apache.commons.codec.DecoderException
```
    Returns:
    
    an array of Xids of commits that have been prepared on the server.
    
    Throws:
    
    org.apache.commons.codec.DecoderException - if the response from the server is invalid.
  - isStreamResults
```
public boolean isStreamResults()
```
    If true, automatically use AGStreamTupleQuery. Default is false.
    
    Returns:
    
    boolean the value of the streamResults parameter
    
    See Also:
    
    setStreamResults(boolean)
  - setStreamResults
```
public void setStreamResults(boolean streamResults)
```
    Set to true to automatically use AGStreamTupleQuery for prepareTupleQuery(QueryLanguage, String, String).
    
    Parameters:
    
    streamResults - new setting for the streamResults parameter
    
    See Also:
    
    isStreamResults()
  - clearNamespaces
```
public void clearNamespaces()
                     throws RepositoryException
```
    Specified by:
    
    clearNamespaces in interface RepositoryConnection
    
    Throws:
    
    RepositoryException
  - close
```
public void close()
           throws RepositoryException
```
    Closes the session if there is one started. See session overview and POST close for more details.
    
    Specified by:
    
    close in interface AutoCloseable
    
    Specified by:
    
    close in interface RepositoryConnection
    
    Overrides:
    
    close in class AbstractRepositoryConnection
    
    Throws:
    
    RepositoryException
  - exportStatements
```
public void exportStatements(Resource subj,
                             IRI pred,
                             Value obj,
                             boolean includeInferred,
                             RDFHandler handler,
                             Resource... contexts)
                      throws RDFHandlerException,
                             RepositoryException
```
    Specified by:
    
    exportStatements in interface RepositoryConnection
    
    Throws:
    
    RDFHandlerException
    
    RepositoryException
  - exportStatements
```
public void exportStatements(RDFHandler handler,
                             String... ids)
                      throws RDFHandlerException,
                             RepositoryException
```
    Throws:
    
    RDFHandlerException
    
    RepositoryException
  - getContextIDs
```
public RepositoryResult<Resource> getContextIDs()
                                         throws RepositoryException
```
    Specified by:
    
    getContextIDs in interface RepositoryConnection
    
    Throws:
    
    RepositoryException
  - createRepositoryResult
```
public <E> RepositoryResult<E> createRepositoryResult(Iterable<? extends E> elements)
```
    Creates a RepositoryResult for the supplied element set.
    
    Type Parameters:
    
    E - the class of elements in the set
    
    Parameters:
    
    elements - the set of elements
    
    Returns:
    
    RepositoryResult the set of elements as a RepositoryResult
  - getNamespace
```
public String getNamespace(String prefix)
                    throws RepositoryException
```
    Specified by:
    
    getNamespace in interface RepositoryConnection
    
    Throws:
    
    RepositoryException
  - getNamespaces
```
public RepositoryResult<Namespace> getNamespaces()
                                          throws RepositoryException
```
    Specified by:
    
    getNamespaces in interface RepositoryConnection
    
    Throws:
    
    RepositoryException
  - getStatements
```
public RepositoryResult<Statement> getStatements(Resource subj,
                                                 IRI pred,
                                                 Value obj,
                                                 boolean includeInferred,
                                                 Resource... contexts)
                                          throws RepositoryException
```
    Specified by:
    
    getStatements in interface RepositoryConnection
    
    Throws:
    
    RepositoryException
  - downloadStatements
```
public void downloadStatements(File file,
                               Resource subj,
                               IRI pred,
                               Value obj,
                               boolean includeInferred,
                               Resource... contexts)
                        throws AGHttpException
```
    Downloads statements matching given pattern to a file.
    The output format is determined by the server.
    
    Parameters:
    
    file - Output path.
    
    subj - Subject filter.
    
    pred - Predicate filter.
    
    obj - Object filter.
    
    includeInferred - If true, inferred triples will be included in the result.
    
    contexts - Optional list of graphs to export.
    
    Throws:
    
    AGHttpException - .
  - downloadStatements
```
public void downloadStatements(String file,
                               Resource subj,
                               IRI pred,
                               Value obj,
                               boolean includeInferred,
                               Resource... contexts)
                        throws AGHttpException
```
    Downloads statements matching given pattern to a file.
    The output format is determined by the server.
    
    Parameters:
    
    file - Output path.
    
    subj - Subject filter.
    
    pred - Predicate filter.
    
    obj - Object filter.
    
    includeInferred - If true, inferred triples will be included in the result.
    
    contexts - Optional list of graphs to export.
    
    Throws:
    
    AGHttpException - .
  - downloadStatements
```
public void downloadStatements(File file,
                               RDFFormat format,
                               Resource subj,
                               IRI pred,
                               Value obj,
                               boolean includeInferred,
                               Resource... contexts)
                        throws AGHttpException
```
    Downloads statements matching given pattern to a file.
    
    Parameters:
    
    file - Output path.
    
    format - Format to export the data in.
    
    subj - Subject filter.
    
    pred - Predicate filter.
    
    obj - Object filter.
    
    includeInferred - If true, inferred triples will be included in the result.
    
    contexts - Optional list of graphs to export.
    
    Throws:
    
    AGHttpException - .
  - downloadStatements
```
public void downloadStatements(String file,
                               RDFFormat format,
                               Resource subj,
                               IRI pred,
                               Value obj,
                               boolean includeInferred,
                               Resource... contexts)
                        throws AGHttpException
```
    Downloads statements matching given pattern to a file.
    
    Parameters:
    
    file - Output path.
    
    format - Format to export the data in.
    
    subj - Subject filter.
    
    pred - Predicate filter.
    
    obj - Object filter.
    
    includeInferred - If true, inferred triples will be included in the result.
    
    contexts - Optional list of graphs to export.
    
    Throws:
    
    AGHttpException - .
  - downloadStatements
```
public void downloadStatements(File file,
                               String mimeType,
                               Resource subj,
                               IRI pred,
                               Value obj,
                               boolean includeInferred,
                               Resource... contexts)
                        throws AGHttpException
```
    Downloads statements matching given pattern to a file.
    
    Parameters:
    
    file - Output path.
    
    mimeType - MIME type that will be requested from the server (output format).
    
    subj - Subject filter.
    
    pred - Predicate filter.
    
    obj - Object filter.
    
    includeInferred - If true, inferred triples will be included in the result.
    
    contexts - Optional list of graphs to export.
    
    Throws:
    
    AGHttpException - .
  - downloadStatements
```
public void downloadStatements(String file,
                               String mimeType,
                               Resource subj,
                               IRI pred,
                               Value obj,
                               boolean includeInferred,
                               Resource... contexts)
                        throws AGHttpException
```
    Downloads statements matching given pattern to a file.
    
    Parameters:
    
    file - Output path.
    
    mimeType - MIME type that will be requested from the server (output format).
    
    subj - Subject filter.
    
    pred - Predicate filter.
    
    obj - Object filter.
    
    includeInferred - If true, inferred triples will be included in the result.
    
    contexts - Optional list of graphs to export.
    
    Throws:
    
    AGHttpException - .
  - streamStatements
```
public InputStream streamStatements(Resource subj,
                                    IRI pred,
                                    Value obj,
                                    boolean includeInferred,
                                    Resource... contexts)
                             throws AGHttpException
```
    Returns statements matching given pattern as an InputStream.
    The output format will be chosen by the server.
    Note that it is important to close the returned stream, to avoid resource leaks.
    
    Parameters:
    
    subj - Subject filter.
    
    pred - Predicate filter.
    
    obj - Object filter.
    
    includeInferred - If true, inferred triples will be included in the result.
    
    contexts - Optional list of graphs to export.
    
    Returns:
    
    An input stream containing response data. The caller MUST close this stream to release connection resources.
    
    Throws:
    
    AGHttpException - .
  - streamStatements
```
public InputStream streamStatements(String mimeType,
                                    Resource subj,
                                    IRI pred,
                                    Value obj,
                                    boolean includeInferred,
                                    Resource... contexts)
                             throws AGHttpException
```
    Returns statements matching given pattern as an InputStream.
    Note that it is important to close the returned stream, to avoid resource leaks.
    
    Parameters:
    
    mimeType - MIME type that will be requested from the server (output format).
    
    subj - Subject filter.
    
    pred - Predicate filter.
    
    obj - Object filter.
    
    includeInferred - If true, inferred triples will be included in the result.
    
    contexts - Optional list of graphs to export.
    
    Returns:
    
    An input stream containing response data. The caller MUST close this stream to release connection resources.
    
    Throws:
    
    AGHttpException - .
  - streamStatements
```
public InputStream streamStatements(RDFFormat format,
                                    Resource subj,
                                    IRI pred,
                                    Value obj,
                                    boolean includeInferred,
                                    Resource... contexts)
                             throws AGHttpException
```
    Returns statements matching given pattern as an InputStream.
    Note that it is important to close the returned stream, to avoid resource leaks.
    
    Parameters:
    
    format - Format to export the data in.
    
    subj - Subject filter.
    
    pred - Predicate filter.
    
    obj - Object filter.
    
    includeInferred - If true, inferred triples will be included in the result.
    
    contexts - Optional list of graphs to export.
    
    Returns:
    
    An input stream containing response data. The caller MUST close this stream to release connection resources.
    
    Throws:
    
    AGHttpException - .
  - getStatements
```
public RepositoryResult<Statement> getStatements(String... ids)
                                          throws RepositoryException
```
    Returns statements having the specified ids.
    This api is subject to change. There is currently no natural way to obtain a statement's triple id from the java client; when that is possible, this api may change.
    
    Parameters:
    
    ids - Strings representing statement ids
    
    Returns:
    
    the statements having the specified ids. The result object is a RepositoryResult object, a lazy Iterator-like object containing Statements and optionally throwing a RepositoryException when an error when a problem occurs during retrieval
    
    Throws:
    
    RepositoryException - if there is an error with this request
  - downloadStatements
```
public void downloadStatements(File file,
                               RDFFormat format,
                               String ids)
                        throws AGHttpException
```
    Downloads statements with given ids to a file.
    
    Parameters:
    
    file - Output path.
    
    format - Format to export the data in.
    
    ids - Strings representing statement ids
    
    Throws:
    
    AGHttpException - .
  - downloadStatements
```
public void downloadStatements(String file,
                               RDFFormat format,
                               String ids)
                        throws AGHttpException
```
    Downloads statements with given ids to a file.
    
    Parameters:
    
    file - Output path.
    
    format - Format to export the data in.
    
    ids - Strings representing statement ids
    
    Throws:
    
    AGHttpException - .
  - downloadStatements
```
public void downloadStatements(File file,
                               String mimeType,
                               String ids)
                        throws AGHttpException
```
    Downloads statements with given ids to a file.
    
    Parameters:
    
    file - Output path.
    
    mimeType - MIME type to be requested from the server. Use "*/*" to let the server choose the output format.
    
    ids - Strings representing statement ids
    
    Throws:
    
    AGHttpException - .
  - downloadStatements
```
public void downloadStatements(String file,
                               String mimeType,
                               String ids)
                        throws AGHttpException
```
    Downloads statements with given ids to a file.
    
    Parameters:
    
    file - Output path.
    
    mimeType - MIME type to be requested from the server. Use "*/*" to let the server choose the output format.
    
    ids - Strings representing statement ids
    
    Throws:
    
    AGHttpException - .
  - streamStatements
```
public InputStream streamStatements(RDFFormat format,
                                    String... ids)
                             throws AGHttpException
```
    Returns statements with given ids as an InputStream.
    Note that it is important to close the returned stream, to avoid resource leaks.
    
    Parameters:
    
    format - Format to export the data in.
    
    ids - Strings representing statement ids
    
    Returns:
    
    An input stream containing response data. The caller MUST close this stream to release connection resources.
    
    Throws:
    
    AGHttpException - .
  - streamStatements
```
public InputStream streamStatements(String mimeType,
                                    String... ids)
                             throws AGHttpException
```
    Returns statements with given ids as an InputStream.
    Note that it is important to close the returned stream, to avoid resource leaks.
    
    Parameters:
    
    mimeType - MIME type to be requested from the server. Use "*/*" to let the server choose the output format.
    
    ids - Strings representing statement ids
    
    Returns:
    
    An input stream containing response data. The caller MUST close this stream to release connection resources.
    
    Throws:
    
    AGHttpException - .
  - prepareQuery
```
public AGQuery prepareQuery(QueryLanguage ql,
                            String queryString,
                            String baseURI)
```
    Prepares a AGQuery for evaluation on this repository. Note that the preferred way of preparing queries is to use the more specific prepareTupleQuery(QueryLanguage, String, String), prepareBooleanQuery(QueryLanguage, String, String), or prepareGraphQuery(QueryLanguage, String, String) methods instead.
    
    Specified by:
    
    prepareQuery in interface RepositoryConnection
    
    Throws:
    
    UnsupportedOperationException - if the method is not supported for the supplied query language
    
    IllegalArgumentException - if the query type (Tuple, Graph, Boolean) cannot be determined
  - prepareTupleQuery
```
public AGTupleQuery prepareTupleQuery(QueryLanguage ql,
                                      String queryString)
```
    Specified by:
    
    prepareTupleQuery in interface RepositoryConnection
    
    Overrides:
    
    prepareTupleQuery in class AbstractRepositoryConnection
  - prepareTupleQuery
```
public AGTupleQuery prepareTupleQuery(QueryLanguage ql,
                                      String queryString,
                                      String baseURI)
```
    Specified by:
    
    prepareTupleQuery in interface RepositoryConnection
  - prepareGraphQuery
```
public AGGraphQuery prepareGraphQuery(QueryLanguage ql,
                                      String queryString)
```
    Specified by:
    
    prepareGraphQuery in interface RepositoryConnection
    
    Overrides:
    
    prepareGraphQuery in class AbstractRepositoryConnection
  - prepareGraphQuery
```
public AGGraphQuery prepareGraphQuery(QueryLanguage ql,
                                      String queryString,
                                      String baseURI)
```
    Specified by:
    
    prepareGraphQuery in interface RepositoryConnection
  - prepareBooleanQuery
```
public AGBooleanQuery prepareBooleanQuery(QueryLanguage ql,
                                          String queryString)
```
    Specified by:
    
    prepareBooleanQuery in interface RepositoryConnection
    
    Overrides:
    
    prepareBooleanQuery in class AbstractRepositoryConnection
  - prepareBooleanQuery
```
public AGBooleanQuery prepareBooleanQuery(QueryLanguage ql,
                                          String queryString,
                                          String baseURI)
```
    Specified by:
    
    prepareBooleanQuery in interface RepositoryConnection
  - prepareUpdate
```
public AGUpdate prepareUpdate(QueryLanguage ql,
                              String queryString,
                              String baseURI)
```
    Specified by:
    
    prepareUpdate in interface RepositoryConnection
  - prepareUpdate
```
public AGUpdate prepareUpdate(QueryLanguage ql,
                              String queryString)
```
    Specified by:
    
    prepareUpdate in interface RepositoryConnection
    
    Overrides:
    
    prepareUpdate in class AbstractRepositoryConnection
  - removeNamespace
```
public void removeNamespace(String prefix)
                     throws RepositoryException
```
    Specified by:
    
    removeNamespace in interface RepositoryConnection
    
    Throws:
    
    RepositoryException
  - setNamespace
```
public void setNamespace(String prefix,
                         String name)
                  throws RepositoryException
```
    Specified by:
    
    setNamespace in interface RepositoryConnection
    
    Throws:
    
    RepositoryException
  - size
```
public long size(Resource... contexts)
          throws RepositoryException
```
    Specified by:
    
    size in interface RepositoryConnection
    
    Throws:
    
    RepositoryException
  - createFreetextIndex
```
public void createFreetextIndex(String indexName,
                                AGFreetextIndexConfig config)
                         throws RepositoryException
```
    Creates a freetext index with the given name and configuration.
    See documentation for freetext index parameters.
    
    Parameters:
    
    indexName - the index name to create
    
    config - the index configuration
    
    Throws:
    
    RepositoryException - if there is an error with this request
    
    See Also:
    
    AGFreetextIndexConfig.newInstance()
  - deleteFreetextIndex
```
public void deleteFreetextIndex(String indexName)
                         throws RepositoryException
```
    Deletes the freetext index of the specified name.
    
    Parameters:
    
    indexName - the index to be deleted
    
    Throws:
    
    RepositoryException - if there is an error with this request
    
    See Also:
    
    createFreetextIndex(String, AGFreetextIndexConfig)
  - createFreetextIndex
```
public void createFreetextIndex(String name,
                                IRI[] predicates)
                         throws RepositoryException
```
    Deprecated.
    
    Registers a predicate for free text indexing. Once registered, the objects of data added to the repository having this predicate will be text indexed and searchable.
    
    Parameters:
    
    name - of the index to create
    
    predicates - the predicates this index will operate on
    
    Throws:
    
    RepositoryException - if there is an error with this request
    
    See Also:
    
    createFreetextIndex(String, AGFreetextIndexConfig)
  - getFreetextPredicates
```
public String[] getFreetextPredicates(String index)
                               throws RepositoryException
```
    Deprecated.
    
    Gets the predicates that have been registered for text indexing.
    
    Parameters:
    
    index - name of the index to lookup
    
    Returns:
    
    String[] the predicates this index operates on
    
    Throws:
    
    RepositoryException - if there is an error during the request
    
    See Also:
    
    getFreetextIndexConfig(String)
  - getFreetextIndexConfig
```
public AGFreetextIndexConfig getFreetextIndexConfig(String indexName)
                                             throws RepositoryException,
                                                    org.json.JSONException
```
    Gets the configuration of the specified free text index.
    
    Parameters:
    
    indexName - name of the index
    
    Returns:
    
    AGFreetextIndexConfig the configuration of the specified index
    
    Throws:
    
    RepositoryException - if there is an error during the request
    
    org.json.JSONException - if there is a problem parsing the response to JSON
  - getFreetextIndices
```
public String[] getFreetextIndices()
                            throws RepositoryException
```
    Deprecated.
    
    Gets freetext indexes that have been created
    
    Returns:
    
    String[] a list of freetext index names
    
    Throws:
    
    RepositoryException - if there is an error during the request
    
    See Also:
    
    listFreetextIndices()
  - listFreetextIndices
```
public List<String> listFreetextIndices()
                                 throws RepositoryException
```
    Lists the freetext indices that have been defined for this repository.
    
    Returns:
    
    List a list of freetext index names
    
    Throws:
    
    RepositoryException - if there is an error during the request
  - registerPredicateMapping
```
public void registerPredicateMapping(IRI predicate,
                                     IRI primtype)
                              throws RepositoryException
```
    Registers a predicate mapping from the predicate to a primitive datatype. This can be useful in speeding up query performance and enabling range queries over datatypes.
    Once registered, the objects of any data added via this connection that have this predicate will be mapped to the primitive datatype.
    
    For example, registering that predicate <http://example.org/age> is mapped to XMLSchema.INT and adding the triple: <http://example.org/Fred> <http://example.org/age> "24" will result in the object being treated as "24"^^xsd:int.
    
    See mapping overview and POST predicate mapping.
    
    Parameters:
    
    predicate - the predicate URI
    
    primtype - the datatype URI
    
    Throws:
    
    RepositoryException - if there is an error during the request
    
    See Also:
    
    getPredicateMappings()
  - deletePredicateMapping
```
public void deletePredicateMapping(IRI predicate)
                            throws RepositoryException
```
    Deletes any predicate mapping associated with the given predicate.
    See mapping overview and DELETE predicate mapping.
    
    Parameters:
    
    predicate - the predicate mapping to delete
    
    Throws:
    
    RepositoryException - if there is an error during the request
    
    See Also:
    
    getPredicateMappings()
  - getPredicateMappings
```
public String[] getPredicateMappings()
                              throws RepositoryException
```
    Gets the predicate mappings defined for this connection.
    See mapping overview and GET predicate mapping and the Lisp reference for the predicate-mapping function.
    
    Returns:
    
    String[] the predicate mappings that have been registered
    
    Throws:
    
    RepositoryException - if there is an error during the request
    
    See Also:
    
    registerPredicateMapping(IRI, IRI), deletePredicateMapping(IRI), getDatatypeMappings()
  - registerDatatypeMapping
```
public void registerDatatypeMapping(IRI datatype,
                                    IRI primtype)
                             throws RepositoryException
```
    Registers a datatype mapping from the datatype to a primitive datatype. This can be useful in speeding up query performance and enabling range queries over user datatypes.
    Once registered, the objects of any data added via this connection that have this datatype will be mapped to the primitive datatype.
    
    For example, registering that datatype <http://example.org/usertype> is mapped to XMLSchema.INT and adding the triple: <http://example.org/Fred> <http://example.org/age> "24"^^<http://example.org/usertype> will result in the object being treated as "24"^^xsd:int.
    
    See mapping overview and POST type mapping.
    
    Parameters:
    
    datatype - the name of the datatype mapping to register
    
    primtype - the primitive type of the new mapping
    
    Throws:
    
    RepositoryException - if there is an error during the request
    
    See Also:
    
    getDatatypeMappings()
  - deleteDatatypeMapping
```
public void deleteDatatypeMapping(IRI datatype)
                           throws RepositoryException
```
    Deletes any datatype mapping associated with the given datatype.
    See mapping overview and DELETE type mapping.
    
    Parameters:
    
    datatype - the datatype mapping to delete
    
    Throws:
    
    RepositoryException - if there is an error during the request
    
    See Also:
    
    getDatatypeMappings(), clearMappings()
  - getDatatypeMappings
```
public String[] getDatatypeMappings()
                             throws RepositoryException
```
    Gets the datatype mappings defined for this connection.
    See mapping overview and GET type mapping and the Lisp reference for the datatype-mapping function.
    
    Returns:
    
    String[] the datatype mappings that have been registered
    
    Throws:
    
    RepositoryException - if there is an error during the request
    
    See Also:
    
    deleteDatatypeMapping(IRI), clearMappings(), registerDatatypeMapping(IRI, IRI), getPredicateMappings()
  - clearMappings
```
public void clearMappings()
                   throws RepositoryException
```
    Deletes all user-defined predicate and datatype mappings for this connection, and reestablishes the automatic mappings for primitive datatypes.
    This is equivalent to clearMappings(false).
    See mapping overview and DELETE all mapping for more details.
    
    Throws:
    
    RepositoryException - if there is an error during the request
    
    See Also:
    
    getDatatypeMappings(), getPredicateMappings()
  - clearMappings
```
public void clearMappings(boolean includeAutoEncodedPrimitiveTypes)
                   throws RepositoryException
```
    Deletes all predicate and user-defined datatype mappings for this connection.
    When includeAutoEncodedPrimitiveTypes is true, also deletes the automatic mappings for primitive datatypes; this is rarely what you want to do, as it will cause range queries to perform much less efficiently than when encodings are used; this option can be useful for ensuring literal forms are preserved in the store (there can be precision loss when encoding some literals).
    See mapping overview and DELETE all mapping for more details.
    
    Parameters:
    
    includeAutoEncodedPrimitiveTypes - true if auto-encoded primitive types should be cleared
    
    Throws:
    
    RepositoryException - if there is an error during the request
    
    See Also:
    
    getDatatypeMappings(), getPredicateMappings()
  - clearAttributes
```
public void clearAttributes()
                     throws RepositoryException
```
    Deletes all attribute definitions from the repository.
    
    Throws:
    
    RepositoryException - if there is an error during the request
  - addRules
```
public void addRules(String rules)
              throws RepositoryException
```
    Adds Prolog rules to be used on this connection.
    See Prolog Lisp documentation and Prolog functor registration.
    Starts a session if one is not already started. See session overview for more details. Starting a session causes http requests to use a new port, which may cause an exception if the client can not access it. See Session Port Setup.
    
    Parameters:
    
    rules - a string of rule text
    
    Throws:
    
    RepositoryException - if there is an error during the request
    
    See Also:
    
    addRules(InputStream)
  - addRules
```
public void addRules(InputStream rulestream)
              throws RepositoryException
```
    Adds Prolog rules to be used on this connection.
    See Prolog Lisp documentation and Prolog functor registration.
    Starts a session if one is not already started. See session overview for more details. Starting a session causes http requests to use a new port, which may cause an exception if the client can not access it. See Session Port Setup.
    
    Parameters:
    
    rulestream - a stream of rule text
    
    Throws:
    
    RepositoryException - if there is an error during the request
    
    See Also:
    
    addRules(String)
  - evalInServer
```
public String evalInServer(String lispForm)
                    throws RepositoryException
```
    Evaluates a Lisp form on the server, and returns the result as a String.
    See HTTP POST eval.
    
    Parameters:
    
    lispForm - the Lisp form to evaluate
    
    Returns:
    
    String the result of the evaluation
    
    Throws:
    
    RepositoryException - if there is an error during the request
    
    See Also:
    
    evalInServer(String)
  - evalInServer
```
public String evalInServer(InputStream stream)
                    throws RepositoryException
```
    Evaluates a Lisp form on the server, and returns the result as a String.
    See HTTP POST eval.
    
    Parameters:
    
    stream - the Lisp form to evaluate
    
    Returns:
    
    the result in a String
    
    Throws:
    
    RepositoryException - if there is an error during the request
    
    See Also:
    
    evalInServer(String)
  - load
```
public void load(IRI source,
                 String baseURI,
                 RDFFormat dataFormat,
                 Resource... contexts)
          throws RepositoryException
```
    Instructs the server to fetch and load data from the specified URI.
    
    Parameters:
    
    source - the URI to fetch and load
    
    baseURI - the base URI for the source document
    
    dataFormat - the RDF data format for the source document
    
    contexts - zero or more contexts into which data will be loaded
    
    Throws:
    
    RepositoryException - if there is an error during the request
  - load
```
public void load(IRI source,
                 String baseURI,
                 RDFFormat dataFormat,
                 org.json.JSONObject attributes,
                 Resource... contexts)
          throws RepositoryException
```
    Instructs the server to fetch and load data from the specified URI.
    
    Parameters:
    
    source - the URI to fetch and load
    
    baseURI - the base URI for the source document
    
    dataFormat - the RDF data format for the source document
    
    attributes - a JSONObject of attribute bindings that will be added to each statement imported from `source'. For RDFFormats that support the specification of attributes (like NQX) these attributes will be applied to statements that do not already specify attributes
    
    contexts - zero or more contexts into which data will be loaded
    
    Throws:
    
    RepositoryException - if there is an error during the request
  - load
```
public void load(String absoluteServerPath,
                 String baseURI,
                 RDFFormat dataFormat,
                 Resource... contexts)
          throws RepositoryException
```
    Instructs the server to load data from the specified server-side path.
    
    Parameters:
    
    absoluteServerPath - the path to the server-side source file
    
    baseURI - the base URI for the source document
    
    dataFormat - the RDF data format for the source document
    
    contexts - zero or more contexts into which data will be loaded
    
    Throws:
    
    RepositoryException - if there is an error during the request
  - load
```
public void load(String absoluteServerPath,
                 String baseURI,
                 RDFFormat dataFormat,
                 org.json.JSONObject attributes,
                 Resource... contexts)
          throws RepositoryException
```
    Instructs the server to load data from the specified server-side path.
    
    Parameters:
    
    absoluteServerPath - the path to the server-side source file
    
    baseURI - the base URI for the source document
    
    dataFormat - the RDF data format for the source document
    
    attributes - a JSONObject of attribute bindings that will be added to each statement imported from `absoluteServerPath'. For RDFFormats that support the specification of attributes (like NQX) these attributes will be applied to statements that do not already specify attributes
    
    contexts - zero or more contexts into which data will be loaded
    
    Throws:
    
    RepositoryException - if there is an error during the request
  - ping
```
public void ping()
          throws RepositoryException
```
    Instructs the server to extend the life of this connection's dedicated session, if it is using one. Sessions that are idle for more than the session lifetime will be terminated by the server.
    Note that this method is called automatically before the timeout expires.
    
    See session overview and GET ping for more details.
    
    Throws:
    
    RepositoryException - if there is an error during the request
    
    See Also:
    
    setSessionLifetime(int)
  - getGeoTypes
```
public String[] getGeoTypes()
                     throws RepositoryException
```
    Returns:
    
    String[] the geospatial types that have been registered
    
    Throws:
    
    RepositoryException - if there is an error during the request
  - registerCartesianType
```
public IRI registerCartesianType(float stripWidth,
                                 float xmin,
                                 float xmax,
                                 float ymin,
                                 float ymax)
                          throws RepositoryException
```
    Registers a cartesian geospatial subtype.
    
    Parameters:
    
    stripWidth - the strip width in some units
    
    xmin - the minimum x range
    
    ymin - the minimum y range
    
    xmax - the maximum x range
    
    ymax - the maximum y range
    
    Returns:
    
    URI the datatype encoding of this subtype
    
    Throws:
    
    RepositoryException - if there is an error during the request
  - registerSphericalType
```
public IRI registerSphericalType(float stripWidth,
                                 String unit,
                                 float latmin,
                                 float lonmin,
                                 float latmax,
                                 float lonmax)
                          throws RepositoryException
```
    Registers a spherical geospatial subtype.
    
    Parameters:
    
    stripWidth - the strip width in some units
    
    unit - the distance unit stripWidth is specified in
    
    latmin - the minimum latitude range
    
    lonmin - the minimum longitude range
    
    latmax - the maximum latitude range
    
    lonmax - the maximum longitude range
    
    Returns:
    
    URI the datatype encoding of this subtype
    
    Throws:
    
    RepositoryException - if there is an error during the request
  - registerSphericalType
```
public IRI registerSphericalType(float stripWidth,
                                 String unit)
                          throws RepositoryException
```
    Throws:
    
    RepositoryException
  - registerPolygon
```
public void registerPolygon(IRI polygon,
                            List<Literal> points)
                     throws RepositoryException
```
    Registers a polygon.
    
    Parameters:
    
    polygon - the name of this polygon
    
    points - a List of points describing the polygon
    
    Throws:
    
    RepositoryException - if there is an error during the request
  - getStatementsInBox
```
public RepositoryResult<Statement> getStatementsInBox(IRI type,
                                                      IRI predicate,
                                                      float xmin,
                                                      float xmax,
                                                      float ymin,
                                                      float ymax,
                                                      int limit,
                                                      boolean infer)
                                               throws RepositoryException
```
    Throws:
    
    RepositoryException
  - getStatementsInCircle
```
public RepositoryResult<Statement> getStatementsInCircle(IRI type,
                                                         IRI predicate,
                                                         float x,
                                                         float y,
                                                         float radius,
                                                         int limit,
                                                         boolean infer)
                                                  throws RepositoryException
```
    Throws:
    
    RepositoryException
  - getGeoHaversine
```
public RepositoryResult<Statement> getGeoHaversine(IRI type,
                                                   IRI predicate,
                                                   float lat,
                                                   float lon,
                                                   float radius,
                                                   String unit,
                                                   int limit,
                                                   boolean infer)
                                            throws RepositoryException
```
    Throws:
    
    RepositoryException
  - getStatementsInPolygon
```
public RepositoryResult<Statement> getStatementsInPolygon(IRI type,
                                                          IRI predicate,
                                                          IRI polygon,
                                                          int limit,
                                                          boolean infer)
                                                   throws RepositoryException
```
    Throws:
    
    RepositoryException
  - registerSNAGenerator
```
public void registerSNAGenerator(String generator,
                                 List<IRI> objectOfs,
                                 List<IRI> subjectOfs,
                                 List<IRI> undirecteds,
                                 String query)
                          throws RepositoryException
```
    See Social network analysis Lisp documentation and SNA generator registration.
    Starts a session if one is not already started. See session overview for more details. Starting a session causes http requests to use a new port, which may cause an exception if the client can not access it. See Session Port Setup.
    
    Parameters:
    
    generator - Generator name
    
    objectOfs - a list of predicates
    
    subjectOfs - a list of predicates
    
    undirecteds - a list of predicates
    
    query - a string representation of a select clause
    
    Throws:
    
    RepositoryException - if there is an error during the request
  - registerSNANeighborMatrix
```
public void registerSNANeighborMatrix(String matrix,
                                      String generator,
                                      List<IRI> group,
                                      int depth)
                               throws RepositoryException
```
    Throws:
    
    RepositoryException
  - listIndices
```
public List<String> listIndices()
                         throws RDF4JException
```
    Returns a list of actively managed indices for this repository.
    
    Returns:
    
    a list of actively managed indices for this repository
    
    Throws:
    
    RDF4JException - if there is an error during the request
  - listValidIndices
```
public List<String> listValidIndices()
                              throws RDF4JException
```
    Returns a list of all possible index types for this repository.
    
    Returns:
    
    a list of valid index types
    
    Throws:
    
    RDF4JException - if there is an error during the request
  - addIndex
```
public void addIndex(String type)
              throws RepositoryException
```
    Adds the given index to the list of actively managed indices. This will take affect on the next commit.
    
    Parameters:
    
    type - a valid index type
    
    Throws:
    
    RepositoryException - if there is an error during the request
    
    See Also:
    
    listValidIndices()
  - dropIndex
```
public void dropIndex(String type)
               throws RepositoryException
```
    Drops the given index from the list of actively managed indices. This will take affect on the next commit.
    
    Parameters:
    
    type - an actively managed index type
    
    Throws:
    
    RepositoryException - if there is an error during the request
    
    See Also:
    
    listValidIndices()
  - sendRDFTransaction
```
public void sendRDFTransaction(InputStream rdftransaction)
                        throws RepositoryException,
                               RDFParseException,
                               IOException
```
    Executes an application/x-rdftransaction.
    This method is useful for bundling add/remove operations into a single request and minimizing round trips to the server.
    Changes are committed iff the connection is in autoCommit mode. For increased throughput when sending multiple rdftransaction requests, consider using autoCommit=false and committing less frequently .
    
    Parameters:
    
    rdftransaction - a stream in application/x-rdftransaction format
    
    Throws:
    
    RepositoryException - if there is an error during the request
    
    RDFParseException - if malformed data is encountered
    
    IOException - on errors reading from the rdftransaction stream
  - sendRDFTransaction
```
public void sendRDFTransaction(InputStream rdftransaction,
                               org.json.JSONObject attributes)
                        throws RepositoryException,
                               RDFParseException,
                               IOException
```
    send an RDFTransaction, including attributes.
    
    Parameters:
    
    rdftransaction - a stream in application/x-rdftransaction format
    
    attributes - a JSONObject of attribute bindings that will be added to each triple imported from `rdftransaction'.
    
    Throws:
    
    RepositoryException - if there is an error during the request
    
    RDFParseException - if malformed data is encountered
    
    IOException - on errors reading from the rdftransaction stream
  - registerEncodableNamespace
```
public void registerEncodableNamespace(String namespace,
                                       String format)
                                throws RepositoryException
```
    Registers an encodable namespace having the specified format.
    Registering an encodable namespace enables a more efficient encoding of URIs in a namespace, and generation of unique URIs for that namespace, because its URIs are declared to conform to a specified format; the namespace is thereby bounded in size, and encodable.
    
    The namespace is any valid URIref, e.g.: http://franz.com/ns0
    
    The format is a string using a simplified regular expression syntax supporting character ranges and counts specifying the suffix portion of the URIs in the namespace, e.g: [a-z][0-9]-[a-f]{3}
    
    Generation of unique URIs AGValueFactory.generateURI(String) for the above namespace and format might yield an ID such as:
    http://franz.com/ns0@@a0-aaa
    
    Note: "@@" is used to concatenate the namespace and id suffix to facilitate efficient recognition/encoding during parsing.
    
    The format can be ambiguous (e.g., "[A-Z]{1,2}[B-C}{0,1}"). We will not check for ambiguity in this first version but can add this checking at a later time.
    
    If the format corresponds to a namespace that is not encodable (it may be malformed, or perhaps it's too large to encode), an exception is thrown.
    
    For more details, see Encoded IDs.
    
    Parameters:
    
    namespace - a valid namespace, a URI ref
    
    format - a valid format for an encodable namespace
    
    Throws:
    
    RepositoryException - if there is an error during the request
    
    See Also:
    
    registerEncodableNamespaces(Iterable), listEncodableNamespaces(), unregisterEncodableNamespace(String), AGValueFactory.generateURI(String), AGValueFactory.generateURIs(String, int)
  - registerEncodableNamespaces
```
public void registerEncodableNamespaces(Iterable<? extends AGFormattedNamespace> formattedNamespaces)
                                 throws RepositoryException
```
    Registers multiple formatted namespaces in a single request.
    
    Parameters:
    
    formattedNamespaces - an iterable collection of formatted namespaces
    
    Throws:
    
    RepositoryException - if there is an error during the request
    
    See Also:
    
    registerEncodableNamespace(String, String)
  - listEncodableNamespaces
```
public List<AGFormattedNamespace> listEncodableNamespaces()
                                                   throws RDF4JException
```
    Returns a list of the registered encodable namespaces.
    
    Returns:
    
    List a list of the registered encodable namespaces
    
    Throws:
    
    RDF4JException - if there is a problem parsing the request
    
    See Also:
    
    registerEncodableNamespace(String, String)
  - unregisterEncodableNamespace
```
public void unregisterEncodableNamespace(String namespace)
                                  throws RepositoryException
```
    Unregisters the specified encodable namespace.
    
    Parameters:
    
    namespace - the namespace to unregister
    
    Throws:
    
    RepositoryException - if there is an error during the request
    
    See Also:
    
    registerEncodableNamespace(String, String)
  - callStoredProc
```
public Object callStoredProc(String functionName,
                             String moduleName,
                             Object... args)
                      throws RepositoryException
```
    Deprecated. The stored proc feature and API are experimental, and subject to change in a future release.
    
    Invoke a stored procedure on the AllegroGraph server.
    The input arguments and the return value can be: String, Integer, null, byte[], or Object[] or List of these (can be nested).
    
    See also prepareHttpRepoClient().callStoredProc(functionName, moduleName, args)
    
    Parameters:
    
    functionName - stored proc lisp function, for example "addTwo"
    
    moduleName - lisp FASL file name, for example "example.fasl"
    
    args - arguments to the stored proc
    
    Returns:
    
    return value of stored proc
    
    Throws:
    
    AGCustomStoredProcException - for errors from stored proc
    
    RepositoryException
    
    Since:
    
    v4.2
  - getSessionLifetime
```
public int getSessionLifetime()
```
    Returns the lifetime for a dedicated session spawned by this connection.
    See also: Session overview.
    
    Returns:
    
    the session lifetime, in seconds
    
    See Also:
    
    setSessionLifetime(int), ping()
  - setSessionLifetime
```
public void setSessionLifetime(int lifetimeInSeconds)
```
    Sets the 'lifetime' for a dedicated session spawned by this connection. Seconds a session can be idle before being collected. If unset, the lifetime defaults to the value of DefaultSessionTimeout. If set, the value must not be larger than MaximumSessionTimeout. See Session directives in Server Configuration and Control for more information.
    Also see session overview and POST session for more details.
    
    Parameters:
    
    lifetimeInSeconds - the session lifetime, in seconds
    
    See Also:
    
    getSessionLifetime(), ping()
  - setSessionLoadInitFile
```
public void setSessionLoadInitFile(boolean loadInitFile)
```
    Sets the 'loadInitFile' flag for a dedicated session spawned by this connection. This method does not create a session.
    See also: Session overview.
    
    Parameters:
    
    loadInitFile - boolean determining if the init file is loaded into this session
    
    See Also:
    
    addSessionLoadScript(String)
  - addSessionLoadScript
```
public void addSessionLoadScript(String scriptName)
```
    Adds a 'script' for a dedicated session spawned by this connection. This method does not create a session. May be called multiple times for different scripts. The script text must already be uploaded to the user.
    Scripts are server code that may be loaded during a session.
    
    See also: Session overview.
    
    Parameters:
    
    scriptName - name of the script to be loaded
    
    See Also:
    
    setSessionLoadInitFile(boolean)
  - getStoreID
```
public long getStoreID()
                throws RepositoryException
```
    Returns the store ID
    
    Returns:
    
    The store ID
    
    Throws:
    
    RepositoryException - if there is an error during the request
  - enableTripleCache
```
public void enableTripleCache(long size)
                       throws RepositoryException
```
    Enables the spogi cache in this repository.
    Takes a size argument to set the size of the cache.
    
    Parameters:
    
    size - the size of the cache, in triples
    
    Throws:
    
    RepositoryException - if there is an error during the request
  - getTripleCacheSize
```
public long getTripleCacheSize()
                        throws RepositoryException
```
    Returns the size of the spogi cache.
    
    Returns:
    
    the size of the spogi cache, in triples
    
    Throws:
    
    RepositoryException - if there is an error during the request
  - disableTripleCache
```
public void disableTripleCache()
                        throws RepositoryException
```
    Disables the spogi triple cache.
    
    Throws:
    
    RepositoryException - if there is an error during the request
  - getUploadCommitPeriod
```
public int getUploadCommitPeriod()
                          throws RepositoryException
```
    Gets the commit period used within large add/load operations.
    
    Returns:
    
    int the current upload commit period
    
    Throws:
    
    RepositoryException - if there is an error with this request
    
    See Also:
    
    AGHttpRepoClient.getUploadCommitPeriod()
  - setUploadCommitPeriod
```
public void setUploadCommitPeriod(int period)
                           throws RepositoryException
```
    Sets the commit period to use within large add/load operations.
    
    Parameters:
    
    period - commit after this many statements
    
    Throws:
    
    RepositoryException - if there is an error with this request
    
    See Also:
    
    AGHttpRepoClient.setUploadCommitPeriod(int)
  - optimizeIndices
```
public void optimizeIndices(Boolean wait,
                            int level)
                     throws RepositoryException
```
    Instruct the server to optimize the indices for this store.
    
    Parameters:
    
    wait - a boolean, false for request to return immediately
    
    level - determines the work to be done. See the index documentation for an explanation of the different levels
    
    Throws:
    
    RepositoryException - if there is an error with this request See the Index documentation for more details.
  - optimizeIndices
```
public void optimizeIndices(Boolean wait)
                     throws RepositoryException
```
    Throws:
    
    RepositoryException
  - getSpinFunction
```
public String getSpinFunction(String uri)
                       throws RDF4JException
```
    Parameters:
    
    uri - SPIN function identifier
    
    Returns:
    
    String the SPIN function query text
    
    Throws:
    
    RDF4JException - if there is an error with this request
    
    Since:
    
    v4.4
    
    See Also:
    
    putSpinFunction(AGSpinFunction), deleteSpinFunction(String), listSpinFunctions(), getSpinMagicProperty(String)
  - listSpinFunctions
```
public List<AGSpinFunction> listSpinFunctions()
                                       throws RDF4JException
```
    Returns:
    
    List currently defined SPIN functions
    
    Throws:
    
    RDF4JException - if there is an error with this request
    
    Since:
    
    v4.4
    
    See Also:
    
    getSpinFunction(String), putSpinFunction(AGSpinFunction), deleteSpinFunction(String), listSpinMagicProperties()
  - putSpinFunction
```
public void putSpinFunction(AGSpinFunction fn)
                     throws RDF4JException
```
    Parameters:
    
    fn - the SPIN function to add
    
    Throws:
    
    RDF4JException - if there is an error with this request
    
    Since:
    
    v4.4
    
    See Also:
    
    getSpinFunction(String), deleteSpinFunction(String), putSpinMagicProperty(AGSpinMagicProperty)
  - deleteSpinFunction
```
public void deleteSpinFunction(String uri)
                        throws RDF4JException
```
    Parameters:
    
    uri - SPIN function identifier
    
    Throws:
    
    RDF4JException - if there is an error with this request
    
    Since:
    
    v4.4
    
    See Also:
    
    putSpinFunction(AGSpinFunction), getSpinFunction(String)
  - getSpinMagicProperty
```
public String getSpinMagicProperty(String uri)
                            throws RDF4JException
```
    Parameters:
    
    uri - SPIN magic property identifier
    
    Returns:
    
    String describing the SPIN magic property
    
    Throws:
    
    RDF4JException - if there is an error with this request
    
    Since:
    
    v4.4
    
    See Also:
    
    putSpinMagicProperty(AGSpinMagicProperty), deleteSpinMagicProperty(String)
  - listSpinMagicProperties
```
public List<AGSpinMagicProperty> listSpinMagicProperties()
                                                  throws RDF4JException
```
    Returns:
    
    List all defined SPIN magic properties
    
    Throws:
    
    RDF4JException - if there is an error with this request
    
    Since:
    
    v4.4
    
    See Also:
    
    getSpinMagicProperty(String), putSpinMagicProperty(AGSpinMagicProperty), deleteSpinMagicProperty(String), listSpinFunctions()
  - deleteSpinMagicProperty
```
public void deleteSpinMagicProperty(String uri)
                             throws RDF4JException
```
    Parameters:
    
    uri - SPIN magic property identifier
    
    Throws:
    
    RDF4JException - if there is an error with this request
    
    Since:
    
    v4.4
    
    See Also:
    
    putSpinMagicProperty(AGSpinMagicProperty), getSpinMagicProperty(String)
  - putSpinMagicProperty
```
public void putSpinMagicProperty(AGSpinMagicProperty fn)
                          throws RDF4JException
```
    Parameters:
    
    fn - the SPIN magic property to add
    
    Throws:
    
    RDF4JException - if there is an error with this request
    
    Since:
    
    v4.4
    
    See Also:
    
    getSpinMagicProperty(String), deleteSpinMagicProperty(String), putSpinFunction(AGSpinFunction)
  - deleteDuplicates
```
public void deleteDuplicates(String comparisonMode)
                      throws RepositoryException
```
    Deletes all duplicates from the store.
    The comparisonMode determines what will be deemed a "duplicate".
    If comparisonMode is "spog", quad parts (s,p,o,g) will all be compared when looking for duplicates.
    If comparisonMode is "spo", only the (s,p,o) parts will be compared; the same triple in different graphs will thus be deemed duplicates.
    See also the protocol documentation for deleting duplicates
    
    Parameters:
    
    comparisonMode - method to determine what is a duplicate
    
    Throws:
    
    AGHttpException - if there is an error with this request
    
    RepositoryException
  - getDuplicateStatements
```
public RepositoryResult<Statement> getDuplicateStatements(String comparisonMode)
                                                   throws RepositoryException
```
    Returns all duplicates from the store.
    The comparisonMode determines what will be deemed a "duplicate".
    If comparisonMode is "spog", quad parts (s,p,o,g) will all be compared when looking for duplicates.
    If comparisonMode is "spo", only the (s,p,o) parts will be compared; the same triple in different graphs will thus be deemed duplicates.
    See also the protocol documentation for deleting duplicates
    
    Parameters:
    
    comparisonMode - method to determine what is a duplicate
    
    Returns:
    
    RepositoryResult the duplicates that exist in the store
    
    Throws:
    
    AGHttpException - if there is an error with this request
    
    RepositoryException
  - materialize
```
public long materialize(AGMaterializer materializer)
                 throws RepositoryException
```
    Materializes inferred statements (generates and adds them to the store).
    The materializer's configuration determines how statements are materialized.
    
    Parameters:
    
    materializer - the materializer to use
    
    Returns:
    
    long the number of statements added
    
    Throws:
    
    AGHttpException - if there is an error with this request
    
    RepositoryException
    
    See Also:
    
    AGMaterializer.newInstance()
  - deleteMaterialized
```
public long deleteMaterialized()
                        throws RepositoryException
```
    Deletes materialized statements from the default graph.
    
    Returns:
    
    the number of statements deleted
    
    Throws:
    
    AGHttpException - if there is an error with this request
    
    RepositoryException
    
    See Also:
    
    materialize(AGMaterializer)
  - deleteMaterialized
```
public long deleteMaterialized(AGMaterializer materializer)
                        throws RepositoryException
```
    Deletes materialized statements.
    
    Parameters:
    
    materializer - Materializer parameters used to create the triples.
    
    Returns:
    
    the number of statements deleted
    
    Throws:
    
    AGHttpException - if there is an error with this request
    
    RepositoryException
    
    See Also:
    
    materialize(AGMaterializer)
  - deleteMaterialized
```
public long deleteMaterialized(Resource inferredGraph)
                        throws RepositoryException
```
    Deletes materialized statements from given graph.
    
    Parameters:
    
    inferredGraph - Graph to delete the statements from. If null the default graph will be used.
    
    Returns:
    
    the number of statements deleted
    
    Throws:
    
    AGHttpException - if there is an error with this request
    
    RepositoryException
    
    See Also:
    
    materialize(AGMaterializer)
  - setMasqueradeAsUser
```
public void setMasqueradeAsUser(String user)
                         throws RepositoryException
```
    Sets the AG user for X-Masquerade-As-User requests.
    For AG superusers only. This allows AG superusers to run requests as another user in a dedicated session.
    
    Parameters:
    
    user - the user for X-Masquerade-As-User requests
    
    Throws:
    
    RepositoryException - if there is an error with this request
  - begin
```
public void begin()
           throws RepositoryException
```
    Begins a transaction requiring commit() or rollback() to be called to end the transaction.
    
    Specified by:
    
    begin in interface RepositoryConnection
    
    Throws:
    
    RepositoryException - if there is an error with this request
    
    Since:
    
    2.7.0
    
    See Also:
    
    isActive(), commit(), rollback()
  - isActive
```
public boolean isActive()
                 throws UnknownTransactionStateException,
                        RepositoryException
```
    Indicates if a transaction is currently active on the connection. A transaction is active if begin() has been called, and becomes inactive after commit() or rollback() has been called.
    
    Specified by:
    
    isActive in interface RepositoryConnection
    
    Returns:
    
    true iff a transaction is active, false iff no transaction is active.
    
    Throws:
    
    UnknownTransactionStateException - if the transaction state can not be determined. This can happen for instance when communication with a repository fails or times out.
    
    RepositoryException - if there is an error with this request
    
    Since:
    
    2.7.0
  - clear
```
public void clear(Resource... contexts)
           throws RepositoryException
```
    Removes all statement(s) within the specified contexts.
    
    Specified by:
    
    clear in interface RepositoryConnection
    
    Overrides:
    
    clear in class AbstractRepositoryConnection
    
    Parameters:
    
    contexts - the context(s) to remove the data from. Note that this parameter is a vararg and as such is optional. If no contexts are supplied the method operates on the entire repository
    
    Throws:
    
    RepositoryException - if the statement(s) could not be removed from the repository, for example because the repository is not writable
  - deleteAttributeDefinition
```
public void deleteAttributeDefinition(String name)
                               throws RepositoryException
```
    Delete an existing triple attribute definition.
    
    Parameters:
    
    name - The name of the defined attribute to delete
    
    Throws:
    
    RepositoryException - if there is an error with this request
  - getAttributeDefinitions
```
public org.json.JSONArray getAttributeDefinitions()
                                           throws RepositoryException,
                                                  org.json.JSONException
```
    Return a list of all attributes defined for the current connection.
    
    Returns:
    
    JSONArray of Triple Attribute definitions
    
    Throws:
    
    RepositoryException - if there is an error with this request
    
    org.json.JSONException - if there is an error parsing the response to JSON
  - getAttributeDefinition
```
public org.json.JSONArray getAttributeDefinition(String name)
                                          throws RepositoryException,
                                                 org.json.JSONException
```
    Return the definition of the attribute named by NAME.
    
    Parameters:
    
    name - the attribute definition to lookup
    
    Returns:
    
    JSONArray of all found definitions
    
    Throws:
    
    RepositoryException - if there is an error with this request
    
    org.json.JSONException - if there is an error parsing the response to JSON
  - getStaticAttributeFilter
```
public String getStaticAttributeFilter()
                                throws RepositoryException
```
    Fetch the string representation of the static attribute filter defined on this repository
    
    Returns:
    
    String, or null if no static filter is defined
    
    Throws:
    
    RepositoryException - if there is an error with this request
  - setStaticAttributeFilter
```
public void setStaticAttributeFilter(String filter)
                              throws RepositoryException
```
    Establish a static attribute filter on the current repository.
    
    Parameters:
    
    filter - a String representing a static attribute filter definition
    
    Throws:
    
    RepositoryException - if there is an error with this request
  - deleteStaticAttributeFilter
```
public void deleteStaticAttributeFilter()
                                 throws RepositoryException
```
    Delete the static attribute filter defined on this repository.
    
    Throws:
    
    RepositoryException - if there is an error with this request
  - getUserAttributes
```
public String getUserAttributes()
```
  - setUserAttributes
```
public void setUserAttributes(String value)
```
  - setUserAttributes
```
public void setUserAttributes(org.json.JSONObject value)
```
  - setTransactionSettings
```
public void setTransactionSettings(TransactionSettings transactionSettings)
```
    Configure distributed transaction behavior.
    
    Parameters:
    
    transactionSettings - Distributed transaction settings.
  - transactionSettingsCtx
```
public Ctx transactionSettingsCtx(TransactionSettings transactionSettings)
```
    A 'context manager' for temporarily changing transaction settings.
    Use it in a try-with-resources block, like this:
```
 try (Ctx ignored = conn.transactionSettingsCtx(newSettings)) {
     // Any explicit or implicit commits here will use new settings
 }
 
```
    Parameters:
    
    transactionSettings - New distributed transaction settings.
    
    Returns:
    
    A closeable object that can be used in try-with-resources statement. When closed the object will restore old transaction settings.
  - setPool
```
public void setPool(AGConnPool pool)
```
    Sets the connection pool this object will be returned to on close.
    Set to null to make close really shutdown the connection.
    
    Parameters:
    
    pool - Connection pool.
  - warmup
```
public void warmup()
```
    Asks the server to read store's internal data structures into memory. Use warmup(WarmupConfig) to specify which structures should be read.
  - warmup
```
public void warmup(WarmupConfig config)
```
    Asks the server to read store's internal data structures into memory.
    
    Parameters:
    
    config - Config object that can be used to specify which structures should be read into memory. If this parameter is null then the choice will be left to the server.

Class AGRepositoryConnection

Dedicated Session Overview

Data-type and Predicate Mapping

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class org.eclipse.rdf4j.repository.base.AbstractRepositoryConnection

Methods inherited from class java.lang.Object

Methods inherited from interface org.eclipse.rdf4j.repository.RepositoryConnection

Field Detail

PROP_STREAM_RESULTS

PROP_USE_ADD_STATEMENT_BUFFER

PROP_ADD_STATEMENT_BUFFER_MAX_SIZE

DEFAULT_ADD_STATEMENT_BUFFER_SIZE

Constructor Detail

AGRepositoryConnection

AGRepositoryConnection

Method Detail

toString

getRepository

getServer

prepareHttpRepoClient

isAddStatementBufferEnabled

setAddStatementBufferEnabled

isUseAddStatementBuffer

getAddStatementBufferMaxSize

setAddStatementBufferMaxSize

getNumBufferedAddStatements

getValueFactory

add

add

add

add

add

add

add

add

add

add

add

add

add

add

remove

remove

add

add

remove

remove

isAutoCommit

setAutoCommit

getXAResource

prepareCommit

commit

commit

commit

rollback

rollback

getPreparedTransactions

isStreamResults

setStreamResults

clearNamespaces

close

exportStatements

exportStatements

getContextIDs

createRepositoryResult

getNamespace

getNamespaces

getStatements

downloadStatements

downloadStatements

downloadStatements

downloadStatements

downloadStatements

downloadStatements

streamStatements

streamStatements

streamStatements