diff --git a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/database/HibernateItemWriter.java b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/database/HibernateItemWriter.java index 395785f27..60f47cdb1 100644 --- a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/database/HibernateItemWriter.java +++ b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/database/HibernateItemWriter.java @@ -96,6 +96,10 @@ public class HibernateItemWriter implements ItemWriter, InitializingBean { */ protected void doWrite(HibernateOperations hibernateTemplate, List items) { + if (logger.isDebugEnabled()) { + logger.debug("Writing to Hibernate with " + items.size() + " items."); + } + if (!items.isEmpty()) { long saveOrUpdateCount = 0; for (T item : items) { diff --git a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/database/JpaItemWriter.java b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/database/JpaItemWriter.java index 117766d70..7447d8d7f 100644 --- a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/database/JpaItemWriter.java +++ b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/database/JpaItemWriter.java @@ -96,6 +96,10 @@ public class JpaItemWriter implements ItemWriter, InitializingBean { */ protected void doWrite(EntityManager entityManager, List items) { + if (logger.isDebugEnabled()) { + logger.debug("Writing to JPA with " + items.size() + " items."); + } + if (!items.isEmpty()) { long mergeCount = 0; for (T item : items) { diff --git a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/FlatFileItemWriter.java b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/FlatFileItemWriter.java index 30f26f7b3..4dcd9cc06 100644 --- a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/FlatFileItemWriter.java +++ b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/file/FlatFileItemWriter.java @@ -25,11 +25,14 @@ import java.nio.channels.FileChannel; import java.nio.charset.UnsupportedCharsetException; import java.util.List; +import org.apache.commons.logging.Log; +import org.apache.commons.logging.LogFactory; import org.springframework.batch.item.ExecutionContext; import org.springframework.batch.item.ItemStream; import org.springframework.batch.item.ItemStreamException; import org.springframework.batch.item.WriteFailedException; import org.springframework.batch.item.WriterNotOpenException; +import org.springframework.batch.item.database.JdbcBatchItemWriter; import org.springframework.batch.item.file.transform.LineAggregator; import org.springframework.batch.item.util.ExecutionContextUserSupport; import org.springframework.batch.item.util.FileUtils; @@ -56,6 +59,8 @@ import org.springframework.util.ClassUtils; public class FlatFileItemWriter extends ExecutionContextUserSupport implements ResourceAwareItemWriterItemStream, InitializingBean { + protected static final Log logger = LogFactory.getLog(JdbcBatchItemWriter.class); + private static final String DEFAULT_LINE_SEPARATOR = System.getProperty("line.separator"); private static final String WRITTEN_STATISTICS_NAME = "written"; @@ -182,6 +187,10 @@ public class FlatFileItemWriter extends ExecutionContextUserSupport implement throw new WriterNotOpenException("Writer must be open before it can be written to"); } + if (logger.isDebugEnabled()) { + logger.debug("Writing to flat file with " + items.size() + " items."); + } + OutputState state = getOutputState(); StringBuilder lines = new StringBuilder(); diff --git a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/jms/JmsItemWriter.java b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/jms/JmsItemWriter.java index d95dedbd3..588186f62 100644 --- a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/jms/JmsItemWriter.java +++ b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/jms/JmsItemWriter.java @@ -66,9 +66,15 @@ public class JmsItemWriter implements ItemWriter { * @see org.springframework.batch.item.ItemWriter#write(java.util.List) */ public void write(List items) throws Exception { + + if (logger.isDebugEnabled()) { + logger.debug("Writing to JMS with " + items.size() + " items."); + } + for (T item : items) { jmsTemplate.convertAndSend(item); } + } }