玄幻小说,遮天辰东小说

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營(yíng)銷解決方案

數(shù)據(jù)訪問層DAL實(shí)現(xiàn)過程

這里為了演示上簡(jiǎn)單，假設(shè)：后臺(tái)數(shù)據(jù)庫(暫為SqlServer只有用戶表User與部門表Department)，各表字段相應(yīng)精簡(jiǎn):

創(chuàng)新互聯(lián)公司專注于中大型企業(yè)的網(wǎng)站建設(shè)、成都網(wǎng)站建設(shè)和網(wǎng)站改版、網(wǎng)站營(yíng)銷服務(wù)，追求商業(yè)策劃與數(shù)據(jù)分析、創(chuàng)意藝術(shù)與技術(shù)開發(fā)的融合，累計(jì)客戶上千多家，服務(wù)滿意度達(dá)97%。幫助廣大客戶順利對(duì)接上互聯(lián)網(wǎng)浪潮，準(zhǔn)確優(yōu)選出符合自己需要的互聯(lián)網(wǎng)運(yùn)用，我們將一直專注高端網(wǎng)站設(shè)計(jì)和互聯(lián)網(wǎng)程序開發(fā)，在前進(jìn)的路上，與客戶一起成長(zhǎng)！

User(用戶表)
Id	主鍵
Name	姓名
DeptId	部門編號(hào)
其余字段省略......

Department(部門表)
Id	主鍵
Name	名稱
Desc	部門描述
其余字段省略......

　　后臺(tái)數(shù)據(jù)庫：testdb的情況

建立相關(guān)的存儲(chǔ)過程：

一般我個(gè)人也喜歡ORM轉(zhuǎn)換成實(shí)體對(duì)象（見截圖）

(注意：這里增加了DeptTitle屬性<部門名稱>)

　　現(xiàn)在就是訪問數(shù)據(jù)庫SqlServer類型，封裝到SqlserverProvider中。如果將來訪問Access數(shù)據(jù)庫,對(duì)應(yīng)訪問封裝到AccessProvider中。

　　(Provider這里表示數(shù)據(jù)訪問提供程序)

　　SqlUserProvier專門實(shí)現(xiàn)對(duì)SqlServer的表User的操作，AccessUserProvider專門實(shí)現(xiàn)對(duì)Access的表User的操作，很顯然，操作功能都相同(增刪改查)，因而對(duì)不同子類的相同部分抽象出來，形成父類(UserProvider)。

開始著手具體子類實(shí)現(xiàn)：SqlUserProvider:UserProvider

　　(上圖數(shù)據(jù)庫連接串錯(cuò)誤：?jiǎn)卧~integrated才是正確的，***面調(diào)試錯(cuò)誤后改正。)

　　我們發(fā)現(xiàn)重載的GetUsers方法，大量代碼重復(fù)，進(jìn)行方法重構(gòu)(重復(fù)代碼重構(gòu)為方法GetUsersFromReader)！

　　繼續(xù)具體實(shí)現(xiàn)父類的抽象方法：GetUserById，發(fā)現(xiàn)該方法的部分代碼與先前的GetUsersFromReader方法中的部分代碼又重復(fù)了！

　　發(fā)現(xiàn)上圖紅色部分重復(fù)（該圖GetUserById方法忘記傳遞存儲(chǔ)過程所需的參數(shù)了），再接著方法重構(gòu)，提煉重復(fù)的代碼，避免以后改動(dòng)的多次修改。

　　接著編寫該類后續(xù)的方法（增/刪/改）：(可以打開VS開發(fā)環(huán)境中的<服務(wù)器資源管理器>，連接上對(duì)應(yīng)的數(shù)據(jù)庫后，看存儲(chǔ)過程的參數(shù)，以免編碼遺忘傳參)

接著也來看看類：AccessUserProvider，見下圖

　　上圖GetUsers方法中的查詢語句沒有聯(lián)合查詢，后續(xù)會(huì)改動(dòng)。(這里僅僅示范，其似Access是可以類似建立查詢表<后臺(tái)調(diào)用類似存儲(chǔ)過程方式>)

　　我們發(fā)現(xiàn)UserProvider的兩個(gè)子類的方法GetUserFromReader和GetUsersFromReader有重復(fù)代碼(僅僅是方法的參數(shù)不同) [想辦法抽象出來，放在父類中]

　　而方法的參數(shù)雖然是SqlDataReader與OleDbDataReader，但是查看定義，看到它們有自己的父類：DbDataReader。

