.net 數據庫操做

using System;

using System.Collections.Generic;

using System.Text;

using System.Data;

using System.Data.SqlClient;

using System.Configuration;

namespace DB

{

    public class DataAccess

    {

        public string connectstring = System.Configuration.ConfigurationSettings.AppSettings["MyConnectionString"].ToString();

        //public string connectstring = ConfigurationManager.ConnectionStrings["MyConnectionString"].ToString();

        private SqlConnection cn;

        private SqlDataAdapter sda;

        private SqlDataReader sdr;

        private SqlCommand cmd;

        private DataSet ds;

        private DataView dv;

        /// <summary>

        /// 打開數據庫鏈接

        /// </summary>

        public void Open()

        {

            #region

            cn = new SqlConnection(connectstring);

            cn.Open();

            #endregion

        }

        /// <summary>

        /// 關閉數據庫鏈接

        /// </summary>

        public void Close()

        {

            #region

            if (cn != null)

            {

                cn.Close();

                cn.Dispose();

            }

            #endregion

        }

        /// <summary>

        /// 返回DataSet數據集 錯誤返回null

        /// </summary>

        /// <param name="strSql">SQL語句</param>

        public DataSet GetDs(string strSql)

        {

            #region

            Open();

            try

            {

                sda = new SqlDataAdapter(strSql, cn);

                ds = new DataSet();

                sda.Fill(ds);

                return ds;

            }

            catch

            {

                return null;

            }

            finally {

                Close();

            }

            

            #endregion

        }

        /// <summary>

        /// 添加DataSet表 無返回

        /// </summary>

        /// <param name="ds">DataSet對象</param>

        /// <param name="strSql">Sql語句</param>

        /// <param name="strTableName">表名</param>

        public void GetDs(DataSet ds, string strSql, string strTableName)

        {

            #region

            Open();

            try

            {

                sda = new SqlDataAdapter(strSql, cn);

                sda.Fill(ds, strTableName);

            }

            catch { 

            }

            Close();

            #endregion

        }

        /// <summary>

        /// 返回DataView數據視圖

        /// </summary>

        /// <param name="strSql">Sql語句</param>

        public DataView GetDv(string strSql)

        {

            #region

            dv = GetDs(strSql).Tables[0].DefaultView;

            return dv;

            #endregion

        }

        /// <summary>

        /// 得到DataTable對象 錯誤返回空

        /// </summary>

        /// <param name="strSql">SQL語句</param>

        /// <returns></returns>

        public DataTable GetTable(string strSql)

        {

            #region

            try

            {

                return GetDs(strSql).Tables[0];

            }

            catch {

                return null;

            }

            #endregion

        }

        /// <summary>

        /// 得到一行數據（SqlDataReader） 出錯拋出錯誤

        /// </summary>

        /// <param name="strSql">sql語句</param>

        /// <returns></returns>

        public SqlDataReader GetDataReader(string strSql)

        {

            #region

            Open();

            try{

                cmd = new SqlCommand(strSql, cn);

                sdr = cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);

                return sdr;

            }

            catch (Exception ex){

                throw (ex);

            }

            finally {

                Close();

            }

            #endregion

        }

        /// <summary>

        /// 返回DataAdapter 出錯拋出錯誤

        /// </summary>

        /// <param name="strSql"></param>

        /// <returns></returns>

        public SqlDataAdapter GetDataAdapter(string strSql)

        {

            #region

            Open();

            try

            {

                return new SqlDataAdapter(strSql, cn);

            }

            catch (Exception ex)

            {

                throw (ex);

            }

            finally {

                Close();

            }

            #endregion

        }

        /// <summary>

        /// 得到單個記錄（object） 出錯拋出錯誤

        /// </summary>

        /// <param name="strSql">sql語句</param>

        /// <returns></returns>

        public object GetSingeData(string strSql)

        {

            #region

            Open();

            try

            {

                cmd = new SqlCommand(strSql, cn);

                return cmd.ExecuteScalar();

            }

            catch (Exception ex)

            {

                throw (ex);

            }

            finally

            {

                Close();

            }

            #endregion

        }

        /// <summary>

        /// 執行Sql語句 無返回值

        /// </summary>

        /// <param name="strSql"></param>

        public void RunSql(string strSql)

        {

            #region

            Open();

            try

            {

                cmd = new SqlCommand(strSql, cn);

                cmd.ExecuteNonQuery();

            }

            catch

            {

            }

            finally {

                Close();

            }

            

            #endregion

        }

        /// <summary>

        /// 執行SQL語句，並返回第一行第一列結果的字符串 出錯返回空

        /// </summary>

        /// <param name="strSql">SQL語句</param>

        /// <returns></returns>

        public string RunSqlReturn(string strSql)

        {

            #region

            string strReturn = "";

            Open();

            try

            {

                cmd = new SqlCommand(strSql, cn);

                strReturn = cmd.ExecuteScalar().ToString();

            }

            catch 

            {

                strReturn = null;

            }

            Close();

            return strReturn;

            #endregion

        }

        /// <summary>

        /// 執行SQL語句，並返回name字段的結果集合 出錯返回空

        /// </summary>

        /// <param name="strSql">SQL語句</param>

        /// <param name="name">字段名</param>

        /// <returns></returns>

        public List<string>  RunSqlReturn(string strSql,string name )

        {

            #region

            List<string> strReturn = new List<string>();

            Open();

            try

            {

                cmd = new SqlCommand(strSql, cn);

                SqlDataReader reader = cmd.ExecuteReader();

                while (reader.Read())

                {

                    strReturn.Add(reader[name] as string);

                }

            }

            catch

            {

                strReturn = null;

            }

            Close();

            return strReturn;

            #endregion

        }

        /// <summary>

        /// 未知

        /// </summary>

        /// <param name="dataTable"></param>

        /// <param name="size"></param>

        public void UpdateChange(DataTable dataTable, Int32 size)

        {

            Open();

            SqlDataAdapter sda = new SqlDataAdapter();

            sda.UpdateCommand = new SqlCommand("update agenda set sortId=@sortId where Id=@Id", cn);

            sda.UpdateCommand.Parameters.Add("@sortId", SqlDbType.Int, 4, "sortId");

            sda.UpdateCommand.Parameters.Add("@ID", SqlDbType.Int, 4, "ID");

            sda.UpdateCommand.UpdatedRowSource = UpdateRowSource.None;

            sda.UpdateBatchSize = size;

            sda.Update(dataTable);

        }

        /// <summary>

        /// 經過command對象執行DML語句，主要完成刪除，添加和修改

        /// </summary>

        /// <param name="sqlstr"></param>

        /// <returns></returns>

        public bool execmdnonqy(string strSql)

        {

            Open();

            try

            {

                cmd = new SqlCommand(strSql, cn);

                cmd.ExecuteNonQuery();

                return true;

            }

            catch

            {

                return false;

            }

            finally {

                Close();

            }

            

        }

    }

}