Chinaunix首页 | 论坛 | 博客

Leungffy XUExueliangfei.blog.chinaunix.net

首页　| 　博文目录　| 　关于我

xueliangfei

  • 博客访问： 2316316
  • 博文数量： 252
  • 博客积分： 5472
  • 博客等级： 大校
  • 技术积分： 3107
  • 用 户 组： 普通用户
  • 注册时间： 2011-09-17 18:39
文章分类

全部博文（252）

文章存档

2012年（96）

2011年（156）

我的朋友
最近访客
推荐博文
相关博文
Java事务处理-JDBC事务例子

分类： Java

2011-12-08 16:53:11

买书的例子 程序应该将图书数量的操作和更新account用户余额的操作作为一个事务来处理，只有这两个操作都完成的情况下，才能提交事务，否则就回滚事务。
 
1  buy.html
  1. <html>
  2.     <head>
  3.         <title>购买图书</title>
  4.     </head>
  5.     <body>
  6.         购买《Servlet/JSP深入详解》<p>
  7.         <form action="trade" method="post">
  8.             输入用户名：&nbsp;&nbsp;<input type="text" name="userid"><br>
  9.             输入购买数量：<input type="text" name="quantity"><p>
  10.             <input type="reset" value="重填">
  11.             <input type="submit" value="购买">
  12.         </form>
  13.     </body>
  14. </html>
2  TradeServlet.java
 
  1. package servlet;

  3. import javax.servlet.*;
  4. import java.io.*;
  5. import javax.servlet.http.*;
  6. import java.sql.*;

  8. public class TradeServlet extends HttpServlet
  9. {
  10.     private String url;
  11.     private String user;
  12.     private String password;
  13.     
  14.     public void init() throws ServletException
  15.     {
  16.         ServletContext sc=getServletContext();
  17.         String driverClass=sc.getInitParameter("driverClass");
  18.         url=sc.getInitParameter("url");
  19.         user=sc.getInitParameter("user");
  20.         password=sc.getInitParameter("password");
  21.         try
  22.         {
  23.             Class.forName(driverClass);
  24.         }
  25.         catch(ClassNotFoundException ce)
  26.         {
  27.             throw new ServletException("加载数据库驱动失败！");
  28.         }
  29.     }
  30.     
  31.     public void doGet(HttpServletRequest req, HttpServletResponse resp)
  32.                throws ServletException,IOException
  33.     {
  34.         Connection conn=null;
  35.         Statement stmt=null;
  36.         PreparedStatement pstmt=null;
  37.         ResultSet rs=null;
  38.         
  39.         resp.setContentType("text/html;charset=gb2312");
  40.         PrintWriter out=resp.getWriter();
  41.         
  42.         req.setCharacterEncoding("gb2312");
  43.         
  44.         String userid=req.getParameter("userid");
  45.         String quantity=req.getParameter("quantity");
  46.         
  47.         if(null==userid || userid.equals("") ||
  48.            null==quantity || quantity.equals(""))
  49.         {
  50.             
  51.             out.println("错误的请求参数");
  52.             out.close();
  53.         }
  54.         else
  55.         {
  56.             try
  57.             {
  58.                 conn=DriverManager.getConnection(url,user,password);
  59.                 
  60.                 conn.setAutoCommit(false);
  61.                 conn.setTransactionIsolation(Connection.TRANSACTION_REPEATABLE_READ);
  62.                 
  63.                 stmt=conn.createStatement();
  64.                 rs=stmt.executeQuery("select price,amount from bookinfo where id=3");
  65.                 rs.next();
  66.                 float price=rs.getFloat(1);
  67.                 int amount=rs.getInt(2);
  68.                 
  69.                 int num=Integer.parseInt(quantity);
  70.                 if(amount>=num)
  71.                 {
  72.                     pstmt=conn.prepareStatement("update bookinfo set amount = ? where id = 3");
  73.                     pstmt.setInt(1,amount-num);
  74.                     pstmt.executeUpdate();
  75.                 }
  76.                 else
  77.                 {
  78.                     out.println("您所购买的图书库存数量不足。");
  79.                     out.close();
  80.                     return;
  81.                 }
  82.                 pstmt=conn.prepareStatement("select balance from account where userid = ?");
  83.                 pstmt.setString(1,userid);
  84.                 rs=pstmt.executeQuery();
  85.                 
  86.                 rs.next();
  87.                 float balance=rs.getFloat(1);
  88.                 
  89.                 float totalPrice=price*num;
  90.                 
  91.                 if(balance>=totalPrice)
  92.                 {
  93.                     pstmt=conn.prepareStatement("update account set balance = ? where userid = ?");
  94.                     pstmt.setFloat(1,balance-totalPrice);
  95.                     pstmt.setString(2,userid);
  96.                     pstmt.executeUpdate();
  97.                 }
  98.                 else
  99.                 {
  100.                     conn.rollback();
  101.                     out.println("您的余额不足。");
  102.                     out.close();
  103.                     return;
  104.                 }
  105.                 conn.commit();
  106.                 out.println("交易成功!");
  107.                 out.close();
  108.             }
  109.             catch(SQLException se)
  110.             {
  111.                 if(conn!=null)
  112.                 {
  113.                     try
  114.                     {
  115.                         conn.rollback();
  116.                     }
  117.                     catch(SQLException ***)
  118.                     {
  119.                         ***.printStackTrace();
  120.                     }
  121.                 }
  122.                 se.printStackTrace();
  123.             }
  124.             finally
  125.             {
  126.                 if(rs!=null)
  127.                 {
  128.                     try
  129.                     {
  130.                         rs.close();
  131.                     }
  132.                     catch(SQLException se)
  133.                     {
  134.                         se.printStackTrace();
  135.                     }
  136.                     rs=null;
  137.                 }
  138.                 if(stmt!=null)
  139.                 {
  140.                     try
  141.                     {
  142.                         stmt.close();
  143.                     }
  144.                     catch(SQLException se)
  145.                     {
  146.                         se.printStackTrace();
  147.                     }
  148.                     stmt=null;
  149.                 }
  150.                 if(pstmt!=null)
  151.                 {
  152.                     try
  153.                     {
  154.                         pstmt.close();
  155.                     }
  156.                     catch(SQLException se)
  157.                     {
  158.                         se.printStackTrace();
  159.                     }
  160.                     pstmt=null;
  161.                 }
  162.                 if(conn!=null)
  163.                 {
  164.                     try
  165.                     {
  166.                         conn.close();
  167.                     }
  168.                     catch(SQLException se)
  169.                     {
  170.                         se.printStackTrace();
  171.                     }
  172.                     conn=null;
  173.                 }
  174.             }
  175.         }
  176.     }
  177.     
  178.     public void doPost(HttpServletRequest req, HttpServletResponse resp)
  179.                throws ServletException,IOException
  180.     {
  181.         doGet(req,resp);
  182.     }
  183. }
 
 
