public abstract class SQLAdapter extends SimpleSQLAdapter
Abstract adapter dedicated to SQL query input streams
The only method to implement is the single line level processRow() method
The SQL query is provided as the input stream
err, log, out
Constructor and Description |
---|
SQLAdapter() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getSQL()
Get SQL query
|
void |
process()
Executes each SQL (or the single one set by setSQL) query and iterates on results
Each result line is passed to the processLine() method for processing |
java.lang.String |
processHead(java.lang.String[] head)
Select result header processing.
|
abstract java.lang.String |
processRow(long rowNumber,
java.lang.String[] row)
Select result row processing to implement
|
java.lang.String |
processSelect(java.lang.String sql,
java.util.Vector<java.lang.String[]> rows)
Iterates on select results and calls processHead and processRow
|
java.lang.String |
processUpdate(java.lang.String sql,
int result)
Update result processing.
|
void |
setSQL(java.lang.String sql)
Set SQL query
|
getDataSource, preProcess, setDataSource
append, appendError, appendLog, appendLog, close, directProcess, getErrorStream, getErrorWriter, getGrant, getInput, getInputReader, getInputStream, getLogStream, getLogWriter, getName, getOutput, getOutputStream, getOutputWriter, getParameter, getParameters, getProcessCount, getStatus, init, postProcess, setInputStream, setOutputStream, setParameter, setProcessCount, setStatus
public final java.lang.String getSQL()
Get SQL query
public final void setSQL(java.lang.String sql)
Set SQL query
public void process() throws java.lang.InterruptedException
Executes each SQL (or the single one set by setSQL) query and iterates on results
Each result line is passed to the processLine() method for processing
process
in interface AdapterInterface
process
in class SimpleSQLAdapter
java.lang.InterruptedException
public final java.lang.String processSelect(java.lang.String sql, java.util.Vector<java.lang.String[]> rows) throws java.lang.Exception, java.lang.InterruptedException
processSelect
in class SimpleSQLAdapter
sql
- SQL statementrows
- Result rows (including headers)java.lang.Exception
java.lang.InterruptedException
public java.lang.String processHead(java.lang.String[] head) throws java.lang.Exception
Select result header processing. Does nothing by default, can be overriden if required
head
- Result headerjava.lang.Exception
public abstract java.lang.String processRow(long rowNumber, java.lang.String[] row) throws java.lang.Exception, java.lang.InterruptedException
Select result row processing to implement
rowNumber
- Input row number (1 is the first line)row
- Input row valuesjava.lang.Exception
java.lang.InterruptedException
public java.lang.String processUpdate(java.lang.String sql, int result) throws java.lang.Exception
Update result processing. Does nothing by default, can be overriden if required
processUpdate
in class SimpleSQLAdapter
sql
- SQL statementresult
- Resultjava.lang.Exception
Copyright (c)2006-2014 Simplicite Software. All Rights Reserved.