Microsoft.Practices.EnterpriseLibrary.Data--使用存储过程，参数及事务

一． 使用存储过程：

关于数据访问应用程序块的介绍在入门篇里面已经说过了，这里不再重复。下面我们来看看在数据访问应用程序块里面使用存储过程的方法：

1． 不传递参数：不传递参数时值需要指定存储过程的名称，已经命令的类型即可。

1/**//// <summary>
2 /// 执行存储过程(1)——不传递参数(NoPara)
3 /// </summary>
4 private void FormatDataBySp1()
5 {
6 /**////创建数据库实例
7 Database db = DatabaseFactory.CreateDatabase("NorthWind");
8
9 /**////传递参数
10 DbCommand dbc = db.GetStoredProcCommand("GetProductsList");
11
12 /**////执行存储过程
13 DataSet ds = db.ExecuteDataSet(dbc);
14
15 /**////绑定数据
16 DataGrid1.DataSource = ds.Tables[0];
17 DataGrid1.DataBind();
18 }

2． 传递输入参数：需要注意的是在增加参数时是AddInParameter。

1/**//// <summary>
2 /// 执行存储过程(2)——传递输入参数(Input)
3 /// </summary>
4 private void FormatDataBySp2()
5 {
6 /**////创建数据库实例
7 Database db = DatabaseFactory.CreateDatabase("NorthWind");
8
9 /**////传递参数
10 DbCommand dbc = db.GetStoredProcCommand("CustOrdersDetail");
11 dbc.AddInParameter("@OrderID",System.Data.DbType.Int32,10248);
12
13 /**////执行存储过程
14 DataSet ds = db.ExecuteDataSet(dbc);
15
16 /**////绑定数据
17 DataGrid1.DataSource = ds.Tables[0];
18 DataGrid1.DataBind();
19 }

3． 传递输出参数：需要注意的是在增加参数时是AddOutParameter。

1/**//// <summary>
2 /// 执行存储过程(3)——传递输出参数(Output)
3 /// </summary>
4 private void FormatDataBySp3()
5 {
6 /**////创建数据库实例
7 Database db = DatabaseFactory.CreateDatabase("NorthWind");
8
9 /**////传递参数
10 DbCommand dbc = db.GetStoredProcCommand("GetProductDetails");
11
12 dbc.AddInParameter("@ProductID",System.Data.DbType.Int32,12);
13 dbc.AddOutParameter("@ProductName",System.Data.DbType.String,50); //输出
14
15 /**////执行存储过程
16 db.ExecuteNonQuery(dbc);
17
18 string result = dbc.GetParameterValue("@ProductName").ToString(); //得到输出参数的值
19 }

二． 使用事务：

在企业库数据访问应用程序块里面，对事务提供了很好的支持，具体的使用方法在程序里面有注释，这里就不多说了。

1/**//// <summary>
2 /// 利用事务更改数据
3 /// </summary>
4 private void ExecuteUseTran()
5 {
6 /**////创建数据库实例
7 Database db = DatabaseFactory.CreateDatabase("NorthWind");
8
9 using(IDbConnection Idbconn = db.GetConnection())
10 {
11 /**////打开连接
12 Idbconn.Open();
13
14 /**////创建事务
15 IDbTransaction Idbtran = Idbconn.BeginTransaction();
16
17 try
18 {
19 /**////执行两个存储过程
20 db.ExecuteNonQuery(CommandType.StoredProcedure,"InserOrders");
21 db.ExecuteDataSet(CommandType.StoredProcedure,"UpdateProducts");
22
23 /**////执行完成后提交事务
24 Idbtran.Commit();
25 }
26 catch
27 {
28 /**////回滚事务
29 Idbtran.Rollback();
30 }
31 finally
32 {
33 /**////关闭连接
34 Idbconn.Close();
35 }
36 }
37
38 }

Microsoft.Practices.EnterpriseLibrary.Data 数据库操作

