public class AGRepository extends org.openrdf.repository.base.RepositoryBase implements AGAbstractRepository
AGCatalog
contains multiple repositories.
With the Sesame API, most data operations on a repository are done through
the AGRepositoryConnection
returned by getConnection()
.Constructor and Description |
---|
AGRepository(AGCatalog catalog,
String repositoryID)
Creates an AGRepository instance for a repository having the given
repository id in the given catalog.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Calls Sesame method
RepositoryBase.shutDown() . |
void |
ensureDBIdle()
Waits until background db processes have gone idle.
|
void |
forceCheckpoint()
Forces a checkpoint for this repository.
|
AGCatalog |
getCatalog()
Gets the catalog to which this repository belongs.
|
String |
getCatalogPrefixedRepositoryID() |
AGRepositoryConnection |
getConnection()
Create a connection to the repository.
|
AGRepositoryConnection |
getConnection(ScheduledExecutorService executor)
Create a connection to the repository.
|
File |
getDataDir()
Deprecated.
not applicable to AllegroGraph
|
String |
getDuplicateSuppressionPolicy()
Returns the repository's duplicate suppression policy.
|
com.franz.agraph.http.AGHTTPClient |
getHTTPClient()
The http connection to AllegroGraph server.
|
String |
getRepositoryID()
Gets the repository id for this repository.
|
String |
getRepositoryURL()
The AllegroGraph URL of this repository.
|
String |
getSpec() |
AGValueFactory |
getValueFactory() |
boolean |
isBulkMode()
Returns the repository's bulkMode setting.
|
boolean |
isWritable()
Returns true iff this repository is writable.
|
void |
setBulkMode(boolean bulkMode)
Sets the repository's bulkMode (defaults to false).
|
void |
setConnPool(AGConnPool pool)
Sets the connection pool to use with this repository.
|
void |
setDataDir(File dataDir)
Deprecated.
not applicable to AllegroGraph
|
void |
setDuplicateSuppressionPolicy(String policy)
Sets the repository's duplicate suppression policy.
|
initialize, isInitialized, shutDown
public AGRepository(AGCatalog catalog, String repositoryID)
Preferred access is from AGCatalog
methods
such as AGCatalog.createRepository(String, boolean)
or AGCatalog.openRepository(String)
.
public AGCatalog getCatalog()
getCatalog
in interface AGAbstractRepository
public String getRepositoryID()
public String getCatalogPrefixedRepositoryID()
public String getRepositoryURL()
public AGValueFactory getValueFactory()
getValueFactory
in interface AGAbstractRepository
getValueFactory
in interface org.openrdf.repository.Repository
public com.franz.agraph.http.AGHTTPClient getHTTPClient()
public AGRepositoryConnection getConnection(ScheduledExecutorService executor) throws org.openrdf.repository.RepositoryException
getConnection
in interface AGAbstractRepository
executor
- Executor service used to schedule maintenance tasks,
such as calling ping() periodically.
Set to null to disable such tasks.
Call getConnection()
to use the default executor
specified by the server object.
This argument is ignored if connection pooling is used.org.openrdf.repository.RepositoryException
public AGRepositoryConnection getConnection() throws org.openrdf.repository.RepositoryException
getConnection
in interface AGAbstractRepository
getConnection
in interface org.openrdf.repository.Repository
org.openrdf.repository.RepositoryException
public boolean isWritable() throws org.openrdf.repository.RepositoryException
isWritable
in interface org.openrdf.repository.Repository
org.openrdf.repository.RepositoryException
public String getSpec()
getSpec
in interface AGAbstractRepository
public File getDataDir()
getDataDir
in interface org.openrdf.repository.Repository
public void setDataDir(File dataDir)
setDataDir
in interface org.openrdf.repository.Repository
public void close() throws org.openrdf.repository.RepositoryException
RepositoryBase.shutDown()
.close
in interface Closeable
org.openrdf.repository.RepositoryException
Closeable.close()
public void setBulkMode(boolean bulkMode) throws org.openrdf.repository.RepositoryException
org.openrdf.repository.RepositoryException
isBulkMode()
public boolean isBulkMode() throws org.openrdf.repository.RepositoryException
org.openrdf.repository.RepositoryException
setBulkMode(boolean)
public void setDuplicateSuppressionPolicy(String policy) throws org.openrdf.repository.RepositoryException
AGRepositoryConnection.deleteDuplicates(String)
.
See also the protocol documentation for
suppressing duplicates.policy
- name of the suppression policy to useorg.openrdf.repository.RepositoryException
getDuplicateSuppressionPolicy()
public String getDuplicateSuppressionPolicy() throws org.openrdf.repository.RepositoryException
org.openrdf.repository.RepositoryException
setDuplicateSuppressionPolicy(String)
public void setConnPool(AGConnPool pool)
Enables the repository to use a connection pool so that Sesame apps can transparently benefit from connection pooling. If pool is not null, getConnection() borrows a connection from the pool, and closing the connection returns it to the pool. The pool is closed when the Repository is shutdown.
Note that the AGConnPool parameters:
AGConnProp.serverUrl, "http://localhost:10035",
AGConnProp.username, "test",
AGConnProp.password, "xyzzy",
AGConnProp.catalog, "/",
AGConnProp.repository, "my_repo",
are currently assumed to match those of this repository.
AGConnPool
public void forceCheckpoint() throws org.openrdf.repository.RepositoryException
org.openrdf.repository.RepositoryException
public void ensureDBIdle() throws org.openrdf.repository.RepositoryException
org.openrdf.repository.RepositoryException