[亲测]c#执行存储过程并返回GUID主键

小渣渣

1. public class DBHelper
   
2.     {
   
3.         private static readonly string ConnStr = ConfigurationManager.AppSettings["Test"];
   
4.         /// <summary>
   
5.         /// 执行sql语句
   
6.         /// </summary>
   
7.         /// <param name="strSql"></param>
   
8.         /// <returns>返回影响行数</returns>
   
9.         public int ExecuteNonQuery(string strSql)
   
10.         {
    
11.             int result = 0;
    
12.             using (SqlConnection con = new SqlConnection(ConnStr))
    
13.             {
    
14.                 if (con.State == ConnectionState.Closed)
    
15.                     con.Open();
    
16.                 using (SqlCommand cmd = new SqlCommand(strSql, con))
    
17.                 {
    
18.                     result = cmd.ExecuteNonQuery();
    
19.                 }
    
20.                 con.Close();
    
21. 
    
22.                 return result;
    
23.             }
    
24.         }
    
25.         /// <summary>
    
26.         /// 执行存储过程
    
27.         /// </summary>
    
28.         /// <param name="strProcedure"></param>
    
29.         /// <param name="param"></param>
    
30.         /// <returns>返回影响行数</returns>
    
31.         public int ExecuteNonQuery(string strProcedure, SqlParameter[] param)
    
32.         {
    
33.             int result = 0;
    
34.             using (SqlConnection con = new SqlConnection(ConnStr))
    
35.             {
    
36.                 if (con.State == ConnectionState.Closed)
    
37.                     con.Open();
    
38.                 using (SqlCommand cmd = new SqlCommand())
    
39.                 {
    
40.                     cmd.CommandType = CommandType.StoredProcedure;
    
41.                     cmd.CommandText = strProcedure;
    
42.                     cmd.Connection = con;
    
43. 
    
44.                     foreach (var item in param)
    
45.                     {
    
46.                         cmd.Parameters.Add(item);
    
47.                     }
    
48. 
    
49.                     result = cmd.ExecuteNonQuery();
    
50.                 }
    
51. 
    
52.                 con.Close();
    
53. 
    
54.                 return result;
    
55.             }
    
56.         }
    
57.         /// <summary>
    
58.         /// 查询
    
59.         /// </summary>
    
60.         /// <param name="strSql"></param>
    
61.         /// <returns>返回DataSet</returns>
    
62.         public DataSet ExecuteDataSet(string strSql)
    
63.         {
    
64.             using (DataSet ds = new DataSet())
    
65.             {
    
66.                 using (SqlConnection con = new SqlConnection(ConnStr))
    
67.                 {
    
68.                     if (con.State == ConnectionState.Closed)
    
69.                         con.Open();
    
70.                     using (SqlCommand cmd = new SqlCommand(strSql, con))
    
71.                     {
    
72.                         using (SqlDataAdapter sda = new SqlDataAdapter())
    
73.                         {
    
74.                             sda.SelectCommand = cmd;
    
75.                             sda.Fill(ds);
    
76.                         }
    
77.                     }
    
78.                     con.Close();
    
79.                 }
    
80. 
    
81.                 return ds;
    
82.             }
    
83.         }
    
84. 
    
85.         public DataSet ExecuteDataSet(string strProcedure, SqlParameter[] param)
    
86.         {
    
87.             using (DataSet ds = new DataSet())
    
88.             {
    
89.                 using (SqlConnection con = new SqlConnection(ConnStr))
    
90.                 {
    
91.                     if (con.State == ConnectionState.Closed)
    
92.                         con.Open();
    
93.                     using (SqlCommand cmd = new SqlCommand())
    
94.                     {
    
95.                         cmd.CommandType = CommandType.StoredProcedure;
    
96.                         cmd.CommandText = strProcedure;
    
97.                         cmd.Connection = con;
    
98. 
    
99.                         foreach (var item in param)
    
100.                         {
     
101.                             cmd.Parameters.Add(item);
     
102.                         }
     
103.                         using (SqlDataAdapter sda = new SqlDataAdapter())
     
104.                         {
     
105.                             sda.SelectCommand = cmd;
     
106.                             sda.Fill(ds);
     
107.                         }
     
108.                     }
     
109.                     con.Close();
     
110.                 }
     
111.                 return ds;
     
112.             }
     
113.         }
     
114. 
     
115.         public int ExecuteNonQueryReturnRecordID(string strProcedure, SqlParameter[] param)
     
116.         {
     
117.             int result = 0;
     
118.             using (SqlConnection con = new SqlConnection(ConnStr))
     
119.             {
     
120.                 if (con.State == ConnectionState.Closed)
     
121.                     con.Open();
     
122.                 using (SqlCommand cmd = new SqlCommand())
     
123.                 {
     
124.                     cmd.CommandType = CommandType.StoredProcedure;
     
125.                     cmd.CommandText = strProcedure;
     
126.                     cmd.Connection = con;
     
127. 
     
128.                     foreach (var item in param)
     
129.                     {
     
130.                         cmd.Parameters.Add(item);
     
131.                     }
     
132. 
     
133.                     cmd.ExecuteNonQuery();
     
134. 
     
135.                     result = int.Parse(cmd.Parameters["ID"].Value.ToString());
     
136.                 }
     
137. 
     
138.                 con.Close();
     
139. 
     
140.                 return result;
     
141.             }
     
142.         }
     
143. 
     
144.         public SqlParameterCollection ExecuteNonQueryReturns(string strProcedure, SqlParameter[] param)
     
145.         {
     
146.             SqlParameterCollection spc = null;
     
147.             using (SqlConnection con = new SqlConnection(ConnStr))
     
148.             {
     
149.                 if (con.State == ConnectionState.Closed)
     
150.                     con.Open();
     
151.                 using (SqlCommand cmd = new SqlCommand())
     
152.                 {
     
153.                     cmd.CommandType = CommandType.StoredProcedure;
     
154.                     cmd.CommandText = strProcedure;
     
155.                     cmd.Connection = con;
     
156. 
     
157.                     foreach (var item in param)
     
158.                     {
     
159.                         cmd.Parameters.Add(item);
     
160.                     }
     
161. 
     
162.                     cmd.ExecuteNonQuery();
     
163. 
     
164.                     spc = cmd.Parameters;
     
165.                 }
     
166.                 con.Close();
     
167. 
     
168.                 return spc;
     
169.             }
     
170.         }
     
171.     }

