dbhelper.cs

简单手表销售管理(三层开发)源码

using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.SqlClient;
using System.Configuration;

//该源码下载自www.51aspx.com(５１ａｓpｘ．ｃｏｍ)

namespace MyWatchShop.DAL
{
   public static class DbHelper
    {
        private static SqlConnection connection;
        public static SqlConnection Connection
        {
            get
            {
                if (connection==null)
                {
                    string connString = ConfigurationManager.ConnectionStrings["MyWatchShop"].ConnectionString;
                    connection = new SqlConnection(connString);
                    connection.Open();
                }
                else
                {
                    if (connection.State==ConnectionState.Closed)
                    {
                        connection.Open();
                    }
                    else if (connection.State==ConnectionState.Broken)
                    {
                        connection.Close();
                        connection.Open();
                    }
                }

                return connection;
                       
            }
        }


       public static int  ExeCommand(string sql)
       {
           SqlCommand cmd = new SqlCommand(sql,Connection);
           int result = cmd.ExecuteNonQuery();
           return result;
       }

       public static int ExeCommand(string sql, params SqlParameter[] para)
       {
           SqlCommand cmd = new SqlCommand(sql,Connection);
           cmd.Parameters.AddRange(para);
           int result = cmd.ExecuteNonQuery();
           return result;

       }

       public static DataTable GetDataTable(string sql)
       {
           SqlCommand cmd = new SqlCommand(sql, Connection);
           SqlDataAdapter da = new SqlDataAdapter(cmd);

           DataSet ds = new DataSet();
           da.Fill(ds);

           return ds.Tables[0];

       }

       public static DataTable GetDataTable(string sql, params SqlParameter[] para)
       {
           SqlCommand cmd = new SqlCommand(sql,Connection);

           cmd.Parameters.AddRange(para);

           SqlDataAdapter da = new SqlDataAdapter(cmd);

           DataSet ds = new DataSet();

           da.Fill(ds);

           return  ds.Tables[0];
       }

        

    }
}