JDBC系列教程之八：事务-ACID

TxTest.java

package com.hyneng.jdbc;

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

/**

* 2010-10-07

* @author HuangYineng

*/

public class TxTest {

   public static void main(String[] args) throws  SQLException {

      test();

   }

   static void test() throws  SQLException {

      Connection conn = null;

      Statement st = null;

      ResultSet rs = null;

      try {

          conn = JdbcUtils.getConnection();

          //关闭自动提交

          conn.setAutoCommit(false);

          conn.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);

          st = conn.createStatement();

          String sql = "update user set money=money-10 where id=1";

          st.executeUpdate(sql);

          sql = "select money from user where id=2";

          rs = st.executeQuery(sql);

          float money = 0.0f;

          if (rs.next()) {

             money = rs.getFloat("money");

          }

          if (money > 400)

             throw new RuntimeException("已经超过最大值！");

          sql = "update user set money=money+10 where id=2";

          st.executeUpdate(sql);

          //手动提交

          conn.commit();

      } catch (SQLException e) {

          if (conn != null)

             //出现异常，回滚

             conn.rollback();

          throw e;

      } finally {

          JdbcUtils.free(rs, st,  conn);

      }

   }

}