打造自己的數據訪問層一
項目開發中，大多數開發人員的核心工作就是如何對數據進行存儲及訪問。為了進行數據操作，我們首先得解決幾個基本問題：
1、如何與一個數據庫建立連接。
2、如何從數據庫讀取相應的數據。
3、如何對數據表進行增改操作。
.NET中，ADO.NET很方便的解決了上面三個問題，我們可以使用DbConnection進行連接，DataSet進行數據存儲，DataAdapter進行數據更新。先看一段代碼：
- //創建DbConnection對象連接數據庫
- SqlConnection conn = new SqlConnection();
- conn.ConnectionString = "server=.;uid=sa;password=123456; database=DATA_BASE; max pool size=300;";
- //創建DataAdapter、Command對象，讀取數據
- SqlDataAdapter da = new SqlDataAdapter();
- SqlCommand cmd = new SqlCommand();
- cmd.Connection = conn;
- cmd.CommandText = "SELECT * FROM TEST";
- da.SelectCommand = cmd;
- //創建DataSet對象，存儲數據，建立與物理表的映射
- DataSet ds = new DataSet();
- da.Fill(ds, "TEST");
上述代碼實現對數據庫“DATA_BASE”中“TEST”表數據讀取，并用DataSet時行存儲。
既然讀出了TEST表中的數據，接下來要解決的就是如何對TEST表進行增、刪、改操作。
為實現增、刪、改操作，需要為DataAdapter指定InsertCommand、DeleteCommand以及UpdateCommand，并為每個Command對象綁定參數：
- //新增數據
- cmd = new SqlCommand();
- cmd.Connection = conn;
- cmd.CommandText = "INSERT INTO TEST (ID, NAME, VAL) VALUES (@ID, @NAME, @VAL)";
- SqlParameter param = new SqlParameter("@ID", null);
- param.SourceColumn = "ID";
- cmd.Parameters.Add(param);
- param = new SqlParameter("@NAME", null);
- param.SourceColumn = "NAME";
- cmd.Parameters.Add(param);
- param = new SqlParameter("@VAL", null);
- param.SourceColumn = "VAL";
- cmd.Parameters.Add(param);
- da.InsertCommand = cmd;
- //修改數據
- cmd = new SqlCommand();
- cmd.Connection = conn;
- cmd.CommandText = "UPDATE TEST SET NAME = @NAME, VAL = @VAL WHERE ID = @ID";
- param = new SqlParameter("@ID", null);
- param.SourceColumn = "ID";
- cmd.Parameters.Add(param);
- param = new SqlParameter("@NAME", null);
- param.SourceColumn = "NAME";
- cmd.Parameters.Add(param);
- param = new SqlParameter("@VAL", null);
- param.SourceColumn = "VAL";
- cmd.Parameters.Add(param);
- da.UpdateCommand = cmd;
- //刪除數據
- cmd = new SqlCommand();
- cmd.Connection = conn;cmd.CommandText = "DELETE FROM TEST WHERE ID = @ID";
- param = new SqlParameter("@ID", null);
- param.SourceColumn = "ID";
- cmd.Parameters.Add(param);
- da.DeleteCommand = cmd;
完成準備工作后，利用DataTable進行數據操作：
- DataTable dt = ds.Tables["TEST"];
- dt.PrimaryKey = new DataColumn[] { dt.Columns["ID"] };
- dt.Rows.Add(new object[]{
- Guid.NewGuid().ToString(), string.Format("測試：{0}", DateTime.Now), string.Format("測試值：{0}", DateTime.Now)
- });
- DataRow dr = dt.Rows.Find("f8dc2c64-f51a-4e99-bde1-a20069b09c3a");
- if (dr != null){
- dr["NAME"] = string.Format("測試修改：{0}", DateTime.Now);
- }
- dr = dt.Rows.Find("ed7d079b-81ec-4ba4-bf85-688621e495e7");
- if (dr != null){
- dr.Delete();
- }
***調用DataAdapter的Update方法保存變更后的數據：
da.Update(ds, "TEST");
利用ADO.NET的上述方法，我們已經完成了對數據庫的完整操作。
注：上述代碼是利用DataAdapter對數據庫進行讀寫的基本原理，非常重要，我們后面的改造都將以此作為依據。
雖然我們已經能完成對數據的操作，但現實際上還是存在很多問題：
1、我們只是對MSSql數據庫進行操作，如果要對Oracle或MySql進行操作我們得定義新的Oracle或MySql數據對象，如果能由系統自動判斷操作的數據庫類型，我們就能省去對數據對象的關注。
2、我們做了太多的準備工作，我們只對一張表進行操作，如查我們要對多張表進行操作，參數又很多，實際上會產生大量的重復代碼，我們得考慮消除這些代碼。
對于上述問題，如果我們自己實現一個數據訪問層，對ADO.NET對象進行封裝，只關注實際的數據的操作，而不關注系統是如何與數據庫進行連接、如何進行參數傳遞，那我們的需求就算基本滿足了。
我們可以先進行假設，需要達成如下效果，以偽碼的形式給出：
- 創建數據執行者：DataExecuter：execObj；
- 創建數據映射對象：DataMapping map;
- 由映射對象填充數據集：map.Fill(sqlText, "TEST", ds);
- 設置映射對象更新命令：map.SetCommands(Insert | Update | Delete, ds);
- DataTable進行實際增、刪、改操作。
- 數據執行者執行***的變更操作：execObj.Update(ds);
后面我將一步步看到上述假設是如何實現的。
原文鏈接：http://www.cnblogs.com/FlySoul/archive/2011/05/02/2034368.html
【編輯推薦】
