com.partnersoft.io

Class DataRecordCopier

java.lang.Object

com.partnersoft.io.DataRecordCopier

public class DataRecordCopier
extends java.lang.Object

Handles copying values from a DataRecordSource into a DataRecordSink.

Copyright 2009 Partner Software, Inc.

Author:

Rich Stepanski

Constructor Summary

Constructors

Constructor and Description
DataRecordCopier(DataRecordSource source, DataRecordSink sink) Creates a new DataRecordCopier.
DataRecordCopier(DataRecordSource source, DataRecordSink sink, Naming<java.lang.String> fieldMapping) Creates a new DataRecordCopier.

Method Summary

Methods

Modifier and Type	Method and Description
int	copy() Copies all values in source into sink.
int	copy(boolean closeSink, boolean closeSource) Copies all values in source into sink.

Methods inherited from class java.lang.Object

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

Constructor Detail

DataRecordCopier

public DataRecordCopier(DataRecordSource source,
                DataRecordSink sink)

Creates a new DataRecordCopier. Assumes field names to copy from source match those to copy into sink.

Parameters:

source - - DataRecordSource to read from

sink - - DataRecordSink to write to

DataRecordCopier

public DataRecordCopier(DataRecordSource source,
                DataRecordSink sink,
                Naming<java.lang.String> fieldMapping)

Creates a new DataRecordCopier. Uses passed fieldMapping to copy values from source into sink.

fieldMapping is source field names keyed to destination field names.

Parameters:

source - - DataRecordSource to read from

sink - - DataRecordSink to write to

fieldMapping - - Naming of source field names to destination sink names

Method Detail

copy

public int copy()
         throws java.lang.Exception

Copies all values in source into sink. Closes both sink and source when copy completes.

Returns:

number of records copied.

Throws:

java.lang.Exception - if a problem occurs during read/write

copy

public int copy(boolean closeSink,
       boolean closeSource)
         throws java.lang.Exception

Copies all values in source into sink.

Parameters:

closeSink - - if true, closes sink after copy.

closeSource - - if true, closes source after copy.

Returns:

number of records copied.

Throws:

java.lang.Exception - if a problem occurs during read/write