数据库事务处理

[java]代码库
package mysql2;
 
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
 
public class TestCommit {
    private static  Connection con = null;
    private static ResultSet result=null;
    private static PreparedStatement pre =null;
     
    public static void main(String[] args) {
        //1.加载数据库驱动
        try {
            Class.forName("com.mysql.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            System.out.println("加载失败！");
            e.printStackTrace();
        }
        System.out.println("加载成功！");
     
        //2.连接数据库
        try {
            con=DriverManager.getConnection("jdbc:mysql://localhost:3306/db_library", "root", "123");
        } catch (SQLException e) {
            System.out.println("连接数据库失败！");
            e.printStackTrace();
        }
          System.out.println("成功连接数据库！");
           
           
        //3.执行sql语句语句的PreparedStatement,然后执行sql语句
          /*
           * update useraccount set totalmoney=totalmoney-1000 where name='李四'
           * update useraccount set totalmoney=totalmoney+1000 where name='王二'
           */
       
        /*try {
            String name1="李四";
            pre=con.prepareStatement("update useraccount set totalmoney=totalmoney-1000 where name=?");
            pre.setString(1, name1);
            int result =pre.executeUpdate();
            System.out.println(result);
        } catch (SQLException e1) {
            e1.printStackTrace();
        }
         
         
         
          //模拟数据库出现故障：死机、服务器出现问题，是认为控制不了的
          
         
           Integer.parseInt("kbq");//无法将kbq转成整数，肯定会报错
         
 
            try {
                String name2="王二";
                pre=con.prepareStatement("update useraccount set totalmoney=totalmoney+1000 where name=?");
                pre.setString(1, name2);
                int result = pre.executeUpdate();
                System.out.println(result);
            } catch (SQLException e1) {
                e1.printStackTrace();
            }*/
             
            try{
                //设置手工提交
                con.setAutoCommit(false);
                String name1="李四";
                pre=con.prepareStatement("update useraccount set totalmoney=totalmoney-1000 where name=?");
                pre.setString(1, name1);
                int result =pre.executeUpdate();
                System.out.println(result);
         
               //模拟数据库出现故障：死机、服务器出现问题，是认为控制不了的
                 Integer.parseInt("kbq");//无法将kbq转成整数，肯定会报错
             
                    String name2="王二";
                    pre=con.prepareStatement("update useraccount set totalmoney=totalmoney+1000 where name=?");
                    pre.setString(1, name2);
                    int result1 = pre.executeUpdate();
                    System.out.println(result1);
                    //提交事务
                    con.commit();
            }catch (SQLException e1) {
                try {
                    con.rollback();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                e1.printStackTrace();   
            }
                   
               
              //4.释放数据库的资源
              finally{
                  try {
                      if(result!=null)
                      result.close();
                      if(pre!=null)
                      pre.close();
                      if(con!=null)
                      con.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
              }
               
              System.out.println("执行成功！");
 
    }  
 
}
用户注册

用户登录

发表随想

该用户最新代码

编程随想

[java]代码库

网友评论 (发表评论)

发表评论：

评论须知：

扫码下载

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