`
hesihua
  • 浏览: 233757 次
  • 性别: Icon_minigender_2
  • 来自: 武汉
社区版块
存档分类
最新评论

JDBC

    博客分类:
  • java
 
阅读更多

   在用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提交之后要重新创建一个连接才能看到数据库里的数据。

分享到:
评论

相关推荐

    JDBCDriver3.0.rar_jdbc driver 3.0_sql jdbc 3.0_sql server jdbc_s

    《深入理解JDBC Driver 3.0:聚焦SQL Server JDBC》 在IT行业中,数据库连接是应用程序与数据存储之间的桥梁,而JDBC(Java Database Connectivity)则是Java平台中用于访问数据库的标准API。JDBC Driver 3.0是针对...

    sqlserver驱动包 jdbc驱动 sqljdbc.jar和sqljdbc4.jar

    SQL Server驱动包是用于Java应用程序通过JDBC(Java Database Connectivity)接口与Microsoft SQL Server数据库进行交互的必备组件。本文将详细介绍这两个重要的驱动文件——sqljdbc.jar和sqljdbc4.jar,以及如何...

    sqljdbc和sqljdbc4 sqlserver最新驱动

    SQLJDBC和SQLJDBC4是Microsoft为Java应用程序提供的用于连接SQL Server数据库的驱动程序。这两个版本都是JDBC(Java Database Connectivity)驱动,允许Java开发者在应用程序中与SQL Server进行交互。下面将详细介绍...

    Spring Data JDBC与JDBC的区别

    Spring Data JDBC与JDBC是两种不同的数据库访问方式,它们在Java开发中有着广泛的应用。JDBC(Java Database Connectivity)是Java平台的标准API,用于与各种数据库进行交互。它提供了低级别的数据库操作,如建立...

    mysql jdbc 驱动 适用于5.6版本及以下数据库

    mysql jdbc 驱动 适用于5.6版本及以下数据库 mysql jdbc 驱动 适用于5.6版本及以下数据库 mysql jdbc 驱动 适用于5.6版本及以下数据库 mysql jdbc 驱动 适用于5.6版本及以下数据库 mysql jdbc 驱动 适用于5.6版本及...

    mysql jdbc 驱动 适用于5.7及以上版本数据库

    mysql jdbc 驱动 适用于5.7及以上版本数据库 mysql jdbc 驱动 适用于5.7及以上版本数据库 mysql jdbc 驱动 适用于5.7及以上版本数据库 mysql jdbc 驱动 适用于5.7及以上版本数据库 mysql jdbc 驱动 适用于5.7及以上...

    sqljdbc41、sqljdbc42的官方jar包

    在Java编程语言中,JDBC(Java Database Connectivity)是一个核心的API,用于连接Java应用程序与各种类型的数据库。这里我们关注的是两个特定版本的Microsoft SQL Server的JDBC驱动:sqljdbc41.jar和sqljdbc42.jar...

    Dm7JdbcDriver16.jar Dm7JdbcDriver17.jar Dm7JdbcDriver18.jar

    在给定的压缩包文件中,包含了三个不同版本的达梦JDBC驱动,分别是Dm7JdbcDriver16.jar、Dm7JdbcDriver17.jar和Dm7JdbcDriver18.jar。 1. **JDBC驱动介绍**: JDBC是Java中用于与各种数据库进行交互的标准接口,它...

    sql server2000 jdbc

    SQL Server 2000 JDBC 是Java编程语言与Microsoft SQL Server 2000数据库进行交互的一种重要方式。JDBC(Java Database Connectivity)是Java API,允许Java应用程序通过Java虚拟机(JVM)与各种数据库建立连接。在...

    Access_JDBC30

    标题 "Access_JDBC30" 暗示了这是一个与Microsoft Access数据库相关的Java JDBC驱动程序。JDBC(Java Database Connectivity)是Java编程语言中用于连接和操作数据库的标准接口。这个jar包,"Access_JDBC30.jar",...

    kingbaseV8 jdbc 驱动

    KingbaseV8 JDBC驱动是连接KingbaseV8数据库的重要组件,允许Java应用程序通过JDBC(Java Database Connectivity)接口与数据库进行交互。JDBC是Java语言中用来规范客户端程序如何访问数据库的应用程序接口,提供了...

    sqljdbc4(sqlserver jdbc驱动下载和安装)

    在IT行业中,数据库是至关重要的组成部分,而SQL Server作为一款广泛应用的关系型数据库管理系统,它的连接与操作离不开JDBC(Java Database Connectivity)驱动。本篇将详细介绍如何下载和安装sqljdbc4,这是...

    java jdbc 需要包

    Java JDBC(Java Database Connectivity)是Java编程语言中用于与各种数据库进行交互的一组接口和类。它提供了一种标准化的方法,让程序员可以使用SQL语句访问数据库,而无需关心具体的数据库实现细节。在Java应用...

    access的jdbc驱动

    Access的JDBC驱动是Java数据库连接(Java Database Connectivity, JDBC)的一种实现,它允许Java程序与Microsoft Access数据库进行交互。在JDK 1.8之后,Oracle公司不再默认提供对ODBC(Open Database Connectivity...

    sqljdbc4.jar, sqljdbc41.jar, sqljdbc42.jar三个包

    标题中的"sqljdbc4.jar, sqljdbc41.jar, sqljdbc42.jar"是指Microsoft SQL Server为Java应用程序提供的Java Database Connectivity (JDBC)驱动程序。这些JAR文件是数据库连接的关键,允许Java代码与SQL Server进行...

    sqljdbc 3.0及4.0

    `sqljdbc`是Microsoft提供的一个驱动程序,使得Java应用程序能够与SQL Server数据库进行交互。在这个场景中,我们关注的是`sqljdbc 3.0`和`4.0`版本,这两个版本都是专门为Java设计的,用于连接SQL Server 2000。 `...

    sqljdbc42.jar、sqljdbc41.jar 更新日期2017-12-21

    标题中的"sqljdbc42.jar、sqljdbc41.jar 更新日期2017-12-21"指的是Microsoft SQL Server的Java Database Connectivity (JDBC) 驱动的两个不同版本,它们分别对应于Java SE 7和Java SE 8的兼容性。JDBC驱动是Java...

    sqljdbc4-3.0.jar

    标题“sqljdbc4-3.0.jar”指向的是一个特定版本的Microsoft SQL Server JDBC驱动程序,它是用于在Java应用程序中连接和操作SQL Server数据库的桥梁。这个版本的驱动(3.0)支持与SQL Server 2000的兼容性。 在描述...

Global site tag (gtag.js) - Google Analytics