數(shù)據(jù)訪(fǎng)問(wèn)層DAL實(shí)現(xiàn)過(guò)程
這里為了演示上簡(jiǎn)單，假設(shè)：后臺(tái)數(shù)據(jù)庫(kù)(暫為SqlServer只有用戶(hù)表User與部門(mén)表Department)，各表字段相應(yīng)精簡(jiǎn):
| User(用戶(hù)表) | |
| Id | 主鍵 |
| Name | 姓名 |
| DeptId | 部門(mén)編號(hào) |
| 其余字段省略...... | |
| Department(部門(mén)表) | |
| Id | 主鍵 |
| Name | 名稱(chēng) |
| Desc | 部門(mén)描述 |
| 其余字段省略...... | |
后臺(tái)數(shù)據(jù)庫(kù)：testdb的情況
建立相關(guān)的存儲(chǔ)過(guò)程：
一般我個(gè)人也喜歡ORM轉(zhuǎn)換成實(shí)體對(duì)象（見(jiàn)截圖）
(注意：這里增加了DeptTitle屬性<部門(mén)名稱(chēng)>)
現(xiàn)在就是訪(fǎng)問(wèn)數(shù)據(jù)庫(kù)SqlServer類(lèi)型，封裝到SqlserverProvider中。如果將來(lái)訪(fǎng)問(wèn)Access數(shù)據(jù)庫(kù),對(duì)應(yīng)訪(fǎng)問(wèn)封裝到AccessProvider中。
(Provider這里表示數(shù)據(jù)訪(fǎng)問(wèn)提供程序)
SqlUserProvier專(zhuān)門(mén)實(shí)現(xiàn)對(duì)SqlServer的表User的操作，AccessUserProvider專(zhuān)門(mén)實(shí)現(xiàn)對(duì)Access的表User的操作，很顯然，操作功能都相同(增刪改查<CRUD>)，因而對(duì)不同子類(lèi)的相同部分抽象出來(lái)，形成父類(lèi)(UserProvider)。
開(kāi)始著手具體子類(lèi)實(shí)現(xiàn)：SqlUserProvider:UserProvider
(上圖數(shù)據(jù)庫(kù)連接串錯(cuò)誤：?jiǎn)卧~integrated才是正確的，***面調(diào)試錯(cuò)誤后改正。)
我們發(fā)現(xiàn)重載的GetUsers方法，大量代碼重復(fù)，進(jìn)行方法重構(gòu)(重復(fù)代碼重構(gòu)為方法GetUsersFromReader)！
繼續(xù)具體實(shí)現(xiàn)父類(lèi)的抽象方法：GetUserById，發(fā)現(xiàn)該方法的部分代碼與先前的GetUsersFromReader方法中的部分代碼又重復(fù)了！
發(fā)現(xiàn)上圖紅色部分重復(fù)（該圖GetUserById方法忘記傳遞存儲(chǔ)過(guò)程所需的參數(shù)了），再接著方法重構(gòu)，提煉重復(fù)的代碼，避免以后改動(dòng)的多次修改。
接著編寫(xiě)該類(lèi)后續(xù)的方法（增/刪/改）：(可以打開(kāi)VS開(kāi)發(fā)環(huán)境中的<服務(wù)器資源管理器>，連接上對(duì)應(yīng)的數(shù)據(jù)庫(kù)后，看存儲(chǔ)過(guò)程的參數(shù)，以免編碼遺忘傳參)
接著也來(lái)看看 類(lèi)：AccessUserProvider，見(jiàn)下圖
上圖GetUsers方法中的查詢(xún)語(yǔ)句沒(méi)有聯(lián)合查詢(xún)，后續(xù)會(huì)改動(dòng)。(這里僅僅示范，其似Access是可以類(lèi)似建立查詢(xún)表<后臺(tái)調(diào)用類(lèi)似存儲(chǔ)過(guò)程方式>)
我們發(fā)現(xiàn)UserProvider的兩個(gè)子類(lèi)的方法GetUserFromReader和GetUsersFromReader有重復(fù)代碼(僅僅是方法的參數(shù)不同) [想辦法抽象出來(lái)，放在父類(lèi)中]
而方法的參數(shù)雖然是SqlDataReader與OleDbDataReader，但是查看定義，看到它們有自己的父類(lèi)：DbDataReader。
public class SqlDataReader : DbDataReader, IDataReader, IDisposable, IDataRecord
public sealed class OleDbDataReader : DbDataReader
改寫(xiě)父類(lèi)：UserProvider
父類(lèi)的方法加上修飾符protected，是為了確保只有子類(lèi)能夠訪(fǎng)問(wèn)。
子類(lèi)便可以直接調(diào)用父類(lèi)的方法了(GetUserFromReader和GetUsersFromReader方法)，見(jiàn)截圖：
類(lèi)似的完善SqlDepartmentProvider類(lèi)和AccessDepartmentProvider類(lèi)的代碼
（父類(lèi)：DepartmentProvider提供保護(hù)方法GetDeparmentFromReader和GetDepartmentsFromReader）
每個(gè)具體的子類(lèi)Provider都重復(fù)了屬性：ConnString，所以決定建一個(gè)父類(lèi)：DataAccess來(lái)存放該屬性(UserProvider與DepartProvider都繼承自它)，實(shí)際上DataAccess還可以包含其它的屬性和共用方法。
- namespace抽象工廠(chǎng)模式.DAL
- {
- publicabstractclassDataAccess
- {
- privatestring_connString ="";
- publicstringConnString
- { get{ return_connString; } }
- }
- }
public abstract class UserProvider:DataAccess
public abstract class DepartmentProvider:DataAccess
通常：數(shù)據(jù)庫(kù)連接串的內(nèi)容都是存儲(chǔ)在對(duì)應(yīng)的配置文件中，而不硬編碼。
桌面應(yīng)用程序—[app.config]，web應(yīng)用程序---[web.config]，這里以app.config示例，數(shù)據(jù)庫(kù)連接串先按照SqlServer數(shù)據(jù)庫(kù)訪(fǎng)問(wèn)的。
- <?xml version="1.0" encoding="utf-8" ?>
- <configuration>
- <connectionStrings>
- <add name="DBConnString"
- connectionString="SERVER=.sqlexpress;DATABASE=testdb;INTEGRATED SECURITY=true"/>
- </connectionStrings>
- </configuration>
一定要手動(dòng)引用：System.configuration，然后通過(guò)ConfigurationManager類(lèi)來(lái)訪(fǎng)問(wèn)連接串。
可以想象，根據(jù)數(shù)據(jù)庫(kù)的類(lèi)型不同，實(shí)際底層操控的數(shù)據(jù)提供程序?yàn)镾ql__Provider或是Access__Provider。
但對(duì)于用戶(hù)調(diào)用者(業(yè)務(wù)邏輯層)只需要操控Provider就可以了。
假設(shè)我所在城市有兩個(gè)行政分區(qū)(東一區(qū)和西二區(qū))，有一家“真不錯(cuò)”總店[經(jīng)營(yíng)快餐系列的]在這兩個(gè)區(qū)都有連鎖店，對(duì)外統(tǒng)一電話(huà)：1111777。
(設(shè)一個(gè)總機(jī)號(hào)碼當(dāng)然方便了，總不至于將來(lái)開(kāi)了10家分店，對(duì)外公布10個(gè)電話(huà)號(hào)碼，誰(shuí)能記住啊？)
比如說(shuō)：我現(xiàn)在餓了，想吃這家提供的“經(jīng)濟(jì)型快餐(一素<炒萵苣>一湯<豆腐湯>)”，我只要打電話(huà)111177，那邊只需要了解我的地址就可以了。(可以想象：知道了我的地址<就能明白所在行政區(qū)，然后公司總店去指派所在區(qū)的分店來(lái)服務(wù)>)，對(duì)于客戶(hù)我而言：如何指派哪家分店來(lái)服務(wù)，以及經(jīng)濟(jì)型快餐如何制作的，我都不會(huì)關(guān)心的。我只關(guān)心：要好吃，然后要快點(diǎn)(畢竟，餓太久會(huì)受不了的。)
回到我們的程序：
UserProvider好比一個(gè)物品蔬菜<萵苣>，DepartmentProvider好比湯菜<豆腐>。Access文件夾[經(jīng)濟(jì)型]，SqlServer文件夾[商務(wù)型] (你會(huì)問(wèn)一個(gè)題外問(wèn)題：有葷菜嗎？我的回答是：盡量別吃，如今都是激素喂出來(lái)的<現(xiàn)在人們消耗太快了，以前自然方式半年才能長(zhǎng)大的動(dòng)物，如今1個(gè)月人工方式就用激素喂成了>。吃多了，身體容易得病)。
只有一個(gè)問(wèn)題：既然BLL(相對(duì)于DAL就是客戶(hù)調(diào)用者)只認(rèn)(UserProvider/DepartmentProvider)，又是如何調(diào)用實(shí)際其作用的子類(lèi)呢？
這就需要用到設(shè)計(jì)模式中的<簡(jiǎn)單工廠(chǎng)模式> （具體選擇哪個(gè)子類(lèi)實(shí)際上用父類(lèi)來(lái)完成<根據(jù)客戶(hù)配置需求>）
當(dāng)然這里的配置文件：數(shù)據(jù)庫(kù)連接串和providerType需要匹配好。
父類(lèi)：UserProvider我們提供靜態(tài)的Instance，來(lái)決定實(shí)際的子類(lèi)(SqlUserProvider或者AccessUserProvider，根據(jù)配置文件的ProviderType的value來(lái)定)
如果將來(lái)出現(xiàn)了OracleUserProvider/DB2UserProvider/MySqlUserProvider/XmlUserProvider，這個(gè)藍(lán)色框框仍然需要增加case分支。這就不好了，需要再編碼(修改)，好的設(shè)計(jì)方式應(yīng)該是對(duì)擴(kuò)展開(kāi)放，對(duì)修改封閉。而且這里羅列出了所有的具體子類(lèi)Provider，其實(shí)只需要一個(gè)子類(lèi)Provider，但是其他的子類(lèi)Provider也被迫出現(xiàn)在一起<大雜燴>(其實(shí)子類(lèi)之間出現(xiàn)了耦合) 所以這種方式不可取，需要解決。
這里用反射的方式來(lái)解決這個(gè)問(wèn)題。
首先約束：ProviderType的賦值需要規(guī)范，只能從(Sql/Access/DB2/MySql/Xml)選擇一個(gè)呢。可以發(fā)現(xiàn)：實(shí)際的子類(lèi)名：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)目(類(lèi)庫(kù))，請(qǐng)使用Assembly.Load等方式，這里由于是以文件夾方式組織的(DAL文件夾)<用Activator.CreateInstance可以O(shè)K.>
以后客戶(hù)端(BLL)調(diào)用的時(shí)候：比如刪除用戶(hù)表的記錄，就可以如下調(diào)用了：
UserProvider.Instance.DeleteUser(id)了。//這里BLL已經(jīng)不知道是由哪個(gè)子類(lèi)(如SqlUserProvider)來(lái)實(shí)際工作的。
進(jìn)行一下測(cè)試，看是否運(yùn)行正常！
發(fā)現(xiàn)錯(cuò)誤：一：數(shù)據(jù)庫(kù)連接串需要修改：
二：文件夾SqlServer改成Sql。以前的命名空間對(duì)應(yīng)改動(dòng)下：
namespace抽象工廠(chǎng)模式.DAL.Provider.Sql
{
publicclassSqlDepartmentProvider:DepartmentProvider
………………………………………….
namespace抽象工廠(chǎng)模式.DAL.Provider.Sql
{
publicclassSqlUserProvider:UserProvider
………………………………………………………….
三：Type.GetType(需要完整的限定名)
測(cè)試通過(guò)：但發(fā)現(xiàn)沒(méi)有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抽象工廠(chǎng)模式.DAL;
- using抽象工廠(chǎng)模式.DAL.Entity;
- namespace抽象工廠(chǎng)模式.DAL.Provider.Access
- {
- publicclassAccessUserProvider:UserProvider
- {
- publicoverrideList<User> GetUsers()
- {
- using(OleDbConnection conn = newOleDbConnection(ConnString))
- {
- vardbcmd = conn.CreateCommand();
- dbcmd.CommandText = "GetUsers";
- dbcmd.CommandType = CommandType.StoredProcedure;
- conn.Open();
- returnGetUsersFromReader(dbcmd.ExecuteReader());
- }
- }
- publicoverrideList<User> 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截圖：
原文鏈接：http://www.cnblogs.com/netxiaochong/archive/2012/01/10/2318119.html
【編輯推薦】
- 系統(tǒng)架構(gòu)師談企業(yè)應(yīng)用架構(gòu)之開(kāi)卷有益
- 系統(tǒng)架構(gòu)師談企業(yè)應(yīng)用架構(gòu)之系統(tǒng)建模1
- 系統(tǒng)架構(gòu)師談企業(yè)應(yīng)用架構(gòu)之系統(tǒng)建模2
- 系統(tǒng)架構(gòu)師談企業(yè)應(yīng)用架構(gòu)之系統(tǒng)建模3
- 系統(tǒng)架構(gòu)師談企業(yè)應(yīng)用架構(gòu)之系統(tǒng)建模4
- 系統(tǒng)架構(gòu)師談企業(yè)應(yīng)用架構(gòu)之系統(tǒng)設(shè)計(jì)規(guī)范與原則1
- 系統(tǒng)架構(gòu)師談企業(yè)應(yīng)用架構(gòu)之系統(tǒng)設(shè)計(jì)規(guī)范與原則2
- 系統(tǒng)架構(gòu)師談企業(yè)應(yīng)用架構(gòu)之業(yè)務(wù)邏輯層
- 系統(tǒng)架構(gòu)師談企業(yè)應(yīng)用架構(gòu)之表現(xiàn)層
- 系統(tǒng)架構(gòu)師談企業(yè)應(yīng)用架構(gòu)之服務(wù)層
- 系統(tǒng)架構(gòu)師談企業(yè)應(yīng)用架構(gòu)之?dāng)?shù)據(jù)訪(fǎng)問(wèn)層
