第四节: EF调用存储过程的通用写法和DBFirst模式子类调用的特有写法

一. 背景

 　　上一个章节，介绍了EF调用两类SQL语句，主要是借助 ExecuteSqlCommand  和 SqlQuery 两个方法来完成，在本章节主要是复习几类存储过程的写法和对应的EF调用这几类存储过程的写法，另外介绍EF的DBFirst模式的下EF存储过程的特有写法。

　　本章要达到以下几个目标：

　　① 熟练掌握存储过程的相关概念和几类写法(去复习)

　　② EF各种模式调用各种存储过程的通用写法(也是借助  ExecuteSqlCommand  和 SqlQuery )

　　③ EF的DBFirst模式事先映射好存储过程，简洁调用的写法

二. EF调用存储过程

 　　EF调用存储过程通用的写法，分两类：　　

　　① 对于查询相关的存储过程，调用 SqlQuery 方法

　　② 对于增删改或其他的存储过程，调用 ExecuteSqlCommand 方法

1. 不含任何参数(查询类的存储过程)

 　　直接调用SqlQuery方法进行操作。

if (exists (select * from sys.objects where name = 'GetAll'))
    drop proc GetAll
go
    create proc GetAll
as
    select * from TestOne;

-- 调用
exec GetAll;

      private static void NewMethod(DbContext db)
        {
            Console.WriteLine("---------------------------------1. 测试查询所有数据(不含输入参数)----------------------------------------");
            List<TestOne> tList = db.Database.SqlQuery<TestOne>("GetAll").ToList();
            foreach (var item in tList)
            {
                Console.WriteLine("id为：{0}，t1为：{1}，t2为：{2}", item.id, item.t1, item.t2);
            }
        }

2. 含多个输入参数(查询类的存储过程)

 　　调用SqlQuery方法进行操作，传入参数的使用要使用SqlParameter参数化的方式进行传入，特别注意：调用时，存储过程的名字后面的参数 必须按照SqlParameter中的先后顺序来写。

if (exists (select * from sys.objects where name = 'GetALLBy'))
    drop proc GetALLBy
go
    create proc GetALLBy(
        @id varchar(32),
        @t1 varchar(32)
    )
as
    select * from TestOne where id=@id and t1=@t1;

exec GetALLBy @id='1',@t1='2';

 　　　　private static void NewMethod2(DbContext db)
        {
            Console.WriteLine("---------------------------------2. 测试根据指定条件查询数据(含输入参数)----------------------------------------");
            SqlParameter[] para ={
                                           new SqlParameter("@id","1"),
                                           new SqlParameter("@t1","txt1")
                                  };
            //调用的时，存储过程的名字后面的参数 必须按照SqlParameter中的先后顺序来写
            List<TestOne> tList = db.Database.SqlQuery<TestOne>("GetALLBy @id,@t1", para).ToList();
            foreach (var item in tList)
            {
                Console.WriteLine("id为：{0}，t1为：{1}，t2为：{2}", item.id, item.t1, item.t2);
            }
        }

3. 增删改的存储过程(含1个输入参数)

 　　调用 ExecuteSqlCommand  方法来执行，针对输入参数，要采用SqlParameter的方式来进行传参数

if (exists (select * from sys.objects where name = 'DoSome'))
    drop proc DoSome
go 
    create proc DoSome(
        @id varchar(32)
    )
as
    begin transaction
 begin try
        truncate table [dbo].[TestOne];
        insert into TestOne values(@id,'1','2');
        delete from TestOne where id='2'
    commit transaction
 end try
 begin catch
    rollback transaction
 end catch

 exec DoSome 1

  private static void NewMethod3(DbContext db)
        {
            Console.WriteLine("---------------------------------3. 测试根据指定条件查询数据(含输入参数)----------------------------------------");
            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("没有更多数据进行处理");
            }

        }

4. 带输出参数的存储过程的调用

GO
 if (exists (select * from sys.objects where name = 'GetT1Value'))
    drop proc GetT1Value
go
    create proc GetT1Value(
        @t1 varchar(32),
        @count int output
    )
as
    select @count=count(*) from TestOne where t1=@t1;
    select * from TestOne where t1=@t1;
