1. 程式人生 > >JDBC基本和資料庫事務

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);

接下來,.將需要新增事務的程式碼放入trycatch塊中然後,在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