　　public class SqlDataReader :DbDataReader, IDataReader, IDisposable, IDataRecord

　　public sealed class OleDbDataReader :DbDataReader

　　改寫父類：UserProvider

父類的方法加上修飾符protected，是為了確保只有子類能夠訪問。

　　子類便可以直接調(diào)用父類的方法了(GetUserFromReader和GetUsersFromReader方法)，見截圖：

類似的完善SqlDepartmentProvider類和AccessDepartmentProvider類的代碼

　?。ǜ割悾篋epartmentProvider提供保護(hù)方法GetDeparmentFromReader和GetDepartmentsFromReader）

　　每個(gè)具體的子類Provider都重復(fù)了屬性：ConnString，所以決定建一個(gè)父類：DataAccess來存放該屬性(UserProvider與DepartProvider都繼承自它)，實(shí)際上DataAccess還可以包含其它的屬性和共用方法。

 
 
 
 
  
  
  
  namespace抽象工廠模式.DAL 
  
  
  
  { 
  
  
  
  publicabstractclassDataAccess 
  
  
  
  { 
  
  
  
  privatestring_connString =""; 
  
  
  
  publicstringConnString 
  
  
  
  { get{ return_connString; } } 
  
  
  
  } 
  
  
  
  }

　　public abstract class UserProvider:DataAccess

　　public abstract class DepartmentProvider:DataAccess

　　通常：數(shù)據(jù)庫連接串的內(nèi)容都是存儲(chǔ)在對(duì)應(yīng)的配置文件中，而不硬編碼。

　　桌面應(yīng)用程序—[app.config]，web應(yīng)用程序---[web.config]，這里以app.config示例，數(shù)據(jù)庫連接串先按照SqlServer數(shù)據(jù)庫訪問的。

 
 
 
 
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
  
connectionString="SERVER=.sqlexpress;DATABASE=testdb;INTEGRATED SECURITY=true"/>

　　一定要手動(dòng)引用：System.configuration，然后通過ConfigurationManager類來訪問連接串。

　　可以想象，根據(jù)數(shù)據(jù)庫的類型不同，實(shí)際底層操控的數(shù)據(jù)提供程序?yàn)镾ql__Provider或是Access__Provider。

　　但對(duì)于用戶調(diào)用者(業(yè)務(wù)邏輯層)只需要操控Provider就可以了。

　　假設(shè)我所在城市有兩個(gè)行政分區(qū)(東一區(qū)和西二區(qū))，有一家“真不錯(cuò)”總店[經(jīng)營(yíng)快餐系列的]在這兩個(gè)區(qū)都有連鎖店，對(duì)外統(tǒng)一電話：1111777。

　　(設(shè)一個(gè)總機(jī)號(hào)碼當(dāng)然方便了，總不至于將來開了10家分店，對(duì)外公布10個(gè)電話號(hào)碼，誰能記住??？)

　　比如說：我現(xiàn)在餓了，想吃這家提供的“經(jīng)濟(jì)型快餐(一素<炒萵苣>一湯<豆腐湯>)”，我只要打電話111177，那邊只需要了解我的地址就可以了。(可以想象：知道了我的地址<就能明白所在行政區(qū)，然后公司總店去指派所在區(qū)的分店來服務(wù)>)，對(duì)于客戶我而言：如何指派哪家分店來服務(wù)，以及經(jīng)濟(jì)型快餐如何制作的，我都不會(huì)關(guān)心的。我只關(guān)心：要好吃，然后要快點(diǎn)(畢竟，餓太久會(huì)受不了的。)

　　回到我們的程序：

　　UserProvider好比一個(gè)物品蔬菜<萵苣>，DepartmentProvider好比湯菜<豆腐>。Access文件夾[經(jīng)濟(jì)型]，SqlServer文件夾[商務(wù)型] (你會(huì)問一個(gè)題外問題：有葷菜嗎？我的回答是：盡量別吃，如今都是激素喂出來的<現(xiàn)在人們消耗太快了，以前自然方式半年才能長(zhǎng)大的動(dòng)物，如今1個(gè)月人工方式就用激素喂成了>。吃多了，身體容易得病)。

　　只有一個(gè)問題：既然BLL(相對(duì)于DAL就是客戶調(diào)用者)只認(rèn)(UserProvider/DepartmentProvider)，又是如何調(diào)用實(shí)際其作用的子類呢？

　　這就需要用到設(shè)計(jì)模式中的<簡(jiǎn)單工廠模式> （具體選擇哪個(gè)子類實(shí)際上用父類來完成<根據(jù)客戶配置需求>）

