用户注册



邮箱:

密码:

用户登录


邮箱:

密码:
记住登录一个月忘记密码?

发表随想


还能输入:200字
云代码 - jsp代码库

Spring 使用TransactionTemplate进行事务管理

2012-10-25 作者: 神马举报

[jsp]代码库

import java.sql.ResultSet;
import java.sql.SQLException;

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowCallbackHandler;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.TransactionCallback;
import org.springframework.transaction.support.TransactionTemplate;

import com.sunflower.entity.People;

/**
 * 
 * Spring 使用TransactionTemplate进行事务管理
 * 
 * @author Caihanyuan
 * @time 2012-10-7 下午03:50:45
 * 
 */
public class BankDaoImp implements BankDao {
	private JdbcTemplate jdbcTemplate;
	private TransactionTemplate transactionTemplate;

	public JdbcTemplate getJdbcTemplate() {
		return jdbcTemplate;
	}

	public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
		this.jdbcTemplate = jdbcTemplate;
	}

	public TransactionTemplate getTransactionTemplate() {
		return transactionTemplate;
	}

	public void setTransactionTemplate(TransactionTemplate transactionTemplate) {
		this.transactionTemplate = transactionTemplate;
	}

	@Override
	public double getMoney(final People people) {
		double money = people.getMoney();
		// 开始事务,如果出现状况则回滚
		transactionTemplate.execute(new TransactionCallback<People>() {
			@Override
			public People doInTransaction(TransactionStatus ts) {
				try {
					final People people2 = new People();
					// 使用JdbcTemplate进行持久化层操作
					String sql = "select money from bank where name = ?";
					Object[] params = new Object[] { people.getName() };
					// 查询
					jdbcTemplate.query(sql, params, new RowCallbackHandler() {
						@Override
						public void processRow(ResultSet rs)
								throws SQLException {
							people2.setMoney(rs.getDouble("money"));
							System.out.println(people.getName() + "用户还有"
									+ rs.getDouble("money") + "元余款");
							System.out.println(people.getName() + "要从账户中取出"
									+ people.getMoney() + "元");
							if (people2.getMoney() < people.getMoney()) {
								System.out.println("余额不足");
								people.setMoney(-1);
								return;
							}
						}
					});

					if (people.getMoney() < 0)
						return null;
					else {
						sql = "update bank set money = ? where name = ?";
						Object[] params2 = new Object[] {
								people2.getMoney() - people.getMoney(),
								people.getName() };
						jdbcTemplate.update(sql, params2);
						System.out.println("剩余余额:"
								+ (people2.getMoney() - people.getMoney()));
					}
				} catch (Exception e) {
					ts.setRollbackOnly();
				}

				// 如果成功,事务被提交
				return people;
			}
		});

		return people.getMoney();
	}
}


网友评论    (发表评论)


发表评论:

评论须知:

  • 1、评论每次加2分,每天上限为30;
  • 2、请文明用语,共同创建干净的技术交流环境;
  • 3、若被发现提交非法信息,评论将会被删除,并且给予扣分处理,严重者给予封号处理;
  • 4、请勿发布广告信息或其他无关评论,否则将会删除评论并扣分,严重者给予封号处理。


扫码下载

加载中,请稍后...

输入口令后可复制整站源码

加载中,请稍后...