简单学习Linqtosql存储过程

在介绍Linq to sql存储过程之前，先来介绍一下普通存储过程，这样更有助于大家对Linq to sql存储过程的理解。

首先在查询分析器运行下面的代码来创建一个存储过程：

 
 
 
    
  
  
  
  1. create proc sp_singleresultset   
    2.   
  
  
  2. as   
    3.   
  
  
  3. set nocount on   
    4.   
  
  
  4. select * from customers   
    5.

然后打开IDE的服务器资源管理器，之前我们从表中拖动表到dbml设计视图，这次我们从存储过程中找到刚才创建的存储过程，然后拖动到设计视图。在方法面板中可以看到已经创建了一个sp_singleresultset的方法。

然后打开Northwind.designer.cs，可以找到下面的代码：

 
 
 
    
  
  
  
  1. [Function(Name="dbo.sp_singleresultset")]   
    2.   
  
  
  2. public ISingleResult sp_singleresultset()   
    3.   
  
  
  3. {   
    4.   
  
  
  4. IExecuteResult result = this.ExecuteMethodCall(this, 
    5.   
  
  
  5. ((MethodInfo)(MethodInfo.GetCurrentMethod())));   
    6.   
  
  
  6. return ((ISingleResult)(result.ReturnValue));   
    7.   
  
  
  7. }  
    8.

我们可以发现，IDE为这个Linq to sql存储过程单独生成了返回结果集的实体定义，你可能会觉得很奇怪，IDE怎么知道这个存储过程将会返回哪些数据那?其实，在把存储过程拖拽入dbml设计视图的时候，IDE就执行了类似下面的命令：

 
 
 
    
  
  
  
  1. SET FMTONLY ON;   
    2.   
  
  
  2. exec Northwind.dbo.sp_singleresultset   
    3.   
  
  
  3. SET FMTONLY OFF;  
    4.

这样就可以直接获取Linq to sql存储过程返回的元数据而无须执行存储过程。

其实我们存储过程返回的就是顾客表的数据，如果你觉得为存储过程单独设置结果集实体有些浪费的话可以在存储过程的属性窗口中调整返回类型从“自动生成的类型”到Customer，不过以后你只能通过删除方法面板中的存储过程，然后重新添加来还原到“自动生成的类型”。下面，我们可以写如下的Linq to object代码进行查询：

var 单结果集存储过程 =

 
 
 
    
  
  
  
  1. from c in ctx.sp_singleresultset()   
    2.   
  
  
  2. where c.CustomerID.StartsWith("A")   
    3.   
  
  
  3. select c;  
    4.

在这里确实是Linq to object的，因为查询句法不会被整句翻译成SQL，而是从Linq to sql存储过程存储过程的返回对象中再去对对象进行查询。SQL代码如下：

 
 
 
    
  
  
  
  1. EXEC @RETURN_VALUE = [dbo].[sp_singleresultset]   
    2.   
  
  
  2. -- @RETURN_VALUE: Output Int32 (Size = 0; Prec = 0; Scale = 0) []  
    3.

Linq to sql存储过程之带参数的存储过程

创建如下存储过程：

 
 
 
    
  
  
  
  1. create proc [dbo].[sp_withparameter]   
    2.   
  
  
  2. @customerid nchar(5),   
    3.   
  
  
  3. @rowcount int output   
    4.   
  
  
  4. as   
    5.   
  
  
  5. set nocount on   
    6.   
  
  
  6. set @rowcount = (select count(*) from customers where 
    7.   
  
  
  7. customerid = @customerid)  
    8.

使用同样的方法生成存储过程方法，然后使用下面的代码进行测试：

 
 
 
    
  
  
  
  1. int? rowcount = -1;   
    2.   
  
  
  2. ctx.sp_withparameter("", ref rowcount);   
    3.   
  
  
  3. Response.Write(rowcount);   
    4.   
  
  
  4. ctx.sp_withparameter("ALFKI", ref rowcount);   
    5.   
  
  
  5. Response.Write(rowcount);  
    6.

