作者：Jacky
声明：本文版权归作者和博客园共有，欢迎转载，但未经作者同意必须保留此段声明，且在文章页面明显位置给出原文连接，否则保留追究法律责任的权利。
从EF6开始，增加了DateBase类，他通过从 DbContext 对象获取此类的实例。可用于管理支持数据库上下文或连接的实际数据库。这包括创建、删除和检查数据库的存在。
在6以前，我们使用EF,需要借助ADO.NET才能直接执行SQL语句。由于Linq查询自身存在的一些短板，例如有以下场景：在上万的数据容量的情况下，需要联合3个表以下的查询统计时，Linq就显出了自己的不足。这时 有一定经验的人肯定想到了使用存储过程 将业务中复杂的逻辑运算放到数据库执行，这时就需要用到DataBase
下面我就DataBase类提供的一些常用方法，帮助我们在程序中直接对数据库进行读写操作。
使用SqlQuery<T>()执行Sql语句，存储过程，视图
仓储层代码
1 2 3 4 | 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
执行存储过程
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 | 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;} |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 | 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` = @ageWHERE `name` = @name;", p_age, p_name);//异步的方式执行SQL，并返回受影响的行数Task<int> result2 = db.Database.ExecuteSqlCommandAsync("DROP TABLE `test`;");} |
注：如果需要创建或删除当前数据库，Database属性中还存在.Create() 和.Delete()方法，它们不接受参数，返回一个bool值表示执行成功或失败。
在每个数据实体集合DbSet<T>下也有一个.SqlQuery()，功能与上面介绍的一样，只不过DbSet<T>下的.SqlQuery()只能返回DbSet<T>中包含的类型。但DbSet<T>下的.SqlQuery()在返回数据的同时还会让数据库上下文（DBModel）跟踪返回数据的状态，如果返回的数据发生了修改，就可以使用.SaveChanges()将结果直接保存回数据库。而.Database.SqlQuery()查出的结果则是做不到的。
1 2 3 4 5 6 7 8 9 10 11 12 13 | 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;//通知数据上下文，这条记录也被修改了 |
1 2 | db.SaveChanges();} |
对基础存储连接开始一个事务
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 | //事务处理using (DbContextTransaction dbTransaction = deliverRepository.EFDb.Database.BeginTransaction()){ try { //需要事务处理的逻辑代码 //事务提交 dbTransaction.Commit(); } catch (Exception ex) { dbTransaction.Rollback(); throw new Exception(ex.Message); }} |
DataBase类的基本用法就这么多，有什么遗漏的欢迎大家补充！
Asp.Net MVC EF之一：使用Database类在EF框架中执行Sql语句
原文：https://www.cnblogs.com/lonelyxmas/p/12434467.html