StationTotalSys/StationTotalSys(2.1.3.1)/DAL/MySQLDBHelper.cs

using MySql.Data.MySqlClient;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Web.Configuration;
using Tool;

namespace DAL
{
    public class MySQLDBHelper
    {
        public DataTable GetDataTable(string ip, string sql)
        {

            try
            {

                string mysqlPwd = WebConfigurationManager.ConnectionStrings["mysqlPwd"] == null ? "RU#@xcN1NGSp" : WebConfigurationManager.ConnectionStrings["mysqlPwd"].ConnectionString;
                string mysqlUser = WebConfigurationManager.ConnectionStrings["mysqlUser"] == null ? "root" : WebConfigurationManager.ConnectionStrings["mysqlPwd"].ConnectionString;
                //port = 3306,user = 'root',password = 'RU#@xcN1NGSp',db = 'etcmj'
                // string ConString = "Server=127.0.0.1;Database=etcmj; User ID=root;Password=RU#@xcN1NGSp;port=3306;CharSet=utf8;pooling=true;";
                string conn = string.Format("Server={0};Database=etcmj;User ID={2};Password={1};port=3306;CharSet=utf8;pooling=true; Connection Timeout=10;", ip, mysqlPwd, mysqlUser);
                LogCommon.WriteLogNormalTS(conn);
                //LogCommon.WriteLogNormalTS("1");

                using (MySqlConnection con = new MySqlConnection(conn))
                {

                    try
                    {
                        con.Open();//打开连接 
                        MySqlDataAdapter da = new MySqlDataAdapter(sql, con);
                        DataSet ds = new DataSet();
                        da.Fill(ds);
                        DataTable dt = ds.Tables[0];
                        da.Dispose();

                        return dt;
                    }
                    catch (Exception ex)
                    {
                        con.Close();

                        LogCommon.WriteLogNormalTS(ex.Message);

                        return null;
                    }
                }
            }
            catch (Exception ex)
            {


                LogCommon.WriteLogNormalTS(ex.Message);

                // throw ex;
                return null;
            }


        }
    }
}