Abstract Factory 抽象工厂设计模式

简单工厂模式虽然实现了使对象的创建与使用进行分离，但一次只能创建一个对象。它不能实现一次创建一系列相互依赖对象的需求，为此我们需要学习抽象工厂模式。



抽象工厂：主要功能是生产抽象产品； 如：生产学员、管理员等抽象产品。

抽象产品：主要功能是提供实体产品访问接口； 如：提供学员、管理员等实体产品数据访问的接口。

实体工厂：主要功能是生产实体产品； 如：SQL Server和Access形式的学员、管理员等数据访问对象。

实体产品：主要功能是实现自己的功能； 如：分别实现不同的数据库访问。

对 MySchoolPro（项目）的数据访问层用抽象工厂设计模式进行改造，如下图所示：



抽象工厂（Abstract Factory）设计模式的使用思路概括如下：

提供一系列相互依赖对象的创建；

封装对象的常规创建方法（new）；

提供统一调用数据访问方法的方式；

避免调用数据访问方法和具体对象创建工作的紧偶合。

抽象工厂（Abstract Factory）设计模式的概念：

提供一个创建一系列相关或相互依赖对象的接口，而无需指定它们具体的类。

抽象工厂（Abstract Factory）设计模式的使用场合：

一个系统要独立于它产品的创建、组合和表示时。

一个系统要由多个产品系列中的一个来配置时。

[b]MySchoolPro（项目）应用示例
[/b]



用抽象工厂设计模式实现的数据访问层



抽象工厂设计模式与项目中使用的类、接口的对应关系



项目间的依赖关系

项目MySchoolIDAL：提供信息数据访问接口




IStudentService


using System;


using System.Collections.Generic;


using System.Text;


using System.Data;


using System.Data.SqlClient;


using MySchoolModels; //引用实体类






/**//* ******************************


* 接口名：IStudentService


* 功能描叙：提供学员信息数据访问接口


* *****************************/




namespace MySchoolIDAL






{


public interface IStudentService






{


Student GetStudentByLoginID(string loginId);


}


}




IAdminService


using System;


using System.Collections.Generic;


using System.Text;


using System.Data;


using System.Data.SqlClient;


using MySchoolModels; //引用实体类






/**//* ******************************


* 接口名：IAdminService


* 功能描叙：提供管理员信息数据访问接口


* *****************************/




namespace MySchoolIDAL






{


public interface IAdminService






{


Admin GetAdminByLoginID(string loginId);


}


}

项目MySchoolDAL：提供信息数据访问




StudentService


using System;


using System.Collections.Generic;


using System.Text;


using System.Configuration;


using System.Data;


using System.Data.SqlClient;


using MySchoolModels; //引用实体类


using MySchoolIDAL; //引用抽象访问接口






/**//* ******************************


* 接口名：StudentService


* 功能描叙：提供学员信息数据访问


* *****************************/




namespace MySchoolDAL.SqlServer






{


public class StudentService: IStudentService






{




Private Members#region Private Members


// 从配置文件中读取数据库连接字符串


private readonly string connString =


ConfigurationSettings.AppSettings["MySchoolConnectionString"].ToString();


private readonly string dboOwner =


ConfigurationSettings.AppSettings["DataBaseOwner"].ToString();


#endregion






Public Methods#region Public Methods




/**//// <summary>


/// 根据登录ID 得到学员实体


/// </summary>


/// <param name="loginID">登录ID</param>


/// <returns>学员信息实体</returns>


public Student GetStudentByLoginID(string loginID)






{


Student student = new Student();


using (SqlConnection conn = new SqlConnection(connString))






{


SqlCommand objCommand = new SqlCommand(dboOwner + ".usp_SelectStudentInfoByLoginID",conn);


objCommand.Parameters.Add("@LoginID", SqlDbType.NVarChar, 50).Value = loginID;


conn.Open();


using (SqlDataReader objReader = objCommand.ExecuteReader(CommandBehavior.CloseConnection))






{


if (objReader.Read())






{


student.LoginId = Convert.ToString(objReader["LoginId"]);


student.StudentNO = Convert.ToString(objReader["StudentNO"]);


student.StudentName = Convert.ToString(objReader["StudentName"]);


student.Phone = Convert.ToString(objReader["Phone"]);


}


}


conn.Close();


conn.Dispose();


}


return student;


}


#endregion


}


}




StudentService


using System;


using System.Collections.Generic;


using System.Text;


using System.Configuration;


using System.Data;


using System.Data.OleDb;


using MySchoolModels; //引用实体类


using MySchoolIDAL; //引用抽象访问接口






/**//* ******************************


* 接口名：StudentService


* 功能描叙：提供学员信息数据访问


* *****************************/




namespace MySchoolDAL.Access






{


public class StudentService : IStudentService






{




Private Members#region Private Members


// 从配置文件中读取数据库连接字符串


string sql = string.Empty;


string connectionString = "Provider=Microsoft.Jet.OLEDB.4.0; Data Source=MySchool.mdb";


#endregion






Public Methods#region Public Methods




/**//// <summary>


/// 根据登录ID 得到学员实体


/// </summary>


/// <param name="loginID">登录ID</param>


/// <returns>学员信息实体</returns>


public Student GetStudentByLoginID(string loginID)






{


Student student = new Student();


sql = "select * from Student where LoginId='" + loginID + "'";


using (OleDbConnection conn = new OleDbConnection(connectionString))






{


OleDbCommand objCommand = new OleDbCommand(sql,conn);


objCommand.CommandType = CommandType.Text;


conn.Open();


using (OleDbDataReader objReader = objCommand.ExecuteReader(CommandBehavior.CloseConnection))






{


if (objReader.Read())






{


student.LoginId = Convert.ToString(objReader["LoginId"]);


student.StudentNO = Convert.ToString(objReader["StudentNO"]);


student.StudentName = Convert.ToString(objReader["StudentName"]);


student.Phone = Convert.ToString(objReader["Phone"]);


}


}


conn.Close();


conn.Dispose();


}


return student;


}


#endregion


}


}

