Java实现的mysql事务处理操作示例

package com.test.jdbc;

import java.sql.connection;

import java.sql.drivermanager;

import java.sql.preparedstatement;

import java.sql.resultset;

import java.sql.sqlexception;

import java.sql.statement;

/**

  * 事务的基本用法

  *

  */

public class test {

   public static void main(string[] args) {

     connection conn = null ;

     preparedstatement ps1 = null ;

     preparedstatement ps2 = null ;

     try {

       //加载驱动类

       class .forname( "com.mysql.jdbc.driver" );

       conn = drivermanager.getconnection( "jdbc:mysql://localhost:3306/testjdbc" , "root" , "123456" );

       conn.setautocommit( false ); //jdbc中默认是true，自动提交事务

       ps1 = conn.preparestatement( "insert into t_user (username,pwd) values (?,?)" ); //?是占位符

       ps1.setobject( 1 , "张三" );

       ps1.setobject( 2 , "666666" );

       ps1.execute();

       system.out.println( "插入一个用户张三" );

       try {

         thread.sleep( 3000 );

       } catch (interruptedexception e) {

         e.printstacktrace();

       }

       ps2 = conn.preparestatement( "insert into t_user (username,pwd) values (?,?)" );

       ps2.setobject( 1 , "李四" );

       ps2.setobject( 2 , "123456" );

       ps2.execute();

       system.out.println( "插入一个用户李四" );

       conn.commit(); //提交事务

     } catch (classnotfoundexception e) {

       e.printstacktrace();

       try {

         conn.rollback(); //某一条数据添加失败时，回滚

       } catch (sqlexception e1) {

         e1.printstacktrace();

       }

     } catch (sqlexception e) {

       e.printstacktrace();

     } finally {

       try {

         if (ps1!= null ){

           ps1.close();

         }

       } catch (sqlexception e) {

         e.printstacktrace();

       }

       try {

         if (conn!= null ){

           conn.close();

         }

       } catch (sqlexception e) {

         e.printstacktrace();

       }

     }

   }

}

ps2 = conn.preparestatement( "insert into t_user (username,pwd) values (?)" );