Asp.Net MVC EF之一：使用Database類在EF框架中執行Sql語句 ...
引言
從EF6開始，增加了DateBase類，他通過從 DbContext 對象獲取此類的實例。可用於管理支持資料庫上下文或連接的實際資料庫。這包括創建、刪除和檢查資料庫的存在。
在6以前，我們使用EF,需要藉助ADO.NET才能直接執行SQL語句。由於Linq查詢自身存在的一些短板，例如有以下場景：在上萬的數據容量的情況下，需要聯合3個表以下的查詢統計時，Linq就顯出了自己的不足。這時 有一定經驗的人肯定想到了使用存儲過程 將業務中複雜的邏輯運算放到資料庫執行，這時就需要用到DataBase
下麵我就DataBase類提供的一些常用方法，幫助我們在程式中直接對資料庫進行讀寫操作。
正文
1. SqlQuery<T>(string sql,params object[] parameter)
使用SqlQuery<T>()執行Sql語句，存儲過程，視圖
倉儲層代碼
public IQueryable<TEntity> QuerySql<TEntity>(string strSql, params SqlParameter[] dbParameter) where TEntity : class
{
return dbcontext.Database.SqlQuery<TEntity>(strSql, dbParameter).AsQueryable<TEntity>();
}
dbcontext: EF上下文
執行sql語句
var data = new RepositoryBase().QuerySql<CustomerListViewModel>(sqlStr);
CustomerListViewModel：查詢結果的DTO對象，通過這種方式，只要你的DTO的屬性與查詢結果的返回欄位一致，就可以將查詢結果映射到DTO
執行存儲過程
public List<StoreListViewModel> QueryStoreListSplit(Pagination pagination, string uId, string shopCode)
{
List<StoreListViewModel> dtoResult = new List<StoreListViewModel>();
string sqlwhere = "";
string msg = "";
string sqlStr = "EXEC [dbo].[sp_CustomerStoreList] @UId, @Where, @msg OUT";
if (!string.IsNullOrEmpty(shopCode))
{
sqlwhere = " AND s.F_ShopCode = '" + shopCode + "'";
}
SqlParameter[] parms = new SqlParameter[]
{
new SqlParameter("@UId",uId),
new SqlParameter("@Where",sqlwhere),
new SqlParameter("@msg",System.Data.SqlDbType.NVarChar,200)
};
parms[2].Direction = System.Data.ParameterDirection.Output;
dtoResult = customerRepository.GetCustomerStoreList(sqlStr, pagination, parms);
msg = parms[2].Value.ToString();
return dtoResult;
}
2. 使用 ExecuteSqlCommand()實現 創建，更新，刪除
using (var db = new DBModel()) //創建資料庫上下文
{
//同步的方式執行SQL，並返回受影響的行數
int result = db.Database.ExecuteSqlCommand(@"CREATE TABLE `test` (
`id` INT NOT NULL,
PRIMARY KEY(`id`)); ");
//使用SqlParameter傳值可以避免SQL註入
var p_name = new SqlParameter("@name", "蘿莉");
var p_age = new SqlParameter("@age", 13);
//如果使用的是MySql資料庫 需要SqlParameter把替換為MySqlParameter
//var p_name = new MySqlParameter("@name", "蘿莉");
//var p_age = new MySqlParameter("@age", 13);
//更改學生年齡
result = db.Database.ExecuteSqlCommand(@"UPDATE `student`
SET `age` = @age
WHERE `name` = @name;", p_age, p_name);
//非同步的方式執行SQL，並返回受影響的行數
Task<int> result2 = db.Database.ExecuteSqlCommandAsync("DROP TABLE `test`;");
}
註：如果需要創建或刪除當前資料庫，Database屬性中還存在.Create() 和.Delete()方法，它們不接受參數，返回一個bool值表示執行成功或失敗。
3. 使用DbSet<T>下的.SqlQuery()
在每個數據實體集合DbSet<T>下也有一個.SqlQuery()，功能與上面介紹的一樣，只不過DbSet<T>下的.SqlQuery()只能返回DbSet<T>中包含的類型。但DbSet<T>下的.SqlQuery()在返回數據的同時還會讓資料庫上下文（DBModel）跟蹤返回數據的狀態，如果返回的數據發生了修改，就可以使用.SaveChanges()將結果直接保存回資料庫。而.Database.SqlQuery()查出的結果則是做不到的。
using (var db = new DBModel()) //創建資料庫上下文
{
//查詢叫蘿莉的學生信息，並修改她的年齡
student result1 = db.students.SqlQuery("SELECT * FROM student WHERE name = '蘿莉'").FirstOrDefault();
result1.age = 13; //通過實體集合下.SqlQuery查詢到的數據，修改之後是可以保存到資料庫的
student result2 = db.Database.SqlQuery<student>("SELECT * FROM student WHERE name = '旺財'").FirstOrDefault();
result2.age = 21; //因為使用的是.Database.SqlQuery查詢到的，所以這裡的修改不會保存到資料庫
//如果希望.Database.SqlQuery下查出的數據在修改後也能保存到資料庫
student result3 = db.Database.SqlQuery<student>("SELECT * FROM student WHERE name = '小明'").FirstOrDefault();
result3.age = 36;
db.Entry<student>(result3).State = System.Data.Entity.EntityState.Modified;//通知數據上下文，這條記錄也被修改了
db.SaveChanges(); }
4.BeginTransaction()
對基礎存儲連接開始一個事務
//事務處理
using (DbContextTransaction dbTransaction = deliverRepository.EFDb.Database.BeginTransaction())
{
try
{
//需要事務處理的邏輯代碼
//事務提交
dbTransaction.Commit();
}
catch (Exception ex)
{
dbTransaction.Rollback();
throw new Exception(ex.Message);
}
}
DataBase類的基本用法就這麼多，有什麼遺漏的歡迎大家補充！
PS:歡迎掃描下方二維碼，加入QQ群
