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

Class KiWiTransactionalConnection

java.lang.Object

org.openrdf.sail.helpers.SailConnectionWrapper

org.openrdf.sail.helpers.NotifyingSailConnectionWrapper

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

All Implemented Interfaces:

TransactionalSailConnection, org.openrdf.sail.NotifyingSailConnection, org.openrdf.sail.SailConnection, org.openrdf.sail.SailConnectionListener

public class KiWiTransactionalConnection
extends org.openrdf.sail.helpers.NotifyingSailConnectionWrapper
implements org.openrdf.sail.SailConnectionListener, TransactionalSailConnection

This is an extended version of the KiWi triple store connection 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.

Author: Sebastian Schaffert

Constructor Summary

Constructors

Constructor and Description
KiWiTransactionalConnection(org.openrdf.sail.NotifyingSailConnection wrapped, Collection<TransactionListener> listeners)

Method Summary

Methods

Modifier and Type	Method and Description
void	addTransactionListener(TransactionListener listener) Add a transaction listener to the transactional connection.
void	begin()
void	commit() Notify the listeners of a commit before and after calling the super method
void	removeTransactionListener(TransactionListener listener) Remove a transaction listener from the transactional connection
void	rollback() Notify the listeners after rolling back.
void	statementAdded(org.openrdf.model.Statement triple) This method is called when a triple has been added to the repository.
void	statementRemoved(org.openrdf.model.Statement triple) This method is called when a triple has been removed from the repository.

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

addConnectionListener, getWrappedConnection, removeConnectionListener

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

addStatement, addStatement, clear, clearNamespaces, close, endUpdate, evaluate, getContextIDs, getNamespace, getNamespaces, getStatements, isActive, isOpen, prepare, removeNamespace, removeStatement, removeStatements, setNamespace, size, size, startUpdate

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.NotifyingSailConnection

addConnectionListener, removeConnectionListener

Methods inherited from interface org.openrdf.sail.SailConnection

addStatement, addStatement, clear, clearNamespaces, close, endUpdate, evaluate, getContextIDs, getNamespace, getNamespaces, getStatements, isActive, isOpen, prepare, removeNamespace, removeStatement, removeStatements, setNamespace, size, startUpdate

Constructor Detail

KiWiTransactionalConnection

public KiWiTransactionalConnection(org.openrdf.sail.NotifyingSailConnection wrapped,
                           Collection<TransactionListener> listeners)
                            throws org.openrdf.sail.SailException

Throws:

org.openrdf.sail.SailException

Method Detail

addTransactionListener

public void addTransactionListener(TransactionListener listener)

Add a transaction listener to the transactional connection.

Specified by:

addTransactionListener in interface TransactionalSailConnection

Parameters:

listener -

removeTransactionListener

public void removeTransactionListener(TransactionListener listener)

Remove a transaction listener from the transactional connection

Specified by:

removeTransactionListener in interface TransactionalSailConnection

Parameters:

listener -

statementAdded

public void statementAdded(org.openrdf.model.Statement triple)

This method is called when a triple has been added to the repository. It can be overridden by subclasses to add additional functionality.

Specified by:

statementAdded in interface org.openrdf.sail.SailConnectionListener

Parameters:

triple -

statementRemoved

public void statementRemoved(org.openrdf.model.Statement triple)

This method is called when a triple has been removed from the repository. It can be overridden by subclasses to add additional functionality.

Specified by:

statementRemoved in interface org.openrdf.sail.SailConnectionListener

Parameters:

triple -

begin

public void begin()
           throws org.openrdf.sail.SailException

Specified by:

begin in interface org.openrdf.sail.SailConnection

Overrides:

begin in class org.openrdf.sail.helpers.SailConnectionWrapper

Throws:

org.openrdf.sail.SailException

commit

public void commit()
            throws org.openrdf.sail.SailException

Notify the listeners of a commit before and after calling the super method

Specified by:

commit in interface org.openrdf.sail.SailConnection

Overrides:

commit in class org.openrdf.sail.helpers.SailConnectionWrapper

Throws:

org.openrdf.sail.SailException

rollback

public void rollback()
              throws org.openrdf.sail.SailException

Notify the listeners after rolling back.

Specified by:

rollback in interface org.openrdf.sail.SailConnection

Overrides:

rollback in class org.openrdf.sail.helpers.SailConnectionWrapper

Throws:

org.openrdf.sail.SailException