当前文件路径：XingHuanWebSms/App_Code/Comm/DBClass.cs 
1
using System;
2using System.IO;
3using System.Data;
4using System.Data.SqlClient;
5using System.Text;
6using System.Configuration;
7using System.Security.Cryptography;
8using System.Net;
9using System.Drawing;
10using System.Text.RegularExpressions;
11//该源码下载自www.51aspx.com(５１ａｓｐx．ｃｏｍ)
12
13namespace DBLibrary
14
...{
15
public class DBClass : IDisposable
16
...{
17 public SqlConnection conn;
18 private string ConnName;
19 private string ConnString = "";
20
21 public DBClass()
22 ...{
23 ConnString = System.Configuration.ConfigurationManager.AppSettings["ConnString"].ToString();
24 //conn = new SqlConnection(ConnString);
25
}
26 public DBClass(string conn_str)
27 ...{
28 if (conn_str != null && conn_str.Trim() != "")
29 ...{
30 ConnName = conn_str.Trim();
31 }
32 ConnString = System.Configuration.ConfigurationManager.AppSettings[ConnName].ToString();
33 //conn = new SqlConnection(ConnString);
34 }
35
36 public void Dispose()
37 ...{
38 if (conn != null)
39 ...{
40 if (conn.State == ConnectionState.Open)
41 ...{
42 conn.Close();
43 }
44 conn.Dispose();
45 conn = null;
46 }
47 //conn = null;
48 }
49
50 /**//// <summary>
51 /// 打开数据库
52 /// </summary>
53 /// <returns>成功或者失败</returns>
54 public bool Open()
55 ...{
56 if (ConnString == null || ConnString.Trim()=="")
57 ...{
58 return false;
59 }
60 try
61 ...{
62 if (conn.State == ConnectionState.Closed)
63 ...{
64 conn = new SqlConnection(ConnString);
65 conn.Open();
66 }
67 }
68 catch
69 ...{
70 return false;
71 }
72 return true;
73 }
74 /**//// <summary>
75 /// 关闭数据库
76 /// </summary>
77 public void Close()
78 ...{
79 if (conn != null)
80 ...{
81 conn.Close();
82 }
83 conn.Dispose();
84 }
85
86
87
88 /**//// <summary>
89 /// 运行储存过程
90 /// </summary>
91 /// <param name="ProcedureName">储存过程的名称</param>
92 /// <returns>返回值</returns>
93 public int RunProcedureForInt(string ProcedureName)
94 ...{
95 using(SqlConnection cn = new SqlConnection(ConnString))
96 ...{
97 int ret = -1;
98 try
99 ...{
100 SqlCommand Sqlcmd = new SqlCommand(ProcedureName, cn);
101 Sqlcmd.CommandType = CommandType.StoredProcedure;
102 Sqlcmd.Parameters.Add(new SqlParameter("ReturnValue", SqlDbType.Int, 4, ParameterDirection.ReturnValue, false, 0, 0, string.Empty, DataRowVersion.Default, null));
103 cn.Open();
104 Sqlcmd.ExecuteNonQuery();
105 ret = (int)Sqlcmd.Parameters["ReturnValue"].Value;
106 }
107 catch(Exception ex)
108 ...{
109 throw new Exception(ex.Message);
110 }
111 finally
112 ...{
113 cn.Close();
114 }
115 return ret;
116 }
117 }
118
119
120 /**//// <summary>
121 /// 运行没有参数的过程
122 /// </summary>
123 /// <param name="ProcedureName">proc name</param>
124 /// <param name="SqlReader">out sqldatareader</param>
125 public void RunProcForDataReader(string ProcedureName, out SqlDataReader SqlReader)
126 ...{
127 RunProcForDataReader(ProcedureName, null, out SqlReader);
128 }
129 /**//// <summary>
130 /// 运行过程,返回空
131 /// </summary>
132 /// <param name="ProcedureName">过程名</param>
133 /// <param name="SqlPrams">参数名数组</param>
134 /// <param name="SqlReader">输出Datareader结果</param>
135 public void RunProcForDataReader(string ProcedureName, SqlParameter[] SqlPrams, out SqlDataReader SqlReader)
136 ...{
137 try
138 ...{
139 SqlConnection cn = new SqlConnection(ConnString);
140 cn.Open();
141 SqlCommand Sqlcmd = new SqlCommand(ProcedureName, cn);
142 Sqlcmd.CommandType = CommandType.StoredProcedure;
143 if (SqlPrams != null)
144 ...{
145 foreach (SqlParameter Sqlparameter in SqlPrams)
146 ...{
147 Sqlcmd.Parameters.Add(Sqlparameter);
148 }
149 }
150 Sqlcmd.Parameters.Add(new SqlParameter("ReturnValue", SqlDbType.Int, 4, ParameterDirection.ReturnValue, false, 0, 0, string.Empty, DataRowVersion.Default, null));
151 SqlReader = Sqlcmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
152 }
153 catch (Exception ex)
154 ...{
155 throw new Exception(ex.Message);
156
157 }
158 }
159 /**////
160 /// 运行SQL Server储存过程
161 ///
162 /// 储存过程名称
163 /// 以SqlDataReader返回储存过程结果
164 public void RunProcedure(string ProcedureName, out SqlDataReader SqlReader)
165 ...{
166 using (SqlConnection cn = new SqlConnection(ConnString))
167 ...{
168 try
169 ...{
170 SqlCommand Sqlcmd = new SqlCommand(ProcedureName, cn);
171 Sqlcmd.CommandType = CommandType.StoredProcedure;
172 Sqlcmd.Parameters.Add(new SqlParameter("ReturnValue", SqlDbType.Int, 4, ParameterDirection.ReturnValue, false, 0, 0, string.Empty, DataRowVersion.Default, null));
173 cn.Open();
174 SqlReader = Sqlcmd.ExecuteReader(CommandBehavior.CloseConnection);
175 }
176 catch(Exception ex)
177 ...{
178 throw new Exception(ex.Message);
179 }
180 }
181 }
182
183 /**//// <summary>
184 /// /// 运行SQL Server储存过程
185 /// </summary>
186 /// <param name="ProcedureName">储存过程名称</param>
187 /// <param name="SqlPrams">储存过程参数</param>
188 /// <returns>储存过程返回值</returns>
189 public int RunProcedureForInt(string ProcedureName, SqlParameter[] SqlPrams)
190 ...{
191 using (SqlConnection cn = new SqlConnection(ConnString))
192 ...{
193 int ret = -1;
194 try
195 ...{
196 SqlCommand Sqlcmd = new SqlCommand(ProcedureName, cn);
197 Sqlcmd.CommandType = CommandType.StoredProcedure;
198 if (SqlPrams != null)
199 ...{
200 foreach (SqlParameter Sqlparameter in SqlPrams)
201 ...{
202 Sqlcmd.Parameters.Add(Sqlparameter);
203 }
204 }
205 Sqlcmd.Parameters.Add(new SqlParameter("ReturnValue", SqlDbType.Int, 4, ParameterDirection.ReturnValue, false, 0, 0, string.Empty, DataRowVersion.Default, null));
206
207 cn.Open();
208 Sqlcmd.ExecuteNonQuery();
209 ret = (int)Sqlcmd.Parameters["ReturnValue"].Value;
210 }
211 catch(Exception ex)
212 ...{
213 throw new Exception(ex.Message);
214 }
215 finally
216 ...{
217 cn.Close();
218 }
219 return ret;
220 }
221 }
222 /**//// <summary>
223 /// 创建DataSet对象
224 /// </summary>
225 /// <param name="ProcedureName">储存过程名称</param>
226 /// <param name="Table">数据表名</param>
227 /// <returns>DataSet对象</returns>
228 ///
229
230
231 public DataSet RunProcedureForDataSet(string ProcedureName)
232 ...{
233 using (SqlConnection cn = new SqlConnection(ConnString))
234 ...{
235 DataSet SqlDS = new DataSet();
236 try
237 ...{
238 SqlDataAdapter ada = new SqlDataAdapter(ProcedureName, cn);
239 ada.SelectCommand.CommandType = CommandType.StoredProcedure;
240 ada.SelectCommand.Parameters.Add(new SqlParameter("ReturnValue", SqlDbType.Int, 4, ParameterDirection.ReturnValue, false, 0, 0, string.Empty, DataRowVersion.Default, null));
241 cn.Open();
242 ada.Fill(SqlDS);
243 }
244 catch (Exception e)
245 ...{
246 throw new Exception(e.Message);
247 }
248 finally
249 ...{
250 cn.Close();
251 }
252 return (SqlDS);
253 }
254 }
255
256 /**//// <summary>
257 /// 运行SQL Server储存过程
258 /// </summary>
259 /// <param name="ProcedureName">储存过程名称</param>
260 /// <param name="SqlPrams">Sql参数</param>
261 /// <param name="Table">数据表名</param>
262 /// <returns>DataSet对象</returns>
263 public DataSet RunProcedureForDataSet(string ProcedureName, SqlParameter[] SqlPrams)
264 ...{
265 using (SqlConnection cn = new SqlConnection(ConnString))
266 ...{
267 DataSet SqlDS = new DataSet();
268 try
269 ...{
270 SqlDataAdapter SqlDA = new SqlDataAdapter(ProcedureName, cn);
271
