JDBC

   在用java处理数据库事务时，java.sql.Connection提供对本地事物支持的方法有：

  void setAutoCommit(boolean autoCommit)throws SQLException;//设置对数据库的更改是否自动提交

  void commit()throws SQLException;//提交对数据库的更改

  void rollback()throws SQLEception;//撤销更改

 

  数据库本地事务默认情况下是自动提交，如果手动使用本地事务，那么应该首先设置手动提交事务,即下面语句：

  setAutoCommit(false);

 

   在这种模式下，才能使用commit()和rollback()方法。

 

下面这个程序，所有的操作是在一个事物里面，所以commit前和后是一样的结果:

package com.j2ee14.ch7;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class DataBaseTransaction {
	Connection conn = null;

	public void testTransaction() {
		try {
			conn.setAutoCommit(false);
			Statement stmt = conn.createStatement();
			for (int i = 0; i < 10; i++)
				stmt.execute("insert into customer1 values('" + i
						+ "','hesihua',25)");
			System.out.println("before commit, the table is .....");
			viewTable();
			conn.commit();
			System.out.println("after coomit the table is....");
			viewTable();

		} catch (Exception e) {
			e.printStackTrace();
			System.out.println("eror");
			try{
				conn.rollback();
			}catch(SQLException ex){
				System.out.println("fatal error occur");
			}
		}

	}

	public void createTable() {
		try {
			conn.createStatement()
					.execute(
							"create table customer1(id varchar(20),name varchar(50),age int)");
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	public void viewTable() {
		try {
			ResultSet rst = conn.createStatement().executeQuery(
					"select * from customer1");
			while (rst.next()) {
				System.out.print(rst.getString("id")+"\t");
			}
			rst.close();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	
	public static void main(String[] args)throws Exception {
		Class.forName("org.gjt.mm.mysql.Driver").newInstance();
		DataBaseTransaction test=new DataBaseTransaction();
		
		test.conn=DriverManager.getConnection("jdbc:mysql://127.0.0.1/j2ee14","root","123456");
		test.createTable();
		test.testTransaction();
		
	}

}

 执行后的结果为：

before commit, the table is .....
0 1 2 3 4 5 6 7 8 9 after coomit the table is....
0 1 2 3 4 5 6 7 8 9 

 

插播一个见识：

事务都是指不同的连接之间的关系
同一个连接内你执行了什么操作就是什么结果
就相当于一个事务有一个缓存，未提交时操作只影响缓存，还没影响到数据库，所以其他事务看不到，只有提交后其他事务才看得到。

 

现在我改写了上面的程序就可以明显看到commit前和commit后的区别：

package com.j2ee14.ch7;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class DataBaseTransaction {
//	Connection conn = null;

//	public void testTransaction(Connection conn,Statement stmt) {
//		try {
//			conn.setAutoCommit(false);
//			Statement stmt = conn.createStatement();
//			for (int i = 0; i < 10; i++)
//				stmt.execute("insert into customer1 values('" + i
//						+ "','hesihua',25)");
//			System.out.println("before commit, the table is .....");
//			viewTable();
//			conn.commit();
//			System.out.println("after coomit the table is....");
//			viewTable();
//
//		} catch (Exception e) {
//			e.printStackTrace();
//			System.out.println("eror");
//			try{
//				conn.rollback();
//			}catch(SQLException ex){
//				System.out.println("fatal error occur");
//			}
//		}
//
//	}

	public void addRecode(Connection conn,Statement stmt){
		try{
		for (int i = 0; i < 10; i++)
			stmt.execute("insert into customer1 values('" + i
					+ "','hesihua',25)");
		}catch(Exception e){
			e.printStackTrace();
		}
	}
	public void createTable(Connection conn,Statement stmt) {
		try {
			stmt.execute("create table customer1(id varchar(20),name varchar(50),age int)TYPE=INNODB");
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	public void viewTable(Connection conn) {
		try {
			ResultSet rst = conn.createStatement().executeQuery(
					"select * from customer1");
			while (rst.next()) {
				System.out.print(rst.getString("id")+"\t");
			}
			System.out.println();
			rst.close();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	
	public static void main(String[] args)throws Exception {
		Class.forName("org.gjt.mm.mysql.Driver").newInstance();
		DataBaseTransaction test=new DataBaseTransaction();
		
		Connection conn = null;
		Connection conn1 = null;
		Connection conn2 = null;
		
		conn=DriverManager.getConnection("jdbc:mysql://127.0.0.1/j2ee14","root","123456");					
		conn.setAutoCommit(false);			
		Statement stmt = conn.createStatement();
		
		test.createTable(conn,stmt);
		conn.commit();
		test.addRecode(conn, stmt);
		
		System.out.println("before commit, the table is .....");
		
		conn2=DriverManager.getConnection("jdbc:mysql://127.0.0.1/j2ee14","root","123456");
		test.viewTable(conn2);
		
		try{
		conn.commit();
		}catch(Exception e){
			conn.rollback();
			e.printStackTrace();			
		}
		
		System.out.println("after coomit the table is....");
		
		conn1=DriverManager.getConnection("jdbc:mysql://127.0.0.1/j2ee14","root","123456");		
		test.viewTable(conn1);
		
		stmt.close();
		conn.close();
		conn1.close();
		conn2.close();
	}

}

 

执行的结果为：

before commit, the table is .....

 

after coomit the table is....
0 1 2 3 4 5 6 7 8 9 

 

 有点想不明白的是为什么在conn提交之后要重新创建一个连接才能看到数据库里的数据。