第七节：EF Core调用SQL语句和存储过程(2.x和3.x写法)

一. 查询类

　　EFCore2.x中用 FromSql 方法，EFCore3.x中用 FromSqlRaw 方法，二者使用起来基本一致。

1.说明

　　A. SQL查询必须返回实体的所有属性字段。

　　B. 结果集中的列名必须与属性映射到的列名相匹配。

　　C. SQL查询不能包含关联数据

　　D. 除Select以为的其它SQL语句无法运行。

2.调用SQL语句的几种情况

　　A. 基本的原生SQL查询

　　B. 利用$内插语法进行传递

　　C. 原生SQL与linq语法相结合

　　D. 利用SqlParameter进行参数化查询

代码分享：（2.x版本的写法）

{
                using (EFDB01Context db = new EFDB01Context())
                {
                    //1.基本的原生SQL查询
                    var userList1 = db.Set<T_UserInfor>().FromSql("select * from T_UserInfor where id!='123'").ToList();

                    //2.利用$内插语法进行传递
                    var myId = "2fc343069e0a4a559b62b08d5999dbcd";
                    var userList2 = db.Set<T_UserInfor>().FromSql($"select * from T_UserInfor where id= {myId}").ToList();

                    //3.原生SQL与linq语法相结合
                    var userList3 = db.Set<T_UserInfor>().FromSql($"select * from T_UserInfor")
                        .Where(u => u.id == "2fc343069e0a4a559b62b08d5999dbcd")
                        .ToList();
                    var userList4 = db.Set<T_UserInfor>().FromSql($"select * from T_UserInfor")
                        .Where(u => u.id != "1111")
                        .OrderBy(u => u.addTime)
                        .ToList();

                    //4.利用SqlParameter进行参数化查询
                    SqlParameter[] paras ={
                                             new SqlParameter("@id","2fc343069e0a4a559b62b08d5999dbcd"),
                                             new SqlParameter("@userName","ypf"),
                                        };
                    var userList5 = db.Set<T_UserInfor>().FromSql("select * from T_UserInfor where id=@id and userName=@userName", paras).ToList();
                }
}

3.调用存储过程的几种情况

　 可以利用SqlParameter传递参数，防止sql注入。

　　A.不含任何参数

　　B.含多个输入参数

　　C.含输入参数和输出参数

 用到的表结构：

 对应的生成存储过程的代码：

USE [EFDB01]

--事先准备：插入两条数据
select * from T_UserInfor
truncate table T_UserInfor
insert into T_UserInfor values('01','ypf','男',12,'2019-08-08')
insert into T_UserInfor values('02','ypf2','女',30,'2019-09-08')

-- 1. 不含任何参数存储过程
if (exists (select * from sys.objects where name = 'GetAll'))
    drop proc GetAll
go
    create proc GetAll
as
    select * from T_UserInfor;

-- 调用
exec GetAll;


--2. 含多个输入参数的存储过程
if (exists (select * from sys.objects where name = 'GetALLBy'))
    drop proc GetALLBy
go
    create proc GetALLBy(
        @id varchar(32),
        @userName varchar(20)
    )
as
    select * from T_UserInfor where id=@id and userName=@userName;

exec GetALLBy @id='01',@userName='ypf';

--3. 含输出参数的存储过程
 if (exists (select * from sys.objects where name = 'GetSpecial'))
    drop proc GetSpecial
go
    create proc GetSpecial(
        @userName varchar(32),
        @count int output
    )
as
    select @count=count(*) from T_UserInfor;
    select * from T_UserInfor where userName= @userName;

go
declare @myCount int;
exec GetSpecial 'ypf',@myCount output;
select @myCount as myCount;

对应EF调用的代码：（2.x的写法）

            {
                using (EFDB01Context db = new EFDB01Context())
                {
                    //1. 不含任何参数存储过程
                    var data1 = db.Set<T_UserInfor>().FromSql("GetAll").ToList();

                    //2. 含多个输入参数的存储过程
                    SqlParameter[] para ={
                                           new SqlParameter("@id","01"),
                                           new SqlParameter("@userName","ypf")
                                  };
                    var data2 = db.Set<T_UserInfor>().FromSql("GetALLBy @id,@userName", para).ToList();

                    //3. 带输出参数的存储过程
                    //把输出参数单独拿出来声明
                    SqlParameter myCount = new SqlParameter("@count", SqlDbType.Int);
                    myCount.Direction = ParameterDirection.Output;
                    //把输出参数放到数组里
                    SqlParameter[] para2 ={
                                           new SqlParameter("@userName","ypf"),
                                           myCount
                                     };
                    var data3 = db.Set<T_UserInfor>().FromSql("exec GetSpecial @userName,@count out", para2).ToList();
                    //通过输出参数在数组中的位置来获取返回值。
                    var count = para2[1].Value;

                }
            }

二. 其它类

　　EFCore2.x中用 ExecuteSqlCommand 方法，EFCore3.x中用 ExecuteSqlRaw 方法，二者使用起来基本一致。

1.说明

　　主要用于调用除了查询外其它的SQL语句。

2.调用SQL语句的情况

　　A. 基本的原生SQL查询

　　B. 利用$内插语法进行传递

　　C. 利用SqlParameter进行参数化查询

代码分享：（2.x的写法）

            {
                using (EFDB01Context db = new EFDB01Context())
                {

                    //1.增加
                    int result1 = db.Database.ExecuteSqlCommand("insert into T_UserInfor values('01','test1','男',21,'2019-09-09')");

                    //2. 修改
                    SqlParameter[] paras ={
                                                     new SqlParameter("@id","01"),
                                                     new SqlParameter("@userSex","未知"),
                                                };
                    int result2 = db.Database.ExecuteSqlCommand("update T_UserInfor set userSex=@userSex where id=@id", paras);

                    //3. 删除
                    var myId = "01";
                    int result3 = db.Database.ExecuteSqlCommand($"delete from T_UserInfor where id={myId}");

                    //4. 其它指令
                    int result4 = db.Database.ExecuteSqlCommand("truncate table T_UserInfor");
                }
            }

3.调用存储过程的情况

 存储过程代码

--4. 非查询类的存储过程
if (exists (select * from sys.objects where name = 'DoSome'))
    drop proc DoSome
go 
    create proc DoSome(
        @id varchar(32)
    )
as
    begin transaction
 begin try
        insert into T_UserInfor values(@id,'ypf','男',12,'2019-08-08');
        delete from T_UserInfor where id='02'
    commit transaction
 end try
 begin catch
    rollback transaction
 end catch

 exec DoSome '03'

EF的调用代码 （2.x的写法）

            {
                using (EFDB01Context db = new EFDB01Context())
                {
                    SqlParameter[] para ={
                                           new SqlParameter("@id",Guid.NewGuid().ToString("N")),
                                     };
                    int n = db.Database.ExecuteSqlCommand("DoSome @id", para);
                    if (n > 0)
                    {
                        Console.WriteLine("操作成功");
                    }
                    else
                    {
                        Console.WriteLine("没有更多数据进行处理");
                    }
                }
            }

!

• 作       者 : Yaopengfei(姚鹏飞)
• 博客地址 : http://www.cnblogs.com/yaopengfei/
• 声     明1 : 本人才疏学浅，用郭德纲的话说“我是一个小学生”，如有错误，欢迎讨论，请勿谩骂^_^。
• 声     明2 : 原创博客请在转载时保留原文链接或在文章开头加上本人博客地址，否则保留追究法律责任的权利。