scriptella.driver.csv

Class CsvQuery

java.lang.Object

scriptella.driver.csv.CsvQuery

All Implemented Interfaces:

ParametersCallback

public class CsvQuery
extends java.lang.Object
implements ParametersCallback

Query for CSV file.

Version:

1.0

Author:

Fyodor Kupolov

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.util.logging.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
CsvQuery(CSVReader queryReader, PropertiesSubstitutor substitutor, CsvConnectionParameters csvParams) Creates a query for CSVReader.

Method Summary

Modifier and Type	Method and Description
void	execute(CSVReader reader, QueryCallback queryCallback, AbstractConnection.StatementCounter counter) Executes a query over a specified text content.
protected ColumnsMap	getColumnsMap()
protected java.lang.Object	getCurrentRowValueAt(int columnIndex, java.lang.String columnName) Returns the value of a specified column.
java.lang.Object	getParameter(java.lang.String name) Returns the value of parameter specified by name.
protected ColumnsMap	parseHeader(CSVReader reader)
protected void	processRow(QueryCallback queryCallback, java.lang.String[] r) Processes the current row.
protected boolean	rowMatches(java.lang.String[] r) Checks if current CSV row matches any of the specified patterns.

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final java.util.logging.Logger LOG

Constructor Detail

CsvQuery

public CsvQuery(CSVReader queryReader,
                PropertiesSubstitutor substitutor,
                CsvConnectionParameters csvParams)

Creates a query for CSVReader.

Parameters:

queryReader - query CSVReader.

substitutor - properties substitutor to use. The parameters for the substitutor must be set by a caller.

csvParams - parsed parameters of the CSV connection

Method Detail

execute

public void execute(CSVReader reader,
                    QueryCallback queryCallback,
                    AbstractConnection.StatementCounter counter)
             throws java.io.IOException

Executes a query over a specified text content.

Parameters:

reader - CSV content reader.

queryCallback - callback to use for result set iteration.

counter - statements counter.

Throws:

java.io.IOException - if IO error occurs.

parseHeader

protected ColumnsMap parseHeader(CSVReader reader)
                          throws java.io.IOException

Throws:

java.io.IOException

rowMatches

protected boolean rowMatches(java.lang.String[] r)

Checks if current CSV row matches any of the specified patterns.

Parameters:

r - row to check

Returns:

true if row matches one of queries.

processRow

protected void processRow(QueryCallback queryCallback,
                          java.lang.String[] r)

Processes the current row.

This template method may be used for customizations by sublasses.

Parameters:

queryCallback - query callback to use.

r - row to pass as current parameters callback.

getParameter

public java.lang.Object getParameter(java.lang.String name)

Description copied from interface: ParametersCallback

Returns the value of parameter specified by name.

The callback internally delegates a call to parent callbacks if the parameter cannot be found.

Specified by:

getParameter in interface ParametersCallback

Parameters:

name - parameter name. Providers are allowed (but not required) to ignore a case of the name parameter to comply with their internal model. For example JDBC drivers are case-insensitive to column names.

Returns:

parameter value or null if parameter doesn't exist.

getCurrentRowValueAt

protected java.lang.Object getCurrentRowValueAt(int columnIndex,
                                                java.lang.String columnName)

Returns the value of a specified column.

This method may be overriden to perform conversion etc
2 parameters are passed for performance reasons, so that subclasses may decide wich one to use.

Parameters:

columnIndex - column index

columnName - column name.

Returns:

value of the specified column of the current row.

getColumnsMap

protected ColumnsMap getColumnsMap()