StableVersion4.3/RFIDAutomaticInductionTime/SqlDBHelper.cs

using System;
using System.Data;
using System.Data.SqlClient;
using System.Windows.Forms;

namespace HL_RFIDAutomaticInductionTime
{
    /// <summary>
    /// Sql Server DBHelper 类
    /// </summary>
    public class SqlDBHelper
    {


        /// <summary>
        /// 日志文件路径
        /// </summary>
        private string logPath = Application.StartupPath + @"\Log";

        /// <summary>
        /// 日志文件
        /// </summary>
        FileClass fileClass = new FileClass();
        /// <summary>
        /// 执行
        /// </summary>
        /// <param name="sql_str"></param>
        /// <returns></returns>
        public int DoCom(string sql_str, string strConn)
        {
            SqlConnection connection = new SqlConnection(strConn);
            try
            {
                //打开数据库连接
                connection.Open();

                SqlCommand command = new SqlCommand(sql_str, connection);
                int result_int = command.ExecuteNonQuery();
                connection.Dispose();
                connection.Close();
                return result_int;
            }
            catch (Exception)
            {
                return 0;
            }
        }

        /// <summary>
        /// 查询
        /// </summary>
        /// <param name="sql_str"></param>
        /// <returns></returns>
        public DataTable GetDT(string sql_str, string strConn)
        {
            SqlConnection connection = GetConnection(strConn);
            try
            {
                //打开数据库连接
                connection.Open();
                SqlDataAdapter command_fill = new SqlDataAdapter(sql_str, connection);
                DataSet ds_P = new DataSet();
                command_fill.Fill(ds_P, "ds_P");
                connection.Dispose();
                connection.Close();
                return ds_P.Tables[0];
            }
            catch (Exception e)
            {
                MessageAdd(e.Message);
                return null;
            }
        }

        private static SqlConnection GetConnection(string strConn)
        {
            return new SqlConnection(strConn);
        }

        /// <summary>  
        ///  日志记录
        /// </summary>  
        /// <param name="serviceName">内容</param>  
        public void MessageAdd(string str)
        {
            try
            {
                fileClass.WriteLogFile(logPath, str);//写入记录日志
            }
            catch
            {

            }
        }
    }
}