Added connectionAutoCommit property in JdbcCursorItemReaderBuilder

spring-batch-infrastructure/src/main/java/org/springframework/batch/item/database/builder/JdbcCursorItemReaderBuilder.java

@@ -69,6 +69,8 @@ public class JdbcCursorItemReaderBuilder<T> {
 
 	private int currentItemCount;
 
+	private boolean connectionAutoCommit;
+
 	/**
 	 * Configure if the state of the {@link org.springframework.batch.item.ItemStreamSupport}
 	 * should be persisted within the {@link org.springframework.batch.item.ExecutionContext}
@@ -308,15 +310,15 @@ public JdbcCursorItemReaderBuilder<T> rowMapper(RowMapper<T> rowMapper) {
 	}
 
 	/**
-	 * Creates a {@link BeanPropertyRowMapper} to be used as your
-	 * {@link RowMapper}.
+	 * Set whether "autoCommit" should be overridden for the connection used by the cursor. If not set, defaults to
+	 * Connection / Datasource default configuration.
 	 *
-	 * @param mappedClass the class for the row mapper
+	 * @param connectionAutoCommit value to set on underlying JDBC connection
 	 * @return this instance for method chaining
-	 * @see BeanPropertyRowMapper
+	 * @see JdbcCursorItemReader#setConnectionAutoCommit(boolean)
 	 */
-	public JdbcCursorItemReaderBuilder<T> beanRowMapper(Class<T> mappedClass) {
-		this.rowMapper = new BeanPropertyRowMapper<>(mappedClass);
+	public JdbcCursorItemReaderBuilder<T> connectionAutoCommit(boolean connectionAutoCommit) {
+		this.connectionAutoCommit = connectionAutoCommit;
 
 		return this;
 	}
@@ -356,6 +358,7 @@ public JdbcCursorItemReader<T> build() {
 		reader.setQueryTimeout(this.queryTimeout);
 		reader.setUseSharedExtendedConnection(this.useSharedExtendedConnection);
 		reader.setVerifyCursorPosition(this.verifyCursorPosition);
+		reader.setConnectionAutoCommit(this.connectionAutoCommit);
 
 		return reader;
 	}