Class Changeset

java.lang.Object

org.eclipse.rdf4j.sail.base.Changeset

All Implemented Interfaces:

AutoCloseable, ModelFactory, SailClosable, SailSink

@InternalUseOnly
public abstract class Changeset
extends Object
implements SailSink, ModelFactory

Set of changes applied to an SailSourceBranch awaiting to be flushed into its backing SailSource.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	Changeset.AdderBasedReadWriteLock
static class	Changeset.SimpleStatementPattern

Field Summary

Fields

Modifier and Type	Field	Description
private Map<String,String>	addedNamespaces	Additional namespaces added.
private Model	approved	Statements that have been added as part of a transaction, but has not yet been committed.
private Set<Resource>	approvedContexts	Set of contexts of the approved statements.
private boolean	approvedEmpty
private boolean	closed
private Model	deprecated	Explicit statements that have been removed as part of a transaction, but have not yet been committed.
private Set<Resource>	deprecatedContexts	Set of contexts that were passed to clear(Resource...).
private boolean	deprecatedEmpty
private boolean	namespaceCleared	If all namespaces were removed, other than addedNamespaces.
private Set<Changeset.SimpleStatementPattern>	observed	When in IsolationLevels.SERIALIZABLE this contains all the observed StatementPatterns that were observed by ObservingSailDataset.
private Set<Changeset>	prepend	Changesets that have been SailSink.flush()ed to the same SailSourceBranch, since this object was SailSink.flush()ed.
(package private) Semaphore	prependLock
(package private) Changeset.AdderBasedReadWriteLock	readWriteLock
private List<SailDatasetImpl>	refbacks	Set of SailDatasets that are currently using this Changeset to derive the state of the SailSource.
(package private) Changeset.AdderBasedReadWriteLock	refBacksReadWriteLock
private Set<String>	removedPrefixes	Namespace prefixes that were removed.
private boolean	statementCleared	If all statements were removed, other than approved.

Constructor Summary

Constructors

Constructor	Description
Changeset()

Method Summary

Modifier and Type	Method	Description
void	addRefback(SailDatasetImpl dataset)
void	approve(Resource subj, IRI pred, Value obj, Resource ctx)	Adds a statement to the store.
void	approve(Statement statement)	Adds a statement to the store.
void	approveAll(Set<Statement> approve, Set<Resource> approveContexts)
void	clear(Resource... contexts)	Removes all statements from the specified/all contexts.
void	clearNamespaces()	Removes all namespace declarations from this SailSource.
private <T> Set<T>	cloneSet(Set<T> set)
void	close()	Closes this resource, relinquishing any underlying resources.
void	deprecate(Statement statement)	Removes a statement.
void	deprecateAll(Set<Statement> deprecate)
Map<String,String>	getAddedNamespaces()
Set<Resource>	getApprovedContexts()
(package private) List<Statement>	getApprovedStatements()
(package private) Iterable<Statement>	getApprovedStatements(Resource subj, IRI pred, Value obj, Resource[] contexts)
(package private) Iterable<Triple>	getApprovedTriples(Resource subj, IRI pred, Value obj)
Set<Resource>	getDeprecatedContexts()
(package private) List<Statement>	getDeprecatedStatements()
Set<StatementPattern>	getObservations()	Deprecated. Use getObserved() instead!
Set<Changeset.SimpleStatementPattern>	getObserved()
Set<String>	getRemovedPrefixes()
(package private) boolean	hasApproved()
(package private) boolean	hasApproved(Resource subj, IRI pred, Value obj, Resource[] contexts)
boolean	hasDeprecated()
(package private) boolean	hasDeprecated(Resource subj, IRI pred, Value obj, Resource[] contexts)
(package private) boolean	hasDeprecated(Statement statement)
(package private) boolean	isChanged()
boolean	isNamespaceCleared()
boolean	isRefback()
boolean	isStatementCleared()
void	observe(Resource subj, IRI pred, Value obj, Resource context)	Called to indicate matching statements have been observed and must not change their state until after this SailSink is committed, iff this was opened in an isolation level compatible with IsolationLevels.SERIALIZABLE.
void	observe(Resource subj, IRI pred, Value obj, Resource... contexts)	Called to indicate matching statements have been observed and must not change their state until after this SailSink is committed, iff this was opened in an isolation level compatible with IsolationLevels.SERIALIZABLE.
void	observeAll(Set<Changeset.SimpleStatementPattern> observed)
void	prepare()	Checks if this SailSink is consistent with the isolation level it was created with.
void	prepend(Changeset changeset)
(package private) void	removeApproved(Statement next)
void	removeNamespace(String prefix)	Removes a namespace declaration by removing the association between a prefix and a namespace name.
void	removeRefback(SailDatasetImpl dataset)
protected void	setChangeset(Changeset from)
void	setNamespace(String prefix, String name)	Sets the prefix for a namespace.
Changeset	shallowClone()	Create a shallow clone of this Changeset.
(package private) void	sinkApproved(SailSink sink)
(package private) void	sinkDeprecated(SailSink sink)
void	sinkObserved(SailSink sink)
String	toString()

