Package org.jumpmind.db.sql
Class JdbcSqlReadCursor<T>
java.lang.Object
org.jumpmind.db.sql.JdbcSqlReadCursor<T>
- All Implemented Interfaces:
ISqlReadCursor<T>
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected boolean
protected Connection
protected IConnectionHandler
protected ISqlRowMapper<T>
protected int
protected boolean
protected int
protected ResultSet
protected int
protected ResultSetMetaData
protected JdbcSqlTemplate
protected Statement
-
Constructor Summary
ConstructorsConstructorDescriptionJdbcSqlReadCursor
(JdbcSqlTemplate sqlTemplate, ISqlRowMapper<T> mapper, String sql, Object[] values, int[] types) JdbcSqlReadCursor
(JdbcSqlTemplate sqlTemplate, ISqlRowMapper<T> mapper, String sql, Object[] values, int[] types, IConnectionHandler connectionHandler, boolean returnLobObjects) -
Method Summary
Modifier and TypeMethodDescriptionfinal void
close()
protected static Row
getMapForRow
(ResultSet rs, ResultSetMetaData argResultSetMetaData, int columnCount, boolean readStringsAsBytes, boolean returnLobObjects) next()
-
Field Details
-
c
-
rs
-
st
-
autoCommitFlag
protected boolean autoCommitFlag -
mapper
-
sqlTemplate
-
rowNumber
protected int rowNumber -
originalIsolationLevel
protected int originalIsolationLevel -
rsMetaData
-
rsColumnCount
protected int rsColumnCount -
connectionHandler
-
returnLobObjects
protected boolean returnLobObjects
-
-
Constructor Details
-
JdbcSqlReadCursor
public JdbcSqlReadCursor() -
JdbcSqlReadCursor
public JdbcSqlReadCursor(JdbcSqlTemplate sqlTemplate, ISqlRowMapper<T> mapper, String sql, Object[] values, int[] types) -
JdbcSqlReadCursor
public JdbcSqlReadCursor(JdbcSqlTemplate sqlTemplate, ISqlRowMapper<T> mapper, String sql, Object[] values, int[] types, IConnectionHandler connectionHandler, boolean returnLobObjects)
-
-
Method Details
-
next
- Specified by:
next
in interfaceISqlReadCursor<T>
-
getMapForRow
protected static Row getMapForRow(ResultSet rs, ResultSetMetaData argResultSetMetaData, int columnCount, boolean readStringsAsBytes, boolean returnLobObjects) throws SQLException - Throws:
SQLException
-
close
public final void close()- Specified by:
close
in interfaceISqlReadCursor<T>
-