Package org.oddjob.sql
Class SQLResultsSheet
- All Implemented Interfaces:
Closeable,Flushable,AutoCloseable,Runnable,Consumer<Object>,ArooaSessionAware,BusFilter<Object,,Object> Outbound<Object>
public class SQLResultsSheet
extends AbstractFilter<Object,Object>
implements ArooaSessionAware, Runnable, Closeable, Flushable
- Author:
- rob
Description
Writes SQL results to an output stream.Example
A result sheet for multiple statements.
<oddjob>
<job>
<sql>
<connection>
<connection driver="org.hsqldb.jdbcDriver" url="jdbc:hsqldb:mem:SQLResultsSheet_Example" username="sa" password=""/>
</connection>
<input>
<buffer>
create table FRUIT(
TYPE varchar(16),
VARIETY varchar(16),
COLOUR varchar(32),
SIZE double);
insert into FRUIT values ('Apple', 'Cox', 'Red and Green', 7.6);
insert into FRUIT values ('Orange', 'Jaffa', 'Orange', 9.245);
select * from FRUIT;
shutdown;
</buffer>
</input>
<results>
<sql-results-sheet/>
</results>
</sql>
</job>
</oddjob>
This writes the following to the console:
[0 rows affected, 16 ms.]
[1 rows affected, 0 ms.]
[1 rows affected, 0 ms.]
TYPE VARIETY COLOUR SIZE
------ ------- ------------- -----
Apple Cox Red and Green 7.6
Orange Jaffa Orange 9.245
[2 rows, 212 ms.]
[0 rows affected, 0 ms.]
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()protected Objectvoidflush()booleanvoidrun()voidsetArooaSession(ArooaSession session) Accept the current Arooa Session.voidsetDataOnly(boolean dataOnly) voidsetOutput(OutputStream output) voidwriteBeans(List<Object> beans) Methods inherited from class org.oddjob.beanbus.AbstractFilter
accept, getName, getTo, setName, setTo, toString
-
Constructor Details
-
SQLResultsSheet
public SQLResultsSheet()
-
-
Method Details
-
setArooaSession
Description copied from interface:ArooaSessionAwareAccept the current Arooa Session.- Specified by:
setArooaSessionin interfaceArooaSessionAware- Parameters:
session- The Arooa Session. Never null.
-
run
public void run() -
filter
- Specified by:
filterin classAbstractFilter<Object,Object>
-
writeBeans
-
flush
- Specified by:
flushin interfaceFlushable- Throws:
IOException
-
close
- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Throws:
IOException
-
getOutput
-
setOutput
-
isDataOnly
public boolean isDataOnly() -
setDataOnly
public void setDataOnly(boolean dataOnly)
-