org.oddjob.sql

Class SQLResultsSheet

java.lang.Object

org.oddjob.beanbus.AbstractDestination<F>

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

org.oddjob.sql.SQLResultsSheet

All Implemented Interfaces:

java.lang.Iterable<java.lang.Object>, java.util.Collection<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

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
protected java.lang.Object	filter(java.lang.Object from)
java.io.OutputStream	getOutput()
boolean	isDataOnly()
void	setArooaSession(ArooaSession session) Accept the current Arooa Session.
void	setBusConductor(BusConductor busConductor)
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

add, getName, getTo, setName, setTo, toString

Methods inherited from class org.oddjob.beanbus.AbstractDestination

addAll, clear, contains, containsAll, isEmpty, iterator, remove, removeAll, retainAll, size, toArray, toArray

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Collection

addAll, clear, contains, containsAll, equals, hashCode, isEmpty, iterator, parallelStream, remove, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray

Methods inherited from interface java.lang.Iterable

forEach

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.

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)

getOutput

public java.io.OutputStream getOutput()

setOutput

public void setOutput(java.io.OutputStream output)

isDataOnly

public boolean isDataOnly()

setDataOnly

public void setDataOnly(boolean dataOnly)

setBusConductor

@Inject
public void setBusConductor(BusConductor busConductor)