• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

Asp.NetMVCEF之一:使用Database类在EF框架中执行Sql语句

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

引言

从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类的基本用法就这么多,有什么遗漏的欢迎大家补充!

 

 


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
ASP.NET中实现中文简/繁体自动转换的类发布时间:2022-07-10
下一篇:
asp.net在网站根目录下创建文件夹发布时间:2022-07-10
热门推荐
热门话题
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap