public class SqlDataRecordInsertSink extends DataRecordSink
Copyright 2009 Partner Software, Inc.
| Constructor and Description |
|---|
SqlDataRecordInsertSink(SqlConnection connection,
java.lang.String tableName,
boolean closeWhenDone,
java.util.List<java.lang.String> fieldNames)
Creates a new SqlDataRecordInsertSink for inserting records to a given database.
|
SqlDataRecordInsertSink(SqlConnection connection,
java.lang.String tableName,
boolean closeWhenDone,
java.lang.String... fieldNames)
Creates a new SqlDataRecordInsertSink for inserting records to a given database.
|
| Modifier and Type | Method and Description |
|---|---|
void |
closeImp() |
void |
openImp() |
void |
writeImp(java.util.List<java.lang.Object> payload) |
void |
writeImp(Naming<java.lang.Object> payload) |
void |
writeImp(java.lang.Object... payload) |
close, getException, getFieldNames, open, write, write, writepublic SqlDataRecordInsertSink(SqlConnection connection, java.lang.String tableName, boolean closeWhenDone, java.util.List<java.lang.String> fieldNames)
connection - - SqlConnection for the database to insert to.fieldNames - - String list of field names to insert, in order.tableName - - Name of table to insert to.closeWhenDone - - if true, connection will be closed when close() is called.public SqlDataRecordInsertSink(SqlConnection connection, java.lang.String tableName, boolean closeWhenDone, java.lang.String... fieldNames)
connection - - SqlConnection for the database to insert to.tableName - - Name of table to insert to.closeWhenDone - - if true, connection will be closed when close() is called.fieldNames - - String array of field names to insert, in order.public void closeImp()
throws java.lang.Exception
closeImp in class DataRecordSinkjava.lang.Exceptionpublic void openImp()
throws java.lang.Exception
openImp in class DataRecordSinkjava.lang.Exceptionpublic void writeImp(Naming<java.lang.Object> payload) throws java.lang.Exception
writeImp in class DataRecordSinkjava.lang.Exceptionpublic void writeImp(java.lang.Object... payload)
throws java.lang.Exception
writeImp in class DataRecordSinkjava.lang.Exceptionpublic void writeImp(java.util.List<java.lang.Object> payload)
throws java.lang.Exception
writeImp in class DataRecordSinkjava.lang.Exception