org.deri.tarql

Class TarqlQueryExecution

java.lang.Object

org.deri.tarql.TarqlQueryExecution

public class TarqlQueryExecution
extends java.lang.Object

The execution of a TarqlQuery over a particular CSV file. Results can be delivered written into a Model or as an iterator over triples.

Field Summary

Fields

Modifier and Type	Field and Description
private CSVTable	table
private TarqlQuery	tq

Constructor Summary

Constructors

Constructor and Description
TarqlQueryExecution(InputStreamSource source, CSVOptions options, TarqlQuery query) Sets up a new query execution.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Close CSV table input.
void	exec(com.hp.hpl.jena.rdf.model.Model model) Execute all queries over the table.
com.hp.hpl.jena.query.ResultSet	execSelect() Execute a select over the model.
java.util.Iterator<com.hp.hpl.jena.graph.Triple>	execTriples()
com.hp.hpl.jena.query.Query	getFirstQuery()
private void	modifyQuery(com.hp.hpl.jena.query.Query query, com.hp.hpl.jena.sparql.algebra.Table table) Modifies a query so that it operates onto a table.

Methods inherited from class java.lang.Object

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

Field Detail

table

private final CSVTable table

tq

private final TarqlQuery tq

Constructor Detail

TarqlQueryExecution

public TarqlQueryExecution(InputStreamSource source,
                   CSVOptions options,
                   TarqlQuery query)

Sets up a new query execution.

Parameters:

source - The input CSV file.

options - Configuration options for the CSV file.

query - The input query.

Method Detail

modifyQuery

private void modifyQuery(com.hp.hpl.jena.query.Query query,
               com.hp.hpl.jena.sparql.algebra.Table table)

Modifies a query so that it operates onto a table. This is achieved by appending the table as a VALUES block to the end of the main query pattern.

Parameters:

query - Original query; will be modified in place

table - Data table to be added into the query

exec

public void exec(com.hp.hpl.jena.rdf.model.Model model)
          throws java.io.IOException

Execute all queries over the table.

Parameters:

model - Input model.

Throws:

java.io.IOException

execTriples

public java.util.Iterator<com.hp.hpl.jena.graph.Triple> execTriples()
                                                             throws java.io.IOException

Throws:

java.io.IOException

getFirstQuery

public com.hp.hpl.jena.query.Query getFirstQuery()

Returns:

Get the first query in the list.

execSelect

public com.hp.hpl.jena.query.ResultSet execSelect()

Execute a select over the model.

Returns:

Resulset of the select query.

close

public void close()

Close CSV table input.