1  44、45行 调用请求对象的getParameter()方法得到用户名和购买图书的数量
 
2  60行 调用Connection对象的setAutoCommit()方法 传递 false参数 取消自动提交
 
3  61行 调用Connection对象的setTransactionIsolation()方法设置事务的隔离等级为Repeatable Read
 
4  99行 如果用户的余额不足 那么这次交易失败 调用Connection的rollback()方法，回到交易开始之前的状态，也就是回到bookinfo表中书的书目没发生改变的时候
 
注意： 如果在调用rollback()方法之前调用了commit()方法，那么只能回滚到上一次调用commit()方法之后所作的改变
 
5  104行 若果所有的操作都成功了 调用Connection对象的commit()方法提交事务，也就是向数据库提交所有的改变
 
6  在交易过程中，若果发生了异常 那么就在114行 调用Connection对象的rollback()方法回滚所有的改变
 
 
上面这个servlet用到了两种方式保证交易的正常进行
 
1 利用异常处理机制 一旦交易过程发生异常 就取消所有的改变
2 在交易的业务逻辑中进行判断 当用户的账户金额小于购买金额的时候 就取消所作的改变
阅读(24943) | 评论(0) | 转发(0) |
0

上一篇：Java事务处理

下一篇：会话跟踪之-HttpSession接口的方法

给主人留下些什么吧！~~
关于我们 | 关于IT168 | 联系方式 | 广告合作 | 法律声明 | 免费注册

Copyright 2001-2010 ChinaUnix.net All Rights Reserved 北京皓辰网域网络信息技术有限公司. 版权所有

感谢所有关心和支持过ChinaUnix的朋友们

16024965号-6