结果输出了“01”。说明ID为“”的顾客数为0，而ID为“ALFKI”的顾客数为1。Linq to sql存储过程存储过程的输出参数被封装成了ref参数，对于C#语法来说非常合情合理。SQL代码如下

 
 
 
    
  
  
  
  1. EXEC @RETURN_VALUE = [dbo].[sp_withparameter] @customerid = @p0,
    2.   
  
  
  2.  @rowcount = @p1 OUTPUT   
    3.   
  
  
  3. -- @p0: Input StringFixedLength (Size = 5; Prec = 0; Scale = 0) []   
    4.   
  
  
  4. -- @p1: InputOutput Int32 (Size = 0; Prec = 0; Scale = 0) [-1]   
    5.   
  
  
  5. -- @RETURN_VALUE: Output Int32 (Size = 0; Prec = 0; Scale = 0) []  
    6.

Linq to sql存储过程之带返回值的存储过程

再来创建第三个存储过程：

 
 
 
    
  
  
  
  1. create proc [dbo].[sp_withreturnvalue]   
    2.   
  
  
  2. @customerid nchar(5)   
    3.   
  
  
  3. as   
    4.   
  
  
  4. set nocount on   
    5.   
  
  
  5. if exists (select 1 from customers where customerid = @customerid)   
    6.   
  
  
  6. return 101   
    7.   
  
  
  7. else   
    8.   
  
  
  8. return 100  
    9.

生成方法后，可以通过下面的代码进行测试：

 
 
 
    
  
  
  
  1. Response.Write(ctx.sp_withreturnvalue(""));   
    2.   
  
  
  2. Response.Write(ctx.sp_withreturnvalue("ALFKI"));  
    3.

运行后程序输出“100101”

Linq to sql存储过程之多结果集的存储过程

再来创建一个多结果集的存储过程：

 
 
 
    
  
  
  
  1. 　create proc [dbo].[sp_multiresultset]   
    2.   
  
  
  2. as   
    3.   
  
  
  3. set nocount on   
    4.   
  
  
  4. select * from customers   
    5.   
  
  
  5. select * from employees  
    6.

找到生成的存储过程方法：

 
 
 
    
  
  
  
  1. 　[Function(Name="dbo.sp_multiresultset")]   
    2.   
  
  
  2. public ISingleResult sp_multiresultset()   
    3.   
  
  
  3. {   
    4.   
  
  
  4. IExecuteResult result = this.ExecuteMethodCall(this,
    5.   
  
  
  5.  ((MethodInfo)(MethodInfo.GetCurrentMethod())));   
    6.   
  
  
  6. return ((ISingleResult)(result.ReturnValue));   
    7.   
  
  
  7. }  
    8.

由于现在的VS2008会把多结果集Linq to sql存储过程识别为单结果集存储过程(只认识第一个结果集)，我们只能对Linq to sql存储过程方法多小动手术，修改为：

 
 
 
    
  
  
  
  1. [Function(Name="dbo.sp_multiresultset")]   
    2.   
  
  
  2. [ResultType(typeof(Customer))]   
    3.   
  
  
  3. [ResultType(typeof(Employee))]   
    4.   
  
  
  4. public IMultipleResults sp_multiresultset()   
    5.   
  
  
  5. {   
    6.   
  
  
  6. IExecuteResult result = this.ExecuteMethodCall(this, 
    7.   
  
  
  7. ((MethodInfo)(MethodInfo.GetCurrentMethod())));   
    8.   
  
  
  8. return (IMultipleResults)(result.ReturnValue);   
    9.   
  
  
  9. }  
    10.

然后使用下面的代码测试：

 
 
 
    
  
  
  
  1. var 多结果集存储过程 = ctx.sp_multiresultset();   
    2.   
  
  
  2. var Customers = 多结果集存储过程.GetResult();   
    3.   
  
  
  3. var Employees = 多结果集存储过程.GetResult();  
    4.   
  
  
  4. GridView1.DataSource = from emp in Employees where 
    5.   
  
  
  5. emp.FirstName.Contains("A") select emp;  
    6.   
  
  
  6. 　GridView1.DataBind();   
    7.   
  
  
  7. GridView2.DataSource = from c in Customers where 
    8.   
  
  
  8. c.CustomerID.StartsWith("A") select c;  
    9.   
  
  
  9. GridView2.DataBind(); 
    10.

