天天看點

自己封裝的ASP.NET的MYSQL的資料庫操作類

自己封裝的ASP.NET的MYSQL的資料庫操作類
自己封裝的ASP.NET的MYSQL的資料庫操作類

代碼

/**

 * 作者:牛腩

 * 建立時間:2010年3月7日17時35分

 * 類說明:對MYSQL資料庫的操作類

 */ 

using System;

using System.Data;

using MySql.Data.MySqlClient;

namespace Niunan.BYLW.Utility

{

    /// <summary>對MYSQL資料庫的操作類

    /// 

    /// </summary>

    public class MYSQLHelper

    {

        private MySqlConnection conn = null;

        private MySqlCommand cmd = null;

        private MySqlDataReader sdr = null;

        public MYSQLHelper()

        {

            //string connStr = WebConfigurationManager.ConnectionStrings["connStr"].ToString();

            string connStr = "server=localhost;database=test;uid=root;pwd=123456;charset=utf8";

            conn = new MySqlConnection(connStr);

        }

        /// <summary>建立Command對象

        /// 

        /// </summary>

        /// <param name="sql">SQL語句</param>

        public void CreateCommand(string sql)

            conn.Open();

            cmd = new MySqlCommand(sql, conn);

        /// <summary>添加參數

        /// <param name="paramName">參數名稱</param>

        /// <param name="value">值</param>

        public void AddParameter(string paramName, object value)

            cmd.Parameters.Add(new MySqlParameter(paramName, value));

        /// <summary>執行不帶參數的增删改SQL語句

        ///  

        /// <param name="cmdText">增删改SQL語句</param>

        /// <param name="ct">指令類型</param>

        /// <returns></returns>

        public bool ExecuteNonQuery()

            int res;

            try

            {

                res = cmd.ExecuteNonQuery();

                if (res > 0)

                {

                    return true;

                }

            }

            catch (Exception ex)

                throw ex;

            finally

                if (conn.State == ConnectionState.Open)

                    conn.Close();

            return false;

        /// <summary>執行查詢SQL語句

        /// <param name="cmdText">查詢SQL語句</param>

        public DataTable ExecuteQuery()

            DataTable dt = new DataTable();

            using (sdr = cmd.ExecuteReader(CommandBehavior.CloseConnection))

                dt.Load(sdr);

            return dt;

        /// <summary>傳回查詢SQL語句查詢出的結果的第一行第一列的值

        public string ExecuteScalar()

            string res = "";

                object obj = cmd.ExecuteScalar();

                if (obj != null)

                    res = obj.ToString();

            return res;

    }

}

都是把那個SQLITEHelper的操作類搬過來的,改了MySqlConnection等變量名,對MYSQL來說經常會出現中文亂碼,經實驗,解決方法:

① 用PHPMYADMIN建立MYSQL資料庫的時候記得選擇UTF-8的編碼

② 在上面的資料庫操作類中的連接配接字元串中記得加上charset=utf8

這樣用上面的操作類來插入中文就不會出現亂碼了。