javatools.database

Class Database.Inserter

java.lang.Object

javatools.database.Database.Inserter

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

Enclosing class:

Database

public class Database.Inserter
extends java.lang.Object
implements java.io.Closeable

Represents a bulk loader

Field Summary

Fields

Modifier and Type	Field and Description
protected SQLType[]	columnTypes Column types
protected java.lang.String	tableName Table where the data will be inserted
protected java.util.List<java.util.List<java.lang.Object>>	values the currently cached values

Constructor Summary

Constructors

Constructor and Description
Inserter(java.lang.String table) Creates a bulk loader
Inserter(java.lang.String table, java.lang.Class<?>... columnTypes) Creates a bulk loader for a table with column types given by Java classes
Inserter(java.lang.String table, int... columnTypes) Creates a bulk loader with column types from java.sql.Type
Inserter(java.lang.String table, java.lang.String[] colnames, java.lang.Class<?>[] coltypes) Creates a bulk loader for specific coloumns of a table with column types given by their names and Java classes

Method Summary

Modifier and Type	Method and Description
void	close() Flushes and closes
protected void	finalize()
void	flush() Flushes the batch
protected void	flush(java.util.List<java.util.List<java.lang.Object>> batch)
int	getBatchSize() returns the number of entries gathered
int	getBatchThreshold() returns the batch size set (i.e.
java.lang.String	getTableName() Returns the table name
void	insert(java.util.List<java.lang.Object> row) Inserts a row
void	insert(java.lang.Object... values) Inserts a row
int	numColumns() Returns the number of columns
void	setBatchThreshold(int size) Inserter - Attribute Accessors ****
protected void	setTargetTable(java.lang.String table) Sets the target table into which values shall be inserted
protected void	setTargetTable(java.lang.String table, java.lang.Class<?>... columnTypes) Sets the target table into which values shall be inserted with the types of the table columns explicitly given
protected void	setTargetTable(java.lang.String table, int... columnTypes) Sets the target table into which values shall be inserted with the types of the table columns explicitly given (as java.sql.Type types)
protected void	setTargetTable(java.lang.String table, java.lang.String[] colnames, java.lang.Class<?>[] coltypes)

Methods inherited from class java.lang.Object

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

Field Detail

values

protected java.util.List<java.util.List<java.lang.Object>> values

the currently cached values

tableName

protected java.lang.String tableName

Table where the data will be inserted

columnTypes

protected SQLType[] columnTypes

Column types

Constructor Detail

Inserter

public Inserter(java.lang.String table)
         throws java.sql.SQLException

Creates a bulk loader

Throws:

java.sql.SQLException

Inserter

public Inserter(java.lang.String table,
                java.lang.Class<?>... columnTypes)
         throws java.sql.SQLException

Creates a bulk loader for a table with column types given by Java classes

Throws:

java.sql.SQLException

Inserter

public Inserter(java.lang.String table,
                int... columnTypes)
         throws java.sql.SQLException

Creates a bulk loader with column types from java.sql.Type

Throws:

java.sql.SQLException

Inserter

public Inserter(java.lang.String table,
                java.lang.String[] colnames,
                java.lang.Class<?>[] coltypes)
         throws java.sql.SQLException

Creates a bulk loader for specific coloumns of a table with column types given by their names and Java classes

Throws:

java.sql.SQLException

Method Detail

close

public void close()

Flushes and closes

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

finalize

protected void finalize()

Overrides:

finalize in class java.lang.Object

setBatchThreshold

public void setBatchThreshold(int size)

Inserter - Attribute Accessors ****

getBatchThreshold

public int getBatchThreshold()

returns the batch size set (i.e. after how many entries gathered the inserter should be flushed)

getTableName

public java.lang.String getTableName()

Returns the table name

getBatchSize

public int getBatchSize()

returns the number of entries gathered

numColumns

public int numColumns()

Returns the number of columns

setTargetTable

protected void setTargetTable(java.lang.String table)
                       throws java.sql.SQLException

Sets the target table into which values shall be inserted

Throws:

java.sql.SQLException

setTargetTable

protected void setTargetTable(java.lang.String table,
                              java.lang.Class<?>... columnTypes)
                       throws java.sql.SQLException

Sets the target table into which values shall be inserted with the types of the table columns explicitly given

Throws:

java.sql.SQLException

setTargetTable

protected void setTargetTable(java.lang.String table,
                              int... columnTypes)
                       throws java.sql.SQLException

Sets the target table into which values shall be inserted with the types of the table columns explicitly given (as java.sql.Type types)

Throws:

java.sql.SQLException

setTargetTable

protected void setTargetTable(java.lang.String table,
                              java.lang.String[] colnames,
                              java.lang.Class<?>[] coltypes)
                       throws java.sql.SQLException

Throws:

java.sql.SQLException

insert

public void insert(java.util.List<java.lang.Object> row)
            throws java.sql.SQLException

Inserts a row

Throws:

java.sql.SQLException

insert

public void insert(java.lang.Object... values)
            throws java.sql.SQLException

Inserts a row

Throws:

java.sql.SQLException

flush

public void flush()
           throws java.sql.SQLException

Flushes the batch

Throws:

java.sql.SQLException

flush

protected void flush(java.util.List<java.util.List<java.lang.Object>> batch)
              throws java.sql.SQLException

Throws:

java.sql.SQLException