学步园

package org.kodejava.example.sql;<br /> import java.sql.*;<br /> public class TransactionRollbackExample {<br /> public static void main(String[] args) throws Exception {<br /> String url = "jdbc:mysql://localhost/testdb";<br /> String username = "root";<br /> String password = "";<br /> Connection conn = null;<br /> try {<br /> Class.forName("com.mysql.jdbc.Driver");<br /> conn = DriverManager.getConnection(url, username, password);<br /> conn.setAutoCommit(false);<br /> StringBuilder sb = new StringBuilder("INSERT INTO orders (username, order_date) " +<br /> "VALUES ('javaduke', '2007-12-13')");<br /> Statement orderStmt = conn.createStatement();<br /> orderStmt.execute(sb.toString(), Statement.RETURN_GENERATED_KEYS);<br /> ResultSet keys = orderStmt.getGeneratedKeys();<br /> int id = 1;<br /> while (keys.next()) {<br /> id = keys.getInt(1);<br /> }<br /> String insertDetail = "INSERT INTO order_details (order_id, product_id, quantity, price) " +<br /> "VALUES (?, ?, ?, ?)";<br /> PreparedStatement detailStmt = conn.prepareStatement(insertDetail);<br /> detailStmt.setInt(1, id);<br /> detailStmt.setString(2, "P0000001");<br /> detailStmt.setInt(3, 10);<br /> detailStmt.setDouble(4, 100);<br /> detailStmt.execute();<br /> //<br /> // Commit transaction to mark it as a success database operation<br /> //<br /> conn.commit();<br /> System.out.println("Transaction commit...");<br /> } catch (SQLException e) {<br /> //<br /> // Rollback any database transaction due to exception occured<br /> //<br /> if (conn != null) {<br /> conn.rollback();<br /> System.out.println("Connection rollback...");<br /> }<br /> e.printStackTrace();<br /> } finally {<br /> if (conn != null && !conn.isClosed()) {<br /> conn.close();<br /> }<br /> }<br /> }<br /> }<br />