打造自己的數(shù)據(jù)訪問層一
項目開發(fā)中，大多數(shù)開發(fā)人員的核心工作就是如何對數(shù)據(jù)進行存儲及訪問。為了進行數(shù)據(jù)操作，我們首先得解決幾個基本問題：
1、如何與一個數(shù)據(jù)庫建立連接。
2、如何從數(shù)據(jù)庫讀取相應的數(shù)據(jù)。
3、如何對數(shù)據(jù)表進行增改操作。
.NET中，ADO.NET很方便的解決了上面三個問題，我們可以使用DbConnection進行連接，DataSet進行數(shù)據(jù)存儲，DataAdapter進行數(shù)據(jù)更新。先看一段代碼：
- //創(chuàng)建DbConnection對象連接數(shù)據(jù)庫
- SqlConnection conn = new SqlConnection();
- conn.ConnectionString = "server=.;uid=sa;password=123456; database=DATA_BASE; max pool size=300;";
- //創(chuàng)建DataAdapter、Command對象，讀取數(shù)據(jù)
- SqlDataAdapter da = new SqlDataAdapter();
- SqlCommand cmd = new SqlCommand();
- cmd.Connection = conn;
- cmd.CommandText = "SELECT * FROM TEST";
- da.SelectCommand = cmd;
- //創(chuàng)建DataSet對象，存儲數(shù)據(jù)，建立與物理表的映射
- DataSet ds = new DataSet();
- da.Fill(ds, "TEST");
上述代碼實現(xiàn)對數(shù)據(jù)庫“DATA_BASE”中“TEST”表數(shù)據(jù)讀取，并用DataSet時行存儲。
既然讀出了TEST表中的數(shù)據(jù)，接下來要解決的就是如何對TEST表進行增、刪、改操作。
為實現(xiàn)增、刪、改操作，需要為DataAdapter指定InsertCommand、DeleteCommand以及UpdateCommand，并為每個Command對象綁定參數(shù)：
- //新增數(shù)據(jù)
- 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;
- //修改數(shù)據(jù)
- 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;
- //刪除數(shù)據(jù)
- 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進行數(shù)據(jù)操作：
- 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方法保存變更后的數(shù)據(jù)：
da.Update(ds, "TEST");
利用ADO.NET的上述方法，我們已經(jīng)完成了對數(shù)據(jù)庫的完整操作。
注：上述代碼是利用DataAdapter對數(shù)據(jù)庫進行讀寫的基本原理，非常重要，我們后面的改造都將以此作為依據(jù)。
雖然我們已經(jīng)能完成對數(shù)據(jù)的操作，但現(xiàn)實際上還是存在很多問題：
1、我們只是對MSSql數(shù)據(jù)庫進行操作，如果要對Oracle或MySql進行操作我們得定義新的Oracle或MySql數(shù)據(jù)對象，如果能由系統(tǒng)自動判斷操作的數(shù)據(jù)庫類型，我們就能省去對數(shù)據(jù)對象的關注。
2、我們做了太多的準備工作，我們只對一張表進行操作，如查我們要對多張表進行操作，參數(shù)又很多，實際上會產(chǎn)生大量的重復代碼，我們得考慮消除這些代碼。
對于上述問題，如果我們自己實現(xiàn)一個數(shù)據(jù)訪問層，對ADO.NET對象進行封裝，只關注實際的數(shù)據(jù)的操作，而不關注系統(tǒng)是如何與數(shù)據(jù)庫進行連接、如何進行參數(shù)傳遞，那我們的需求就算基本滿足了。
我們可以先進行假設，需要達成如下效果，以偽碼的形式給出：
- 創(chuàng)建數(shù)據(jù)執(zhí)行者：DataExecuter：execObj；
- 創(chuàng)建數(shù)據(jù)映射對象：DataMapping map;
- 由映射對象填充數(shù)據(jù)集：map.Fill(sqlText, "TEST", ds);
- 設置映射對象更新命令：map.SetCommands(Insert | Update | Delete, ds);
- DataTable進行實際增、刪、改操作。
- 數(shù)據(jù)執(zhí)行者執(zhí)行***的變更操作：execObj.Update(ds);
后面我將一步步看到上述假設是如何實現(xiàn)的。
原文鏈接：http://www.cnblogs.com/FlySoul/archive/2011/05/02/2034368.html
【編輯推薦】
- 曬曬我的通用數(shù)據(jù)訪問層
- 幾步走，教你創(chuàng)建簡單訪問數(shù)據(jù)庫方法
- 一句代碼實現(xiàn)批量數(shù)據(jù)綁定 下
- 一步一步設計你的數(shù)據(jù)庫1
- 不重復隨機數(shù)列生成算法
