JDBC基本和資料庫事務
JDBC:
是一種用於執行SQL語句的Java API,它可以為多種關係資料庫提供統一訪問。
功能:與資料庫建立連線、傳送SQL語句並處理結果。
顯示資料庫:show databases;
使用資料庫:user 庫名; (如:user mysql;)
顯示資料庫表:show tables;
顯示錶結構:describe 表名; (如:describe time_zone;)
建資料庫:create database 庫名; (如:create database school;)
在資料庫中建立表:create table 表名(欄位定義);
如; user school; //不能少
(id int(3) not null primary key,
name char(10),
address varchar(50),
year date );
新增記錄:insert into 表名 values(各欄位名);
如:insert into teacher values(001,’abc’,’hbes’,’1975-03-03’);
查詢記錄:select 欄位 from 表名 where 條件;
如:select * from teacher;
select name from teacher where id = 001;
刪除記錄:delete from 表名 where 條件;
如:delete from teacher where id = 002;
delete from teacher;
更新記錄:update 表名 set 欄位名=值 where 條件;
如:update teacher set address = ‘wust’ where id = ‘001’;
刪除表:drop table 表名;
刪除資料庫:drop database 庫名;
MySQL中文處理:
先執行:Set Names GBK;
create table teacher
( id int(3) not null primary key,
name char(10),
address varchar(50),
year date )
default character set gbk;
就可新增和顯示漢字資料
介面說明:
java.sql.DriverManager:處理驅動程式的調入和管理。
java.sql.Connection:其物件代表對特定資料庫的一個連線。
java.sql.Statement:一個特定的容器,用以執行SQL語句。
java.sql.ResultSet:其物件代表執行一個Select語句後的結果集合。
Java訪問資料庫的基本步驟:
1、裝載資料庫的JDBC驅動程式:
Class.forName(“org.gjt.mm.mysql.Driver”).newInstance();
2、建立與資料庫額連線:Connection conn = DriverManager.getConnectiton(url,使用者名稱,密碼);
MySQL連線串:”jdbc:mysql://主機:埠號/資料庫名”
例如:String url = “jdbc:mysql://localhost:3306/school”;
3、建立Statement物件,準備執行SQL語句:
Statement stmt = conn.createStatement();
4、執行SQL語句:
常見3種執行SQL語句的方法:
1)executeQuery()--用於Select語句,返回結果集(ResultSet).
String sql = “select * from 表名”;
ResultSet rs = stmt.executeQuery(sql);
2) executeUpdate()--用於建立和更新表(如Update/Insert/Delete/Create),返回受影響行數(int)。
String sql = “Delete from 表名 where ...”;
int rsCount = stmt.executeUpdate(sql);
3) execute()--用於執行任何SQL語句,返回布林值(執行是否成功)。
5、處理ResultSet結果集(主要是查詢結果集)
while(rs.next()){
String s1 = rs.getString(“name”);//根據列名取值
...
或String s2 = rs.getString(2);//根據列號取值(從1開始)
或int id = rs.getInt(1);
}
6、依次關閉ResultSet、Statement和Connection物件:
rs.close(); stmt.close(); conn.close();
import java.io.*; import java.sql.*;
public class test {
public static void main(String[] args) throws Exception {
String url ="jdbc:mysql://localhost:3306/school"; //資料庫連線字串
Class.forName("org.gjt.mm.mysql.Driver").newInstance(); //載入驅動程式
Connection conn= DriverManager.getConnection(url,"root","dba"); //建立連線
Statement stmt=conn.createStatement(); //建立SQL容器
String sql="select * from teacher"; //表為teacher
ResultSet rs=stmt.executeQuery(sql); //獲得結果集
while( rs.next() ) { //處理結果集
System.out.print(rs.getString("id")+" ");
System.out.print(rs.getString("name")+" ");
System.out.print(rs.getString("address")+" ");
System.out.print(rs.getString("year")+"\n");
}
rs.close(); stmt.close(); conn.close(); //關閉次序
}
}
注意MySQL驅動問題;
在當前專案中新增該驅動:
右擊當前專案;
選擇Build path → add External Archieves→引入mysql-connector-java-5.1.10-bin.jar。
條件查詢:
String name = (new Scanner(System.in)).nextLine();
String sql = “select * from teacher where name =‘“+name+”’”;
ResultSet rs = stmt.executeQuery(sql);
//處理查詢結果集
基本語句:
String sql="update teacher set name='amy' where id='002'";
int rowCount=stmt.executeUpdate(sql);
String sql="insert into teacher values(002,'hgdamy','wust','1974-02-03')";
int rowCount=stmt.executeUpdate(sql);
String sql="delete from teacher where id='002'";
int rowCount=stmt.executeUpdate(sql);
之後再查詢
sql="select * from teacher ";
ResultSet rs=stmt.executeQuery(sql);
資料庫事務:
在資料庫中,事務是指一組邏輯操作單元,使資料從一種狀態變換到另一種狀態。
為確保資料庫中資料的一致性,資料的操縱應當是離散的成組的邏輯單元:當它全部完成時,資料的一致性可以保持,而當這個單元中的一部分操作失敗,整個事務應全部視為錯誤,所有從起始點以後的操作應全部回退到開始狀態。 事務的操作:先定義開始一個事務,然後對資料作修改操作,這時如果提交(COMMIT),這些修改就永久地儲存下來,如果回退(ROLLBACK),資料庫管理系統將放棄所作的所有修改而回到開始事務時的狀態。
事務的ACID屬性:
1、原子性(Atomicity):是指事務是一個不可分割的工作單位,事務中的操作要麼都發生,要麼都不發生。
2、一致性(Consistency):事務必須使資料庫從一個一致性狀態變換到另外一個一致性狀態。
3、隔離性(Isolation):是指一個事務的執行不能被其它事務干擾,即一個事務內部的操作及使用的資料對併發的其它事務是隔離的,併發執行的各個事務之間不能互相干擾。
4、永續性(Durability):是指一個事務一旦被提交,它對資料庫中資料的改變就是永久性的,接下來的其它操作和資料庫故障不應該對其有任何影響。
事務:指構成單個邏輯工作單元的操作集合 事務處理:保證所有事務都作為一個工作單元來執行,即使出現了故障,都不能改變這種執行方式。當在一個事務中執行多個操作時,要麼所有的事務都被提交(commit),要麼整個事務回滾(rollback)到最初狀態。 當一個連線物件被建立時,預設情況下是自動提交事務:每次執行一個 SQL 語句時,如果執行成功,就會向資料庫自動提交,而不能回滾。
當JDBC程式向資料庫獲得一個Connection物件時,預設情況下這個Connection物件會自動向資料庫提交在它上面傳送的SQL語句。若想關閉這種預設提交方式,讓多條SQL在一個事務中執行,並且保證這些語句是在同一時間共同執行時,我們就應該為這多條語句定義一個事務。
設定事務的提交方式為非自動提交:
conn.setAutoCommit(false);
接下來,.將需要新增事務的程式碼放入try,catch塊中。然後,在try塊內新增事務的提交操作,表示操作無異常,提交事務:
conn.commit();
在catch塊內添加回滾事務,表示操作出現異常,撤銷事務:
conn.rollback();
最後,設定事務提交方式為自動提交:
conn.setAutoCommit(true);
資料庫的隔離級別:
對於同時執行的多個事務, 當這些事務訪問資料庫中相同的資料時, 如果沒有采取必要的隔離機制, 就會導致各種併發問題:
髒讀: 對於兩個事物 T1, T2, T1 讀取了已經被 T2 更新但還沒有被提交的欄位. 之後, 若 T2 回滾, T1讀取的內容就是臨時且無效的.
不可重複讀: 對於兩個事物 T1, T2, T1 讀取了一個欄位, 然後 T2 更新了該欄位. 之後, T1再次讀取同一個欄位, 值就不同了.
幻讀: 對於兩個事物 T1, T2, T1 從一個表中讀取了一個欄位, 然後 T2 在該表中插入了一些新的行. 之後, 如果 T1 再次讀取同一個表, 就會多出幾行.
資料庫事務的隔離性: 資料庫系統必須具有隔離併發執行各個事務的能力, 使它們不會相互影響, 避免各種併發問題.
一個事務與其他事務隔離的程度稱為隔離級別. 資料庫規定了多種事務隔離級別, 不同隔離級別對應不同的干擾程度, 隔離級別越高, 資料一致性就越好, 但併發性越弱。
資料庫提供的4種事務隔離級別:
Oracle 支援的 2 種事務隔離級別:READ COMMITED, SERIALIZABLE. Oracle 預設的事務隔離級別為: READ COMMITED Mysql 支援 4 中事務隔離級別. Mysql 預設的事務隔離級別為: REPEATABLE READ