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