复制代码

先附上DBHelp的方法
存储过程如下：

1. ALTER PROCEDURE [dbo].[pAddsp_UserInfoByEmail]
   
2.         @ID VARCHAR(50),
   
3.         @PASSLOGIN VARCHAR(32),
   
4.         @GUID UNIQUEIDENTIFIER OUTPUT
   
5. AS
   
6. BEGIN
   
7.         SELECT @GUID=NEWID()
   
8.         INSERT INTO sp_UserInfo([GUID],[PasswordLogin],[Email],[IsEmailValidate],[CreateDate],[Statas]) VALUES (@GUID,@PASSLOGIN,@ID,1,GETDATE(),1)
   
9. END
   
10. GO

复制代码

执行的代码：

1. public class pAddsp_UserInfoByEmail:DBHelper
   
2.     {
   
3.         private string Email;
   
4.         private string PassLogin;
   
5.         public pAddsp_UserInfoByEmail(string mail, string passlogin)
   
6.         {
   
7.             this.Email = mail;
   
8.             this.PassLogin = passlogin;
   
9.         }
   
10.         public string ExecutionProcedure()
    
11.         {
    
12.             try
    
13.             {
    
14.                 var param = new SqlParameter[3];
    
15.                 param[0] = new SqlParameter("ID", this.Email);
    
16.                 param[1] = new SqlParameter("PASSLOGIN", this.PassLogin);
    
17.                 param[2] = new SqlParameter("GUID", SqlDbType.UniqueIdentifier);
    
18.                 param[2].Direction = ParameterDirection.Output;
    
19.                 var sp=base.ExecuteNonQueryReturns("pAddsp_UserInfoByEmail", param);
    
20.                 return sp["GUID"].Value.ToString();
    
21.             }
    
22.             catch (Exception ex)
    
23.             {
    
24.                 return null;
    
25.             }
    
26.         }

复制代码