在您保證SQL語句兼容的前提下,透過它來訪問數(shù)據(jù)庫時(shí),在不需要改變DAL層一點(diǎn)代碼的前提下,只要修改一下配置文件,它便可以為你跨不同類型的數(shù)據(jù)庫。
讓你的DAL層代碼更見簡練。它會根據(jù)配置文件配置的連接信息,自動為你創(chuàng)建數(shù)據(jù)庫連接,執(zhí)行操作。關(guān)閉連接,釋放連接等.
讓DAL層的不同模塊訪問不同類型或不同數(shù)據(jù)庫更加方便。
不錯的執(zhí)行效率,它基于原生ADO.NET。只會反射一次訪問不同數(shù)據(jù)庫的ADO提供者的程序集(DAM最終都是通過這些提供者來實(shí)現(xiàn)訪問不同類型數(shù)據(jù)庫的)。
它的配置:
代碼如下:
<appsettings>
<add key="rpsconnection" value="mssql"/>
<add key="damconnection" value="sqlite" />
</appsettings>
<connectionstrings>
<add name="sqlite" connectionString="" providerName="System.Data.SQLite.SQLiteConnection;System.Data.SQLite"/>
<add name="mssql" connectionString="" providerName="System.Data.SqlClient.SqlConnection;System.Data" />
</connectionstrings>
appsettings
1.添加一個(gè)KV。KEY="damconnection" VALUE="下面connectionstrings中的一個(gè)name的一項(xiàng)"."damconnection"為默認(rèn)的DAM讀取的KEY, KEY的名字請不要更換. VALUE的值可以根據(jù)您默認(rèn)連接的數(shù)據(jù)庫連接變而變.
2.如果想應(yīng)用多個(gè)數(shù)據(jù)庫連接,來訪問不同的數(shù)據(jù)庫. 您可以在appsettings中添加別的KV項(xiàng).代碼里使用DAM中Config或者Factroy來創(chuàng)建不同的數(shù)據(jù)庫連接,可以實(shí)現(xiàn)訪問不同的或不同類型的數(shù)據(jù)庫.
connectionstrings
1.項(xiàng)中connectionString值不需要變
2.項(xiàng)中providerName值分為三個(gè)部分連接的完整類名 ; 連接類所在的程序集名
(命名空間+類名) (中間用";"分開) (注意不加.dll)測試代碼:
DAL層測試代碼
代碼如下:
/// <summary>
/// 數(shù)據(jù)訪問層
/// 透過Dam訪問數(shù)據(jù)庫
/// </summary>
public class DALTest
{
/// <summary>
/// 最簡單的插入操作
/// Execute會幫你自動創(chuàng)建所對應(yīng)數(shù)據(jù)庫的連接、執(zhí)行操作、釋放Command、關(guān)閉連接、釋放鏈接等
/// </summary>
/// <returns>執(zhí)行后受影響行數(shù)</returns>
public int Insert()
{
return Execute.SExecuteNonQuery("sp_name", null);
//return Execute.SExecuteNonQuery("insert into tablename (..) values (..)", CommandType.Text , null);
}
/// <summary>
/// 帶參數(shù)的插入操作
/// Execute會幫你自動創(chuàng)建所對應(yīng)數(shù)據(jù)庫的連接
/// 并幫你把參數(shù)類型轉(zhuǎn)換為所對應(yīng)數(shù)據(jù)庫類型的參數(shù)進(jìn)行數(shù)據(jù)庫操作.
/// </summary>
/// <returns></returns>
public int Insert_Paras()
{
DbParameter[] paras =
{
new MySqlParameter("p1","p1value")
,new SqlParameter("p2","p2value")
};
return Execute.SExecuteNonQuery("sp_name", paras);
}
/// <summary>
/// 帶參數(shù)的插入操作,并能得到參數(shù)返回值
/// Execute會幫你自動創(chuàng)建所對應(yīng)數(shù)據(jù)庫的連接
/// 并幫你把參數(shù)類型轉(zhuǎn)換為所對應(yīng)數(shù)據(jù)庫類型的參數(shù)進(jìn)行數(shù)據(jù)庫操作.
/// 執(zhí)行完成您可得到返回值
/// </summary>
/// <returns></returns>
public int Insert_Paras(ref string outputValue)
{
int resultInt = 0;
DbParameter[] paras =
{
new MySqlParameter("p1","p1value")
,new SqlParameter("p2_output","")
{
Direction = ParameterDirection.Output
}
};
resultInt = Execute.SExecuteNonQuery("sp_name", paras);
if (paras[1].Value != null) outputValue = paras[1].Value.ToString();
return resultInt;
}
/// <summary>
/// 帶參數(shù)的插入操作,并能得到參數(shù)返回值,此參數(shù)從BLL層傳來
///同上...
/// </summary>
/// <returns></returns>
public int Insert_Paras(DbParameter[] paras)
{
return Execute.SExecuteNonQuery("sp_name", paras);
//這樣可以在BLL層通過 paras[1]來獲取返回參數(shù)了
}
/// <summary>
/// 執(zhí)行同連接多操作的事務(wù)處理
/// 這里使用1個(gè)帶參數(shù)的存儲過程和一個(gè)不帶參數(shù)的sql語句操作
/// 使用是靜態(tài)調(diào)用方法
/// </summary>
/// <returns></returns>
public bool Insert_Transaction()
{
bool resultBool = false;
DbParameter[] paras =
{
new MySqlParameter("p1","p1value")
,new SqlParameter("p2","p2value")
};
DbConnection connection = null;
DbTransaction transaction = null;
try
{
connection = Factory.CreateConnection();
connection.Open();
transaction = connection.BeginTransaction();
int resultInt1 = Execute.SExecuteNonQuery(connection, transaction, "sp_name1", paras);
int resultInt2 = Execute.SExecuteNonQuery(connection, transaction, "insert into tablename (...) values (...)", null);
if (resultInt1 > 0 && resultInt2 > 0)
{
transaction.Commit();
resultBool = true;
}
else
{
transaction.Rollback();
}
}
catch (Exception)
{
if (transaction != null)
{
transaction.Rollback();
}
}
finally
{
if (transaction != null)
{
transaction.Dispose();
}
if (connection != null)
{
//這里需要手動關(guān)閉連接!!
connection.Close();
connection.Dispose();
}
}
return resultBool;
}
/// <summary>
/// 執(zhí)行同連接多任務(wù)操作(不使用事務(wù))
/// 這里我們使用對象方法。這樣執(zhí)行多任務(wù)操作可能會穩(wěn)定點(diǎn)和效率高點(diǎn)
/// </summary>
/// <returns></returns>
public void Insert_much()
{
Execute exec = Execute.NewExecute;
DbConnection connection = null;
try
{
connection = Factory.CreateConnection();
exec.ExecuteNonQuery(connection, null, "sp_name", null);
exec.ExecuteNonQuery(connection, null, "sp_name2", null);
}
finally
{
if (connection != null)
{
//因?yàn)檎{(diào)用了 帶事務(wù)的那個(gè)方法(但是我們設(shè)置事務(wù)為NULL,事務(wù)無效)
//所以連接不會自動關(guān)閉釋放,我們需要手動釋放
connection.Close();
connection.Dispose();
}
}
}
}
Dam: Dam.rar
有興趣的可以看看:) 內(nèi)部有幫助文檔。聲明:本網(wǎng)頁內(nèi)容旨在傳播知識,若有侵權(quán)等問題請及時(shí)與本網(wǎng)聯(lián)系,我們將在第一時(shí)間刪除處理。TEL:177 7030 7066 E-MAIL:11247931@qq.com