打造自己的数据访问层(三)
生活随笔
收集整理的這篇文章主要介紹了
打造自己的数据访问层(三)
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
上一篇打造自己的數據訪問層(二)中,我們已具體實現了數據訪問層對應的功能,該進行收尾工作了,先來看段代碼,試試上一篇實現的功能:
View Code string sqlText = "SELECT ID, NAME, VAL FROM TEST";
string columns = "ID, NAME, VAL";
DataSet ds = new DataSet();
DataExecutor execObj = new MSSqlExecutor();
DataMapping map = new DataMapping();
map.ExecuteObject = execObj;
map.TableName = "TEST";
map.KeyColumns = "ID";
map.Columns = "ID, NAME, VAL";
DataMapping map = new DataMapping(execObj.GetInstant(), "TEST", "ID", columns);
map.Fill(sqlText, "TEST");
map.SetCommands(DataCommandType.Insert | DataCommandType.Update | DataCommandType.Delete, ds);
//DataTable方式進行增、刪、改
bool isSuccess = execObj.Update();
果然已經完成了對數據庫的讀寫操作了,至少不用再寫大段的參數傳遞代碼,功能都已經實現了,是不是就完成了?
仔細看看上面的代碼,實際上還有問題尚未解決,看看這句:
DataExecutor execObj = new MSSqlExecutor();
竟然在代碼里直接實例化一個MSSql的執行對象,這樣一開始提出的數據庫之間的切換問題根本就沒有從本質上解決。
再回過頭來看上一篇,有一個方法public IDbConnection GetConn(),用來獲取數據連接對像,之前并沒有說明其如何實現。
我們知道DBConnection有兩個關鍵信息:
1、與哪種類型的數據庫產生連接,這個前面已經解決了。
2、傳遞與數據庫連接的帳號信息、訪問庫信息的ConnectionString,這個并沒有提及。
看看第二點以前是怎么做的:
View Code public IDbConnection GetConn()
{
if (conn != null)
{
return conn;
}
conn = new SqlConnection();
conn.ConnectionString = 連接字串;
return conn;
}
上面出現了連接字串,這個字串從哪來?
總結下,要完成最終的數據訪問輸出,還需要解決兩個問題:
1、動態進行不同數據庫之間的切換。
2、解決數據連接字串的來源問題。
接著就來解決這兩問題,先解決第二個問題,有個比較簡單的方法,將連接字串寫入配置文件中去,數據訪問層只需知道它傳遞過來KEY值:
<appSettings>
<add key="ConnStr" value="server=.;uid=sa;password=123456;database=DATA_BASE;max pool size=300"/>
</appSettings>
第一個問題解決了,只剩下最后一個問題了,如何動態切換不同的數據庫,也就是說,在使用的時候不需要自己NEW一個對象,而是通過第三方來創建一個對象,實際上,設計模式里已提出了方案,創建型模式,有興趣的朋友可以自行研究,我們這里只需要用到簡單工廠模式:
View Code public sealed class ExecutorFactory
{
public static DataExecutor Create()
{
return Create(DatabaseType.MSSql);
}
public static DataExecutor Create(DatabaseType dbType)
{
AbstractDataBase dataBase = null;
Switch(dbType)
{
case DatabaseType.MSSql:
dataBase = new MSSqlDataBase();
break;
case DatabaseType.Oracle:
dataBase = new OracleDataBase();
break;
}
return dataBase.Create();
}
}
現在可對這句代碼進行替換了:DataExecutor execObj = new MSSqlExecutor();
替換為:DataExecutor execObj = ExecutorFactory.Create();
至此,問題都解決了,切換數據庫是只需更改DatabaseType為相應的數庫類型。?
接下來再考慮下,如果改變數據庫類型也不需要變動程序,能不能實現?
還是利用配置文件,只是此時提供的不是類型字串,而是實際的數據執行者程序集信息,再利用.NET的天然優勢反射可以實現了。
最終配置文件為:
<appSettings>
<add key="ConnStr" value="server=.;uid=sa;password=123456;database=DATA_BASE;max pool size=300"/>
<add key="DBExecutor" value="FM.DataAccess, FM.DataAccess.MappingExcuter.MSSqlExecutor"></add>
</appSettings>
改造后的工廠:
View Code public sealed class ExecutorFactory
{
public static DataExecutor Create()
{
return Create(null);
}
public static DataExecutor Create(string dataBaseTypeKey)
{
return Create(dataBaseTypeKey, null);
}
public static DataExecutor Create(string dataBaseTypeKey, string connStrKey)
{
if (string.IsNullOrEmpty(dataBaseTypeKey))
{
dataBaseTypeKey = "DBExecutor";
}
string[] sltDataBaseType = ConfigReader.Read(dataBaseTypeKey).Split(',');
string asselblyName = sltDataBaseType[0];
string nameSpace = sltDataBaseType[1].Trim();
Assembly assembly = Assembly.Load(asselblyName);
DataExecutor execObj = assembly.CreateInstance(nameSpace) as DataExecutor;
execObj.SetConnectionString(connStrKey);
return execObj;
}
}
到此為止,數據訪問層最終完成,當然這里還有很多問題有待解決,但其基本框架已形成了,以此為依據,根據業務變化,實現自己的擴展,不斷更新,最終才能真正形成完善的數據訪問層。
下面提供本文的示例代碼:
?數據訪問層示例
View Code string sqlText = "SELECT ID, NAME, VAL FROM TEST";
string columns = "ID, NAME, VAL";
DataSet ds = new DataSet();
DataExecutor execObj = new MSSqlExecutor();
DataMapping map = new DataMapping();
map.ExecuteObject = execObj;
map.TableName = "TEST";
map.KeyColumns = "ID";
map.Columns = "ID, NAME, VAL";
DataMapping map = new DataMapping(execObj.GetInstant(), "TEST", "ID", columns);
map.Fill(sqlText, "TEST");
map.SetCommands(DataCommandType.Insert | DataCommandType.Update | DataCommandType.Delete, ds);
//DataTable方式進行增、刪、改
bool isSuccess = execObj.Update();
果然已經完成了對數據庫的讀寫操作了,至少不用再寫大段的參數傳遞代碼,功能都已經實現了,是不是就完成了?
仔細看看上面的代碼,實際上還有問題尚未解決,看看這句:
DataExecutor execObj = new MSSqlExecutor();
竟然在代碼里直接實例化一個MSSql的執行對象,這樣一開始提出的數據庫之間的切換問題根本就沒有從本質上解決。
再回過頭來看上一篇,有一個方法public IDbConnection GetConn(),用來獲取數據連接對像,之前并沒有說明其如何實現。
我們知道DBConnection有兩個關鍵信息:
1、與哪種類型的數據庫產生連接,這個前面已經解決了。
2、傳遞與數據庫連接的帳號信息、訪問庫信息的ConnectionString,這個并沒有提及。
看看第二點以前是怎么做的:
View Code public IDbConnection GetConn()
{
if (conn != null)
{
return conn;
}
conn = new SqlConnection();
conn.ConnectionString = 連接字串;
return conn;
}
上面出現了連接字串,這個字串從哪來?
總結下,要完成最終的數據訪問輸出,還需要解決兩個問題:
1、動態進行不同數據庫之間的切換。
2、解決數據連接字串的來源問題。
接著就來解決這兩問題,先解決第二個問題,有個比較簡單的方法,將連接字串寫入配置文件中去,數據訪問層只需知道它傳遞過來KEY值:
<appSettings>
<add key="ConnStr" value="server=.;uid=sa;password=123456;database=DATA_BASE;max pool size=300"/>
</appSettings>
第一個問題解決了,只剩下最后一個問題了,如何動態切換不同的數據庫,也就是說,在使用的時候不需要自己NEW一個對象,而是通過第三方來創建一個對象,實際上,設計模式里已提出了方案,創建型模式,有興趣的朋友可以自行研究,我們這里只需要用到簡單工廠模式:
View Code public sealed class ExecutorFactory
{
public static DataExecutor Create()
{
return Create(DatabaseType.MSSql);
}
public static DataExecutor Create(DatabaseType dbType)
{
AbstractDataBase dataBase = null;
Switch(dbType)
{
case DatabaseType.MSSql:
dataBase = new MSSqlDataBase();
break;
case DatabaseType.Oracle:
dataBase = new OracleDataBase();
break;
}
return dataBase.Create();
}
}
現在可對這句代碼進行替換了:DataExecutor execObj = new MSSqlExecutor();
替換為:DataExecutor execObj = ExecutorFactory.Create();
至此,問題都解決了,切換數據庫是只需更改DatabaseType為相應的數庫類型。?
接下來再考慮下,如果改變數據庫類型也不需要變動程序,能不能實現?
還是利用配置文件,只是此時提供的不是類型字串,而是實際的數據執行者程序集信息,再利用.NET的天然優勢反射可以實現了。
最終配置文件為:
<appSettings>
<add key="ConnStr" value="server=.;uid=sa;password=123456;database=DATA_BASE;max pool size=300"/>
<add key="DBExecutor" value="FM.DataAccess, FM.DataAccess.MappingExcuter.MSSqlExecutor"></add>
</appSettings>
改造后的工廠:
View Code public sealed class ExecutorFactory
{
public static DataExecutor Create()
{
return Create(null);
}
public static DataExecutor Create(string dataBaseTypeKey)
{
return Create(dataBaseTypeKey, null);
}
public static DataExecutor Create(string dataBaseTypeKey, string connStrKey)
{
if (string.IsNullOrEmpty(dataBaseTypeKey))
{
dataBaseTypeKey = "DBExecutor";
}
string[] sltDataBaseType = ConfigReader.Read(dataBaseTypeKey).Split(',');
string asselblyName = sltDataBaseType[0];
string nameSpace = sltDataBaseType[1].Trim();
Assembly assembly = Assembly.Load(asselblyName);
DataExecutor execObj = assembly.CreateInstance(nameSpace) as DataExecutor;
execObj.SetConnectionString(connStrKey);
return execObj;
}
}
到此為止,數據訪問層最終完成,當然這里還有很多問題有待解決,但其基本框架已形成了,以此為依據,根據業務變化,實現自己的擴展,不斷更新,最終才能真正形成完善的數據訪問層。
下面提供本文的示例代碼:
?數據訪問層示例
轉載于:https://www.cnblogs.com/FlySoul/archive/2011/05/08/2040292.html
總結
以上是生活随笔為你收集整理的打造自己的数据访问层(三)的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 3.装饰模式
- 下一篇: C++中固定长度短字符串比较是否相同,忽