From 395752d710d5d6911168db0356c6bf142adb8d80 Mon Sep 17 00:00:00 2001 From: erilong Date: Fri, 18 Apr 2008 14:18:59 +0000 Subject: [PATCH] error is caught and logged by caller --- .../service/impl/IncomingBatchService.java | 27 ++++++++----------- 1 file changed, 11 insertions(+), 16 deletions(-) diff --git a/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java b/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java index c5a6618db3..bece195849 100644 --- a/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java +++ b/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java @@ -109,22 +109,17 @@ public int updateIncomingBatch(IncomingBatch status) { } public void insertIncomingBatchHistory(IncomingBatchHistory history) { - try { - jdbcTemplate.update(insertIncomingBatchHistorySql, new Object[] { - Long.valueOf(history.getBatchId()), history.getNodeId(), history.getStatus().toString(), - history.getNetworkMillis(), history.getFilterMillis(), history.getDatabaseMillis(), - history.getHostName(), history.getByteCount(), history.getStatementCount(), - history.getFallbackInsertCount(), history.getFallbackUpdateCount(), - history.getMissingDeleteCount(), history.getFailedRowNumber(), history.getStartTime(), - history.getEndTime(), history.getSqlState(), history.getSqlCode(), - StringUtils.abbreviate(history.getSqlMessage(), 50) }, new int[] { Types.INTEGER, Types.VARCHAR, Types.CHAR, - Types.INTEGER, Types.INTEGER, Types.INTEGER, Types.VARCHAR, Types.INTEGER, Types.INTEGER, - Types.INTEGER, Types.INTEGER, Types.INTEGER, Types.INTEGER, Types.TIMESTAMP, - Types.TIMESTAMP, Types.VARCHAR, Types.INTEGER, Types.VARCHAR }); - } catch (RuntimeException ex) { - logger.error(ex, ex); - throw ex; - } + jdbcTemplate.update(insertIncomingBatchHistorySql, new Object[] { Long.valueOf(history.getBatchId()), + history.getNodeId(), history.getStatus().toString(), history.getNetworkMillis(), + history.getFilterMillis(), history.getDatabaseMillis(), history.getHostName(), + history.getByteCount(), history.getStatementCount(), history.getFallbackInsertCount(), + history.getFallbackUpdateCount(), history.getMissingDeleteCount(), + history.getFailedRowNumber(), history.getStartTime(), history.getEndTime(), + history.getSqlState(), history.getSqlCode(), + StringUtils.abbreviate(history.getSqlMessage(), 50) }, new int[] { Types.INTEGER, + Types.VARCHAR, Types.CHAR, Types.INTEGER, Types.INTEGER, Types.INTEGER, Types.VARCHAR, + Types.INTEGER, Types.INTEGER, Types.INTEGER, Types.INTEGER, Types.INTEGER, Types.INTEGER, + Types.TIMESTAMP, Types.TIMESTAMP, Types.VARCHAR, Types.INTEGER, Types.VARCHAR }); } class IncomingBatchMapper implements RowMapper {