|
Franz Inc, AllegroGraph | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.openrdf.repository.base.RepositoryBase com.franz.agraph.repository.AGRepository
public class AGRepository
Implements the Sesame Repository interface for AllegroGraph, representing
triple-stores
on the server.
In AllegroGraph, an AGCatalog
contains multiple repositories.
With the Sesame API, most data operations on a repository are done through
the AGRepositoryConnection
returned by getConnection()
.
Constructor Summary | |
---|---|
AGRepository(AGCatalog catalog,
String repositoryID)
Creates an AGRepository instance for a repository having the given repository id in the given catalog. |
Method Summary | |
---|---|
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. |
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. |
Methods inherited from class org.openrdf.repository.base.RepositoryBase |
---|
initialize, isInitialized, shutDown |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.openrdf.repository.Repository |
---|
initialize, isInitialized, shutDown |
Constructor Detail |
---|
public AGRepository(AGCatalog catalog, String repositoryID)
Preferred access is from AGCatalog
methods
such as AGCatalog.createRepository(String, boolean)
or AGCatalog.openRepository(String)
.
Method Detail |
---|
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() 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 use
org.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
|
Copyright © 2008-2012 Franz Inc. | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |