黑马程序员技术交流社区

标题: SqlHepler [打印本页]

---

作者: 王三好王三好    时间: 2013-5-5 15:26
标题: SqlHepler
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data.SqlClient;
using System.Data;

namespace 登录案例
{
    class SqlHepler
    {
        private static string connStr ="Data Source=.;Database=MY;Integrated Security=True";
        public static int ExecuteNonQuery(string sql, params SqlParameter[] parameters)
        {
            using (SqlConnection conn = new SqlConnection(connStr))
            {
                conn.Open();
                using (SqlCommand cmd = conn.CreateCommand())
                {
                    cmd.CommandText = sql;
                    //foreach (SqlParameter param in parameters)
                    //{
                    //    cmd.Parameters.Add(param);
                    //}
                    cmd.Parameters.AddRange(parameters);
                    return cmd.ExecuteNonQuery();
                }
            }
        }

        public static object ExecuteScalar(string sql, params SqlParameter[] parameters)
        {
            using (SqlConnection conn = new SqlConnection(connStr))
            {
                conn.Open();
                using (SqlCommand cmd = conn.CreateCommand())
                {
                    cmd.CommandText = sql;
                    cmd.Parameters.AddRange(parameters);
                    return cmd.ExecuteScalar();
                }
            }
        }

        //只用来执行查询结果比较少的sql
        public static DataTable ExecuteDataTable(string sql, params SqlParameter[] parameters)
        {
            using (SqlConnection conn = new SqlConnection(connStr))
            {
                conn.Open();
                using (SqlCommand cmd = conn.CreateCommand())
                {
                    cmd.CommandText = sql;
                    cmd.Parameters.AddRange(parameters);

                    SqlDataAdapter adapter = new SqlDataAdapter(cmd);
                    DataSet dataset = new DataSet();
                    adapter.Fill(dataset);
                    return dataset.Tables[0];
                }
            }
        }
    }
}

---

作者: Jacky_Chen1990    时间: 2013-5-5 15:31
呃，java,路过。尹兄无处不在。。。

---

作者: 风雪再现    时间: 2013-5-6 17:34

1. public static int ExecuteNonQuery(string sql, params SqlParameter[] parameters)
   
2.         {
   
3.             string conStr = ConfigurationManager.ConnectionStrings["conStr"].ConnectionString;
   
4.             SqlConnection conn = new SqlConnection(conStr);
   
5.             conn.Open();
   
6.             SqlCommand com = conn.CreateCommand();
   
7.             com.CommandText = sql;
   
8.             foreach (SqlParameter parameter in parameters)
   
9.             {
   
10.                 com.Parameters.Add(parameter);
    
11.             }
    
12.             
    
13.             return com.ExecuteNonQuery();
    
14. 
    
15.         }
    
16.         /// <summary>
    
17.         /// 重载ExecuteScalar（）
    
18.         /// </summary>
    
19.         /// <param name="sql"></param>
    
20.         /// <param name="parameters"></param>
    
21.         /// <returns></returns>
    
22.         public static object ExecuteScalar(string sql, params SqlParameter[] parameters)
    
23.         {
    
24.             string conStr = ConfigurationManager.ConnectionStrings["conStr"].ConnectionString;
    
25.             SqlConnection conn = new SqlConnection(conStr);
    
26.             conn.Open();
    
27.             SqlCommand com = conn.CreateCommand();
    
28.             com.CommandText = sql;
    
29.             foreach (SqlParameter parameter in parameters)
    
30.             {
    
31.                 com.Parameters.Add(parameter);
    
32.                
    
33.             }
    
34. 
    
35.             return com.ExecuteScalar();
    
36.         }
    
37. 
    
38.         public static SqlDataReader ExecuteReader(string sql, params SqlParameter[] parameters)
    
39.         {
    
40.             string conStr = ConfigurationManager.ConnectionStrings["conStr"].ConnectionString;
    
41.             SqlConnection conn = new SqlConnection(conStr);
    
42.             conn.Open();
    
43.             SqlCommand com = conn.CreateCommand();
    
44.             com.CommandText = sql;
    
45.             foreach (SqlParameter parameter in parameters)
    
46.             {
    
47.                 com.Parameters.Add(parameter);
    
48.             }
    
49.             return com.ExecuteReader();
    
50.         }
    
51. 
    
52.         public static DataTable ExecuteDataTable(string sql, params SqlParameter[] parameters)
    
53.         {
    
54.             string conStr = ConfigurationManager.ConnectionStrings["conStr"].ConnectionString;
    
55.             SqlConnection conn = new SqlConnection(conStr);
    
56.             conn.Open();
    
57.             SqlCommand com = conn.CreateCommand();
    
58.             com.CommandText = sql;
    
59.             foreach (SqlParameter parameter in parameters)
    
60.             {
    
61.                 com.Parameters.Add(parameter);
    
62.             }
    
63.             DataSet ds = new DataSet();
    
64.             SqlDataAdapter adapter = new SqlDataAdapter(com);
    
65.             adapter.Fill(ds);
    
66.             //adapter.InsertCommand = conn.CreateCommand();
    
67.             //adapter.InsertCommand.CommandText = "..........";
    
68.             DataTable table = ds.Tables[0];
    
69.             return table;
    
70.         }

复制代码

foreach (SqlParameter parameter in parameters)
            {
                com.Parameters.Add(parameter);
            }
这个循环式不能少的，因为你定义参数的时候params修饰的，参数的个数是不确定的，我的代码没有用using，其他都和你的差不多，希望对你有用

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2