uk.org.ogsadai.converters.csv.resultset
Class ResultSetForwardOnly
java.lang.Object
|
+--uk.org.ogsadai.converters.csv.resultset.AbstractResultSet
|
+--uk.org.ogsadai.converters.csv.resultset.ResultSetForwardOnly
- All Implemented Interfaces:
- CSVHandler, java.sql.ResultSet
- public class ResultSetForwardOnly
- extends AbstractResultSet
A forward-only implementation of a java.sql.ResultSet
. This implementation is suitable for larger result sets as the data is made available when scrolling through the results.
- Author:
- The OGSA-DAI Team.
Fields inherited from interface java.sql.ResultSet |
CLOSE_CURSORS_AT_COMMIT, CONCUR_READ_ONLY, CONCUR_UPDATABLE, FETCH_FORWARD, FETCH_REVERSE, FETCH_UNKNOWN, HOLD_CURSORS_OVER_COMMIT, TYPE_FORWARD_ONLY, TYPE_SCROLL_INSENSITIVE, TYPE_SCROLL_SENSITIVE |
Methods inherited from class uk.org.ogsadai.converters.csv.resultset.AbstractResultSet |
cancelRowUpdates, clearWarnings, close, deleteRow, findColumn, getArray, getArray, getAsciiStream, getAsciiStream, getBigDecimal, getBigDecimal, getBigDecimal, getBigDecimal, getBinaryStream, getBinaryStream, getBlob, getBlob, getBoolean, getBoolean, getByte, getByte, getBytes, getBytes, getBytes64, getBytes64, getCharacterStream, getCharacterStream, getClob, getClob, getConcurrency, getCursorName, getDate, getDate, getDate, getDate, getDouble, getDouble, getFetchDirection, getFetchSize, getFloat, getFloat, getInt, getInt, getLong, getLong, getObject, getObject, getObject, getObject, getRef, getRef, getShort, getShort, getStatement, getString, getString, getTime, getTime, getTime, getTime, getTimestamp, getTimestamp, getTimestamp, getTimestamp, getUnicodeStream, getUnicodeStream, getURL, getURL, getWarnings, insertRow, moveToCurrentRow, moveToInsertRow, refreshRow, rowDeleted, rowInserted, rowUpdated, setFetchDirection, setFetchSize, updateArray, updateArray, updateAsciiStream, updateAsciiStream, updateBigDecimal, updateBigDecimal, updateBinaryStream, updateBinaryStream, updateBlob, updateBlob, updateBoolean, updateBoolean, updateByte, updateByte, updateBytes, updateBytes, updateCharacterStream, updateCharacterStream, updateClob, updateClob, updateDate, updateDate, updateDouble, updateDouble, updateFloat, updateFloat, updateInt, updateInt, updateLong, updateLong, updateNull, updateNull, updateObject, updateObject, updateObject, updateObject, updateRef, updateRef, updateRow, updateShort, updateShort, updateString, updateString, updateTime, updateTime, updateTimestamp, updateTimestamp, wasNull |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
COPYRIGHT_NOTICE
private static final java.lang.String COPYRIGHT_NOTICE
-
- See Also:
- Constant Field Values
mBufferSize
private int mBufferSize
-
mBuffer
private java.util.LinkedList mBuffer
-
mClosed
private boolean mClosed
-
mCurrentRow
private java.util.Vector mCurrentRow
-
mCursor
private int mCursor
-
mError
private java.lang.Throwable mError
-
ResultSetForwardOnly
public ResultSetForwardOnly()
setError
public void setError(java.lang.Throwable error)
-
Sets an error when there was a problem at the input provider.
-
- Parameters:
error
- Problem at input provider.
getError
public java.lang.Throwable getError()
-
Gets the current error state
-
- Returns:
- current error or
null
if there is no error.
putMetaData
public void putMetaData(java.sql.ResultSetMetaData metadata)
throws java.sql.SQLException
- Description copied from class:
AbstractResultSet
-
Associates
java.sql.ResultSetMetaData
object with ResultSet
.
-
- Specified by:
putMetaData
in interface CSVHandler
- Overrides:
putMetaData
in class AbstractResultSet
-
- Parameters:
metadata
-
java.sql.SQLException
- See Also:
CSVHandler.putMetaData(java.sql.ResultSetMetaData)
putRow
public void putRow(java.util.Vector row)
- Description copied from interface:
CSVHandler
-
Process or store a row of a CSV file.
-
- Specified by:
putRow
in interface CSVHandler
- Specified by:
putRow
in class AbstractResultSet
-
- Parameters:
row
- A Vector
of objects each representing a column value.
next
public boolean next()
throws java.sql.SQLException
-
- Specified by:
next
in interface java.sql.ResultSet
- Specified by:
next
in class AbstractResultSet
-
java.sql.SQLException
setBufferSize
public void setBufferSize(int size)
-
Set the size of the buffer (the maximum number of rows that are being stored).
-
- Parameters:
size
- Number of rows to buffer.
getBufferSize
public int getBufferSize()
-
Returns the current size of the buffer.
-
- Returns:
- maximum number of rows that are being stored.
getMetaData
public java.sql.ResultSetMetaData getMetaData()
throws java.sql.SQLException
-
- Specified by:
getMetaData
in interface java.sql.ResultSet
- Overrides:
getMetaData
in class AbstractResultSet
-
java.sql.SQLException
getCurrentRow
protected java.util.Vector getCurrentRow()
-
Returns the current row vector.
-
- Returns:
- current row
getColumn
protected java.lang.String getColumn(int column)
- Description copied from class:
AbstractResultSet
-
Returns the data of a column,
-
- Specified by:
getColumn
in class AbstractResultSet
-
- Parameters:
column
- Column index.
- Returns:
- data
getRow
public int getRow()
throws java.sql.SQLException
-
- Specified by:
getRow
in interface java.sql.ResultSet
- Specified by:
getRow
in class AbstractResultSet
-
java.sql.SQLException
getType
public int getType()
throws java.sql.SQLException
-
- Specified by:
getType
in interface java.sql.ResultSet
- Specified by:
getType
in class AbstractResultSet
-
java.sql.SQLException
afterLast
public void afterLast()
throws java.sql.SQLException
-
- Specified by:
afterLast
in interface java.sql.ResultSet
- Specified by:
afterLast
in class AbstractResultSet
-
java.sql.SQLException
beforeFirst
public void beforeFirst()
throws java.sql.SQLException
-
- Specified by:
beforeFirst
in interface java.sql.ResultSet
- Specified by:
beforeFirst
in class AbstractResultSet
-
java.sql.SQLException
first
public boolean first()
throws java.sql.SQLException
-
- Specified by:
first
in interface java.sql.ResultSet
- Specified by:
first
in class AbstractResultSet
-
java.sql.SQLException
isAfterLast
public boolean isAfterLast()
throws java.sql.SQLException
-
- Specified by:
isAfterLast
in interface java.sql.ResultSet
- Specified by:
isAfterLast
in class AbstractResultSet
-
java.sql.SQLException
isBeforeFirst
public boolean isBeforeFirst()
throws java.sql.SQLException
-
- Specified by:
isBeforeFirst
in interface java.sql.ResultSet
- Specified by:
isBeforeFirst
in class AbstractResultSet
-
java.sql.SQLException
isFirst
public boolean isFirst()
throws java.sql.SQLException
-
- Specified by:
isFirst
in interface java.sql.ResultSet
- Specified by:
isFirst
in class AbstractResultSet
-
java.sql.SQLException
isLast
public boolean isLast()
throws java.sql.SQLException
-
- Specified by:
isLast
in interface java.sql.ResultSet
- Specified by:
isLast
in class AbstractResultSet
-
java.sql.SQLException
last
public boolean last()
throws java.sql.SQLException
-
- Specified by:
last
in interface java.sql.ResultSet
- Specified by:
last
in class AbstractResultSet
-
java.sql.SQLException
previous
public boolean previous()
throws java.sql.SQLException
-
- Specified by:
previous
in interface java.sql.ResultSet
- Specified by:
previous
in class AbstractResultSet
-
java.sql.SQLException
absolute
public boolean absolute(int arg0)
throws java.sql.SQLException
-
- Specified by:
absolute
in interface java.sql.ResultSet
- Specified by:
absolute
in class AbstractResultSet
-
java.sql.SQLException
relative
public boolean relative(int arg0)
throws java.sql.SQLException
-
- Specified by:
relative
in interface java.sql.ResultSet
- Specified by:
relative
in class AbstractResultSet
-
java.sql.SQLException