首页 > > 网络编程 > Mysql >

菜鸟学习Ado.net笔记一：Ado.net学习之SqlHelper…

2018-06-17 20:50:33来源：未知 阅读 ()

新老客户大回馈,云服务器低至5折 

  1 using System;
  2 using System.Collections.Generic;
  3 using System.Text;
  4 using System.Data.SqlClient;
  5 using System.Data;
  6 using Microsoft.Win32;
  7 
  8 namespace SqlHelp
  9 {
 10     /// <summary>
 11     /// 定义SqlParameter所需的参数对象
 12     /// </summary>
 13     public class Parameter
 14     {
 15         /// <summary>
 16         /// 参数集合构造函数
 17         /// </summary>
 18         /// <param name="paramname">参数名称</param>
 19         /// <param name="value">参数所对应的对象的值</param>
 20         public Parameter(string paramname, object value)
 21         {
 22             this.ParamName = paramname;
 23             this.Obj = value;
 24         }
 25         /// <summary>
 26         /// 参数名称
 27         /// </summary>
 28         public string ParamName
 29         {
 30             get;
 31             set;
 32         }
 33         /// <summary>
 34         /// 参数名称所对应的对象的值
 35         /// </summary>
 36         public object Obj
 37         {
 38             get;
 39             set;
 40         }
 41     }
 42     /// <summary>
 43     /// SqlHelper  ^_^ !
 44     /// </summary>
 45     public class SqlHelper
 46     {
 47         /// <summary>
 48         /// 连接字符串字段
 49         /// </summary>
 50         private static string connStr;
 51 
 52         /// <summary>
 53         /// SQL连接字符串属性
 54         /// </summary>       
 55         public static string ConnStr
 56         {
 57             get { return SqlHelper.connStr; }
 58             set { SqlHelper.connStr = value; }
 59         }
 60 
 61         private static SqlParameter[] GetSqlParameterToArr(List<Parameter> listP)
 62         {
 63             List<SqlParameter> list = new List<SqlParameter>();
 64             foreach (var item in listP)
 65             {
 66                 list.Add(new SqlParameter(item.ParamName, item.Obj));
 67             }
 68             return list.ToArray();
 69         }
 70 
 71         /// <summary>
 72         /// 执行TSQL 语句并返回受影响的行
 73         /// </summary>
 74         /// <param name="sql">需要执行的sql语句</param>
 75         /// <returns></returns>
 76 
 77         public static int ExecuteNonQuery(string sql)
 78         {
 79             try
 80             {
 81                 using (SqlConnection conn = new SqlConnection(connStr))
 82                 {
 83                     conn.Open();
 84                     using (SqlCommand cmd = conn.CreateCommand())
 85                     {
 86                         cmd.CommandText = sql;
 87                         return cmd.ExecuteNonQuery();
 88                     }
 89                 }
 90             }
 91             catch (Exception ex)
 92             {
 93                 throw new Exception(ex.Message);
 94             }
 95         }
 96 
 97         /// <summary>
 98         /// 执行TSQL 语句并返回受影响的行 
 99         /// </summary>
100         /// <param name="sql">需要执行的sql语句</param>
101         /// <param name="paramList">参数的泛型集合</param>
102         /// <returns></returns>
103         public static int ExecuteNonQuery(string sql, List<Parameter> paramList)
104         {
105             try
106             {
107                 using (SqlConnection conn = new SqlConnection(connStr))
108                 {
109                     conn.Open();
110                     using (SqlCommand cmd = conn.CreateCommand())
111                     {
112                         cmd.CommandText = sql;
113                         cmd.Parameters.AddRange(GetSqlParameterToArr(paramList));
114                         return cmd.ExecuteNonQuery();
115                     }
116                 }
117             }
118             catch (Exception ex)
119             {
120                 throw new Exception(ex.Message);
121             }
122         }
123 
124 
125         /// <summary>
126         /// 执行查询，并返回查询所返回的结果集中第一行的第一列 
127         /// </summary>
128         /// <param name="sql">需要执行的sql语句</param>
129         /// <returns></returns>
130 
131         public static object ExecuteScalar(string sql)
132         {
133             try
134             {
135                 using (SqlConnection conn = new SqlConnection(connStr))
136                 {
137                     conn.Open();
138                     using (SqlCommand cmd = conn.CreateCommand())
139                     {
140                         cmd.CommandText = sql;
141                         return cmd.ExecuteScalar();
142                     }
143                 }
144             }
145             catch (Exception ex)
146             {
147                 throw new Exception(ex.Message);
148             }
149         }
150         /// <summary>
151         /// 执行查询，并返回查询所返回的结果集中第一行的第一列 
152         /// </summary>
153         /// <param name="sql">需要执行的sql语句</param>
154         /// <param name="paramList">参数的泛型集合</param>
155         /// <returns></returns>
156         public static object ExecuteScalar(string sql, List<Parameter> paramList)
157         {
158             try
159             {
160                 using (SqlConnection conn = new SqlConnection(connStr))
161                 {
162                     conn.Open();
163                     using (SqlCommand cmd = conn.CreateCommand())
164                     {
165                         cmd.CommandText = sql;
166                         cmd.Parameters.AddRange(GetSqlParameterToArr(paramList));
167                         return cmd.ExecuteScalar();
168                     }
169                 }
170             }
171             catch (Exception ex)
172             {
173                 throw new Exception(ex.Message);
174             }
175         }
176 
177 
178         /// <summary>
179         /// 返回已经填充结果的DataSet 
180         /// </summary>
181         /// <param name="sql">需要执行的sql语句</param>
182         /// <returns></returns>
183 
184         public static DataSet ExecuteDataSet(string sql)
185         {
186             try
187             {
188                 using (SqlConnection conn = new SqlConnection(connStr))
189                 {
190                     conn.Open();
191                     using (SqlCommand cmd = conn.CreateCommand())
192                     {
193                         cmd.CommandText = sql;
194                         SqlDataAdapter adapter = new SqlDataAdapter(cmd);
195                         DataSet dataset = new DataSet();
196                         adapter.Fill(dataset);
197                         return dataset;
198                     }
199                 }
200             }
201             catch (Exception ex)
202             {
203                 throw new Exception(ex.Message);
204             }
205         }
206 
207         /// <summary>
208         /// 返回已经填充结果的DataSet 
209         /// </summary>
210         /// <param name="sql">需要执行的sql语句</param>
211         /// <param name="paramList">参数的泛型集合</param>
212         /// <returns></returns>
213         public static DataSet ExecuteDataSet(string sql, List<Parameter> paramList)
214         {
215             try
216             {
217                 using (SqlConnection conn = new SqlConnection(connStr))
218                 {
219                     conn.Open();
220                     using (SqlCommand cmd = conn.CreateCommand())
221                     {
222                         cmd.CommandText = sql;
223                         cmd.Parameters.AddRange(GetSqlParameterToArr(paramList));
224                         SqlDataAdapter adapter = new SqlDataAdapter(cmd);
225                         DataSet dataset = new DataSet();
226                         adapter.Fill(dataset);
227                         return dataset;
228                     }
229                 }
230             }
231             catch (Exception ex)
232             {
233                 throw new Exception(ex.Message);
234             }
235         }
236 
237 
238         /// <summary>
239         /// 返回查询结果集所返回的字段值的泛型集合 
240         /// </summary>
241         /// <param name="sql">需要执行的sql语句</param>
242         /// <returns></returns>
243 
244         public static List<object> ExecuteReader(string sql)
245         {
246             List<object> obj = new List<object>();
247             try
248             {
249                 using (SqlConnection conn = new SqlConnection(connStr))
250                 {
251                     conn.Open();
252                     using (SqlCommand cmd = conn.CreateCommand())
253                     {
254                         cmd.CommandText = sql;
255                         using (SqlDataReader reader = cmd.ExecuteReader())
256                         {
257                             while (reader.Read())
258                             {
259                                 for (int i = 0; i < reader.FieldCount; i++)
260                                 {
261                                     obj.Add(reader.IsDBNull(i) ? "空值" : reader.GetValue(i));
262                                 }
263                             }
264                             return obj;
265                         }
266                     }
267                 }
268             }
269             catch (Exception ex)
270             {
271                 throw new Exception(ex.Message);
272             }
273         }
274 
275 
276         /// <summary>
277         /// 返回查询结果集所返回的字段值的泛型集合 
278         /// </summary>
279         /// <param name="sql">需要执行的sql语句</param>
280         /// <param name="paramList">参数的泛型集合</param>
281         /// <returns></returns>
282         public static List<object> ExecuteReader(string sql, List<Parameter> paramList)
283         {
284             List<object> obj = new List<object>();
285             try
286             {
287                 using (SqlConnection conn = new SqlConnection(connStr))
288                 {
289                     conn.Open();
290                     using (SqlCommand cmd = conn.CreateCommand())
291                     {
292                         cmd.CommandText = sql;
293                         cmd.Parameters.AddRange(GetSqlParameterToArr(paramList));
294                         using (SqlDataReader reader = cmd.ExecuteReader())
295                         {
296                             while (reader.Read())
297                             {
298                                 for (int i = 0; i < reader.FieldCount; i++)
299                                 {
300                                     obj.Add(reader.IsDBNull(i) ? "空值" : reader.GetValue(i));
301                                 }
302                             }
303                             return obj;
304                         }
305                     }
306                 }
307             }
308             catch (Exception ex)
309             {
310                 throw new Exception(ex.Message);
311             }
312         }
313 
314 
315         /// <summary>
316         /// 获取SqlServer数据库实例名数组 
317         /// </summary>
318         /// <returns></returns>
319         public static string[] GetInstances()
320         {
321             RegistryKey reg = Registry.LocalMachine.OpenSubKey(@"SOFTWARE\Microsoft\Microsoft SQL Server");
322             string[] instances = (string[])reg.GetValue("InstalledInstances", "");
323             try
324             {
325                 if (instances.Length > 0)
326                 {
327                     for (int i = 0; i < instances.Length; i++)
328                     {
329                         if (instances[i] == "MSSQLSERVER")
330                         {
331                             instances[i] = System.Environment.MachineName;
332                         }
333                         else
334                         {
335                             instances[i] = System.Environment.MachineName + @"\" + instances[i];
336                         }
337                     }
338                 }
339                 return instances;
340             }
341             catch (Exception ex)
342             {
343                 throw new Exception(ex.Message);
344             }
345         }
346     }
347 }

