com.partnersoft.io.sql
Class SQLDataRecordSource

java.lang.Object
  com.partnersoft.data.DataRecordSource
      com.partnersoft.io.formats.StreamingDataRecordSource
          com.partnersoft.io.sql.SQLDataRecordSource

All Implemented Interfaces:

Coggable, java.lang.Iterable<Naming>

public class SQLDataRecordSource
extends StreamingDataRecordSource

A source for data records, derived from an SQL query.

Author:

Paul Reavis Copyright 2001 Partner Software, Inc.

Field Summary

Fields inherited from class com.partnersoft.data.DataRecordSource

showProgress, verbose

Constructor Summary

SQLDataRecordSource()

SQLDataRecordSource(DatabaseConnectionConfig database, java.lang.String query)

SQLDataRecordSource(DatabaseConnection connection, java.lang.String query)

Method Summary

void	close()
DataRecordFetcher	createFetcher() Creates a new fetcher to gather data for a new iteration.
java.lang.String	getQuery()
void	setQuery(java.lang.String newQuery)

Methods inherited from class com.partnersoft.io.formats.StreamingDataRecordSource

copyStateFrom, createInputStream, getPath, getPaths, getState, setInputStream, setPath, setPaths, setState

Methods inherited from class com.partnersoft.data.DataRecordSource

clone, getAfterActions, getBeforeActions, getShowProgress, getTransforms, isVerbose, iterator, setAfterActions, setBeforeActions, setShowProgress, setTransforms, setVerbose

Methods inherited from class java.lang.Object

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

Constructor Detail

SQLDataRecordSource

public SQLDataRecordSource()

SQLDataRecordSource

public SQLDataRecordSource(DatabaseConnectionConfig database,
                           java.lang.String query)

SQLDataRecordSource

public SQLDataRecordSource(DatabaseConnection connection,
                           java.lang.String query)

Method Detail

createFetcher

public DataRecordFetcher createFetcher()

Description copied from class: DataRecordSource

Creates a new fetcher to gather data for a new iteration.

Specified by:

createFetcher in class DataRecordSource

close

public void close()

getQuery

public java.lang.String getQuery()

setQuery

public void setQuery(java.lang.String newQuery)