Package com.progress.open4gl.dynamicapi

Class InputTableStreamer

java.lang.Object

com.progress.open4gl.dynamicapi.InputTableStreamer

Direct Known Subclasses:

InputParameterStreamer, InputTableStreamerNoSchema

public class InputTableStreamer
extends Object

This class handles deserialization of data for temp-tables and datasets.

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	stopFlag
protected OutputStream	stream
protected ColumnStreamer	streamer

Constructor Summary

Constructors

Constructor	Description
InputTableStreamer(OutputStream s)
InputTableStreamer(OutputStream s, int serializeFormat)

Method Summary

Modifier and Type	Method	Description
void	doStreamProDataGraph(ProDataGraph dgraph, int p, boolean userData)
protected void	DoStreamResultSet(ResultSet results, ResultSetMetaData metaData, int p, boolean userData)
void	stop()
void	streamOut(ParameterSet params, List<MetaDataIndicator> schemas, int serverMajorVersion)
void	streamResultSet(ResultSet results, ResultSetMetaData metaData)
void	streamResultSet(ResultSet results, ResultSetMetaData metaData, int serverMajorVersion, int flagAndMarshalLevel)
protected void	streamRow(ResultSet results, ResultSetMetaData metaData, boolean traceRow, int rowNumUnused)
protected boolean	wasStopped()

Methods inherited from class java.lang.Object

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

Field Details

stream

protected OutputStream stream

streamer

protected ColumnStreamer streamer

stopFlag

protected boolean stopFlag

Constructor Details

InputTableStreamer

public InputTableStreamer(OutputStream s)

InputTableStreamer

public InputTableStreamer(OutputStream s,
 int serializeFormat)

Method Details

stop

public void stop()

wasStopped

protected boolean wasStopped()

streamOut

public void streamOut(ParameterSet params,
 List<MetaDataIndicator> schemas,
 int serverMajorVersion)
               throws ClientException,
ProDataException

Throws:

ClientException

ProDataException

doStreamProDataGraph

public void doStreamProDataGraph(ProDataGraph dgraph,
 int p,
 boolean userData)
                          throws ClientException,
ProDataException

Throws:

ClientException

ProDataException

streamResultSet

public void streamResultSet(ResultSet results,
 ResultSetMetaData metaData)
                     throws ClientException

Throws:

ClientException

streamResultSet

public void streamResultSet(ResultSet results,
 ResultSetMetaData metaData,
 int serverMajorVersion,
 int flagAndMarshalLevel)
                     throws ClientException

Throws:

ClientException

DoStreamResultSet

protected void DoStreamResultSet(ResultSet results,
 ResultSetMetaData metaData,
 int p,
 boolean userData)
                          throws ClientException

Throws:

ClientException

streamRow

protected void streamRow(ResultSet results,
 ResultSetMetaData metaData,
 boolean traceRow,
 int rowNumUnused)
                  throws ClientException

Throws:

ClientException