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

柔光的暖阳◎ 2022-09-20 15:23 8阅读 0赞

原文：[http://blog.csdn.net/zoohouse/article/details/6533784][http_blog.csdn.net_zoohouse_article_details_6533784]

一． 使用存储过程：

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

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.  Database db = null;  
2.         
3.        \#region 一般调用  
4.        db = DatabaseFactory.CreateDatabase("Connection String");  
5.        int count = (int)db.ExecuteScalar(CommandType.Text, "SELECT Count(\*) From cms\_company");  
6.        string message = string.Format("There are \{0\} customers in the database", count.ToString());  
7.        Response.Write(message);  
8.        \#endregion  
9.   
10.  
11.       \#region 带返回参数，返回值和返回数据集，一般参数的存储过程  
12.       //CREATE PROCEDURE \[dbo\].\[kword\]  
13.       //@kword varchar(250)='',  
14.       //@top int,  
15.       //@otop varchar(250) output  
16.       //As  
17.       //select top 10 \* from Table1 where ntitle like '%'+@kword+'%' and id>@top  
18.       //declare @flag int  
19.       //select @flag=100  
20.       //SET @otop='返回值'  
21.       //return @flag  
22.       db = DatabaseFactory.CreateDatabase("serverConnectionString");//连接字符串变量名  
23.       DbCommand dbcomm = 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.       DataSet ds = db.ExecuteDataSet(dbcomm);//必须有执行的动作后面才能获取值  
30.       //title = (string)db.ExecuteScalar(dbcomm);如果返回只有一个数据，这样也是可以的  
31.       GridView1.DataSource = ds;  
32.       GridView1.DataBind();  
33.   
34.       Response.Write("<br>output输出参数值：" + db.GetParameterValue(dbcomm, "otop").ToString());  
35.       // int testvalue = (int)dbcomm.Parameters\["@RETURN\_VALUE"\].Value; //另一种获取值的方式  
36.       Response.Write("<br />return返回参数值：" + db.GetParameterValue(dbcomm, "RETURN\_VALUE").ToString());  
37.       \#endregion  
38.  
39.  
40.  
41.       \#region 使用事务记录操作数据库  
42.       //CREATE TABLE \[dbo\].\[Table1\](  
43.       //    \[id\] \[int\] IDENTITY(1,1) NOT NULL,  
44.       //    \[ntitle\] \[varchar\](250) NOT NULL,  
45.       //    \[valuea\] \[varchar\](250) NULL,  
46.       // CONSTRAINT \[PK\_Table1\] PRIMARY KEY CLUSTERED   
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 (IDbConnection conn = db.CreateConnection())  
53.       \{  
54.           conn.Open();  
55.           IDbTransaction \_trans = conn.BeginTransaction();  
56.           try  
57.           \{  
58.               DbCommand \_cmd = db.GetSqlStringCommand("INSERT INTO \[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, \_trans as DbTransaction);  
62.               db.ExecuteNonQuery(\_cmd, \_trans as DbTransaction);//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

[http_blog.csdn.net_zoohouse_article_details_6533784]: http://blog.csdn.net/zoohouse/article/details/6533784