sunchaojin的java博客

一.問題的背景

     前段時間，我們作了一個項目，讓客戶使用了一段時間后發現一些問題，我們打開客戶的數據庫看了看，發現存在很多重復數據,重復數據從何而來，我看了看我們的程序，好像我們的代碼已經保證了數據的唯一性。當時通過我深入的研究發現在里面存在一個大大問題。

二．問題的引入 

我們程序的思路代碼思路大致如下（這里為了闡述問題，只是舉個簡單例子)：
1. 假如存在一個表student,表結構如下：

   studentid int (z主鍵，遞增字段,MsSql 2000通過identity標識，oracle通過sequence和觸發器來實現)

   name    varchar(20)

   age      int

假如此表的數據如下：

studentid	name	age
1	張三	16
2	李四	20
3	王五	23
...	...	...

 

2. 程序處理步驟:

   (a)外部傳來一個stuid，stuname，stuage

   (b)先根據外部傳來的stuid在數據庫中查詢此stuid對應的記錄行，如果數據庫里沒有此條件的記錄，則把   (stuid,stuname,stuage)插入數據庫；如果數據庫里有此紀錄行，則把此記錄行的studentname和age列的數據改為stuname,stuage；程序代碼如下：

public class Student{
  public static void insert(String stuname,String stuage)
    {
       try{
           DataBase db=new DataBase();//對數據庫連接，查詢進行了封裝
           db.conectDb();
           String sql="select * from student where name='"+stuname+"' ";
           ResultSet rs=db.query(sql);
           boolean b=false;
            String stuid="";
           while(rs.next){
                stuid=rs.getString("studentid");
                 b=true;
                break;
            }
            if(b)//如果表里沒有stuname，則插入一條新紀錄
            {
                  sql="insert into student (name,age)values("'"+stuname+"'","+age+")";//student表里的studentid是自動產生的，oracle里用sequence實現
            }else{//如果找著了stuid對應的行，則更新
                  sql=”update student set name='"+stuname+"'",age="+age+"  where studentid="+stuid;
            }
            db.update(sql);

            db.close();
       }catch(Exception e)
      {
               db.close();
               e.printStackTrace();
        }
 }

代碼片段1-1
 

   (3)servlet處理

    當然，程序是通過servlet來調用Student.insert(stuid,stuname,stuage)來處理用戶的請求的,servlet代碼如下:

public class InsertServlet extends HttpServlet {
    
   public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
       String stuname=request.getParameter(“stuname”);
       String stuage=request.getParameter(“stuage”);
          Student.insert(stuname,stuage);
        
}
 
} 

三.問題分析

   從上面代碼片段1-1不仔細看，還真覺得沒什么問題，程序好像也保證了向數據庫插入或更新數據的唯一性。哈哈，這只是表面現象，因為事實是數據庫里存在重復數據是千真萬確的。如果你不信，現在來測試一下。我們用多線程來測試，每個線程就相當于一個客戶端。線程如下：

public class Test extends Thread{
    
    public Test(){
        start();
    }
    public void run(){
               Student.insert("小龍", 20+"");
        }
    public static void main(String[] args){
        
        for(int i=0; i<1000; i++){
            new Test();
        }
    }
}

   從上面的代碼可以看出，我要向數據庫里插入studentname='小龍' and  studentage=20的數據，但先要檢查是否存在studentid=3的記錄，如果沒有才插入。通過此線程我們會發現數據庫里有時候會出現兩條關于name為＝'小龍'并且age=20的記錄。 有時候運行此測試代碼一段時間后數據里依然沒有重復數據，你可以把此代碼同時放到多個機器，如果是雙核cpu的話出現重復的機率可能會大一些。
   大概你已經知道問題所在，問題就在于并發。因為有很多用戶可能同時在向數據庫發送請求。

 
上述紅體分析是產生數據庫出現重復的原因，也是程序員容易犯的一個錯誤，最簡單的解決辦法是加上唯一性約束條件, 假設表student的name是唯一的，那我們就給name加唯一性約束unique。所以數據庫會保證只有一個唯一確定的name,當兩個請求同時向數據庫插入相同的name時，會采用搶占式插入，誰先插入其他方就不能再插入數據。

上述方法解決了數據庫里出現重復性數據問題。但還可以用其他的方法解決，這就涉及到數據庫的事務的并發控制。下次再討論。