1. Databasedb=null;
3. #region一般调用
4. db=DatabaseFactory.CreateDatabase("ConnectionString");
5. intcount=(int)db.ExecuteScalar(CommandType.Text,"SELECTCount(*)Fromcms_company");
6. stringmessage=string.Format("Thereare{0}customersinthedatabase",count.ToString());
7. Response.Write(message);
8. #endregion
11. #region带返回参数，返回值和返回数据集，一般参数的存储过程
12. //CREATEPROCEDURE[dbo].[kword]
13. //@kwordvarchar(250)='',
14. //@topint,
15. //@otopvarchar(250)output
16. //As
17. //selecttop10*fromTable1wherentitlelike'%'+@kword+'%'andid>@top
18. //declare@flagint
19. //select@flag=100
20. //SET@otop='返回值'
21. //return@flag
22. db=DatabaseFactory.CreateDatabase("serverConnectionString");//连接字符串变量名
23. DbCommanddbcomm=db.GetStoredProcCommand("kword");//存储过程名
24. db.AddInParameter(dbcomm,"@kword",DbType.String,"创业");//参数名类型值
25. db.AddInParameter(dbcomm,"top",DbType.Int32,2);//参数名类型值
26. db.AddOutParameter(dbcomm,"otop",DbType.String,250);//output参数名类型长度
27. //关键在这里，添加一个参数@RETURN_VALUE类型为ReturnValue
28. db.AddParameter(dbcomm,"@RETURN_VALUE",DbType.String,ParameterDirection.ReturnValue,"",DataRowVersion.Current,null);
29. DataSetds=db.ExecuteDataSet(dbcomm);//必须有执行的动作后面才能获取值
30. //title=(string)db.ExecuteScalar(dbcomm);如果返回只有一个数据，这样也是可以的
31. GridView1.DataSource=ds;
32. GridView1.DataBind();
34. Response.Write("<br>output输出参数值："+db.GetParameterValue(dbcomm,"otop").ToString());
35. //inttestvalue=(int)dbcomm.Parameters["@RETURN_VALUE"].Value;//另一种获取值的方式
36. Response.Write("<br/>return返回参数值："+db.GetParameterValue(dbcomm,"RETURN_VALUE").ToString());
37. #endregion
41. #region使用事务记录操作数据库
42. //CREATETABLE[dbo].[Table1](
43. //[id][int]IDENTITY(1,1)NOTNULL,
44. //[ntitle][varchar](250)NOTNULL,
45. //[valuea][varchar](250)NULL,
46. //CONSTRAINT[PK_Table1]PRIMARYKEYCLUSTERED
47. //(
48. //[ntitle]ASC
49. //)WITH(PAD_INDEX=OFF,STATISTICS_NORECOMPUTE=OFF,IGNORE_DUP_KEY=OFF,ALLOW_ROW_LOCKS=ON,ALLOW_PAGE_LOCKS=ON)ON[PRIMARY]
50. //)ON[PRIMARY]
51. db=DatabaseFactory.CreateDatabase("serverConnectionString");
52. using(IDbConnectionconn=db.CreateConnection())
53. {
54. conn.Open();
55. IDbTransaction_trans=conn.BeginTransaction();
56. try
57. {
58. DbCommand_cmd=db.GetSqlStringCommand("INSERTINTO[Table1]([ntitle],[valuea])VALUES(@ntitle,@valuea)");
59. db.AddInParameter(_cmd,"ntitle",DbType.String,"AA");
60. db.AddInParameter(_cmd,"valuea",DbType.String,"AA");
61. db.ExecuteNonQuery(_cmd,_transasDbTransaction);
62. db.ExecuteNonQuery(_cmd,_transasDbTransaction);//ntitle字段上建有唯一索引，故第二次插入同样记录时会报错
63. _trans.Commit();
64. }
65. catch
66. {
67. try
68. {
69. _trans.Rollback();//事务提交失败时，则回滚(是否回滚成功，可查看表中有无AA的记录即可)
70. }
71. catch{}
72. }
73. finally
74. {
75. conn.Close();
76. }
77. }
78. #endregion