org.jeasy.batch.jdbc

Class JdbcRecordWriter

java.lang.Object

org.jeasy.batch.jdbc.JdbcRecordWriter

All Implemented Interfaces:

RecordWriter

public class JdbcRecordWriter
extends java.lang.Object
implements RecordWriter

Write records to a relational database using the JDBC API.

Author:

Mahmoud Ben Hassine (mahmoud.benhassine@icloud.com)

Constructor Summary

Constructors

Constructor and Description
JdbcRecordWriter(javax.sql.DataSource dataSource, java.lang.String query, PreparedStatementProvider preparedStatementProvider) Create a new JdbcRecordWriter.

Method Summary

Modifier and Type	Method and Description
void	close()
void	open()
void	writeRecords(Batch batch)

Methods inherited from class java.lang.Object

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

Constructor Detail

JdbcRecordWriter

public JdbcRecordWriter(javax.sql.DataSource dataSource,
                        java.lang.String query,
                        PreparedStatementProvider preparedStatementProvider)

Create a new JdbcRecordWriter.

Parameters:

dataSource - the JDBC data source

query - the query to insert data

preparedStatementProvider - the prepared statement provider to map data to the query parameters

Method Detail

open

public void open()
          throws java.lang.Exception

Specified by:

open in interface RecordWriter

Throws:

java.lang.Exception

writeRecords

public void writeRecords(Batch batch)
                  throws java.lang.Exception

Specified by:

writeRecords in interface RecordWriter

Throws:

java.lang.Exception

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface RecordWriter

Throws:

java.lang.Exception