打造自己的數(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的上述方法,我們已經完成了對數(shù)據(jù)庫的完整操作。
注:上述代碼是利用DataAdapter對數(shù)據(jù)庫進行讀寫的基本原理,非常重要,我們后面的改造都將以此作為依據(jù)。
雖然我們已經能完成對數(shù)據(jù)的操作,但現(xiàn)實際上還是存在很多問題:
1、我們只是對MSSql數(shù)據(jù)庫進行操作,如果要對Oracle或MySql進行操作我們得定義新的Oracle或MySql數(shù)據(jù)對象,如果能由系統(tǒng)自動判斷操作的數(shù)據(jù)庫類型,我們就能省去對數(shù)據(jù)對象的關注。
2、我們做了太多的準備工作,我們只對一張表進行操作,如查我們要對多張表進行操作,參數(shù)又很多,實際上會產生大量的重復代碼,我們得考慮消除這些代碼。
對于上述問題,如果我們自己實現(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ù)列生成算法