org.apache.marmotta.kiwi.versioning.persistence

Class KiWiVersioningConnection

java.lang.Object

org.apache.marmotta.kiwi.persistence.KiWiConnection

org.apache.marmotta.kiwi.versioning.persistence.KiWiVersioningConnection

All Implemented Interfaces:

AutoCloseable

public class KiWiVersioningConnection
extends KiWiConnection

Add file description here!

Author: Sebastian Schaffert

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.marmotta.kiwi.persistence.KiWiConnection

KiWiConnection.RetryCommand<T>, KiWiConnection.RetryExecution<T>

Field Summary

Fields inherited from class org.apache.marmotta.kiwi.persistence.KiWiConnection

cacheManager, connection, dialect, persistence, tripleBatch

Constructor Summary

Constructors

Constructor and Description
KiWiVersioningConnection(KiWiPersistence persistence, KiWiDialect dialect, CacheManager cacheManager)

Method Summary

Methods

Modifier and Type	Method and Description
protected String	constructTripleQuerySnapshot(KiWiResource subject, KiWiUriResource predicate, KiWiNode object, KiWiResource context, boolean inferred, Date snapshotDate) Construct the SQL query string from the query pattern passed as arguments
protected Version	constructVersionFromDatabase(ResultSet row) Construct a version from the database using the data contained in the result set row passed as argument.
Version	getLatestVersion(KiWiResource resource, Date date) Return the version that is the most recent version for a resource given a reference date.
long	getSnapshotSize(Date snapshotDate) Count all non-deleted triples in the triple store at the given snapshot date
long	getSnapshotSize(KiWiResource context, Date snapshotDate) Count all non-deleted triples in the triple store at the given snapshot date
Version	getVersion(Long id) Retrieve a version by its id.
org.openrdf.repository.RepositoryResult<org.openrdf.model.Statement>	listTriplesSnapshot(KiWiResource subject, KiWiUriResource predicate, KiWiNode object, KiWiResource context, boolean inferred, Date snapshotDate) Return a Sesame RepositoryResult of statements according to the query pattern given in the arguments.
org.openrdf.repository.RepositoryResult<Version>	listVersions() List all versions in the database; operates directly on the result set, i.e.
org.openrdf.repository.RepositoryResult<Version>	listVersions(Date from, Date to) List all versions in the database; operates directly on the result set, i.e.
org.openrdf.repository.RepositoryResult<Version>	listVersions(KiWiResource r) List all versions in the database affecting the given resource as subject; operates directly on the result set, i.e.
org.openrdf.repository.RepositoryResult<Version>	listVersions(KiWiResource r, Date from, Date to) List all versions in the database; operates directly on the result set, i.e.
void	removeVersion(Long id) Remove the version with the id passed as argument, including all references to added and removed triples.
void	removeVersions(Date until) Remove all versions until the date given as argument.
void	removeVersions(Date from, Date to) Remove all versions in the given time interval.
void	storeVersion(Version data) Store a new version in the database.

Methods inherited from class org.apache.marmotta.kiwi.persistence.KiWiConnection

close, commit, constructNamespaceFromDatabase, constructNodeFromDatabase, constructTripleFromDatabase, constructTripleQuery, constructTriplesFromDatabase, deleteAll, deleteContext, deleteNamespace, deleteTriple, flushBatch, getAutoCommit, getBatchSize, getCacheManager, getConfiguration, getDatabaseTables, getDatabaseVersion, getDialect, getJDBCConnection, getLocale, getMetadata, getNextSequence, getPreparedStatement, getPreparedStatement, getSize, getSize, getTransactionId, getTripleId, isBatchCommit, isClosed, listContexts, listNamespaces, listResources, listResources, listTriples, loadAnonResource, loadLiteral, loadLiteral, loadLiteral, loadLiteral, loadLiteral, loadNamespaceByPrefix, loadNamespaceByUri, loadNodeById, loadNodesByIds, loadTripleById, loadUriResource, requireJDBCConnection, rollback, setAutoCommit, setBatchCommit, setBatchSize, setMetadata, storeNamespace, storeNode, storeTriple, undeleteTriple

Methods inherited from class java.lang.Object

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

Constructor Detail

KiWiVersioningConnection

public KiWiVersioningConnection(KiWiPersistence persistence,
                        KiWiDialect dialect,
                        CacheManager cacheManager)
                         throws SQLException

Throws:

SQLException

Method Detail

storeVersion

public void storeVersion(Version data)
                  throws SQLException

Store a new version in the database. Will query for a new sequence ID for versions, insert a new row in the versions table, and then add join entries to the versions_added and versions_removed tables for each added and removed triple.

Note that this method assumes the transaction data to be already consistent, i.e. a triple is not added and removed at the same time. No check for this situation is performed

Parameters:

data -

Throws:

SQLException

removeVersion

public void removeVersion(Long id)
                   throws SQLException

Remove the version with the id passed as argument, including all references to added and removed triples. The triples themselves are not deleted immediately, we let the garbage collector carry this out periodically.

Parameters:

id -

Throws:

SQLException

removeVersions

public void removeVersions(Date until)
                    throws SQLException

