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群

 

作者：jacky

来源：

声明：本文版权归作者和博客园共有，欢迎转载，但未经作者同意必须保留此段声明，且在文章页面明显位置给出原文连接，否则保留追究法律责任的权利。