當(dāng)然這里的配置文件：數(shù)據(jù)庫連接串和providerType需要匹配好。

　　父類：UserProvider我們提供靜態(tài)的Instance，來決定實(shí)際的子類(SqlUserProvider或者AccessUserProvider，根據(jù)配置文件的ProviderType的value來定)

　　如果將來出現(xiàn)了OracleUserProvider/DB2UserProvider/MySqlUserProvider/XmlUserProvider，這個(gè)藍(lán)色框框仍然需要增加case分支。這就不好了，需要再編碼(修改)，好的設(shè)計(jì)方式應(yīng)該是對(duì)擴(kuò)展開放，對(duì)修改封閉。而且這里羅列出了所有的具體子類Provider，其實(shí)只需要一個(gè)子類Provider，但是其他的子類Provider也被迫出現(xiàn)在一起<大雜燴>(其實(shí)子類之間出現(xiàn)了耦合) 所以這種方式不可取，需要解決。

　　這里用反射的方式來解決這個(gè)問題。

　　首先約束：ProviderType的賦值需要規(guī)范，只能從(Sql/Access/DB2/MySql/Xml)選擇一個(gè)呢。可以發(fā)現(xiàn)：實(shí)際的子類名：ProviderType的值+“UserProvider”。

 
 
 
 
  
  
  
  staticpublicUserProvider Instance 
  
  
  
  { 
  
  
  
  get
  
  
  
  { 
  
  
  
  if(_instance == null) 
  
  
  
  { 
  
  
  
  stringproviderTypeName=ConfigurationManager.AppSettings["ProviderType"] 
  
  
  
  +"UserProvider"; 
  
  
  
  _instance = 
  
  
  
  Activator.CreateInstance(Type.GetType(providerTypeName)) asUserProvider; 
  
  
  
  } 
  
  
  
  return_instance; 
  
  
  
  } 
  
  
  
  }

　　如果：你的DAL是單獨(dú)用程序集方式建立的項(xiàng)目(類庫)，請(qǐng)使用Assembly.Load等方式，這里由于是以文件夾方式組織的(DAL文件夾)<用Activator.CreateInstance可以O(shè)K.>

　　以后客戶端(BLL)調(diào)用的時(shí)候：比如刪除用戶表的記錄，就可以如下調(diào)用了：

　　UserProvider.Instance.DeleteUser(id)了。//這里BLL已經(jīng)不知道是由哪個(gè)子類(如SqlUserProvider)來實(shí)際工作的。

　　進(jìn)行一下測(cè)試，看是否運(yùn)行正常！

　　發(fā)現(xiàn)錯(cuò)誤：一：數(shù)據(jù)庫連接串需要修改：

二：文件夾SqlServer改成Sql。以前的命名空間對(duì)應(yīng)改動(dòng)下：

　　namespace抽象工廠模式.DAL.Provider.Sql

