JDBC实现事务

JDBC实现事务

先得到connection原来的AutoCommit的设置，然后运行完事务后将将他还原。

Booean autoCommit = connection.getAutoCommit();

……

connection.setAutoCommit(autoCommit);

Connection是自动提交的。所以要将自动提交设置成false。

connection.setAutoCommit(false);

在所有数据库操作执行后进行提交。

connection.commit();

如果出现异常，就回滚。

connection.rollback();

package com.star7.forum.dao;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

/**
 * 演示JDBC处理事务。
 * 
 * @created : 2011-6-4上午10:57:27
 * @author star7
 * @email : [e-mail]
 */
public class TestDAo {

	private final String CLASS_NAME = "com.mysql.jdbc.Driver";

	private final String URL = "jdbc:mysql://localhost:3306/forum2_0";

	private final String NAME = "root";

	private final String PASSWORD = "887721";

	/**
	 * 插入语句。
	 * 
	 * void
	 * 
	 * @throws ClassNotFoundException
	 */
	public void insert() throws ClassNotFoundException {

		Class.forName(CLASS_NAME);

		String sql = "INSERT INTO user(name,password,email,role) VALUES('han11','887721','email','A')";

		Connection connection = null;

		PreparedStatement statement = null;

		try {
			int a = 1;

			connection = DriverManager.getConnection(URL,NAME,PASSWORD);

			// 取消自动提交
//			connection.setAutoCommit(false);

			statement = connection.prepareStatement(sql);

			statement.execute();

			if (a == 1)
				throw new SQLException();

			connection.commit();

		} catch (SQLException e) {

			/*try {
				if (connection != null)
					connection.rollback();
			} catch (SQLException e1) {

				throw new RuntimeException("回滚失败", e1);
			}*/

			e.printStackTrace();
		} finally {

			try {

				if (statement != null)
					statement.close();

				if (connection != null)
					connection.close();

			} catch (SQLException e) {
				e.printStackTrace();
			}

		}
	}
}