com.asakusafw.windgate.jdbc

Class JdbcDrainDriver<T>

java.lang.Object

com.asakusafw.windgate.jdbc.JdbcDrainDriver<T>

Type Parameters:

T - the type of data model object

All Implemented Interfaces:

DrainDriver<T>, Preparable, Closeable, AutoCloseable

public class JdbcDrainDriver<T>
extends Object
implements DrainDriver<T>

An implementation of DrainDriver using JDBC.

Since:

0.2.2

Version:

0.9.0

Constructor Summary

Constructors

Constructor and Description
JdbcDrainDriver(JdbcProfile profile, JdbcScript<T> script, Connection connection, boolean truncateOnPrepare) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	close() Disposes this object.
void	prepare() Prepares this driver to invoke DrainDriver.put(Object) method.
void	put(T object) Puts each data model object into the connected resource.

Methods inherited from class java.lang.Object

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

Constructor Detail

JdbcDrainDriver

public JdbcDrainDriver(JdbcProfile profile,
                       JdbcScript<T> script,
                       Connection connection,
                       boolean truncateOnPrepare)

Creates a new instance.

Parameters:

profile - the profile of the target database

script - the script of this action

connection - the connection

truncateOnPrepare - true to truncate the target table on preparation

Throws:

IllegalArgumentException - if any parameter is null

Method Detail

prepare

public void prepare()
             throws IOException

Description copied from interface: DrainDriver

Prepares this driver to invoke DrainDriver.put(Object) method. This method will be invoked before DrainDriver.put(Object) only once. This operation can execute only on the same thread as created this object.

Specified by:

prepare in interface DrainDriver<T>

Specified by:

prepare in interface Preparable

Throws:

IOException - if failed to begin

put

public void put(T object)
         throws IOException

Description copied from interface: DrainDriver

Puts each data model object into the connected resource. This operation can execute only on the same thread as created this object.

Specified by:

put in interface DrainDriver<T>

Parameters:

object - the data model object to be put

Throws:

IOException - if failed to put data

close

public void close()
           throws IOException

Description copied from interface: DrainDriver

Disposes this object. This operation can execute only on the same thread as created this object.

Specified by:

close in interface DrainDriver<T>

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException - if failed to connect