以前也寫過幾篇關于數據訪問的，這里是***的總結。麻雀雖小五臟俱全，數據訪問也許不起眼，但是也要好好的設計一翻。從2004年開始用自己的數據訪問，一直到現在，經歷過兩次大的改版，隨著需求的變化，也增加了不少的功能，小修小改那就更多了。目的就是能夠讓自己更輕松一點。整理思路、整理代碼，寫點東西，一個是給自己留個腳印；另外一個，說不定也許能夠給大家幫個小忙。

目標：

簡單、好用、易擴展、穩定、性能。

特點：

1. 基于ADO.net 2.0 編寫，理論上可以支持多種數據庫，目前測試了SQL Server 和Access，一位朋友幫忙測試了MySQL。Orcale等其他數據庫沒有測試過。
2. 使用非常簡單。
3. 支持事務、存儲過程、參數化SQL等。
4. 對存儲過程的參數進行封裝，更便于操作和更換數據庫。
5. 如果運行是出現異常，可以把異常信息、出錯的SQL保存到文本文件里面，便于調試、修改錯誤。
6. 可以方便的擴展相關功能，遵循關閉開放原則。

不承擔的責任：

不對SQL語句進行檢查。

不負責防止SQL注入。

不負責分頁。

圖示：

結構：

1、 兩個工廠

CommonFactory：生成Db系列的實例，比如DbConnection、DbCommand等。內部使用。他們都是抽象基類不能直接new，需要相應的子類的實例，比如new SqlConnection、new SqlCommand等。這個就需要根據當前的需求（驅動類型）來確定了，也就是這個工廠的職責。
DALFactory：調用者使用的工廠，通過這個工廠，根據數據驅動類型，生成數據訪問的實例。

2、 主體部分

DataAccessLibrary：這個是數據訪問的核心部分，相當于大樹的主干。定義了一個DbCommand Command，通過他來實現各種功能。

主體部分僅實現最基本的功能，定義內部結構、成員，實現輸入和輸出的功能。

輸入主要是ExecuteNonQuery。通過他來傳遞添加、修改、刪除的SQL語句（包括參數化SQL和存儲過程）。還有一個 ExecuteExists，用來判斷數據庫里是否存在指定的記錄。

輸出部分主要是ExecuteReader，這個大家都不陌生吧。其他的原則上都是通過擴展（配件）的方式來實現，不過為了便于調用，還是增加了ExecuteString、T ExecuteScalar<T>(string text)兩個函數。這個對于我來說比較常用，所以就放在主體部分里面了。

另外可以通過子類來實現支持不同數據庫的差異的部分。

3、 配件部分

這個就比較多了，比如對事務的處理、對存儲過程的參數的封裝、對Json 的處理、對添加、修改用SQL（包括參數化SQL）的處理等。每一個都是一個“配件”，這樣就可以通過增加配件的方式增加需要的功能。比如以前是不支持Json格式的記錄的，但是想玩玩ajax，選擇json來傳遞數據，那么就需要把提取出來的數據轉換Json格式。那么就可以增加一個“配件”，就是增加一個類，而不影響其他代碼。

增加功能，并不影響其他的代碼，這個就是對擴展開放，對修改關閉。

實例

//發回復    
Reply.bodyUBB = Request.Form["Editor"];    
Reply.topicID = int.Parse(this.DataID);    
#region 驗證信息    
if (Reply.bodyUBB.Length < 10)    
{    
    Functions.PageRegisterAlert(Page, "請填寫內容，或者內容太短！至少也得寫10個字，對吧。");    
    return;    
}    
 
