注册 登录  
 加关注
   显示下一条  |  关闭
温馨提示!由于新浪微博认证机制调整,您的新浪微博帐号绑定已过期,请重新绑定!立即重新绑定新浪微博》  |  关闭

魑魅魍魉福'HOME

见证成长

 
 
 

日志

 
 

.net 数据库操作  

2013-11-05 21:51:06|  分类: 默认分类 |  标签: |举报 |字号 订阅

  下载LOFTER 我的照片书  |
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();
            }
            
        }
    }
}

  评论这张
 
阅读(346)| 评论(0)
推荐 转载

历史上的今天

评论

<#--最新日志,群博日志--> <#--推荐日志--> <#--引用记录--> <#--博主推荐--> <#--随机阅读--> <#--首页推荐--> <#--历史上的今天--> <#--被推荐日志--> <#--上一篇,下一篇--> <#-- 热度 --> <#-- 网易新闻广告 --> <#--右边模块结构--> <#--评论模块结构--> <#--引用模块结构--> <#--博主发起的投票-->
 
 
 
 
 
 
 
 
 
 
 
 
 
 

页脚

网易公司版权所有 ©1997-2018