Methods inherited from class Object

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

Methods inherited from interface ModelFactory

createEmptyModel

Methods inherited from interface SailSink

deprecate, deprecateByQuery, flush, supportsDeprecateByQuery

Field Details

readWriteLock

Changeset.AdderBasedReadWriteLock readWriteLock

refBacksReadWriteLock

Changeset.AdderBasedReadWriteLock refBacksReadWriteLock

prependLock

Semaphore prependLock

refbacks

private List<SailDatasetImpl> refbacks

Set of SailDatasets that are currently using this Changeset to derive the state of the SailSource.

prepend

private Set<Changeset> prepend

Changesets that have been SailSink.flush()ed to the same SailSourceBranch, since this object was SailSink.flush()ed.

observed

private volatile Set<Changeset.SimpleStatementPattern> observed

When in IsolationLevels.SERIALIZABLE this contains all the observed StatementPatterns that were observed by ObservingSailDataset.

approved

private volatile Model approved

Statements that have been added as part of a transaction, but has not yet been committed.

DO NOT EXPOSE THE MODEL OUTSIDE OF THIS CLASS BECAUSE IT IS NOT THREAD-SAFE

approvedEmpty

private volatile boolean approvedEmpty

deprecated

private volatile Model deprecated

Explicit statements that have been removed as part of a transaction, but have not yet been committed.

DO NOT EXPOSE THE MODEL OUTSIDE OF THIS CLASS BECAUSE IT IS NOT THREAD-SAFE

deprecatedEmpty

private volatile boolean deprecatedEmpty

approvedContexts

private Set<Resource> approvedContexts

Set of contexts of the approved statements.

deprecatedContexts

private volatile Set<Resource> deprecatedContexts

Set of contexts that were passed to clear(Resource...).

addedNamespaces

private Map<String,String> addedNamespaces

Additional namespaces added.

removedPrefixes

private Set<String> removedPrefixes

Namespace prefixes that were removed.

namespaceCleared

private volatile boolean namespaceCleared

If all namespaces were removed, other than addedNamespaces.

statementCleared

private volatile boolean statementCleared

If all statements were removed, other than approved.

closed

private boolean closed

Constructor Details

Changeset

public Changeset()

Method Details

close

public void close()
           throws SailException

Description copied from interface: SailClosable

Closes this resource, relinquishing any underlying resources.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface SailClosable

Throws:

SailException - if this resource cannot be closed

prepare

public void prepare()
             throws SailException

Description copied from interface: SailSink

Checks if this SailSink is consistent with the isolation level it was created with. If this Sink was created with a IsolationLevels.SERIALIZABLE and another conflicting SailSink has already been SailSink.flush()ed, this method will throw a SailConflictException.

Specified by:

prepare in interface SailSink

Throws:

SailException

hasApproved

boolean hasApproved(Resource subj,
 IRI pred,
 Value obj,
 Resource[] contexts)

hasDeprecated

boolean hasDeprecated(Resource subj,
 IRI pred,
 Value obj,
 Resource[] contexts)

addRefback

public void addRefback(SailDatasetImpl dataset)

removeRefback

public void removeRefback(SailDatasetImpl dataset)

isRefback

public boolean isRefback()

prepend

public void prepend(Changeset changeset)

setNamespace

public void setNamespace(String prefix,
 String name)

Description copied from interface: SailSink

Sets the prefix for a namespace.

Specified by:

setNamespace in interface SailSink

Parameters:

prefix - The new prefix, or an empty string in case of the default namespace.

name - The namespace name that the prefix maps to.

removeNamespace

public void removeNamespace(String prefix)

Description copied from interface: SailSink

Removes a namespace declaration by removing the association between a prefix and a namespace name.

Specified by:

removeNamespace in interface SailSink

Parameters:

prefix - The namespace prefix, or an empty string in case of the default namespace.

clearNamespaces

public void clearNamespaces()

Description copied from interface: SailSink

Removes all namespace declarations from this SailSource.

Specified by:

clearNamespaces in interface SailSink

observe

public void observe(Resource subj,
 IRI pred,
 Value obj,
 Resource... contexts)
             throws SailConflictException

Description copied from interface: SailSink