实现数据访问对象创建功能

在抽象工厂（MySchoolDALFactory）项目中的3个类：

1> 抽象工厂类 AbstractDALFactory：用于提供数据访问对象创建功能；




AbstractDALFactory


using System;


using System.Collections.Generic;


using System.Text;


using System.Configuration;


using MySchoolIDAL; //引用数据访问接口






/**//* ******************************


* 接口名：AbstractDALFactory


* 功能描叙：提供数据抽象工厂


* *****************************/




namespace MySchoolDALFactory






{


public abstract class AbstractDALFactory






{


// 创建工厂的选择应该用反射实现


// 这里为了方便理解，使用开关语句实现


public static AbstractDALFactory ChooseFactory()






{


string dbType = ConfigurationSettings.AppSettings["DBType"].ToString();


AbstractDALFactory factory = null;


switch(dbType)






{


case "Sql":


factory = new SqlDAlFactory();


break;


case "Access":


factory = new AccessDALFactory();


break;


}


return factory;


}




// 提供数据访问对象创建功能(抽象工厂提供抽象产品)


public abstract IStudentService CreateStudentService();


public abstract IAdminService CreateAdminService();


}


}

2> SQL Server 实体工厂类 SqlDAlFactory：用于封装SQL Server数据库访问对象的创建；




SqlDAlFactory


using System;


using System.Collections.Generic;


using System.Text;


using MySchoolIDAL; //引用数据访问接口


using MySchoolDAL.SqlServer; //引用数据访问 SqlServer






/**//* ******************************


* 接口名：MySchoolDALFactory


* 功能描叙：提供 Sql Server 工厂对象


* *****************************/




namespace MySchoolDALFactory






{


public class SqlDAlFactory: AbstractDALFactory






{




Public Methods#region Public Methods


public override IStudentService CreateStudentService()






{


return new StudentService();


}


public override IAdminService CreateAdminService()






{


return new AdminService();


}


#endregion


}


}

3> Access实体工厂类 AccessDALFactory：用于封装Access数据库访问对象的创建；




AccessDALFactory


using System;


using System.Collections.Generic;


using System.Text;


using MySchoolIDAL; //引用数据访问接口


using MySchoolDAL.Access; //引用数据访问 Access






/**//* ******************************


* 接口名：AccessDALFactory


* 功能描叙：提供 Access 工厂对象


* *****************************/




namespace MySchoolDALFactory






{


public class AccessDALFactory : AbstractDALFactory






{




Public Methods#region Public Methods


public override IStudentService CreateStudentService()






{


return new StudentService();


}


public override IAdminService CreateAdminService()






{


return new AdminService();


}


#endregion


}


}

业务逻辑层调用数据访问层方法
这里用静态类实现业务逻辑层，当业务逻辑层使用静态类实现后，表示层可以直接调用业务逻辑层的方法，无需实例化对象。

示例用户登录业务逻辑代码


using System;


using System.Collections;


using System.Collections.Generic;


using System.Text;


using MySchoolModels;


using MySchoolIDAL;


using MySchoolDALFactory;






/**//******************************************


* 功能：LoginManager


* 功能描述：提供用户登录


******************************************/




namespace MySchoolBLL






{


public static class LoginManager






{




private Members#region private Members


//调用数据访问层统一数据访问方式


private static AbstractDALFactory factory =


AbstractDALFactory.ChooseFactory();


private static IStudentService studentService =


factory.CreateStudentService();


private static IAdminService adminService =


factory.CreateAdminService();


#endregion






public Methods#region public Methods




/**//// <summary>


/// 登录


/// <summary>


/// <param name="loginID">登录 ID</param>


/// <param name="password">密码</param>


/// <param name="type">用户类型</param>


/// <returns></returns>


public static bool Login(string loginID,string password,string type)






{


bool condition = false;


switch(type)






{


case "管理员":


condition = AdminLogin(loginID, password);


break;


case "学员":


condition = StudentLogin(loginID, password);


break;


}


return condition;


}


#endregion






private Methods#region private Methods




/**//// <summary>


/// 管理员登录


/// <summary>


/// <param name="loginID">登录 ID</param>


/// <param name="password">密码</param>


/// <returns></returns>


private static bool AdminLogin(string loginID, string password)






{


bool condition = false;


string pwd = adminService.GetAdminByLoginID(loginID).LoginPwd.ToString();


if(pwd == password)


condition = true;


return condition;


}






/**//// <summary>


/// 学员登录


/// <summary>


/// <param name="loginID">登录 ID</param>


/// <param name="password">密码</param>


/// <returns></returns>


private static bool StudentLogin(string loginID, string password)






{


bool condition = false;


Student student = new Student();


student = studentService.GetStudentByLoginID(loginID);


if(student.UserStateId != 0)






{


if(student.LoginPwd == password)


condition = true;


}


return condition;


}


#endregion


}


}

实现数据访问接口

操作步骤：

1．搭建数据访问层基本架构：

新增抽象工厂项目（MySchoolDALFactory）；

新增抽象产品项目（MySchoolIDAL）；

实现项目之间的依赖；

2．实现数据访问接口。

3．实现数据访问对象创建功能。

4．业务逻辑层调用数据访问层方法。