lanju-client/shangjian/CommonFunc/SqlServerDbHelper.cs

using System;
using System.Collections;
using System.Collections.Generic;
using System.Configuration;
using System.Data;
using System.Data.Common;
using System.Data.SqlClient;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows;

namespace CommonFunc
{
    public class SqlServerDBHelper
    {
        //日志
        public static readonly log4net.ILog log = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
        private string dbConnStr;
        private SqlConnection dbConn = new SqlConnection();
        SqlCommandBuilder sbBuilder = new SqlCommandBuilder();
        //数据库连接
        public string getDBConnStr()
        {
            return dbConnStr;
        }

        public SqlServerDBHelper(string initDBConnStr)
        {
            if (initDBConnStr == null || initDBConnStr.Length == 0)
            {
                log.WarnFormat("传入的数据库连接串为空！");
            }
            dbConnStr = initDBConnStr;
        }

        /// <summary>
        /// 数据库连接
        /// </summary>
        /// <returns></returns>
        public bool connect()
        {
            bool bSucc = false;
            dbConn.Close();
            dbConn.ConnectionString = dbConnStr;
            try
            {
                dbConn.Open();
                bSucc = true;
                log.InfoFormat("数据库连接已打开！");
            }
            catch (Exception ex)
            {
                log.WarnFormat("连接数据库时发生异常：" + ex.Message);
            }
            return bSucc;
        }

        public void close()
        {
            if (dbConn.State != ConnectionState.Closed)
            {
                dbConn.Close();
                log.InfoFormat("数据库连接已关闭！");
            }
        }

        public ConnectionState connectionState
        {
            get { return dbConn.State; }
        }

        public void CheckConnection()
        {
            if (dbConn.State == ConnectionState.Closed || dbConn.State == ConnectionState.Broken)
            {
                connect();
            }
            else if (dbConn.State == ConnectionState.Connecting || dbConn.State == ConnectionState.Executing || dbConn.State == ConnectionState.Fetching)
            {
                //
            }
        }

        /// <summary>
        /// 执行SQL命令 返回DataSet
        /// </summary>
        /// <param name="sql">sql命令</param>
        /// <param name="type">执行类型</param>
        /// <param name="sqlparams">参数</param>
        /// <returns></returns>
        public DataSet getDataSet(string sql, params SqlParameter[] sqlparams)
        {
            CheckConnection();
            DataSet ds = new DataSet();
            using (SqlDataAdapter da = new SqlDataAdapter(sql, dbConn))
            {
                try
                {
                    if (sqlparams != null)
                    {
                        da.SelectCommand.Parameters.AddRange(sqlparams);
                    }
                    da.Fill(ds);
                    //防止俩个函数使用同一个sqlparams导致的“另一个SqlParameterCollection中已包含SqlParameter”错误
                    da.SelectCommand.Parameters.Clear();
                }
                catch (Exception ex)
                {
                    log.WarnFormat("执行查询操作异常：" + ex.Message);
                }
            }
            return ds;
        }


        /// <summary>
        /// 执行sql（insert、delete、update）语句进行非查询操作
        /// </summary>
        /// <param name="sql">sql命令</param>
        /// <returns>返回受影响行数</returns>
        public int executeUpdate(string sql)
        {
            CheckConnection();
            int rowCount = 0;

            using (SqlCommand cmd = new SqlCommand(sql, dbConn))
            {
                try
                {
                    rowCount = cmd.ExecuteNonQuery();
                }
                catch (Exception ex)
                {
                    log.WarnFormat("执行更新操作异常:{0}", ex.Message);
                }
            }
            return rowCount;
        }

        public int executeUpdate(string sql, params SqlParameter[] sqlparams)
        {
            CheckConnection();
            int rowCount = 0;
            using (SqlCommand cmd = new SqlCommand(sql, dbConn))
            {
                try
                {
                    if (sqlparams != null)
                    {
                        cmd.Parameters.AddRange(sqlparams);
                    }
                    rowCount = cmd.ExecuteNonQuery();
                }
                catch (Exception ex)
                {
                    log.WarnFormat("执行更新操作异常:{0}", ex.Message);
                }
            }
            return rowCount;
        }

        /// <summary>
        /// 使用SqlDataAdapter.Update()更新数据
        /// </summary>
        /// <param name="str"></param>
        public void updateDataTable(DataTable dt, string selectSql, MissingSchemaAction msaOption = MissingSchemaAction.AddWithKey)
        {
            CheckConnection();
            using (SqlDataAdapter da = new SqlDataAdapter())
            {
                da.MissingSchemaAction = msaOption;
                using (SqlCommand cmd = new SqlCommand(selectSql, dbConn))
                {
                    da.SelectCommand = cmd;
                    sbBuilder.DataAdapter = da;
                    da.InsertCommand = da.InsertCommand;
                    da.UpdateCommand = da.UpdateCommand;
                    da.DeleteCommand = da.DeleteCommand;
                    try
                    {
                        da.Update(dt);
                        dt.AcceptChanges();
                    }
                    catch (Exception ex)
                    {
                        log.WarnFormat("数据更新时发生异常{0},SQL:{1}", ex.Message, selectSql);
                    }
                }
            }
        }

        /// <summary>
        /// 执行多条SQL语句，实现数据库事务。
        /// </summary>sql2000数据库
        /// <param name="sqlList">多条SQL语句</param> 
        public bool executeBatchSql(List<string> sqlList)
        {
            CheckConnection();
            bool isCommit = false;
            string currSql = string.Empty;
            SqlTransaction tx = dbConn.BeginTransaction();
            SqlCommand cmd = new SqlCommand();
            try
            {
                cmd.Connection = dbConn;
                cmd.Transaction = tx;
                for (int iLoop = 0; iLoop < sqlList.Count; iLoop++)
                {
                    isCommit = false;
                    currSql = sqlList[iLoop].Trim();
                    if (currSql.Length > 0)
                    {
                        cmd.CommandText = currSql;
                        cmd.ExecuteNonQuery();
                    }
                }
                tx.Commit();
                isCommit = true;
            }
            catch (System.Data.SqlClient.SqlException E)
            {
                tx.Rollback();
                log.WarnFormat("执行事务过程中出现异常：{0},{1}", E.Message, currSql);
            }
            finally
            {
                cmd.Dispose();
            }
            return isCommit;
        }

        public object getScalar(string sql, params SqlParameter[] sqlparams)
        {
            CheckConnection();
            Object scaleValue = null;
            if (dbConn.State != ConnectionState.Open)
            {
                return null;
            }
            DataSet ds = new DataSet();
            using (SqlDataAdapter da = new SqlDataAdapter(sql, dbConn))
            {
                try
                {
                    if (sqlparams != null)
                    {
                        da.SelectCommand.Parameters.AddRange(sqlparams);
                    }
                    da.Fill(ds);
                }
                catch (Exception ex)
                {
                    log.WarnFormat("执行查询操作异常{0},SQL：{1},{2}", ex.Message, sql, sqlparams);
                }
            }
            try
            {
                if (ds.Tables[0].Rows.Count > 0)
                {
                    scaleValue = ds.Tables[0].Rows[0][0];
                }
            }
            catch (Exception ex)
            {
                log.WarnFormat("获取标量值发生异常{0}", ex.Message);
            }
            return scaleValue;
        }
    }
}