go
declare @myCount int;
exec GetT1Value '111',@myCount output;
select @myCount as myCount;

   private static void NewMethod4(DbContext db)
        {
            Console.WriteLine("---------------------------------4. 测试查询含有输入和输出操作----------------------------------------");
            //把输出参数单独拿出来声明
            SqlParameter para1 = new SqlParameter("@t2", SqlDbType.Int);
            para1.Direction = ParameterDirection.Output;
            //把输出参数放到数组里
            SqlParameter[] para2 ={
                                           new SqlParameter("@t1","111"),
                                           para1
                                     };
            var tList1 = db.Database.SqlQuery<TestOne>("exec GetT1Value @t1,@t2 out", para2).ToList();
            //通过输出参数在数组中的位置来获取返回值。
            var count = para2[1].Value;

            Console.WriteLine($"数量count为：{count}");
            foreach (var item in tList1)
            {
                Console.WriteLine("id为：{0}，t1为：{1}，t2为：{2}", item.id, item.t1, item.t2);
            }

        }

 PS：这种调用方式，需要先声明一下输出类型，然后把输出参数放到SqlParameter这个数组里，执行完后，通过数值下标.Value来获取这个返回值。（和DBFirst模式下调用有所不同）

三. DBFirst模式快捷调用存储过程

 　　前面介绍的调用存储过程的方法是通用模式，无论EF的哪种模式都可以使用，这里将介绍DBFirst模式的快捷调用，原理即创建的时候将存储过程映射进来了，所以可以直接调用。如下图：

1. 不含任何参数(查询类存储过程)

-- 1.无参存储过程(查询)
if (exists (select * from sys.objects where name = 'GetAll'))
    drop proc GetAll
go
    create proc GetAll
as
    select * from DBTestOne;

-- 调用
exec GetAll;

   private static void DBNewMethod(EFDB3Entities db)
        {
            Console.WriteLine("---------------------------------1. 测试查询所有数据(不含输入参数)----------------------------------------");
            var tList = db.GetAll().ToList();
            foreach (var item in tList)
            {
                Console.WriteLine("id为：{0}，t1为：{1}，t2为：{2}", item.id, item.t1, item.t2);
            }
        }

2. 含多个输入参数(查询类存储过程)

--2. 有参数的存储过程(查询)
if (exists (select * from sys.objects where name = 'GetALLBy'))
    drop proc GetALLBy
go
    create proc GetALLBy(
        @id varchar(32),
        @t1 varchar(32)
    )
as
    select * from DBTestOne where id=@id and t1=@t1;

exec GetALLBy @id='1',@t1='2';

 　　　　private static void DBNewMethod2(EFDB3Entities db)
        {
            Console.WriteLine("---------------------------------2. 测试根据指定条件查询数据(含输入参数)----------------------------------------");
            var tList = db.GetALLBy("11", "1").ToList();
            foreach (var item in tList)
            {
                Console.WriteLine("id为：{0}，t1为：{1}，t2为：{2}", item.id, item.t1, item.t2);
            }
        }

 3. 增删改存储过程(含1个输入参数)

--3. 增删改的一组过程
if (exists (select * from sys.objects where name = 'DoSome'))
    drop proc DoSome
go 
    create proc DoSome(
        @id varchar(32)
    )
as
    begin transaction
 begin try
        truncate table [dbo].[DBTestOne];
        insert into DBTestOne values(@id,'1','2');
        delete from DBTestOne where id='2'
    commit transaction
 end try
 begin catch
    rollback transaction
 end catch

 go
 exec DoSome 1

 private static void DBNewMethod3(EFDB3Entities db)
        {
            Console.WriteLine("---------------------------------3. 测试根据指定条件查询数据(含输入参数)----------------------------------------");
            int n = db.DoSome("33");
            if (n > 0)
            {
                Console.WriteLine("操作成功");
            }
            else
            {
                Console.WriteLine("没有更多数据进行处理");
            }

        }

4. 带有输出参数

 if (exists (select * from sys.objects where name = 'GetT1Value'))
    drop proc GetT1Value
go
    create proc GetT1Value(
        @t1 varchar(32),
        @count int output
    )
as
    select @count=count(*) from DBTestOne where t1=@t1;
    select * from DBTestOne where t1=@t1;
go
declare @myCount int;
exec GetT1Value '111',@myCount output;
select @myCount as myCount;

  private static void DBNewMethod4(EFDB3Entities db)
        {
            Console.WriteLine("---------------------------------4. 测试查询含有输入和输出操作----------------------------------------");
            //声明一下输出参数
            ObjectParameter para1 = new ObjectParameter("XXX", SqlDbType.Int);

            var tList1 = db.GetT1Value("1", para1).ToList();
            //通过.Value获取输出参数的值。
            var count = para1.Value;

            Console.WriteLine($"数量count为：{count}");
            foreach (var item in tList1)
            {
                Console.WriteLine("id为：{0}，t1为：{1}，t2为：{2}", item.id, item.t1, item.t2);
            }

        }

 PS：需要先声明ObjectParameter对象来存放输出参数，执行完后，通过.Value即可以获取输出参数，输出参数都是一个值，还没遇到集合的(PS:欢迎补充)。

!

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