org.oddjob.sql

Class SQLResultsSheet

java.lang.Object

org.oddjob.beanbus.AbstractFilter<java.lang.Object,java.lang.Object>

org.oddjob.sql.SQLResultsSheet

All Implemented Interfaces:

java.io.Closeable, java.io.Flushable, java.lang.AutoCloseable, java.lang.Runnable, java.util.function.Consumer<java.lang.Object>, ArooaSessionAware, BusFilter<java.lang.Object,java.lang.Object>, Outbound<java.lang.Object>

public class SQLResultsSheet
extends AbstractFilter<java.lang.Object,java.lang.Object>
implements ArooaSessionAware, java.lang.Runnable, java.io.Closeable, java.io.Flushable

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.]

 

Author:

rob

Constructor Summary

Constructors

Constructor and Description
SQLResultsSheet()

Method Summary

Modifier and Type	Method and Description
void	close()
protected java.lang.Object	filter(java.lang.Object from)
void	flush()
java.io.OutputStream	getOutput()
boolean	isDataOnly()
void	run()
void	setArooaSession(ArooaSession session) Accept the current Arooa Session.
void	setDataOnly(boolean dataOnly)
void	setOutput(java.io.OutputStream output)
void	writeBeans(java.util.List<java.lang.Object> beans)

Methods inherited from class org.oddjob.beanbus.AbstractFilter

accept, getName, getTo, setName, setTo, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Consumer

andThen

Constructor Detail

SQLResultsSheet

public SQLResultsSheet()

Method Detail

setArooaSession

public void setArooaSession(ArooaSession session)

Description copied from interface: ArooaSessionAware

Accept the current Arooa Session.

Specified by:

setArooaSession in interface ArooaSessionAware

Parameters:

session - The Arooa Session. Never null.

run

public void run()

Specified by:

run in interface java.lang.Runnable

filter

protected java.lang.Object filter(java.lang.Object from)

Specified by:

filter in class AbstractFilter<java.lang.Object,java.lang.Object>

writeBeans

public void writeBeans(java.util.List<java.lang.Object> beans)

flush

public void flush()
           throws java.io.IOException

Specified by:

flush in interface java.io.Flushable

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

getOutput

public java.io.OutputStream getOutput()

setOutput

public void setOutput(java.io.OutputStream output)

isDataOnly

public boolean isDataOnly()

setDataOnly

public void setDataOnly(boolean dataOnly)