org.apache.marmotta.commons.sesame.transactions.sail

Class KiWiTransactionalSail

java.lang.Object

org.openrdf.sail.helpers.SailWrapper

org.openrdf.sail.helpers.NotifyingSailWrapper

org.apache.marmotta.commons.sesame.transactions.sail.KiWiTransactionalSail

All Implemented Interfaces:

TransactionalSail, org.openrdf.sail.NotifyingSail, org.openrdf.sail.Sail, org.openrdf.sail.StackableSail

public class KiWiTransactionalSail
extends org.openrdf.sail.helpers.NotifyingSailWrapper
implements TransactionalSail

This is an extended version of the KiWi triple store with support for transaction tracking. It offers the possibility to register transaction listeners that are triggered whenever a connection commits or rolls back. If the transaction commits, they are also passed over the transaction data, i.e. the added and removed triples.

Note that even the basic KiWiStore offers transaction support by directly wrapping database transactions. The extended transactions provided by the KiWiTransactionalStore are only necessary for getting access to the transaction data and triggering actions on commit or rollback.s

Author: Sebastian Schaffert

Constructor Summary

Constructors

Constructor and Description
KiWiTransactionalSail(org.openrdf.sail.NotifyingSail base)

Method Summary

Methods

Modifier and Type	Method and Description
void	addTransactionListener(TransactionListener listener) Add a transaction listener to the KiWiTransactionalStore.
org.openrdf.sail.NotifyingSailConnection	getConnection() Returns a store-specific SailConnection object.
boolean	isTransactionsEnabled() Check if extended transaction support is enabled
void	removeTransactionListener(TransactionListener listener) Remove a transaction listener from the list.
void	setTransactionsEnabled(boolean transactionsEnabled) Temporarily enable/disable extended transactions.

Methods inherited from class org.openrdf.sail.helpers.NotifyingSailWrapper

addSailChangedListener, getBaseSail, removeSailChangedListener, setBaseSail

Methods inherited from class org.openrdf.sail.helpers.SailWrapper

getDataDir, getValueFactory, initialize, isWritable, setDataDir, shutDown, verifyBaseSailSet

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.openrdf.sail.NotifyingSail

addSailChangedListener, removeSailChangedListener

Methods inherited from interface org.openrdf.sail.Sail

getDataDir, getValueFactory, initialize, isWritable, setDataDir, shutDown

Constructor Detail

KiWiTransactionalSail

public KiWiTransactionalSail(org.openrdf.sail.NotifyingSail base)

Method Detail

addTransactionListener

public void addTransactionListener(TransactionListener listener)

Add a transaction listener to the KiWiTransactionalStore. The listener will be notified whenever a connection commits or rolls back. The listeners are collected in a list, i.e. a listener that is added first is also executed first.

Specified by:

addTransactionListener in interface TransactionalSail

Parameters:

listener - the listener to add to the list

removeTransactionListener

public void removeTransactionListener(TransactionListener listener)

Remove a transaction listener from the list.

Specified by:

removeTransactionListener in interface TransactionalSail

Parameters:

listener - the listener to remove

isTransactionsEnabled

public boolean isTransactionsEnabled()

Check if extended transaction support is enabled

Specified by:

isTransactionsEnabled in interface TransactionalSail

Returns:

true if extended transactions are enabled

setTransactionsEnabled

public void setTransactionsEnabled(boolean transactionsEnabled)

Temporarily enable/disable extended transactions. Disabling transactions might be useful when bulk loading large amounts of data.

Specified by:

setTransactionsEnabled in interface TransactionalSail

Parameters:

transactionsEnabled -

getConnection

public org.openrdf.sail.NotifyingSailConnection getConnection()
                                                       throws org.openrdf.sail.SailException

Returns a store-specific SailConnection object.

Specified by:

getConnection in interface org.openrdf.sail.NotifyingSail

Specified by:

getConnection in interface org.openrdf.sail.Sail

Overrides:

getConnection in class org.openrdf.sail.helpers.NotifyingSailWrapper

Returns:

A connection to the store.

Throws:

org.openrdf.sail.SailException