现在的位置: 首页 > 综合 > 正文

只执行SQL语句(不执行存储过程)

2012年01月17日 ⁄ 综合 ⁄ 共 2867字 ⁄ 字号 评论关闭
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Text;
  4. using System.Data;
  5. using System.Data.SqlClient;
  6. namespace DBUtility
  7. {
  8.     public class DBHelper
  9.     {
  10.         private static SqlConnection connection;
  11.         //连接数据库
  12.         public static SqlConnection Connection
  13.         {
  14.             get
  15.             {
  16.                 string sqlCon = "server=lyylsoft-server,3668;database=crm;uid=sa;pwd=123;";
  17.                 if (connection == null)
  18.                 {
  19.                     connection = new SqlConnection(sqlCon);
  20.                     connection.Open();
  21.                 }
  22.                 else if (connection.State == ConnectionState.Closed)
  23.                 {
  24.                     connection.Open();
  25.                 }
  26.                 else if (connection.State == ConnectionState.Broken)
  27.                 {
  28.                     connection.Close();
  29.                     connection.Open();
  30.                 }
  31.                 return connection;
  32.             }
  33.         }
  34.         //执行不带参数的非查询语句
  35.         public static int ExecuteCommand(string sql)
  36.         {
  37.             SqlCommand scmd = new SqlCommand(sql, Connection);
  38.             int row = scmd.ExecuteNonQuery();
  39.             return row;
  40.         }
  41.         //执行带参数的非查询语句
  42.         public static int ExecuteCommand(string sql, params SqlParameter[] values)
  43.         {
  44.             SqlCommand scmd = new SqlCommand(sql, Connection);
  45.             scmd.Parameters.AddRange(values);
  46.             int row = scmd.ExecuteNonQuery();
  47.             return row;
  48.         }
  49.         //执行不带参数的查询语句
  50.         public static SqlDataReader GetReader(string sql)
  51.         {
  52.             SqlCommand scmd = new SqlCommand(sql, Connection);
  53.             SqlDataReader reader = scmd.ExecuteReader();
  54.             return reader;
  55.         }
  56.         //执行带参数的查询语句
  57.         public static SqlDataReader GetReader(string sql, params SqlParameter[] values)
  58.         {
  59.             SqlCommand scmd = new SqlCommand(sql, Connection);
  60.             scmd.Parameters.AddRange(values);
  61.             SqlDataReader reader = scmd.ExecuteReader();
  62.             return reader;
  63.         }
  64.         //执行不带参数的判断是否有查询结果的语句
  65.         public static int GetScalar(string safeSql)
  66.         {
  67.             SqlCommand cmd = new SqlCommand(safeSql, Connection);
  68.             int result = Convert.ToInt32(cmd.ExecuteScalar());
  69.             return result;
  70.         }
  71.         //执行带参数的判断是否有查询结果的语句
  72.         public static int GetScalar(string safeSql, params SqlParameter[] values)
  73.         {
  74.             SqlCommand cmd = new SqlCommand(safeSql, Connection);
  75.             cmd.Parameters.AddRange(values);
  76.             int result = Convert.ToInt32(cmd.ExecuteScalar());
  77.             return result;
  78.         }
  79.         //此方法用于以DataTable形式返回多条查询结果
  80.         public static DataTable GetDataSet(string sql)
  81.         {
  82.             SqlDataAdapter sda = new SqlDataAdapter(sql, Connection);
  83.             DataSet ds = new DataSet();
  84.             sda.Fill(ds);
  85.             return ds.Tables[0];
  86.         }
  87.     }
  88. }

抱歉!评论已关闭.