#endregion    
#region 內部字段    
int userID = int.Parse(UserInfo.UserID);    
string ip = Request.UserHostAddress;    
DateTime dateTime = DateTime.Now;    
string bodyHTML;    
#endregion    
#region 處理UBB    
bodyHTML = bodyUBB.Replace("\r", "<BR>");    
//其他略    
#endregion    
//開啟事務    
Dal.ManagerTran.TranBegin();    
ManagerParameter parm = Dal.ManagerParameter;    
#region 設置參數    
parm.ClearParameter();    
parm.AddNewInParameter("TopicID", Reply.topicID);        //     
parm.AddNewInParameter("回復內容", bodyUBB);    
parm.AddNewInParameter("內容HTML", bodyHTML);    
parm.AddNewInParameter("回復人ID", userID);    
parm.AddNewInParameter("回復人IP", ip, 15);    
parm.AddNewInParameter("回復時間", dateTime);    
#endregion                  
#region 保存回復，表名：BBS_Reply    
Dal.ModifyData.InsertData("BBS_Reply");    
if (Dal.ErrorMessage.Length > 0)    
{    
    //出現異常    
    Functions.PageRegisterAlert(Page, "保存您發的回復的時候出現意外情況！");    
    return;    
}    
#endregion    
string sql;    
#region 更新回復人的回復數量，回復時間，以及各種積分。    
sql = @"update BBS_Topic set 回復次數 = 回復次數 + 1 ,***回復時間 = GetDate(),    
***回復人ID = {0},   where TopicID ={1}";    
Dal.ExecuteNonQuery(string.Format(sql, userID,topicID));    
if (Dal.ErrorMessage.Length > 0)    
{    
    //出現異常    
    Functions.PageRegisterAlert(Page, "更新回復數量的時候出現意外情況！");    
    return;    
}    
#endregion    
#region 更新回復人的參與討論的帖子    
sql = "select top 1 UserInTopicID from BBS_UserInTopic where UserID ={0} and TopicID={1} ";    
string userInTopicID = Dal.ExecuteString(string.Format(sql, userID, topicID));    
sql = "select top 1 回復次數 from BBS_Topic where TopicID={0} ";    
string reCount = Dal.ExecuteString(string.Format(sql, topicID)) ?? "0";    
int intintReCount = int.Parse(reCount);    
if (userInTopicID == null)    
{    
    #region 沒有參與過，添加記錄    
    parm.ClearParameter();    
    parm.AddNewInParameter("UserID", userID);    
    parm.AddNewInParameter("TopicID", topicID);    
    parm.AddNewInParameter("***查看時間", dateTime);    
    parm.AddNewInParameter("***查看回復數", intReCount);    
    Dal.ModifyData.InsertData("BBS_UserInTopic");    
    if (Dal.ErrorMessage.Length > 0)    
    {    
        //出現異常    
        Functions.PageRegisterAlert(Page, "增加您參與討論的帖子的時候出現意外情況！");    
        return;    
    }    
    #endregion    
}    
else   
 
{    
    #region 參與過，修改記錄    
    parm.ClearParameter();    
    parm.AddNewInParameter("***查看時間", dateTime);    
    parm.AddNewInParameter("***查看回復數", intReCount);    
    Dal.ModifyData.UpdateData("BBS_UserInTopic", "UserInTopicID=" + userInTopicID);    
    if (Dal.ErrorMessage.Length > 0)    
    {    
        //出現異常    
        Functions.PageRegisterAlert(Page, "更新參與討論的帖子的時候出現意外情況！");    
        return;    
    }    
    #endregion    
}    
#endregion    
//提交事務    
Dal.ManagerTran.TranCommit();    
//正常    
lblMsg.Text = "發表回復成功！感謝您的參與！1秒后重新加載帖子。";    
Functions.PageRegisterJavascript(Page, "reload()");    

簡單寫一個，以論壇的回復為例，這個大家都熟悉，不是太簡單也不是很復雜。

這個沒有按照三層的方式來寫，因為我分不出來哪些是業務邏輯，哪些是數據訪問，都寫到一起了，呵呵。但是這并不是說數據訪問只能寫成這個樣子。這個只是一個具體的、綜合性的例子。也可以把他分一分，找到業務邏輯的部分，提取出去，放在業務層；把數據訪問的部分也提出出去，放在數據層。

這里僅僅是一個數據訪問的調用的示例，并不是說要不要分層。

原文出處：http://www.cnblogs.com/jyk/archive/2011/03/28/1998254.html

【編輯推薦】

1. 曬曬我的通用數據訪問層
2. 幾步走，教你創建簡單訪問數據庫方法
3. 一句代碼實現批量數據綁定 下
4. 一步一步設計你的數據庫1
5. 不重復隨機數列生成算法