為了實現資料庫資料的安全性，資料庫有了事務管理機制。

事務管理具有

原子性 —— 具有相互關聯的一系列操作，要麼一次全部執行成功，要麼執行失敗，資料回滾；

一致性 —— 資料庫在事務執行前後，資料庫都應處於相同的狀態；

永續性 —— 一旦事務提交，事務對於資料庫的變更是持久的；

隔離性 —— 同一資料庫各個事務之間獨立執行，並不互相串擾。

現使用如下程式碼實現對資料庫的事務的表述，通過前後事務執行過程中的衝突，表現事務的原子性。

create table tbl_user(
id int(11) unsigned not null auto_increment,
name varchar(50) not null default '',
password varchar(50) not null default '',
email varchar(50) default '',
primary key (id))
engine = InnoDB
default charset = utf8;

create table tbl_address(
id int(11) unsigned not null auto_increment,
city varchar(20) default null,
country varchar(20) default null,
user_id int(11) unsigned not null,
primary key(id))
engine = innodb
default charset = utf8;

insert into tbl_user(id,name,password,email) values
(1,'xiaoming','123456','
 
[email protected]'),
(2,'xiangzhang','123456','[email protected]');

insert into tbl_address (city,country,user_id) values
('beijing','china',1);

insert into tbl_address (city,country,user_id) values
('tianjin','china',2);

package jdbc_Pack_005;

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

public class JDBC_Cls_005 {

	public static Connection getConnection(){
		Connection connection = null;
		try{
			Class.forName("com.mysql.jdbc.Driver");
			connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/jsp_db","root","1233211234567");
			}
		catch(Exception e){
			e.printStackTrace();
		}
		return connection;
	} 
	
	public static void insertUserData(){
		Connection connection = getConnection();
		try {
			String sql = "INSERT INTO tbl_user(id,name,password,email)"
					+ "VALUES(10,'Tom','123456','
 
[email protected]')";
			Statement statement = (Statement) connection.createStatement();
			int count = statement.executeUpdate(sql);
			System.out.println("向用戶表中插入了"+count+"條記錄 ！");
			connection.close();
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}
	}


	public static void insertAddrData(){
		Connection connection = getConnection();
		try {
			String sql = "INSERT INTO tbl_address(id,city,country,user_id)"
					+ "VALUES(1,'shanghai','china','10')";
			Statement statement = (Statement) connection.createStatement();
			int count = statement.executeUpdate(sql);
			System.out.println("向地址表中插入了"+count+"條記錄 ！");
			connection.close();
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}
	}
	
	public static void main(String []args) {
		insertUserData();
		insertAddrData();
	}
}
 

package jdbc_Pack_005;

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

public class JDBC_Cls_006 {

	public static Connection getConnection(){
		Connection connection = null;
		try{
			Class.forName("com.mysql.jdbc.Driver");
			connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/jsp_db","root","1233211234567");
			}
		catch(Exception e){
			e.printStackTrace();
		}
		return connection;
	} 
	
	public static void insertUserData(Connection connection)throws Exception{
		String sql = "INSERT INTO tbl_user(id,name,password,email)"
				+ "VALUES(10,'Tom','123456','[email protected]')";
		Statement statement = (Statement) connection.createStatement();
		int count = statement.executeUpdate(sql);
		System.out.println("向用戶表中插入了"+count+"條記錄 ！");
	}
 

	public static void insertAddrData(Connection connection)throws Exception{
		String sql = "INSERT INTO tbl_address(id,city,country,user_id)"
				+ "VALUES(1,'shanghai','china','10')";
		Statement statement = (Statement) connection.createStatement();
		int count = statement.executeUpdate(sql);
		System.out.println("向地址表中插入了"+count+"條記錄 ！");
	}
	
	public static void main(String []args) {
		Connection connection = null;
		try {
			connection = getConnection();
			connection.setAutoCommit(false);
			
			insertUserData(connection);
			insertAddrData(connection);	
			
			connection.commit();
		} catch (Exception e1) {
			// TODO: handle exception
			System.out.println("=========== 捕獲到SQL異常 ===========");
			e1.printStackTrace();
			try {
				connection.rollback();
				System.out.println("=========== 事務回滾成功 ===========");
			} catch (Exception e2) {
				e2.printStackTrace();
			}
		}finally{
			try{
				if(connection != null){
					connection.close();
				}
			}catch(Exception e3){
				e3.printStackTrace();
			}
		}
	}
}

配置檔案報錯

Tue Aug 02 17:00:34 CST 2016 WARN: Establishing SSL connection without server's identity verification is not recommended. According to MySQL 5.5.45+, 5.6.26+ and 5.7.6+ requirements SSL connection must be established by default if explicit option isn't set. For compliance with existing applications not using SSL the verifyServerCertificate property is set to 'false'. You need either to explicitly disable SSL by setting useSSL=false, or set useSSL=true and provide truststore for server certificate verification.

driver = com.mysql.jdbc.Driver
dburl = jdbc\:mysql\://localhost\:3306/jsp_db?characterEncoding=utf8&useSSL=false
user = root
password = 1233211234567