Package org.dbunit.dataset.stream

Class BufferedConsumer

java.lang.Object

org.dbunit.dataset.stream.BufferedConsumer

All Implemented Interfaces:

IDataSetConsumer

public class BufferedConsumer
extends Object
implements IDataSetConsumer

Implementation of IDataSetConsumer which buffers all data until the endDataSet() event occurs. This provides the possibility to append new Columns on the fly which is needed for the column sensing feature in FlatXmlDataSet.

Since:

2.3.0

Version:

$Revision$ $Date$

Author:

gommma (gommma AT users.sourceforge.net), Last changed by: $Author$

Constructor Summary

Constructors

Constructor	Description
BufferedConsumer(IDataSetConsumer wrappedConsumer)	Creates a consumer that buffers all data until endDataSet(), then flushes it to the given wrapped consumer.

Method Summary

Modifier and Type	Method	Description
void	endDataSet()	Receive notification of the end of a dataset.
void	endTable()	Receive notification of the end of a table.
void	row(Object[] values)	Receive notification of a table row.
void	startDataSet()	Receive notification of the beginning of a dataset.
void	startTable(ITableMetaData metaData)	Receive notification of the beginning of a table.

Methods inherited from class java.lang.Object

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

Constructor Details

BufferedConsumer

public BufferedConsumer(IDataSetConsumer wrappedConsumer)

Creates a consumer that buffers all data until endDataSet(), then flushes it to the given wrapped consumer.

Parameters:

wrappedConsumer - The consumer that is wrapped

Method Details

startDataSet

public void startDataSet()
                  throws DataSetException

Description copied from interface: IDataSetConsumer

Receive notification of the beginning of a dataset. This method is invoked only once, before any other methods in this interface.

Specified by:

startDataSet in interface IDataSetConsumer

Throws:

DataSetException - if the notification cannot be processed.

endDataSet

public void endDataSet()
                throws DataSetException

Description copied from interface: IDataSetConsumer

Receive notification of the end of a dataset. This method is invoked only once, and it will be the last method invoked in this interface.

Specified by:

endDataSet in interface IDataSetConsumer

Throws:

DataSetException - if the notification cannot be processed.

row

public void row(Object[] values)
         throws DataSetException

Description copied from interface: IDataSetConsumer

Receive notification of a table row. This method is invoked to report each row of a table.

Specified by:

row in interface IDataSetConsumer

Parameters:

values - The row values.

Throws:

DataSetException - if the notification cannot be processed.

startTable

public void startTable(ITableMetaData metaData)
                throws DataSetException

Description copied from interface: IDataSetConsumer

Receive notification of the beginning of a table. This method is invoked at the beginning of every table in the dataset; there will be a corresponding IDataSetConsumer.endDataSet() event for every startTable event (even when the table is empty).

Specified by:

startTable in interface IDataSetConsumer

Parameters:

metaData - the table metadata

Throws:

DataSetException - if the notification cannot be processed.

endTable

public void endTable()
              throws DataSetException

Description copied from interface: IDataSetConsumer

Receive notification of the end of a table.

Specified by:

endTable in interface IDataSetConsumer

Throws:

DataSetException - if the notification cannot be processed.