`
frankensteinlin
  • 浏览: 55212 次
  • 性别: Icon_minigender_1
  • 来自: ShangHai
社区版块
存档分类
最新评论

spring batch 之 编程事务

阅读更多
Spring batch 的writer有本身自己的事务:
比如读取txt文件到第几行了,写到第几行了,step做到哪里了?读了几行需要提交了?这些信息都会写入到数据库中去。

而我们自己的writer也会写数据到数据库中去,这里就有一个transaction同步的问题。
SPRING 的基础设施就很好的解决了这个问题。

看如下代码:
	/**
	 * @see ItemWriter#write(Object)
	 */
	public void write(List<? extends Object> data) throws Exception {
		TestBean rs=null;
		for(Object line : data){
			rs=(TestBean)line;
		}
		
		final Object[] params=new Object[2];
		params[0]=rs.getName();
		params[1]=rs.getAge();
		System.out.println(ToStringBuilder.reflectionToString(rs));
		
		
		TransactionTemplate transactionTemplate = new TransactionTemplate(new DataSourceTransactionManager(dataSource));
		transactionTemplate.execute(new TransactionCallback() {
			public Object doInTransaction(TransactionStatus arg0) {
				JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
				jdbcTemplate.update("insert into BATCH_TEST(NAME,AGE) VALUES(?,?)",params);
				return null;
			}
		});
		
	}


Spring的transaction的关于jdbc数据源的处理基本有下面两部分组成:
  transactionTemplate: 用于组织事务。
  DataSourceTransactionManager:用于同步框架中的事务,其实利用的是localthread
  dataSource 是管理connection的。
jdbcTemplate 用来执行相应的sql。
分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics