设计模式---工厂模型

下面用工厂模型来实现一个连接数据库的例子。实现在不改变代码的前提下，只通过修改相应的配置文件，就可以达到连接Sql Server和Access的目的。

在现实情况中，我们经常遇到同一个程序，在不同的地方要连接不同数据库的问题。为此，我们传统做法是把所有的代码都写在程序中，用if else做判断，然后再选择要连接的数据库。

下面的程序使用工厂模型的概念，利用接口来实现在不改变代码的前提下，只需改动相应的配置文件，就可以达到切换数据库的目的。而且在连接未知数据库时，也不需要改原代码，只需要扩展接口实现类.

说明：示例共有五个文件。

IsqlHelper.cs是定义数据访问接口文件。里面定义了两个数据访问方法:GetData()和SetData()

using Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>; using Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.Collections.Generic; using Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.Linq; using Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.Text; namespace TJVictor.DesignPattern.FactoryPattern { public interface I<a href="/tag/sql/" target="_blank" class="keywords">sql</a>Helper { string GetData(); void SetData(string data); } }

sqlSever.cs继承IsqlHelper接口，实现接口方法

using Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>; using Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.Collections.Generic; using Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.Linq; using Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.Text; namespace TJVictor.DesignPattern.FactoryPattern { public class <a href="/tag/sql/" target="_blank" class="keywords">sql</a>Server:I<a href="/tag/sql/" target="_blank" class="keywords">sql</a>Helper { private string _data; private <a href="/tag/sql/" target="_blank" class="keywords">sql</a>Server() { _data = "<a href="/tag/sql/" target="_blank" class="keywords">sql</a>Server"; } public static I<a href="/tag/sql/" target="_blank" class="keywords">sql</a>Helper GetInstance() { return new <a href="/tag/sql/" target="_blank" class="keywords">sql</a>Server() as I<a href="/tag/sql/" target="_blank" class="keywords">sql</a>Helper; } #region I<a href="/tag/sql/" target="_blank" class="keywords">sql</a>Helper Members public string GetData() { return _data; } public void SetData(string data) { _data = data; } #endregion } }

Access.cs继承IsqlHelper接口，实现接口方法

using Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>; using Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.Collections.Generic; using Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.Linq; using Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.Text; namespace TJVictor.DesignPattern.FactoryPattern { public class Accesss:I<a href="/tag/sql/" target="_blank" class="keywords">sql</a>Helper { private string _data; private Accesss() { _data = "Accesss"; } public static I<a href="/tag/sql/" target="_blank" class="keywords">sql</a>Helper GetInstance() { return new Accesss() as I<a href="/tag/sql/" target="_blank" class="keywords">sql</a>Helper; } #region I<a href="/tag/sql/" target="_blank" class="keywords">sql</a>Helper Members public string GetData() { return _data; } public void SetData(string data) { _data = data; } #endregion } }

sqlFactory.cs是工厂类，根据配置文件动态创建sqlServer或是Access

using Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>; using Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.Collections.Generic; using Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.Linq; using Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.Text; using Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.Con<a href="/tag/fig/" target="_blank" class="keywords">fig</a>uration; namespace TJVictor.DesignPattern.FactoryPattern { public class <a href="/tag/sql/" target="_blank" class="keywords">sql</a>Factory { public static I<a href="/tag/sql/" target="_blank" class="keywords">sql</a>Helper GetInstance() { string appString = Con<a href="/tag/fig/" target="_blank" class="keywords">fig</a>urationManager.ConnectionStrings["ConStr"].ConnectionString; string type = appString.Split(':')[0]; string conStr = appString.Split(':')[1]; //根据<a href="/tag/peizhiwenjian/" target="_blank" class="keywords">配置文件</a>中的设置，返回对应的<a href="/tag/shujuku/" target="_blank" class="keywords">数据库</a>实例 switch (type) { case "<a href="/tag/sql/" target="_blank" class="keywords">sql</a>Server": return <a href="/tag/sql/" target="_blank" class="keywords">sql</a>Server.GetInstance(); case "Access": return Accesss.GetInstance(); default: break; } return null; } } }

App.config是配置文件，定义本地程序需要用哪种数据库连接

<?xml version="1.0" encoding="utf-8" ?> <con<a href="/tag/fig/" target="_blank" class="keywords">fig</a>uration> <connectionStrings> <add name="ConStr" connectionString="<a href="/tag/sql/" target="_blank" class="keywords">sql</a>Server:server=tjvictor/<a href="/tag/sql/" target="_blank" class="keywords">sql</a>server2008;Integrated S<a href="/tag/ecurity/" target="_blank" class="keywords">ecurity</a> = true;database=TestDB;MultipleActiveResultSets=true;"/> <!--<add name="ConStr" connectionString="Access:Provider=Microsoft.Jet.OLEDB.4.0;Data Source=C:/mydatabase.mdb;User Id=admin;Password=;"/>--> </connectionStrings> </con<a href="/tag/fig/" target="_blank" class="keywords">fig</a>uration>

调用代码

I<a href="/tag/sql/" target="_blank" class="keywords">sql</a>Helper <a href="/tag/sql/" target="_blank" class="keywords">sql</a>Helper = <a href="/tag/sql/" target="_blank" class="keywords">sql</a>Factory.GetInstance(); Show(<a href="/tag/sql/" target="_blank" class="keywords">sql</a>Helper.GetData()); <a href="/tag/sql/" target="_blank" class="keywords">sql</a>Helper.SetData("<a href="/tag/dddd/" target="_blank" class="keywords">dddd</a>"); Show(<a href="/tag/sql/" target="_blank" class="keywords">sql</a>Helper.GetData());

大家已经注意到了，调用代码里面都是面向接口编程的，所以只要接口稳定，那么程序的升级或是改动也就是稳定的。

情况一，修改Access的某个访问方法：只需要改Access里面的代码，不需要改主程序的任何地方。

情况二，增加对MysqL的支持：只需要增加一个MysqL.cs，继承IsqlHelper，Factory里面增加对MysqL的判断即可。主程序不需要改任何地方，只需要把配置文件改成MysqL的连接字符串即可。

 

上面的程序只是示例程序，里面的GetData()和SetData()没有意义，下面我给出在一般情况下访问数据库时，需要的接口方法，大家可以按照上面的代码说明，去实现自己的sqlHelper类。

using Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>; using Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.Collections.Generic; using Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.Text; using Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.Data; using Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.Xml; namespace TJVictor.DataBase.<a href="/tag/sql/" target="_blank" class="keywords">sql</a>Helper { public interface I<a href="/tag/sql/" target="_blank" class="keywords">sql</a>Helper { int ExecuteNonQuery(string execute<a href="/tag/sql/" target="_blank" class="keywords">sql</a>); IDataReader ExecuteReader(string execute<a href="/tag/sql/" target="_blank" class="keywords">sql</a>); T ExecuteScalar<T>(string execute<a href="/tag/sql/" target="_blank" class="keywords">sql</a>); DataSet ExecuteDataSet(string execute<a href="/tag/sql/" target="_blank" class="keywords">sql</a>); DataTable ExecuteTable(string execute<a href="/tag/sql/" target="_blank" class="keywords">sql</a>); XmlReader ExecuteXmlReader(string execute<a href="/tag/sql/" target="_blank" class="keywords">sql</a>); } }

 

 

如需转载，请注明本文原创自CSDN TJVictor专栏：http://blog.csdn.net/tjvictor