使用Linq to sql存储过程新增数据

存储过程除了可以直接调用之外，还可以用于实体的增删改操作。还记得在《一步一步学Linq to sql(三)：增删改》中创建的留言簿程序吗?下面我们就来改造这个程序，使用存储过程而不是系统生成的SQL实现实体增删改。首先，我们创建下面的Linq to sql存储过程。

 
 
 
    
  
  
  
  1. create proc sendmessage   
    2.   
  
  
  2. @username varchar(50),   
    3.   
  
  
  3. @message varchar(500)   
    4.   
  
  
  4. as   
    5.   
  
  
  5. insert into tbguestbook   
    6.   
  
  
  6. (id,username,posttime,[message],isreplied,reply)   
    7.   
  
  
  7. values   
    8.   
  
  
  8. (newid(),@username,getdate(),@message,0,'')  
    9.

然后，打开留言簿dbml，把Linq to sql存储过程从服务器资源管理器拖拽到设计视图上。右键点击tbGuestBook实体类，选择配置行为。如下图，为插入操作选择刚才创建的存储过程方法，并进行参数匹配：

由于我们的Linq to sql存储过程只接受2个参数，相应修改以下创建留言的按钮处理事件：

 
 
 
    
  
  
  
  1. protected void btn_SendMessage_Click(object sender, EventArgs e)   
    2.   
  
  
  2. {   
    3.   
  
  
  3. tbGuestBook gb = new tbGuestBook();   
    4.   
  
  
  4. gb.UserName = tb_UserName.Text;   
    5.   
  
  
  5. gb.Message = tb_Message.Text;   
    6.   
  
  
  6. ctx.tbGuestBooks.Add(gb);   
    7.   
  
  
  7. ctx.SubmitChanges();   
    8.   
  
  
  8. SetBind();   
    9.   
  
  
  9. }  
    10.

运行程序后可以发现，在提交修改的时候调用了下面的SQL：

 
 
 
    
  
  
  
  1. 　EXEC @RETURN_VALUE = [dbo].[sendmessage] @username = @p0, @message = @p1   
    2.   
  
  
  2. -- @p0: Input AnsiString (Size = 5; Prec = 0; Scale = 0) [zhuye]   
    3.   
  
  
  3. -- @p1: Input AnsiString (Size = 11; Prec = 0; Scale = 0) [new message]   
    4.   
  
  
  4. -- @RETURN_VALUE: Output Int32 (Size = 0; Prec = 0; Scale = 0) []  
    5.

使用Linq to sql存储过程删除数据

创建如下Linq to sql存储过程：

 
 
 
    
  
  
  
  1. 　create proc delmessage   
    2.   
  
  
  2. @id uniqueidentifier   
    3.   
  
  
  3. as   
    4.   
  
  
  4. delete tbguestbook where id=@id  
    5.

按照前面的步骤生成Linq to sql存储过程方法，并为删除操作执行这个存储过程方法。在选择参数的时候我们可以看到，ID分当前值和原始值，我们选择当前值即可无须改动任何逻辑代码，进行删除留言操作后可以跟踪到下面的SQL：

 
 
 
    
  
  
  
  1. 　EXEC @RETURN_VALUE = [dbo].[delmessage] @id = @p0   
    2.   
  
  
  2. -- @p0: Input Guid (Size = 0; Prec = 0; Scale = 0) 
    3.   
  
  
  3. [9e3c5ee3-2575-458e-899d-4b0bf73e0849]   
    4.   
  
  
  4. -- @RETURN_VALUE: Output Int32 (Size = 0; Prec = 0; Scale = 0) []  
    5.

Linq to sql存储过程之使用存储过程更改数据

