第七節：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 : 原創博客請在轉載時保留原文鏈接或在文章開頭加上本人博客地址，否則保留追究法律責任的權利。