　　{

　　publicclassSqlDepartmentProvider:DepartmentProvider

　　………………………………………….

　　namespace抽象工廠模式.DAL.Provider.Sql

　　{

　　publicclassSqlUserProvider:UserProvider

　　………………………………………………………….

　　三：Type.GetType(需要完整的限定名)

測(cè)試通過：但發(fā)現(xiàn)沒有DeptTitle數(shù)據(jù)，查找錯(cuò)誤發(fā)現(xiàn)

 
 
 
 
  
  
  
  　　publicUser(intid, stringname, intdeptId, stringdeptTitle) 
  
  
  
  　　{ 
  
  
  
  　　this.Id = id; 
  
  
  
  　　this.Name = name; 
  
  
  
  　　this.DeptId = deptId; 
  
  
  
  　　this.DeptTitle = deptTitle; //DeptTitle; 
  
  
  
  　　}

附上：AccessUserProvider的代碼如下：

AccessUserProvider代碼

 
 
 
 
  
  
  
  usingSystem; 
  
  
  
  usingSystem.Collections.Generic; 
  
  
  
  usingSystem.Text; 
  
  
  
  usingSystem.Data; 
  
  
  
  usingSystem.Data.OleDb; 
  
  
  
  using抽象工廠模式.DAL; 
  
  
  
  using抽象工廠模式.DAL.Entity; 
  
  
  
  namespace抽象工廠模式.DAL.Provider.Access 
  
  
  
  { 
  
  
  
  publicclassAccessUserProvider:UserProvider 
  
  
  
  { 
  
  
  
  publicoverrideList GetUsers() 
  
  
  
  { 
  
  
  
  using(OleDbConnection conn = newOleDbConnection(ConnString)) 
  
  
  
  { 
  
  
  
  vardbcmd = conn.CreateCommand(); 
  
  
  
  dbcmd.CommandText = "GetUsers"; 
  
  
  
  dbcmd.CommandType = CommandType.StoredProcedure; 
  
  
  
  conn.Open(); 
  
  
  
  returnGetUsersFromReader(dbcmd.ExecuteReader()); 
  
  
  
  } 
  
  
  
  } 
  
  
  
  publicoverrideList GetUsers(intdeptId) 
  
  
  
  { 
  
  
  
  using(OleDbConnection conn = newOleDbConnection(ConnString)) 
  
  
  
  { 
  
  
  
  vardbcmd = conn.CreateCommand(); 
  
  
  
  dbcmd.CommandText = "GetUsersByDepartmentId"; 
  
  
  
  dbcmd.CommandType = CommandType.StoredProcedure; 
  
  
  
  dbcmd.Parameters.Add("@DeptId", OleDbType.Integer).Value = deptId; 
  
  
  
  conn.Open(); 
  
  
  
  returnGetUsersFromReader(dbcmd.ExecuteReader()); 
  
  
  
  } 
  
  
  
  } 
  
  
  
  publicoverrideUser GetUserById(intid) 
  
  
  
  { 
  
  
  
  using(OleDbConnection conn = newOleDbConnection(ConnString)) 
  
  
  
  { 
  
  
  
  vardbcmd = conn.CreateCommand(); 
  
  
  
  dbcmd.CommandText = "GetUserById"; 
  
  
  
  dbcmd.CommandType = CommandType.StoredProcedure; 
  
  
  
  dbcmd.Parameters.Add("@Id", OleDbType.Integer).Value =id ; 
  
  
  
  conn.Open(); 
  
  
  
  returnGetUserFromReader(dbcmd.ExecuteReader()); 
  
  
  
  } 
  
  
  
  } 
  
  
  
  publicoverrideboolDeleteUser(intid) 
  
  
  
  { 
  
  
  
  using(OleDbConnection conn = newOleDbConnection(ConnString)) 
  
  
  
  { 
  
  
  
  OleDbCommand cmd = newOleDbCommand( 
  
  
  
  "delete from [user] where Id="+ id, conn); 
  
  
  
  conn.Open(); 
  
  
  
  returncmd.ExecuteNonQuery() == 1; 
  
  
  
  } 
  
  
  
  } 
  
  
  
  publicoverrideintInsertUser(User user) 
  
  
  
  { 
  
  
  
  using(OleDbConnection conn = newOleDbConnection(ConnString)) 
  
  
  
  { 
  
  
  
  OleDbCommand cmd = newOleDbCommand( 
  
  
  
  @"insert into [user](name,deptId) values(@id,@name);68select max(id) from [user] as newid",conn); 
  
  
  
  cmd.Parameters.Add("@id", OleDbType.Integer).Value = user.Id; 
  
  
  
  cmd.Parameters.Add("@name", OleDbType.VarChar).Value = user.Name; 
  
  
  
  conn.Open(); 
  
  
  
  return(int)cmd.ExecuteScalar(); 
  
  
  
  } 
  
  
  
  } 
  
  
  
  publicoverrideboolUpdateUser(User user) 
  
  
  
  { 
  
  
  
  using(OleDbConnection conn = newOleDbConnection(ConnString)) 
  
  
  
  { 
  
  
  
  OleDbCommand cmd = newOleDbCommand( 
  
  
  
  "update [user] set name=@name,deptId=@deptid where Id=@id", conn); 
  
  
  
  cmd.Parameters.Add("@name", OleDbType.Integer).Value = user.Name; 
  
  
  
  cmd.Parameters.Add("@deptid", OleDbType.Integer).Value = user.DeptId; 
  
  
  
  cmd.Parameters.Add("@id", OleDbType.Integer).Value = user.Id; 
  
  
  
  conn.Open(); 
  
  
  
  returncmd.ExecuteNonQuery() == 1; 
  
  
  
  } 
  
  
  
  } 
  
  
  
  } 
  
  
  
  }

　　后臺(tái)的testdb.mdb截圖：

當(dāng)前名稱：數(shù)據(jù)訪問層DAL實(shí)現(xiàn)過程
鏈接地址：http://fisionsoft.com.cn/article/ccchgec.html

新聞中心

其他資訊