Called to indicate matching statements have been observed and must not change their state until after this SailSink is committed, iff this was opened in an isolation level compatible with IsolationLevels.SERIALIZABLE.

Specified by:

observe in interface SailSink

Parameters:

subj - A Resource specifying the subject, or null for a wildcard.

pred - A IRI specifying the predicate, or null for a wildcard.

obj - A Value specifying the object, or null for a wildcard.

contexts - The context(s) of the observed statements. Note that this parameter is a vararg and as such is optional. If no contexts are supplied the method operates on all contexts.

Throws:

SailConflictException

observe

public void observe(Resource subj,
 IRI pred,
 Value obj,
 Resource context)
             throws SailConflictException

Description copied from interface: SailSink

Called to indicate matching statements have been observed and must not change their state until after this SailSink is committed, iff this was opened in an isolation level compatible with IsolationLevels.SERIALIZABLE.

Specified by:

observe in interface SailSink

Parameters:

subj - A Resource specifying the subject, or null for a wildcard.

pred - A IRI specifying the predicate, or null for a wildcard.

obj - A Value specifying the object, or null for a wildcard.

context - The context of the observed statements.

Throws:

SailConflictException

observeAll

public void observeAll(Set<Changeset.SimpleStatementPattern> observed)

Specified by:

observeAll in interface SailSink

clear

public void clear(Resource... contexts)

Description copied from interface: SailSink

Removes all statements from the specified/all contexts. If no contexts are specified the method operates on the entire repository.

Specified by:

clear in interface SailSink

Parameters:

contexts - The context(s) from which to remove the statements. Note that this parameter is a vararg and as such is optional. If no contexts are specified the method operates on the entire repository. A null value can be used to match context-less statements.

approve

public void approve(Statement statement)

Description copied from interface: SailSink

Adds a statement to the store.

Specified by:

approve in interface SailSink

Parameters:

statement - The statement to add.

approve

public void approve(Resource subj,
 IRI pred,
 Value obj,
 Resource ctx)
             throws SailException

Description copied from interface: SailSink

Adds a statement to the store.

Specified by:

approve in interface SailSink

Parameters:

subj - The subject of the statement to add.

pred - The predicate of the statement to add.

obj - The object of the statement to add.

ctx - The context to add the statement to.

Throws:

SailException - If the statement could not be added, for example because no transaction is active.

deprecate

public void deprecate(Statement statement)

Description copied from interface: SailSink

Removes a statement.

Specified by:

deprecate in interface SailSink

Parameters:

statement - The statement that should be removed

toString

public String toString()

Overrides:

toString in class Object

setChangeset

protected void setChangeset(Changeset from)

shallowClone

public Changeset shallowClone()

Create a shallow clone of this Changeset. The shallow clone does not clone the underlying data structures, this means that any changes made to the original will potentially be reflected in the clone and vice versa.

Returns:

a new Changeset that is a shallow clone of the current Changeset.

getObserved

public Set<Changeset.SimpleStatementPattern> getObserved()

getObservations

@Deprecated
public Set<StatementPattern> getObservations()

Deprecated.

Use getObserved() instead!

getApprovedContexts

public Set<Resource> getApprovedContexts()

getDeprecatedContexts

public Set<Resource> getDeprecatedContexts()

isStatementCleared

public boolean isStatementCleared()

getAddedNamespaces

public Map<String,String> getAddedNamespaces()

getRemovedPrefixes

public Set<String> getRemovedPrefixes()

isNamespaceCleared

public boolean isNamespaceCleared()

hasDeprecated

public boolean hasDeprecated()

isChanged

boolean isChanged()

getDeprecatedStatements

List<Statement> getDeprecatedStatements()

getApprovedStatements

List<Statement> getApprovedStatements()

hasDeprecated

boolean hasDeprecated(Statement statement)

hasApproved

boolean hasApproved()

getApprovedStatements

Iterable<Statement> getApprovedStatements(Resource subj,
 IRI pred,
 Value obj,
 Resource[] contexts)

getApprovedTriples

Iterable<Triple> getApprovedTriples(Resource subj,
 IRI pred,
 Value obj)

removeApproved

void removeApproved(Statement next)

cloneSet

private <T> Set<T> cloneSet(Set<T> set)

sinkApproved

void sinkApproved(SailSink sink)

sinkDeprecated

void sinkDeprecated(SailSink sink)

sinkObserved

public void sinkObserved(SailSink sink)

approveAll

public void approveAll(Set<Statement> approve,
 Set<Resource> approveContexts)

Specified by:

approveAll in interface SailSink

deprecateAll

public void deprecateAll(Set<Statement> deprecate)

Specified by:

deprecateAll in interface SailSink