< 返回技术文档列表

数据访问层DAL是怎样实现的

发布时间:2021-11-07 02:16:16

数据访问层DAL的实现过程是怎么样的,针对这个问题,这篇文章详细介绍了相对应的分析和解答,希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。

这里为了演示上简单,假设:后台数据库(暂为SqlServer只有用户表User与部门表Department),各表字段相应精简:

User(用户表)
Id主键
Name姓名
DeptId部门编号
其余字段省略......
Department(部门表)
Id主键
Name名称
Desc部门描述
其余字段省略......

后台数据库:testdb的情况

数据访问层DAL是怎样实现的

建立相关的存储过程:

数据访问层DAL是怎样实现的

一般我个人也喜欢ORM转换成实体对象(见截图)

数据访问层DAL是怎样实现的

数据访问层DAL是怎样实现的

(注意:这里增加了DeptTitle属性<部门名称>)

现在就是访问数据库SqlServer类型,封装到SqlserverProvider中。如果将来访问Access数据库,对应访问封装到AccessProvider中。

(Provider这里表示数据访问提供程序)

数据访问层DAL是怎样实现的

SqlUserProvier专门实现对SqlServer的表User的操作,AccessUserProvider专门实现对Access的表User的操作,很显然,操作功能都相同(增删改查<CRUD>),因而对不同子类的相同部分抽象出来,形成父类(UserProvider)。

数据访问层DAL是怎样实现的

开始着手具体子类实现:SqlUserProvider:UserProvider

数据访问层DAL是怎样实现的

(上图数据库连接串错误:单词integrated才是正确的,***面调试错误后改正。)

我们发现重载的GetUsers方法,大量代码重复,进行方法重构(重复代码重构为方法GetUsersFromReader)!

数据访问层DAL是怎样实现的

继续具体实现父类的抽象方法:GetUserById,发现该方法的部分代码与先前的GetUsersFromReader方法中的部分代码又重复了!

数据访问层DAL是怎样实现的

发现上图红色部分重复(该图GetUserById方法忘记传递存储过程所需的参数了),再接着方法重构,提炼重复的代码,避免以后改动的多次修改。

数据访问层DAL是怎样实现的

接着编写该类后续的方法(增/删/改):(可以打开VS开发环境中的<服务器资源管理器>,连接上对应的数据库后,看存储过程的参数,以免编码遗忘传参)

数据访问层DAL是怎样实现的

接着也来看看 类:AccessUserProvider,见下图

数据访问层DAL是怎样实现的

上图GetUsers方法中的查询语句没有联合查询,后续会改动。(这里仅仅示范,其似Access是可以类似建立查询表<后台调用类似存储过程方式>)

我们发现UserProvider的两个子类的方法GetUserFromReader和GetUsersFromReader有重复代码(仅仅是方法的参数不同) [想办法抽象出来,放在父类中]

数据访问层DAL是怎样实现的

而方法的参数虽然是SqlDataReader与OleDbDataReader,但是查看定义,看到它们有自己的父类:DbDataReader。

public class SqlDataReader : DbDataReader, IDataReader, IDisposable, IDataRecord

public sealed class OleDbDataReader : DbDataReader

改写父类:UserProvider

数据访问层DAL是怎样实现的

父类的方法加上修饰符protected,是为了确保只有子类能够访问。

子类便可以直接调用父类的方法了(GetUserFromReader和GetUsersFromReader方法),见截图:

数据访问层DAL是怎样实现的

类似的完善SqlDepartmentProvider类和AccessDepartmentProvider类的代码

(父类:DepartmentProvider提供保护方法GetDeparmentFromReader和GetDepartmentsFromReader)

数据访问层DAL是怎样实现的

每个具体的子类Provider都重复了属性:ConnString,所以决定建一个父类:DataAccess来存放该属性(UserProvider与DepartProvider都继承自它),实际上DataAccess还可以包含其它的属性和共用方法。

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

public abstract class UserProvider:DataAccess

public abstract class DepartmentProvider:DataAccess

通常:数据库连接串的内容都是存储在对应的配置文件中,而不硬编码。

桌面应用程序&mdash;[app.config],web应用程序---[web.config],这里以app.config示例,数据库连接串先按照SqlServer数据库访问的。

数据访问层DAL是怎样实现的

