Class SailUpdateExecutor

java.lang.Object

org.eclipse.rdf4j.repository.sail.helpers.SailUpdateExecutor

public class SailUpdateExecutor
extends Object

Implementation of SailUpdate.execute() using SailConnection.evaluate(TupleExpr, Dataset, BindingSet, boolean) and other SailConnection methods. LOAD is handled at the Repository API level because it requires access to the Rio parser.

See Also:

• SailConnection.startUpdate(UpdateContext)
• SailConnection.endUpdate(UpdateContext)
• SailConnection.addStatement(UpdateContext, Resource, IRI, Value, Resource...)
• SailConnection.removeStatement(UpdateContext, Resource, IRI, Value, Resource...)
• SailConnection.clear(Resource...)
• SailConnection.getContextIDs()
• SailConnection.getStatements(Resource, IRI, Value, boolean, Resource...)
• SailConnection.evaluate(TupleExpr, Dataset, BindingSet, boolean)

Field Summary

Fields

Modifier and Type	Field	Description
private final SailConnection	con
private final RDFLoader	loader
private final org.slf4j.Logger	logger
private final ValueFactory	vf

Constructor Summary

Constructors

Constructor	Description
SailUpdateExecutor(SailConnection con, ValueFactory vf, ParserConfig loadConfig)	Implementation of SailUpdate.execute() using SailConnection.evaluate(TupleExpr, Dataset, BindingSet, boolean) and other SailConnection methods.

Method Summary

Modifier and Type	Method	Description
private Statement	createStatementFromPattern(StatementPattern pattern, BindingSet sourceBinding, MapBindingSet bnodeMapping)
private void	deleteBoundTriples(BindingSet whereBinding, TupleExpr deleteClause, UpdateContext uc)
private CloseableIteration<? extends BindingSet, QueryEvaluationException>	evaluateWhereClause(TupleExpr whereClause, UpdateContext uc, int maxExecutionTime)
protected void	executeAdd(Add add, UpdateContext uc, int maxExecTime)
protected void	executeClear(Clear clearExpr, UpdateContext uc, int maxExecutionTime)
protected void	executeCopy(Copy copy, UpdateContext uc, int maxExecutionTime)
protected void	executeCreate(Create create, UpdateContext uc)
protected void	executeDeleteData(DeleteData deleteDataExpr, UpdateContext uc, int maxExecutionTime)
protected void	executeInsertData(InsertData insertDataExpr, UpdateContext uc, int maxExecutionTime)
protected void	executeLoad(Load load, UpdateContext uc)
protected void	executeModify(Modify modify, UpdateContext uc, int maxExecutionTime)
protected void	executeMove(Move move, UpdateContext uc, int maxExecutionTime)
void	executeUpdate(UpdateExpr updateExpr, Dataset dataset, BindingSet bindings, boolean includeInferred, int maxExecutionTime)
private IRI[]	getDefaultRemoveGraphs(Dataset dataset)
private Value	getValueForVar(Var var, BindingSet bindings)
private void	insertBoundTriples(BindingSet whereBinding, TupleExpr insertClause, UpdateContext uc)

Methods inherited from class Object

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

Field Details

logger

private final org.slf4j.Logger logger

con

private final SailConnection con

vf

private final ValueFactory vf

loader

private final RDFLoader loader

Constructor Details

SailUpdateExecutor

public SailUpdateExecutor(SailConnection con,
 ValueFactory vf,
 ParserConfig loadConfig)

Implementation of SailUpdate.execute() using SailConnection.evaluate(TupleExpr, Dataset, BindingSet, boolean) and other SailConnection methods.

Parameters:

con - Used to read data from and write data to.

vf - Used to create BNodes

loadConfig -

Method Details

executeUpdate

public void executeUpdate(UpdateExpr updateExpr,
 Dataset dataset,
 BindingSet bindings,
 boolean includeInferred,
 int maxExecutionTime)
                   throws SailException,
RDFParseException,
IOException

Parameters:

maxExecutionTime - in seconds.

Throws:

SailException

RDFParseException

IOException

executeLoad

protected void executeLoad(Load load,
 UpdateContext uc)
                    throws IOException,
RDFParseException,
SailException

Throws:

IOException

RDFParseException

SailException

executeCreate

protected void executeCreate(Create create,
 UpdateContext uc)
                      throws SailException

Throws:

SailException

executeCopy

protected void executeCopy(Copy copy,
 UpdateContext uc,
 int maxExecutionTime)
                    throws SailException

Parameters:

copy -

uc -

Throws:

SailException

executeAdd

protected void executeAdd(Add add,
 UpdateContext uc,
 int maxExecTime)
                   throws SailException

Parameters:

add -

uc -

Throws:

SailException

executeMove

protected void executeMove(Move move,
 UpdateContext uc,
 int maxExecutionTime)
                    throws SailException

Parameters:

move -

uc -

Throws:

SailException

executeClear

protected void executeClear(Clear clearExpr,
 UpdateContext uc,
 int maxExecutionTime)
                     throws SailException

Parameters:

clearExpr -

uc -

Throws:

SailException

executeInsertData

protected void executeInsertData(InsertData insertDataExpr,
 UpdateContext uc,
 int maxExecutionTime)
                          throws SailException

Parameters:

insertDataExpr -

uc -

Throws:

SailException

executeDeleteData

protected void executeDeleteData(DeleteData deleteDataExpr,
 UpdateContext uc,
 int maxExecutionTime)
                          throws SailException

Parameters:

deleteDataExpr -

uc -

Throws:

SailException

executeModify

protected void executeModify(Modify modify,
 UpdateContext uc,
 int maxExecutionTime)
                      throws SailException

Throws:

SailException

getDefaultRemoveGraphs

private IRI[] getDefaultRemoveGraphs(Dataset dataset)

evaluateWhereClause

private CloseableIteration<? extends BindingSet, QueryEvaluationException> evaluateWhereClause(TupleExpr whereClause,
 UpdateContext uc,
 int maxExecutionTime)
                                                                                        throws SailException,
QueryEvaluationException

Throws:

SailException

QueryEvaluationException

deleteBoundTriples

private void deleteBoundTriples(BindingSet whereBinding,
 TupleExpr deleteClause,
 UpdateContext uc)
                         throws SailException

Parameters:

whereBinding -

deleteClause -

Throws:

SailException

insertBoundTriples

private void insertBoundTriples(BindingSet whereBinding,
 TupleExpr insertClause,
 UpdateContext uc)
                         throws SailException

Parameters:

whereBinding -

insertClause -

Throws:

SailException

createStatementFromPattern

private Statement createStatementFromPattern(StatementPattern pattern,
 BindingSet sourceBinding,
 MapBindingSet bnodeMapping)
                                      throws SailException

Throws:

SailException

getValueForVar

private Value getValueForVar(Var var,
 BindingSet bindings)
                      throws SailException

Throws:

SailException