创建如下存储过程：

 
 
 
    
  
  
  
  1. create proc replymessage   
    2.   
  
  
  2. @id uniqueidentifier,   
    3.   
  
  
  3. @reply varchar(500)   
    4.   
  
  
  4. as   
    5.   
  
  
  5. update tbguestbook set reply=@reply,isreplied=1 where id=@id  
    6.

由于更新的时候并不会更新主键，所以我们可以为两个参数都指定当前值。回复留言后可以跟踪到下面的SQL：

 
 
 
    
  
  
  
  1. 　EXEC @RETURN_VALUE = [dbo].[replymessage] @id = @p0, @reply = @p1   
    2.   
  
  
  2. -- @p0: Input Guid (Size = 0; Prec = 0; Scale = 0)
    3.   
  
  
  3.  [67a69d0f-a88b-4b22-8939-fed021eb1cb5]   
    4.   
  
  
  4. -- @p1: Input AnsiString (Size = 6; Prec = 0; Scale = 0) [464456]   
    5.   
  
  
  5. -- @RETURN_VALUE: Output Int32 (Size = 0; Prec = 0; Scale = 0) []  
    6.

假设有这样一种应用，我们需要修改留言簿中不合法的用户名：

 
 
 
    
  
  
  
  1. 　create proc modiusername   
    2.   
  
  
  2. @oldusername varchar(50),   
    3.   
  
  
  3. @newusername varchar(50)   
    4.   
  
  
  4. as   
    5.   
  
  
  5. update tbguestbook set username=@newusername where 
    6.   
  
  
  6. username = @oldusername  
    7.

有个网友起名叫“admin”，我们要把所有这个名字修改为“notadmin”。那么，可以如下图设置update操作：

然后运行下面的测试代码：

 
 
 
    
  
  
  
  1. var messages = from gb in ctx.tbGuestBooks   
    2.   
  
  
  2. select gb;   
    3.   
  
  
  3. foreach (var gb in messages)   
    4.   
  
  
  4. {   
    5.   
  
  
  5. if(gb.UserName == "admin")   
    6.   
  
  
  6. gb.UserName = "notadmin";   
    7.   
  
  
  7. }  
    8.

运行程序后能跟踪到下面的SQL：

 
 
 
    
  
  
  
  1. SELECT [t0].[ID], [t0].[UserName], [t0].[PostTime], [t0].[Message], 
    2.   
  
  
  2. [t0].[IsReplied], [t0].[Reply]   
    3.   
  
  
  3. FROM [dbo].[tbGuestBook] AS [t0]   
    4.   
  
  
  4. EXEC @RETURN_VALUE = [dbo].[modiusername] @oldusername = 
    5.   
  
  
  5. @p0, @newusername = @p1   
    6.   
  
  
  6. -- @p0: Input AnsiString (Size = 5; Prec = 0; Scale = 0) [admin]   
    7.   
  
  
  7. -- @p1: Input AnsiString (Size = 8; Prec = 0; Scale = 0) [notadmin]   
    8.   
  
  
  8. -- @RETURN_VALUE: Output Int32 (Size = 0; Prec = 0; Scale = 0) []  
    9.

Linq to sql存储过程就看到这里了，你应该能明白当前值和原始值的含义了吧。

文章名称：简单学习Linqtosql存储过程
文章URL：http://www.shufengxianlan.com/qtweb/news13/384513.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联

猜你还喜欢下面的内容

响应式网站知识

行业网站建设

成都外贸网站建设公司　　 　成都移动机房　　 　网站优化排名　　 　成都ssl证书认证　　 　成都雪糕加盟　　 　成都枢纽中心　　 　营山网站建设　　 　成都网站维护　　 　成都营销网站建设　　 　网站解决方案　　 　成都免费自助建站　　 　重庆水土双线托管　　 　添翼二手车鉴定　　 　小程序　　 　整合营销　　 　卖链接　　 　泽君科技　　 　成都广告设计　　 　德阳电信服务器托管　　 　资阳网站建设