import org.springframework.batch.item.database.BeanPropertyItemSqlParameterSourceProvider; //导入依赖的package包/类
@Bean
@StepScope
public JdbcBatchItemWriter<Customer> customerItemWriter() {
	JdbcBatchItemWriter<Customer> itemWriter = new JdbcBatchItemWriter<>();

	itemWriter.setDataSource(this.dataSource);
	itemWriter.setSql("INSERT INTO NEW_CUSTOMER VALUES (:id, :firstName, :lastName, :birthdate)");
	itemWriter.setItemSqlParameterSourceProvider(new BeanPropertyItemSqlParameterSourceProvider());
	itemWriter.afterPropertiesSet();

	return itemWriter;
}
 

import org.springframework.batch.item.database.BeanPropertyItemSqlParameterSourceProvider; //导入依赖的package包/类
@Bean
JdbcBatchItemWriter<Person> jdbcBatchItemWriter(DataSource h2) {
    JdbcBatchItemWriter<Person> w = new JdbcBatchItemWriter<>();
    w.setDataSource(h2);
    w.setSql("insert into PEOPLE( first, last, email) values ( :first, :last, :email )");
    w.setItemSqlParameterSourceProvider(new BeanPropertyItemSqlParameterSourceProvider<>());
    return w;
}
 

import org.springframework.batch.item.database.BeanPropertyItemSqlParameterSourceProvider; //导入依赖的package包/类
@Bean
public JdbcBatchItemWriter<Item> jdbcBatchItemWriter(){
	JdbcBatchItemWriter<Item> itemWriter = new JdbcBatchItemWriter<Item>();
	itemWriter.setSql("INSERT INTO ITEM (ID, DESCRIPTION) VALUES (:id,:description)");
	itemWriter.setDataSource(dataSource);
	itemWriter.setItemSqlParameterSourceProvider(new BeanPropertyItemSqlParameterSourceProvider<Item>());
	return itemWriter;
}
 

import org.springframework.batch.item.database.BeanPropertyItemSqlParameterSourceProvider; //导入依赖的package包/类
@Bean(name = readCsvFileIntoTableStepWriter)
public JdbcBatchItemWriter<Customer> writer(DataSource dataSource) throws Exception {
    JdbcBatchItemWriter<Customer> jdbcBatchItemWriter = new JdbcBatchItemWriter<Customer>();
    jdbcBatchItemWriter.setAssertUpdates(true);
    jdbcBatchItemWriter.setDataSource(dataSource);
    jdbcBatchItemWriter.setSql(" INSERT INTO customer( first_name, last_name) VALUES ( :firstName , :lastName ) ");
    jdbcBatchItemWriter.setItemSqlParameterSourceProvider(new BeanPropertyItemSqlParameterSourceProvider<Customer>());
    return jdbcBatchItemWriter;
}
 

import org.springframework.batch.item.database.BeanPropertyItemSqlParameterSourceProvider; //导入依赖的package包/类
@Bean
public ItemWriter<Person> dbWriter() {
    JdbcBatchItemWriter<Person> writer = new JdbcBatchItemWriter<>();
    writer.setItemSqlParameterSourceProvider(new BeanPropertyItemSqlParameterSourceProvider<Person>());
    writer.setSql("INSERT INTO person (login, passwd, age) VALUES (:login,:passwd,:age)");
    writer.setDataSource(dataSource);
    return writer;
}
 

import org.springframework.batch.item.database.BeanPropertyItemSqlParameterSourceProvider; //导入依赖的package包/类
@Bean
public JdbcBatchItemWriter<Item> jdbcBatchItemWriter(){
	JdbcBatchItemWriter<Item> itemWriter = new JdbcBatchItemWriter<Item>();
	itemWriter.setSql("INSERT INTO ITEM (ID, DESCRIPTION, FIRST_ACTION, SECOND_ACTION) VALUES (:id,:description,:firstAction,:secondAction)");
	itemWriter.setDataSource(dataSource);
	itemWriter.setItemSqlParameterSourceProvider(new BeanPropertyItemSqlParameterSourceProvider<Item>());
	return itemWriter;
}
 

import org.springframework.batch.item.database.BeanPropertyItemSqlParameterSourceProvider; //导入依赖的package包/类
public ConferenceItemWriter(DataSource ds) {
	super();
	setDataSource(ds);
	setSql("update conference set name=:name where id=:id");
	setItemSqlParameterSourceProvider(new BeanPropertyItemSqlParameterSourceProvider<Conference>() );
}