org.hsqldb.rowio

Class RowInputText

java.lang.Object

java.io.InputStream

org.hsqldb.lib.HsqlByteArrayInputStream

org.hsqldb.rowio.RowInputText

All Implemented Interfaces:

java.io.Closeable, java.io.DataInput, java.lang.AutoCloseable, RowInputInterface

Direct Known Subclasses:

RowInputTextQuoted

public class RowInputText
extends HsqlByteArrayInputStream
implements RowInputInterface

Class for reading the data for a database row in text table format.

Since:

1.7.0

Constructor Summary

Constructors

Constructor and Description
RowInputText(java.lang.String fieldSep, java.lang.String varSep, java.lang.String longvarSep, boolean allQuoted) fredt@users - comment - in future may use a custom subclasse of InputStream to read the data.

Method Summary

Modifier and Type	Method and Description
byte[]	getBuffer()
int	getLineNumber()
long	getPos()
int	getSize()
java.lang.Object	readData(Type type)
java.lang.Object[]	readData(Type[] colTypes) reads row data from a stream using the JDBC types in colTypes
int	readInt()
java.lang.String	readLine()
long	readLong()
short	readShort()
java.lang.String	readString()
int	readType()
void	reset()
void	resetBlock(long filepos, int rowsize) Used to reset the row, ready for a new row to be written into the byte[] buffer by an external routine.
void	resetRow(long filepos, int rowsize) Used to reset the row, ready for a new row to be written into the byte[] buffer by an external routine.
void	setSource(java.lang.String text, long pos, int byteSize)
int	skipBytes(int n)
void	skippedLine()

Methods inherited from class org.hsqldb.lib.HsqlByteArrayInputStream

available, close, mark, markSupported, read, read, readBoolean, readByte, readChar, readDouble, readFloat, readFully, readFully, readUnsignedByte, readUnsignedShort, readUTF, skip

Methods inherited from class java.io.InputStream

read

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.hsqldb.rowio.RowInputInterface

getBuffer, getPos, getSize, readByte, readChar, readData, resetBlock, resetRow

Constructor Detail

RowInputText

public RowInputText(java.lang.String fieldSep,
                    java.lang.String varSep,
                    java.lang.String longvarSep,
                    boolean allQuoted)

fredt@users - comment - in future may use a custom subclasse of InputStream to read the data.

Method Detail

setSource

public void setSource(java.lang.String text,
                      long pos,
                      int byteSize)

readString

public java.lang.String readString()
                            throws java.io.IOException

Specified by:

readString in interface RowInputInterface

Throws:

java.io.IOException

readShort

public short readShort()
                throws java.io.IOException

Specified by:

readShort in interface java.io.DataInput

Specified by:

readShort in interface RowInputInterface

Overrides:

readShort in class HsqlByteArrayInputStream

Throws:

java.io.IOException

readInt

public int readInt()
            throws java.io.IOException

Specified by:

readInt in interface java.io.DataInput

Specified by:

readInt in interface RowInputInterface

Overrides:

readInt in class HsqlByteArrayInputStream

Throws:

java.io.IOException

readLong

public long readLong()
              throws java.io.IOException

Specified by:

readLong in interface java.io.DataInput

Specified by:

readLong in interface RowInputInterface

Overrides:

readLong in class HsqlByteArrayInputStream

Throws:

java.io.IOException

readType

public int readType()
             throws java.io.IOException

Specified by:

readType in interface RowInputInterface

Throws:

java.io.IOException

getLineNumber

public int getLineNumber()

skippedLine

public void skippedLine()

reset

public void reset()

Overrides:

reset in class HsqlByteArrayInputStream

getPos

public long getPos()

getSize

public int getSize()

readData

public java.lang.Object[] readData(Type[] colTypes)
                            throws java.io.IOException

reads row data from a stream using the JDBC types in colTypes

Parameters:

colTypes -

Throws:

java.io.IOException

readData

public java.lang.Object readData(Type type)
                          throws java.io.IOException

Throws:

java.io.IOException

resetRow

public void resetRow(long filepos,
                     int rowsize)

Used to reset the row, ready for a new row to be written into the byte[] buffer by an external routine.

resetBlock

public void resetBlock(long filepos,
                       int rowsize)

Used to reset the row, ready for a new row to be written into the byte[] buffer by an external routine.

getBuffer

public byte[] getBuffer()

skipBytes

public int skipBytes(int n)
              throws java.io.IOException

Specified by:

skipBytes in interface java.io.DataInput

Overrides:

skipBytes in class HsqlByteArrayInputStream

Throws:

java.io.IOException

readLine

public java.lang.String readLine()
                          throws java.io.IOException

Specified by:

readLine in interface java.io.DataInput

Overrides:

readLine in class HsqlByteArrayInputStream

Throws:

java.io.IOException