测试：
1、获取实例

窗体拖入ComboBox控件，设置name值为cbx_server

引入SqlHelper

using SqlHelp

窗体load事件加入：

 1 cbx_server.Items .AddRange ( GetInstances()); 

2、执行带参数查询方法

窗体拖入按钮，name为Bt_Test，并且拖入TextBox控件，name值为txt_Param

引入SqlHelper

using SqlHelp

在按钮点击事件中加入：

 1         private void Bt_Test_Click(object sender, EventArgs e)
 2         {
 3             SqlHelper.ConnStr = @"Data Source=localhost;Initial Catalog=UFsystem;Integrated Security=True";
 4             Parameter param = new Parameter("@id", txt_Param.Text);
 5             List<Parameter> list = new List<Parameter>();
 6             list.Add(param);
 7             List<object> obj = SqlHelper.ExecuteReader(@"select * from ua_user where cuser_id=@id", list);
 8             foreach (var item in obj)
 9             {
10                 Console.WriteLine(item);
11             }
12         }

输出：

admin
admin
空值
True
空值
空值
空值
空值

正在学习c#，有什么地方不对或不合适的请指教。

 

标签：

版权申明：本站文章部分自网络，如有侵权，请联系：west999com@outlook.com
特别注意：本站所有转载文章言论不代表本站观点，本站所提供的摄影照片，插画，设计作品，如需使用，请与原作者联系，版权归原作者所有

上一篇：WPF Canvas 画区域

下一篇：【.NET深呼吸】线程信号量（Semaphore）

相关文章

IDC资讯： 主机资讯 注册资讯 托管资讯 vps资讯 网站建设

网站运营： 建站经验 策划盈利 搜索优化 网站推广 免费资源

网站联盟： 联盟新闻 联盟介绍 联盟点评 网赚技巧

行业资讯： 搜索引擎 网络游戏 电子商务 广告传媒

网络编程： Asp.Net编程 Asp编程 Php编程 Xml编程 Access Mssql Mysql 其它

服务器技术： Web服务器 Ftp服务器 Mail服务器 Dns服务器 安全防护

软件技巧： 其它软件 Word Excel Powerpoint Ghost Vista QQ空间 QQ FlashGet 迅雷

网页制作： FrontPages Dreamweaver Javascript css photoshop fireworks Flash

程序设计： Java技术 C/C++ VB delphi

网络知识： 网络协议 网络安全 网络管理 组网方案 Cisco技术

操作系统： Win2000 WinXP Win2003 Mac OS Linux FreeBSD

热门词条
最新资讯
热门关注
热门标签