com.bigdata.rdf.sail

Class BigdataSailRepository

java.lang.Object

org.openrdf.repository.base.RepositoryBase

org.openrdf.repository.sail.SailRepository

com.bigdata.rdf.sail.BigdataSailRepository

All Implemented Interfaces:

org.openrdf.repository.Repository

public class BigdataSailRepository
extends org.openrdf.repository.sail.SailRepository

Blazegraph specific SailRepository implementation class.

See Also:

BigdataSailRepositoryConnection

Constructor Summary

Constructors

Constructor and Description
BigdataSailRepository(BigdataSail sail)

Method Summary

Methods

Modifier and Type	Method and Description
BigdataSailRepositoryConnection	getConnection()
BigdataSailRepositoryConnection	getReadOnlyConnection() Obtain a read-only connection to the database at the last commit point.
BigdataSailRepositoryConnection	getReadOnlyConnection(long timestamp) Obtain a read-only connection to the database from a historical commit point.
BigdataSailRepositoryConnection	getReadWriteConnection() Return a connection backed by a read-write transaction.
BigdataSail	getSail()
BigdataSailRepositoryConnection	getUnisolatedConnection() Return an unisolated connection to the database.

Methods inherited from class org.openrdf.repository.sail.SailRepository

getDataDir, getValueFactory, initializeInternal, isWritable, setDataDir, shutDownInternal, toString

Methods inherited from class org.openrdf.repository.base.RepositoryBase

initialize, isInitialized, shutDown

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

BigdataSailRepository

public BigdataSailRepository(BigdataSail sail)

Method Detail

getSail

public BigdataSail getSail()

Overrides:

getSail in class org.openrdf.repository.sail.SailRepository

getConnection

public BigdataSailRepositoryConnection getConnection()
                                              throws org.openrdf.repository.RepositoryException

The correct pattern for obtaining an updatable connection, doing work with that connection, and committing or rolling back that update is as follows.

 
 BigdataSailConnection conn = null;
 boolean ok = false;
 try {
     conn = repo.getConnection();
     doWork(conn);
     conn.commit();
     ok = true;
 } finally {
     if (conn != null) {
         if (!ok) {
             conn.rollback();
         }
         conn.close();
     }
 }
 

Specified by:

getConnection in interface org.openrdf.repository.Repository

Overrides:

getConnection in class org.openrdf.repository.sail.SailRepository

Throws:

org.openrdf.repository.RepositoryException

See Also:

BigdataSail.getConnection(), getUnisolatedConnection()

getReadOnlyConnection

public BigdataSailRepositoryConnection getReadOnlyConnection()
                                                      throws org.openrdf.repository.RepositoryException

Obtain a read-only connection to the database at the last commit point. A read-only connection should be used for all pure-readers, as the connection will not be blocked by concurrent writers.

Returns:

a read-only connection to the database

Throws:

org.openrdf.repository.RepositoryException

See Also:

BigdataSail.getReadOnlyConnection()

getReadOnlyConnection

public BigdataSailRepositoryConnection getReadOnlyConnection(long timestamp)
                                                      throws org.openrdf.repository.RepositoryException

Obtain a read-only connection to the database from a historical commit point. A read-only connection should be used for all pure-readers, as the connection will not be blocked by concurrent writers.

Returns:

a read-only connection to the database

Throws:

org.openrdf.repository.RepositoryException

See Also:

BigdataSail.getReadOnlyConnection(long)

getReadWriteConnection

public BigdataSailRepositoryConnection getReadWriteConnection()
                                                       throws org.openrdf.repository.RepositoryException,
                                                              InterruptedException

Return a connection backed by a read-write transaction.

Throws:

InterruptedException

org.openrdf.repository.RepositoryException

See Also:

BigdataSail.getReadWriteConnection()

getUnisolatedConnection

public BigdataSailRepositoryConnection getUnisolatedConnection()
                                                        throws org.openrdf.repository.RepositoryException

Return an unisolated connection to the database. Only one of these allowed at a time.

The correct pattern for obtaining an updatable connection, doing work with that connection, and committing or rolling back that update is as follows.

 
 BigdataSailConnection conn = null;
 boolean ok = false;
 try {
     conn = repo.getConnection();
     doWork(conn);
     conn.commit();
     ok = true;
 } finally {
     if (conn != null) {
         if (!ok) {
             conn.rollback();
         }
         conn.close();
     }
 }
 

Returns:

unisolated connection to the database

Throws:

org.openrdf.repository.RepositoryException

See Also:

BigdataSail.getUnisolatedConnection(), getConnection()