Support JDBCWriter for singlestep batch

resolves 677

Author: cppwfs

spring-cloud-starter-single-step-batch-job/src/main/java/org/springframework/cloud/task/batch/autoconfigure/jdbc/JdbcItemWriterAutoConfiguration.java

@@ -0,0 +1,85 @@
+/*
+ * Copyright 2020-2020 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.task.batch.autoconfigure.jdbc;
+
+import java.util.Map;
+
+import javax.sql.DataSource;
+
+import org.springframework.batch.item.ItemWriter;
+import org.springframework.batch.item.database.ItemPreparedStatementSetter;
+import org.springframework.batch.item.database.ItemSqlParameterSourceProvider;
+import org.springframework.batch.item.database.builder.JdbcBatchItemWriterBuilder;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.AutoConfigureAfter;
+import org.springframework.boot.autoconfigure.batch.BatchAutoConfiguration;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * Autconfiguration for a {@code JdbcBatchItemWriter}.
+ *
+ * @author Glenn Renfro
+ * @since 2.3
+ */
+@Configuration
+@EnableConfigurationProperties(JdbcItemWriterProperties.class)
+@AutoConfigureAfter(BatchAutoConfiguration.class)
+public class JdbcItemWriterAutoConfiguration {
+
+	@Autowired(required = false)
+	private ItemPreparedStatementSetter itemPreparedStatementSetter;
+
+	@Autowired(required = false)
+	private ItemSqlParameterSourceProvider itemSqlParameterSourceProvider;
+
+	private JdbcItemWriterProperties properties;
+
+	private DataSource dataSource;
+
+	public JdbcItemWriterAutoConfiguration(DataSource dataSource,
+			JdbcItemWriterProperties properties) {
+		this.dataSource = dataSource;
+		this.properties = properties;
+	}
+
+	@Bean
+	@ConditionalOnMissingBean
+	@ConditionalOnProperty(prefix = "spring.batch.job.jdbcwriter", name = "name")
+	public ItemWriter<Map<Object, Object>> itemWriter() {
+
+		JdbcBatchItemWriterBuilder<Map<Object, Object>> jdbcBatchItemWriterBuilder = new JdbcBatchItemWriterBuilder<Map<Object, Object>>()
+				.dataSource(this.dataSource).sql(this.properties.getSql());
+		if (this.itemPreparedStatementSetter != null) {
+			jdbcBatchItemWriterBuilder
+					.itemPreparedStatementSetter(this.itemPreparedStatementSetter);
+		}
+		else if (this.itemSqlParameterSourceProvider != null) {
+			jdbcBatchItemWriterBuilder
+					.itemSqlParameterSourceProvider(this.itemSqlParameterSourceProvider);
+		}
+		else {
+			jdbcBatchItemWriterBuilder.columnMapped();
+		}
+		jdbcBatchItemWriterBuilder.assertUpdates(this.properties.isAssertUpdates());
+		return jdbcBatchItemWriterBuilder.build();
+	}
+
+}

spring-cloud-starter-single-step-batch-job/src/main/java/org/springframework/cloud/task/batch/autoconfigure/jdbc/JdbcItemWriterProperties.java

@@ -0,0 +1,86 @@
+/*
+ * Copyright 2020-2020 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.task.batch.autoconfigure.jdbc;
+
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+/**
+ * Properties to configure a {@code JdbcItemWriter}.
+ *
+ * @author Glenn Renfro
+ * @since 2.3
+ */
+@ConfigurationProperties(prefix = "spring.batch.job.jdbcwriter")
+public class JdbcItemWriterProperties {
+
+	private String name;
+
+	private String sql;
+
+	private boolean assertUpdates = true;
+
+	/**
+	 * @return The current sql statement used to update the database.
+	 */
+	public String getSql() {
+		return sql;
+	}
+
+	/**
+	 * Sets the sql statement to be used to update the database.
+	 * @param sql the sql statement to be used.
+	 */
+	public void setSql(String sql) {
+		this.sql = sql;
+	}
+
+	/**
+	 * @return if returns true then each insert will be confirmed to have at least one
+	 * insert in the database.
+	 */
+	public boolean isAssertUpdates() {
+		return assertUpdates;
+	}
+
+	/**
+	 * If set to true, confirms that every insert results in the update of at least one
+	 * row in the database. Defaults to True
+	 */
+	public void setAssertUpdates(boolean assertUpdates) {
+		this.assertUpdates = assertUpdates;
+	}
+
+	/**
+	 * Returns the configured value of the name used to calculate {@code ExecutionContext}
+	 * keys.
+	 * @return the name
+	 */
+	public String getName() {
+		return name;
+	}
+
+	/**
+	 * The name used to calculate the key within the
+	 * {@link org.springframework.batch.item.ExecutionContext}.
+	 * @param name name of the writer instance
+	 * @see org.springframework.batch.item.ItemStreamSupport#setName(String)
+	 */
+	public void setName(String name) {
+		this.name = name;
+	}
+
+}

spring-cloud-starter-single-step-batch-job/src/main/resources/META-INF/spring.factories

@@ -1,4 +1,5 @@
 org.springframework.boot.autoconfigure.EnableAutoConfiguration=org.springframework.cloud.task.batch.autoconfigure.FlatFileItemReaderAutoConfiguration,\
   org.springframework.cloud.task.batch.autoconfigure.RangeConverter,\
   org.springframework.cloud.task.batch.autoconfigure.SingleStepJobAutoConfiguration,\
-  org.springframework.cloud.task.batch.autoconfigure.FlatFileItemWriterAutoConfiguration
+  org.springframework.cloud.task.batch.autoconfigure.FlatFileItemWriterAutoConfiguration, \
+  org.springframework.cloud.task.batch.autoconfigure.jdbc.JdbcItemWriterAutoConfiguration