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 booleanprotected Connectionprotected IConnectionHandlerprotected ISqlRowMapper<T>protected intprotected booleanprotected intprotected ResultSetprotected intprotected ResultSetMetaDataprotected JdbcSqlTemplateprotected 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 voidclose()protected static RowgetMapForRow(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:
nextin 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:
closein interfaceISqlReadCursor<T>
-