设为首页 加入收藏

TOP

C# SQL server数据库基本操作(连接、增、删、改、查)封装(二)
2019-10-09 20:05:58 】 浏览:325
Tags:SQL server 数据库 基本操作 连接 封装
con.State == ConnectionState.Broken)     {      record = "Database connection is destroyed";       return dataSet;     }     if (sql_con.State == ConnectionState.Connecting)     {       record = "The database is in connection";       return dataSet;     }     record = "ERROR";     return dataSet;   }   catch (Exception ex)   {     DataSet dataSet = new DataSet();     record = ex.Message.ToString();     return dataSet;   } }

 小编发现以上这种封装方式还是很麻烦,每次对SQL进行增删改查的时候还得先打开数据库,最后还要关闭,实际运用起来比较麻烦。因此对上面两个增删改查的方法进行了重载,在每次进行操作时都先打开数据库,然后关闭数据库。

        /// <summary>
        /// SQLserver insert,delete,update
        /// </summary>
        /// <param name="sql">insert,delete,update statement</param>
        /// <param name="link">link statement</param>
        /// <returns>Success:success + Number of affected rows; Fail:reason</returns>
        public string Sqlserver_Insdelupd(string sql, string link)
        {
            try
            {
                int num = 0;
                using (SqlConnection con = new SqlConnection(link))
                {
                    con.Open();                    
                    SqlCommand cmd = new SqlCommand(sql, con);  
                    num = cmd.ExecuteNonQuery();            
                    con.Close();
                    return "success" + num;
                }
            }
            catch (Exception ex)
            {
                return ex.Message.ToString();
            }
        }

 

        /// <summary>
        /// SQLserver select
        /// </summary>
        /// <param name="sql">select statement</param>
        /// <param name="link">link statement</param>
        /// <param name="record">Success:success; Fail:reason</param>
        /// <returns>select result</returns>
        public DataSet Sqlserver_Select(string sql, string link, out string record)
        {
            try
            {
                DataSet ds = new DataSet();
                using (SqlConnection con = new SqlConnection(link))
                {
                    con.Open();                                         
                    SqlDataAdapter sda = new SqlDataAdapter(sql, con);  
                    sda.Fill(ds, "sample");                            
                    con.Close();                                       
                    sda.Dispose();                                      
                    record = "success";
                    return ds;
                }
            }
            catch (Exception ex)
            {
                DataSet dataSet = new DataSet();
                record = ex.Message.ToString();
                return dataSet;
            }
        }

小编只是对简单的知识进行整理,通大家分享并方便自己查看,并无恶意,如有侵权,联系小编,小编将立即删除,谢谢。

 

 

 

 

首页 上一页 1 2 下一页 尾页 2/2/2
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇Parallel.ForEach 使用多线遍历循.. 下一篇c#---Socean.RPC实测[并发量13w][..

最新文章

热门文章

Hot 文章

Python

C 语言

C++基础

大数据基础

linux编程基础

C/C++面试题目