Remove all versions until the date given as argument. Iterates over all versions and deletes them individually. Entries in join tables (added/removed triples) are also deleted, the triples themselves not. Deleted triples without version will later be cleaned up by the garbage collector

Parameters:

until - date until when to delete versions

Throws:

SQLException

removeVersions

public void removeVersions(Date from,
                  Date to)
                    throws SQLException

Remove all versions in the given time interval. Iterates over all versions and deletes them individually. Entries in join tables (added/removed triples) are also deleted, the triples themselves not. Deleted triples without version will later be cleaned up by the garbage collector

Parameters:

from - date after which versions will be deleted

to - date before which versions will be deleted

Throws:

SQLException

getVersion

public Version getVersion(Long id)
                   throws SQLException

Retrieve a version by its id. If the version does not exist, returns null

Parameters:

id -

Returns:

Throws:

SQLException

getLatestVersion

public Version getLatestVersion(KiWiResource resource,
                       Date date)
                         throws SQLException

Return the version that is the most recent version for a resource given a reference date. The method will either return the version that was current for the resource at the given date or return null in case such a version does not exist (e.g. before the resource was created).

Parameters:

resource - the resource for which to find a version

date - the reference date

Returns:

the latest version of the resource at the given date, or null if such a version does not exist

Throws:

SQLException

listVersions

public org.openrdf.repository.RepositoryResult<Version> listVersions()
                                                              throws SQLException

List all versions in the database; operates directly on the result set, i.e. the iteration is carried out lazily and needs to be closed when iteration is completed.

Returns:

Throws:

SQLException

listVersions

public org.openrdf.repository.RepositoryResult<Version> listVersions(KiWiResource r)
                                                              throws SQLException

List all versions in the database affecting the given resource as subject; operates directly on the result set, i.e. the iteration is carried out lazily and needs to be closed when iteration is completed.

Returns:

Throws:

SQLException

listVersions

public org.openrdf.repository.RepositoryResult<Version> listVersions(Date from,
                                                            Date to)
                                                              throws SQLException

List all versions in the database; operates directly on the result set, i.e. the iteration is carried out lazily and needs to be closed when iteration is completed.

Returns:

Throws:

SQLException

listVersions

public org.openrdf.repository.RepositoryResult<Version> listVersions(KiWiResource r,
                                                            Date from,
                                                            Date to)
                                                              throws SQLException

List all versions in the database; operates directly on the result set, i.e. the iteration is carried out lazily and needs to be closed when iteration is completed.

Returns:

Throws:

SQLException

constructVersionFromDatabase

protected Version constructVersionFromDatabase(ResultSet row)
                                        throws SQLException

Construct a version from the database using the data contained in the result set row passed as argument. The method will load all added and removed triples in subsequent SQL queries.

The method will not change the ResultSet iterator, only read its values, so it needs to be executed for each row separately.

Parameters:

row -

Returns:

Throws:

SQLException

listTriplesSnapshot

public org.openrdf.repository.RepositoryResult<org.openrdf.model.Statement> listTriplesSnapshot(KiWiResource subject,
                                                                                       KiWiUriResource predicate,
                                                                                       KiWiNode object,
                                                                                       KiWiResource context,
                                                                                       boolean inferred,
                                                                                       Date snapshotDate)
                                                                                         throws SQLException

Return a Sesame RepositoryResult of statements according to the query pattern given in the arguments. Each of the parameters subject, predicate, object and context may be null, indicating a wildcard query. If the boolean parameter "inferred" is set to true, the result will also include inferred triples, if it is set to false only base triples.

The RepositoryResult holds a direct connection to the database and needs to be closed properly, or otherwise the system might run out of resources. The returned RepositoryResult will try its best to clean up when the iteration has completed or the garbage collector calls the finalize() method, but this can take longer than necessary.

Parameters:

subject - the subject to query for, or null for a wildcard query

predicate - the predicate to query for, or null for a wildcard query

object - the object to query for, or null for a wildcard query

context - the context to query for, or null for a wildcard query

inferred - if true, the result will also contain triples inferred by the reasoner, if false not

Returns:

a new RepositoryResult with a direct connection to the database; the result should be properly closed by the caller

Throws:

SQLException

constructTripleQuerySnapshot

protected String constructTripleQuerySnapshot(KiWiResource subject,
                                  KiWiUriResource predicate,
                                  KiWiNode object,
                                  KiWiResource context,
                                  boolean inferred,
                                  Date snapshotDate)

Construct the SQL query string from the query pattern passed as arguments

Parameters:

subject - the subject to query for, or null for a wildcard query

predicate - the predicate to query for, or null for a wildcard query

object - the object to query for, or null for a wildcard query

context - the context to query for, or null for a wildcard query

inferred - if true, the result will also contain triples inferred by the reasoner, if false not

Returns:

an SQL query string representing the triple pattern

getSnapshotSize

public long getSnapshotSize(Date snapshotDate)
                     throws SQLException

Count all non-deleted triples in the triple store at the given snapshot date

Returns:

Throws:

SQLException

getSnapshotSize

public long getSnapshotSize(KiWiResource context,
                   Date snapshotDate)
                     throws SQLException

Count all non-deleted triples in the triple store at the given snapshot date

Returns:

Throws:

SQLException