Package com.illumon.intradaylogger

Class SQLReplicationRow

java.lang.Object

com.illumon.intradaylogger.SQLReplicationRow

All Implemented Interfaces:

SystemInputRow

public class SQLReplicationRow
extends Object
implements SystemInputRow

A thin wrapper for ResultSet consumed by the SQLReplicationLogger. This provides a few services that makes it nicer to generate loggers for SQL replication: - Converts SQLExeptions to IOException for consistency with existing logger classes. - Converts SQL types to Iris types where appropriate. - Convert SQL nulls to the Iris-equivalent null values for primitive types.

Constructor Summary

Constructors

Constructor	Description
SQLReplicationRow(ResultSet resultSet)

Method Summary

Modifier and Type	Method	Description
BigDecimal	getBigDecimal(String name)	Get JDBC BigDecimal (numeric/decimal)
Boolean	getBoolean(String name)	Get an SQL bit/boolean integer as an Iris Boolean
byte	getByte(String name)	Get an SQL tinyint/byte as an Iris byte (converting NULL to the Iris equivalent value).
byte[]	getBytes(String name)	Get a SQL binary value as a byte array.
String	getBytesAsString(String name)	Get an SQL binary value converted to a string.
char	getChar(String name)	Convert JDBC text/varchar/char to Iris char.
Date	getDate(String name)	Get an SQL date
long	getDateAsMillis(String name)	Get an SQL date as millis
long	getDateAsNanos(String name)	Get an SQL date as nanos.
double	getDouble(String name)	Convert JDBC double to Iris double (converting NULL to the Iris equivalent value).
float	getFloat(String name)	Convert JDBC integer to Iris double
int	getInt(String name)	Get an SQL integer as an Iris int (converting NULL to the Iris equivalent value).
long	getLong(String name)	Get an SQL bigint/long as an Iris long (converting NULL to the Iris equivalent value).
short	getShort(String name)	Get an SQL short integer as an Iris short (converting NULL to the Iris equivalent value).
String	getString(String name)	Get string column value.
Time	getTime(String name)	Get an SQL time
long	getTimeAsMillis(String name)	Get an SQL time in millis
long	getTimeAsNanos(String name)	Get an SQL time in nanos.
Timestamp	getTimestamp(String name)	Get an SQL timestamp
long	getTimestampAsMillis(String name)	Get an SQL timestamp in millis
long	getTimestampAsNanos(String name)	Get an SQL timestamp in nanos

Methods inherited from class java.lang.Object

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

Constructor Details

SQLReplicationRow

public SQLReplicationRow(ResultSet resultSet)

Method Details

getBoolean

public Boolean getBoolean(String name)
                   throws IOException

Get an SQL bit/boolean integer as an Iris Boolean

Specified by:

getBoolean in interface SystemInputRow

Parameters:

name -

Returns:

Throws:

IOException

getShort

public short getShort(String name)
               throws IOException

Get an SQL short integer as an Iris short (converting NULL to the Iris equivalent value).

Specified by:

getShort in interface SystemInputRow

Parameters:

name -

Returns:

Throws:

IOException

getInt

public int getInt(String name)
           throws IOException

Get an SQL integer as an Iris int (converting NULL to the Iris equivalent value).

Specified by:

getInt in interface SystemInputRow

Parameters:

name -

Returns:

Throws:

IOException

getLong

public long getLong(String name)
             throws IOException

Get an SQL bigint/long as an Iris long (converting NULL to the Iris equivalent value).

Specified by:

getLong in interface SystemInputRow

Parameters:

name -

Returns:

Throws:

IOException

getByte

public byte getByte(String name)
             throws IOException

Get an SQL tinyint/byte as an Iris byte (converting NULL to the Iris equivalent value).

Specified by:

getByte in interface SystemInputRow

Parameters:

name -

Returns:

Throws:

IOException

getDouble

public double getDouble(String name)
                 throws IOException

Convert JDBC double to Iris double (converting NULL to the Iris equivalent value).

Specified by:

getDouble in interface SystemInputRow

Throws:

IOException

getFloat

public float getFloat(String name)
               throws IOException

Convert JDBC integer to Iris double

Specified by:

getFloat in interface SystemInputRow

Parameters:

name -

Returns:

Throws:

IOException

getBigDecimal

public BigDecimal getBigDecimal(String name)
                         throws IOException

Get JDBC BigDecimal (numeric/decimal)

Specified by:

getBigDecimal in interface SystemInputRow

Parameters:

name -

Returns:

Throws:

IOException

getChar

public char getChar(String name)
             throws IOException

Convert JDBC text/varchar/char to Iris char. If the client is using this, we assume either the database type is of length 1 or they only care about the first character.

Specified by:

getChar in interface SystemInputRow

Parameters:

name -

Returns:

Throws:

IOException

getString

public String getString(String name)
                 throws IOException

Get string column value.

Specified by:

getString in interface SystemInputRow

Parameters:

name -

Returns:

Throws:

IOException

getDate

public Date getDate(String name)
             throws IOException

Get an SQL date

Specified by:

getDate in interface SystemInputRow

Parameters:

name -

Returns:

Throws:

IOException

getDateAsMillis

public long getDateAsMillis(String name)
                     throws IOException

Get an SQL date as millis

Specified by:

getDateAsMillis in interface SystemInputRow

Parameters:

name -

Returns:

Throws:

IOException

getDateAsNanos

public long getDateAsNanos(String name)
                    throws IOException

Get an SQL date as nanos. Note: These have only millisecond precision.

Specified by:

getDateAsNanos in interface SystemInputRow

Parameters:

name -

Returns:

Throws:

IOException

getTimestamp

public Timestamp getTimestamp(String name)
                       throws IOException

Get an SQL timestamp

Specified by:

getTimestamp in interface SystemInputRow

Parameters:

name -

Returns:

Throws:

IOException

getTimestampAsMillis

public long getTimestampAsMillis(String name)
                          throws IOException

Get an SQL timestamp in millis

Specified by:

getTimestampAsMillis in interface SystemInputRow

Parameters:

name -

Returns:

Throws:

IOException

getTimestampAsNanos

public long getTimestampAsNanos(String name)
                         throws IOException

Get an SQL timestamp in nanos

Specified by:

getTimestampAsNanos in interface SystemInputRow

Parameters:

name -

Returns:

Throws:

IOException

getTime

public Time getTime(String name)
             throws IOException

Get an SQL time

Specified by:

getTime in interface SystemInputRow

Parameters:

name -

Returns:

Throws:

IOException

getTimeAsMillis

public long getTimeAsMillis(String name)
                     throws IOException

Get an SQL time in millis

Specified by:

getTimeAsMillis in interface SystemInputRow

Parameters:

name -

Returns:

Throws:

IOException

getTimeAsNanos

public long getTimeAsNanos(String name)
                    throws IOException

Get an SQL time in nanos. Note: These have only millisecond precision.

Specified by:

getTimeAsNanos in interface SystemInputRow

Parameters:

name -

Returns:

Throws:

IOException

getBytes

public byte[] getBytes(String name)
                throws IOException

Get a SQL binary value as a byte array.

Specified by:

getBytes in interface SystemInputRow

Parameters:

name -

Returns:

Throws:

IOException

getBytesAsString

public String getBytesAsString(String name)
                        throws IOException

Get an SQL binary value converted to a string.

Specified by:

getBytesAsString in interface SystemInputRow

Parameters:

name -

Returns:

Throws:

IOException