[NHibernate]存储过程的使用（二）

    <!--存储过程，check参数：none/rowcount/param-->

    <sql-insert>exec TB_CustomerInsert ?,?,?,?</sql-insert>

     <!--<sql-delete check="rowcount" >exec TB_CustomerDelete ?</sql-delete>-->

    <sql-delete>DELETE FROM [TB_Customer] WHERE [CustomerID] = ? and [Version] =?</sql-delete>

测试

         /// <summary>

         /// 通过存储过程添加客户

         /// </summary>

         /// <param name="customer">客户实体</param>

         /// <returns>是否添加成功 </returns>

         public bool AddCustomerUsingProcess(Customer customer)

         {

             try

             {

                 var session = NHibernateHelper.GetSession();

                 //将customer对象写入内存

                 session.Save(customer);

                 //更新到数据库

                 session.Flush();

                 return true;

             }

             catch (Exception ex)

             {

                 throw ex;

             }

         }

运行代码，进行测试，此时会有一个异常
[NHibernate]存储过程的使用（二）

int和guid类型不兼容，猜测是存储过程中参数位置不对，调整参数位置。

 ALTER PROCEDURE [dbo].[TB_CustomerInsert]

 (

     @Version int,

     @CustomerName nvarchar(16) = NULL,

     @CustomerAddress nvarchar(128) = NULL,

     @CustomerID uniqueidentifier OUTPUT

 )

 AS

     --去掉SET NOCOUNT ON

     INSERT INTO [TB_Customer]

     (

         [Version],

         [CustomerName],

         [CustomerAddress],

         [CustomerID]

     )

     VALUES

     (

         @Version,

         @CustomerName,

         @CustomerAddress,

         @CustomerID

     )

     RETURN @@Error

数据表

[NHibernate]存储过程的使用（二）

你会发现，在存储过程中的，参数的顺序id必须在后面，乐观并发控制（版本号）必须在第一个。

如果是自增主键，可能遇到的错误可参考：http://www.cnblogs.com/lyj/archive/2008/11/06/1328240.html

更新对象

首先修改映射文件Customer.hbm.xml，添加<sql-update>节点。同理，参数使用?占位。

     <!--存储过程，check参数：none/rowcount/param-->

     <sql-insert>exec TB_CustomerInsert ?,?,?,?</sql-insert>

     <sql-update>exec TB_CustomerUpdate ?,?,?,?</sql-update>

      <!--<sql-delete check="rowcount" >exec TB_CustomerDelete ?</sql-delete>-->

     <sql-delete>DELETE FROM [TB_Customer] WHERE [CustomerID] = ? and [Version] =?</sql-delete>

测试

         /// <summary>

         /// 使用存储过程修改客户信息

         /// </summary>

         /// <param name="customer">客户对象</param>

         /// <returns>是否修改成功</returns>

         public bool UpdateCustomerUsingProcess(Customer customer)

         {

             try

             {

                 var session = NHibernateHelper.GetSession();

                 //Update the persistent instance with the identifier of the given transient instance.

                 session.Update(customer);

                 session.Flush();

                 return true;

             }

             catch (Exception)

             {

                 throw;

             }

         }

此时还会有那个异常，如图，同样的办法修改存储过程。

[NHibernate]存储过程的使用（二）

修改后的存储过程

 ALTER PROCEDURE [dbo].[TB_CustomerUpdate]

 (

     @Version int,

     @CustomerName nvarchar(16) = NULL,

     @CustomerAddress nvarchar(128) = NULL,

     @CustomerID uniqueidentifier

 )

 AS

     --SET NOCOUNT ON

     UPDATE [TB_Customer]

     SET

         [Version] = @Version,

         [CustomerName] = @CustomerName,

         [CustomerAddress] = @CustomerAddress,

         [CustomerID] = @CustomerID

     WHERE

         [CustomerID] = @CustomerID

     RETURN @@Error

生成的sql语句

exec sp_executesql N'exec TB_CustomerUpdate @p0,@p1,@p2,@p3',N'@p0 int,@p1 nvarchar(4000),@p2 nvarchar(4000),@p3 uniqueidentifier,@p4 int',@p0=3,@p1=N'wolfy22222',@p2=N'南京22222',@p3='DDF63750-3307-461B-B96A-7FF356540CB8',@p4=2

数据表

[NHibernate]存储过程的使用（二）

你通过数据表中的Version，会发现，它发生了变化，从1到2（出现3的原因，是在之前我测试了一下）。并且在sql语句中有一个@p4的参数。

为了更好的实现版本控制的功能，你可以修改存储过程，添加一个@oldeversion参数。

 ALTER PROCEDURE [dbo].[TB_CustomerUpdate]

 (

     @Version int,

     @CustomerName nvarchar(16) = NULL,

     @CustomerAddress nvarchar(128) = NULL,

     @CustomerID uniqueidentifier,

     @oldVersion int

 )

 AS

     --SET NOCOUNT ON

     UPDATE [TB_Customer]

     SET

         [Version] = @Version,

         [CustomerName] = @CustomerName,

         [CustomerAddress] = @CustomerAddress,

         [CustomerID] = @CustomerID

     WHERE

         [CustomerID] = @CustomerID and [Version] =@oldVersion

     RETURN @@Error

在映射文件中，添加一个?，代表@oldVersion。

 <sql-update>exec TB_CustomerUpdate ?,?,?,?,?</sql-update>

生成的sql语句为

[NHibernate]存储过程的使用（二）

这样就跟存储过程中的参数对应上了。

上篇文章也介绍了一种方法，如果你不想执行存储过程，可以使用sql语句也可以达到目的。

   <sql-update>UPDATE TB_CustomerUpdate SET Version=?, [CustomerName]=?,[CustomerAddress]=? WHERE CustomerID=? AND Version=? </sql-update>

总结

本篇文章介绍了如何在nhibernate使用存储过程添加数据，更新数据及在使用过程中需要注意的问题。你可能也有个疑问，为啥使用MyGeneration生成的存储过程，每次都要修改？这个的确是个很让人恼火的地方，没办法，并不能什么东西都十全十美，至少存储过程的语法已经写好了，修改起来也很方便。

秒客网

[NHibernate]存储过程的使用（二）

目录

写在前面

文档与系列文章

创建对象

更新对象

总结

相关文章