Spring/spring-batch
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

RESOLVED - BATCH-909: Turn off getWarnings() call in JdbcCursorItemReader when ignoreWarnings is true

Browse Source 
getWarnings is called only if debug is enabled (given ignoreWarnings == true)
This commit is contained in:
robokaso
2008-11-10 15:06:50 +00:00
parent d789093217
commit 1074e2f72f
1 changed files with 14 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
spring-batch-infrastructure/src/main/java/org/springframework/batch/item/database/JdbcCursorItemReader.java
View File

@@ -178,7 +178,7 @@ public class JdbcCursorItemReader extends AbstractBufferedItemReaderItemStream i
preparedStatementSetter.setValues(preparedStatement);
}
this.rs = preparedStatement.executeQuery();
handleWarnings(preparedStatement.getWarnings());
handleWarnings(preparedStatement);
}
catch (SQLException se) {
close(null);
@@ -237,17 +237,22 @@ public class JdbcCursorItemReader extends AbstractBufferedItemReaderItemStream i
*
* @see org.springframework.jdbc.SQLWarningException
*/
private void handleWarnings(SQLWarning warnings) throws SQLWarningException {
private void handleWarnings(PreparedStatement pstmt) throws SQLWarningException, SQLException {
if (ignoreWarnings) {
SQLWarning warningToLog = warnings;
while (warningToLog != null) {
log.debug("SQLWarning ignored: SQL state '" + warningToLog.getSQLState() + "', error code '"
+ warningToLog.getErrorCode() + "', message [" + warningToLog.getMessage() + "]");
warningToLog = warningToLog.getNextWarning();
if (log.isDebugEnabled()) {
SQLWarning warningToLog = pstmt.getWarnings();
while (warningToLog != null) {
log.debug("SQLWarning ignored: SQL state '" + warningToLog.getSQLState() + "', error code '"
+ warningToLog.getErrorCode() + "', message [" + warningToLog.getMessage() + "]");
warningToLog = warningToLog.getNextWarning();
}
}
}
else if (warnings != null) {
throw new SQLWarningException("Warning not ignored", warnings);
else {
SQLWarning warnings = pstmt.getWarnings();
if (warnings != null) {
throw new SQLWarningException("Warning not ignored", warnings);
}
}
}