com.progress.open4gl.dynamicapi

Class InputTableStreamer

java.lang.Object

com.progress.open4gl.dynamicapi.InputTableStreamer

Direct Known Subclasses:

InputParameterStreamer, InputTableStreamerNoSchema

public class InputTableStreamer
extends java.lang.Object

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

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
InputTableStreamer(java.io.OutputStream s)
InputTableStreamer(java.io.OutputStream s, int serializeFormat)

Method Summary

Modifier and Type	Method and Description
void	doStreamProDataGraph(ProDataGraph dgraph, int p, boolean userData)
protected void	DoStreamResultSet(java.sql.ResultSet results, ResultSetMetaData metaData, int p, boolean userData)
void	stop()
void	streamOut(ParameterSet params, java.util.List<MetaDataIndicator> schemas, int serverMajorVersion)
void	streamResultSet(java.sql.ResultSet results, ResultSetMetaData metaData)
void	streamResultSet(java.sql.ResultSet results, ResultSetMetaData metaData, int serverMajorVersion, int flagAndMarshalLevel)
protected void	streamRow(java.sql.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 Detail

stream

protected java.io.OutputStream stream

streamer

protected ColumnStreamer streamer

stopFlag

protected boolean stopFlag

Constructor Detail

InputTableStreamer

public InputTableStreamer(java.io.OutputStream s)

InputTableStreamer

public InputTableStreamer(java.io.OutputStream s,
                          int serializeFormat)

Method Detail

stop

public void stop()

wasStopped

protected boolean wasStopped()

streamOut

public void streamOut(ParameterSet params,
                      java.util.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(java.sql.ResultSet results,
                            ResultSetMetaData metaData)
                     throws ClientException

Throws:

ClientException

streamResultSet

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

Throws:

ClientException

DoStreamResultSet

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

Throws:

ClientException

streamRow

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

Throws:

ClientException