当前文件：
yyzyqBBS/DBUtility/SqlDataBase.cs[9K，2009-6-12 12:01:01]，
打开代码结构图
1
using System;
2using System.Data;
3using System.Data.SqlClient;
4using System.Configuration;
5
6namespace WeYyzyq.DBUtility
7
...{
8
9
/**//// <summary>
10 /// 数据库操作基类
11 /// 实现对Sql数据库的各种操作
12 /// 创建时间：2006-8-3
13
/// </summary>
14 public class SqlDataBase
15 ...{
16 //获取Web.Config数据库连接字符串
17 private readonly string SqlConnectionString = ConfigurationManager.ConnectionStrings["ConnectionString"].ConnectionString;
18
19 private SqlConnection cn; //创建SQL连接
20 private SqlDataAdapter sda; //创建SQL数据适配器
21 private SqlDataReader sdr; //创建SQL数据读取器
22 private SqlCommand cmd; //创建SQL命令对象
23 private SqlParameter param; //创建SQL参数
24 private DataSet ds; //创建数据集
25 private DataView dv; //创建视图
26
27 /**//// <summary>
28 /// 打开数据库连接
29 /// </summary>
30 public void Open()
31 ...{
32 ...#region
33 cn = new SqlConnection(SqlConnectionString);
34 cn.Open();
35 #endregion
36 }
37
38
39 /**//// <summary>
40 /// 关闭数据库连接
41 /// </summary>
42 public void Close()
43 ...{
44 ...#region
45 if (cn != null)
46 ...{
47 cn.Close();
48 cn.Dispose();
49 }
50 #endregion
51 }
52
53
54 /**//// <summary>
55 /// 返回DataSet数据集
56 /// </summary>
57 /// <param name="strSql">SQL语句</param>
58 public DataSet GetDs(string strSql)
59 ...{
60 ...#region
61 Open();
62 sda = new SqlDataAdapter(strSql, cn);
63 ds = new DataSet();
64 sda.Fill(ds);
65 Close();
66 return ds;
67 #endregion
68 }
69
70 /**//// <summary>
71 /// 添加DataSet表
72 /// </summary>
73 /// <param name="ds">DataSet对象</param>
74 /// <param name="strSql">Sql语句</param>
75 /// <param name="strTableName">表名</param>
76 public void GetDs(DataSet ds, string strSql, string strTableName)
77 ...{
78 ...#region
79 Open();
80 sda = new SqlDataAdapter(strSql, cn);
81 sda.Fill(ds, strTableName);
82 Close();
83 #endregion
84 }
85
86
87 /**//// <summary>
88 /// 返回DataView数据视图
89 /// </summary>
90 /// <param name="strSql">Sql语句</param>
91 public DataView GetDv(string strSql)
92 ...{
93 ...#region
94 dv = GetDs(strSql).Tables[0].DefaultView;
95 return dv;
96 #endregion
97 }
98
99
100 /**//// <summary>
101 /// 获得DataTable对象
102 /// </summary>
103 /// <param name="strSql">SQL语句</param>
104 /// <returns></returns>
105 public DataTable GetTable(string strSql)
106 ...{
107 ...#region
108 return GetDs(strSql).Tables[0];
109 #endregion
110 }
111
112
113 /**//// <summary>
114 /// 获得SqlDataReader对象 使用完须关闭DataReader,关闭数据库连接
115 /// </summary>
116 /// <param name="strSql">sql语句</param>
117 /// <returns></returns>
118 public SqlDataReader GetDataReader(string strSql)
119 ...{
120 ...#region
121 Open();
122 cmd = new SqlCommand(strSql, cn);
123 sdr = cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
124 return sdr;
125 #endregion
126 }
127
128
129
130 /**//// <summary>
131 /// 执行Sql语句
132 /// </summary>
133 /// <param name="strSql"></param>
134 public void RunSql(string strSql)
135 ...{
136 ...#region
137 Open();
138 cmd = new SqlCommand(strSql, cn);
139 cmd.ExecuteNonQuery();
140 Close();
141 #endregion
142 }
143
144
145
146 /**//// <summary>
147 /// 执行SQL语句，并返回第一行第一列结果
148 /// </summary>
149 /// <param name="strSql">SQL语句</param>
150 /// <returns></returns>
151 public string RunSqlReturn(string strSql)
152 ...{
153 ...#region
154 string strReturn = "";
155 Open();
156 try
157 ...{
158 cmd = new SqlCommand(strSql, cn);
159 strReturn = cmd.ExecuteScalar().ToString();
160 }
161 catch ...{ }
162 Close();
163 return strReturn;
164 #endregion
165 }
166
167
168 /**//// <summary>
169 /// 执行存储过程
170 /// </summary>
171 /// <param name="procName">存储过程的名称</param>
172 /// <returns>返回存储过程返回值</returns>
173 public int RunProc(string procName)
174 ...{
175 ...#region
176 cmd = CreateCommand(procName, null);
177 cmd.ExecuteNonQuery();
178 Close();
179 return (int)cmd.Parameters["ReturnValue"].Value;
180 #endregion
181 }
182
183 /**//// <summary>
184 /// 执行存储过程
185 /// </summary>
186 /// <param name="procName">存储过程名称</param>
187 /// <param name="prams">存储过程所需参数</param>
188 /// <returns>返回存储过程返回值</returns>
189 public int RunProc(string procName, SqlParameter[] prams)
190 ...{
191 ...#region
192 cmd = CreateCommand(procName, prams);
193 cmd.ExecuteNonQuery();
194 Close();
195 return (int)cmd.Parameters["ReturnValue"].Value;
196 #endregion
197 }
198
199 /**//// <summary>
200 /// 执行存储过程返回DataReader对象
201 /// </summary>
202 /// <param name="procName">Sql语句</param>
203 /// <param name="dataReader">DataReader对象</param>
204 public void RunProc(string procName, SqlDataReader dataReader)
205 ...{
206 ...#region
207 cmd = CreateCommand(procName, null);
208 dataReader = cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
209 #endregion
210 }
211
212 /**//// <summary>
213 /// 执行存储过程
214 /// </summary>
215 /// <param name="procName">存储过程的名称</param>
216 /// <param name="prams">存储过程所需参数</param>
217 /// <param name="dataReader">DataReader对象</param>
218 public void RunProc(string procName, SqlParameter[] prams, SqlDataReader dataReader)
219 ...{
220 ...#region
221 cmd = CreateCommand(procName, prams);
222 dataReader = cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
223 #endregion
224 }
225
226 /**//// <summary>
227 /// 创建一个SqlCommand对象以此来执行存储过程
228 /// </summary>
229 /// <param name="procName">存储过程的名称</param>
230 /// <param name="prams">存储过程所需参数</param>
231 /// <returns>返回SqlCommand对象</returns>
232 private SqlCommand CreateCommand(string procName, SqlParameter[] prams)
233 ...{
234 ...#region
235 // 确认打开连接
236 Open();
237 cmd = new SqlCommand(procName, cn);
238 cmd.CommandType = CommandType.StoredProcedure;
239
240 // 依次把参数传入存储过程
241 if (prams != null)
242 ...{
243 foreach (SqlParameter parameter in prams)
244 cmd.Parameters.Add(parameter);
245 }
246
247 // 加入返回参数
248 cmd.Parameters.Add(
249 new SqlParameter("ReturnValue", SqlDbType.Int, 4,
250 ParameterDirection.ReturnValue, false, 0, 0,
251 string.Empty, DataRowVersion.Default, null));
252
253 return cmd;
254 #endregion
255 }
256
257
258 /**//// <summary>
259 /// 传入输入参数
260 /// </summary>
261 /// <param name="ParamName">存储过程名称</param>
262 /// <param name="DbType">参数类型</param></param>
263 /// <param name="Size">参数大小</param>
264 /// <param name="Value">参数值</param>
265 /// <returns>新的 parameter 对象</returns>
266 public SqlParameter MakeInParam(string ParamName, SqlDbType DbType, int Size, object Value)
267 ...{
268 ...#region
269 return MakeParam(ParamName, DbType, Size, ParameterDirection.Input, Value);
270
271 #endregion
272 }
273
274 /**//// <summary>
275 /// 传入返回值参数
276 /// </summary>
277 /// <param name="ParamName">存储过程名称</param>
278 /// <param name="DbType">参数类型</param>
279 /// <param name="Size">参数大小</param>
280 /// <returns>新的 parameter 对象</returns>
281 public SqlParameter MakeOutParam(string ParamName, SqlDbType DbType, int Size)
282 ...{
283 ...#region
284 return MakeParam(ParamName, DbType, Size, ParameterDirection.Output, null);
285 #endregion
286 }
287
288
289 /**//// <summary>
290 /// 生成存储过程参数
291 /// </summary>
292 /// <param name="ParamName">存储过程名称</param>
293 /// <param name="DbType">参数类型</param>
294 /// <param name="Size">参数大小</param>
295 /// <param name="Direction">参数方向</param>
296 /// <param name="Value">参数值</param>
297 /// <returns>新的 parameter 对象</returns>
298 public SqlParameter MakeParam(string ParamName, SqlDbType DbType, Int32 Size, ParameterDirection Direction, object Value)
299 ...{
300 ...#region
301
302 if (Size > 0)
303 param = new SqlParameter(ParamName, DbType, Size);
304 else
305 param = new SqlParameter(ParamName, DbType);
306
307 param.Direction = Direction;
308 if (!(Direction == ParameterDirection.Output && Value == null))
309 param.Value = Value;
310
311 return param;
312 #endregion
313 }
314 }
315
316
}
317
打包下载该项目完整源码：永远在一起论坛2.0版源码