<?xml version="1.0" encoding="utf-8" ?> <configuration> <connectionStrings> <add name="DBConnString" connectionString="SERVER=.sqlexpress;DATABASE=testdb;INTEGRATED SECURITY=true"/> </connectionStrings> </configuration>

数据访问层DAL是怎样实现的

一定要手动引用:System.configuration,然后通过ConfigurationManager类来访问连接串。

可以想象,根据数据库的类型不同,实际底层操控的数据提供程序为Sql__Provider或是Access__Provider。

但对于用户调用者(业务逻辑层)只需要操控Provider就可以了。

假设我所在城市有两个行政分区(东一区和西二区),有一家“真不错”总店[经营快餐系列的]在这两个区都有连锁店,对外统一电话:1111777。

(设一个总机号码当然方便了,总不至于将来开了10家分店,对外公布10个电话号码,谁能记住啊?)

比如说:我现在饿了,想吃这家提供的“经济型快餐(一素<炒莴苣>一汤<豆腐汤>)”,我只要打电话111177,那边只需要了解我的地址就可以了。(可以想象:知道了我的地址<就能明白所在行政区,然后公司总店去指派所在区的分店来服务>),对于客户我而言:如何指派哪家分店来服务,以及经济型快餐如何制作的,我都不会关心的。我只关心:要好吃,然后要快点(毕竟,饿太久会受不了的。)

回到我们的程序:

UserProvider好比一个物品蔬菜<莴苣>,DepartmentProvider好比汤菜<豆腐>。Access文件夹[经济型],SqlServer文件夹[商务型] (你会问一个题外问题:有荤菜吗?我的回答是:尽量别吃,如今都是激素喂出来的<现在人们消耗太快了,以前自然方式半年才能长大的动物,如今1个月人工方式就用激素喂成了>。吃多了,身体容易得病)。

只有一个问题:既然BLL(相对于DAL就是客户调用者)只认(UserProvider/DepartmentProvider),又是如何调用实际其作用的子类呢?

这就需要用到设计模式中的<简单工厂模式> (具体选择哪个子类实际上用父类来完成<根据客户配置需求>)

数据访问层DAL是怎样实现的

当然这里的配置文件:数据库连接串和providerType需要匹配好。

父类:UserProvider我们提供静态的Instance,来决定实际的子类(SqlUserProvider或者AccessUserProvider,根据配置文件的ProviderType的value来定)

数据访问层DAL是怎样实现的

如果将来出现了OracleUserProvider/DB2UserProvider/MySqlUserProvider/XmlUserProvider,这个蓝色框框仍然需要增加case分支。这就不好了,需要再编码(修改),好的设计方式应该是对扩展开放,对修改封闭。而且这里罗列出了所有的具体子类Provider,其实只需要一个子类Provider,但是其他的子类Provider也被迫出现在一起<大杂烩>(其实子类之间出现了耦合) 所以这种方式不可取,需要解决。

这里用反射的方式来解决这个问题。

首先约束:ProviderType的赋值需要规范,只能从(Sql/Access/DB2/MySql/Xml)选择一个呢。可以发现:实际的子类名:ProviderType的值+“UserProvider”。

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

如果:你的DAL是单独用程序集方式建立的项目(类库),请使用Assembly.Load等方式,这里由于是以文件夹方式组织的(DAL文件夹)<用Activator.CreateInstance可以OK.>

以后客户端(BLL)调用的时候:比如删除用户表的记录,就可以如下调用了:

UserProvider.Instance.DeleteUser(id)了。//这里BLL已经不知道是由哪个子类(如SqlUserProvider)来实际工作的。

进行一下测试,看是否运行正常!

发现错误:一:数据库连接串需要修改:

数据访问层DAL是怎样实现的

二:文件夹SqlServer改成Sql。以前的命名空间对应改动下:

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

{

publicclassSqlDepartmentProvider:DepartmentProvider

&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;.

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

{

publicclassSqlUserProvider:UserProvider

&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;&hellip;.

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

数据访问层DAL是怎样实现的

测试通过:但发现没有DeptTitle数据,查找错误发现

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

数据访问层DAL是怎样实现的

附上: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<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;  }  }  }  }

后台的testdb.mdb截图:

数据访问层DAL是怎样实现的

关于数据访问层DAL的实现过程是怎么样的问题的解答就分享到这里了,希望以上内容可以对大家有一定的帮助,如果你还有很多疑惑没有解开,可以关注血鸟云行业资讯频道了解更多相关知识。


/template/Home/Zkeys/PC/Static