2. 程式人生 > >C#訪問和操作MYSQL資料庫

C#訪問和操作MYSQL資料庫

阿新 • • 發佈：2018-12-10

這裡介紹下比較簡單的方式，引用MySql.Data.dll然後新增一個MySqlHelper類來對MySql資料庫進行訪問和操作。
1.將MySql.Data.dll引用到你的專案中

下載地址：MySql.Data.rar

新增引用後在你的資料庫操作類(如MySqlHelper.cs)中新增引用宣告

using MySql.Data;
using MySql.Data.MySqlClient;

2.新增一個MySqlHelper類來對MySql資料庫進行操作。 MySqlHelper.CS網上有很多列子，把程式碼拷下來就可以直接使用。如果裡面的ExcecuteNonquery、GetDataSet等基本訪問資料庫方法還是無法滿足你開發需求的話，你還可以自己重新改寫程式碼來擴充其功能。

MySqlHelper：

複製程式碼
using System;
using System.Collections;
using System.Configuration;
using MySql.Data;
using MySql.Data.MySqlClient;
using System.Data;

///
///MYSQLHelper 的摘要說明
///
public abstract class MySqlHelper
{
//資料庫連線字串
public static string Conn = “Database=‘wp’;Data Source=‘localhost’;User Id=‘root’;Password=‘root’;charset=‘utf8’;pooling=true”;

// 用於快取引數的HASH表
private static Hashtable parmCache = Hashtable.Synchronized(new Hashtable());

/// <summary>
///  給定連線的資料庫用假設引數執行一個sql命令（不返回資料集）
/// </summary>
/// <param name="connectionString">一個有效的連線字串</param>
/// <param name="cmdType">命令型別(儲存過程, 文字, 等等)</param>
/// <param name="cmdText">儲存過程名稱或者sql命令語句</param>
/// <param name="commandParameters">執行命令所用引數的集合</param>
/// <returns>執行命令所影響的行數</returns>
public static int ExecuteNonQuery(string connectionString, CommandType cmdType, string cmdText, params MySqlParameter[] commandParameters)
{

    MySqlCommand cmd = new MySqlCommand();

    using (MySqlConnection conn = new MySqlConnection(connectionString))
    {
        PrepareCommand(cmd, conn, null, cmdType, cmdText, commandParameters);
        int val = cmd.ExecuteNonQuery();
        cmd.Parameters.Clear();
        return val;
    }
}

/// <summary>
/// 用現有的資料庫連線執行一個sql命令（不返回資料集）
/// </summary>
/// <param name="connection">一個現有的資料庫連線</param>
/// <param name="cmdType">命令型別(儲存過程, 文字, 等等)</param>
/// <param name="cmdText">儲存過程名稱或者sql命令語句</param>
/// <param name="commandParameters">執行命令所用引數的集合</param>
/// <returns>執行命令所影響的行數</returns>
public static int ExecuteNonQuery(MySqlConnection connection, CommandType cmdType, string cmdText, params MySqlParameter[] commandParameters)
{

    MySqlCommand cmd = new MySqlCommand();

    PrepareCommand(cmd, connection, null, cmdType, cmdText, commandParameters);
    int val = cmd.ExecuteNonQuery();
    cmd.Parameters.Clear();
    return val;
}

/// <summary>
///使用現有的SQL事務執行一個sql命令（不返回資料集）
/// </summary>
/// <remarks>
///舉例:
///  int result = ExecuteNonQuery(connString, CommandType.StoredProcedure, "PublishOrders", new MySqlParameter("@prodid", 24));
/// </remarks>
/// <param name="trans">一個現有的事務</param>
/// <param name="cmdType">命令型別(儲存過程, 文字, 等等)</param>
/// <param name="cmdText">儲存過程名稱或者sql命令語句</param>
/// <param name="commandParameters">執行命令所用引數的集合</param>
/// <returns>執行命令所影響的行數</returns>
public static int ExecuteNonQuery(MySqlTransaction trans, CommandType cmdType, string cmdText, params MySqlParameter[] commandParameters)
{
    MySqlCommand cmd = new MySqlCommand();
    PrepareCommand(cmd, trans.Connection, trans, cmdType, cmdText, commandParameters);
    int val = cmd.ExecuteNonQuery();
    cmd.Parameters.Clear();
    return val;
}

/// <summary>
/// 用執行的資料庫連線執行一個返回資料集的sql命令
/// </summary>
/// <remarks>
/// 舉例:
///  MySqlDataReader r = ExecuteReader(connString, CommandType.StoredProcedure, "PublishOrders", new MySqlParameter("@prodid", 24));
/// </remarks>
/// <param name="connectionString">一個有效的連線字串</param>
/// <param name="cmdType">命令型別(儲存過程, 文字, 等等)</param>
/// <param name="cmdText">儲存過程名稱或者sql命令語句</param>
/// <param name="commandParameters">執行命令所用引數的集合</param>
/// <returns>包含結果的讀取器</returns>
public static MySqlDataReader ExecuteReader(string connectionString, CommandType cmdType, string cmdText, params MySqlParameter[] commandParameters)
{
    //建立一個MySqlCommand物件
    MySqlCommand cmd = new MySqlCommand();
    //建立一個MySqlConnection物件
    MySqlConnection conn = new MySqlConnection(connectionString);

    //在這裡我們用一個try/catch結構執行sql文字命令/儲存過程，因為如果這個方法產生一個異常我們要關閉連線，因為沒有讀取器存在，
    //因此commandBehaviour.CloseConnection 就不會執行
    try
    {
        //呼叫 PrepareCommand 方法，對 MySqlCommand 物件設定引數
        PrepareCommand(cmd, conn, null, cmdType, cmdText, commandParameters);
        //呼叫 MySqlCommand  的 ExecuteReader 方法
        MySqlDataReader reader = cmd.ExecuteReader(CommandBehavior.CloseConnection);
        //清除引數
        cmd.Parameters.Clear();
        return reader;
    }
    catch
    {
        //關閉連線，丟擲異常
        conn.Close();
        throw;
    }
}

/// <summary>
/// 返回DataSet
/// </summary>
/// <param name="connectionString">一個有效的連線字串</param>
/// <param name="cmdType">命令型別(儲存過程, 文字, 等等)</param>
/// <param name="cmdText">儲存過程名稱或者sql命令語句</param>
/// <param name="commandParameters">執行命令所用引數的集合</param>
/// <returns></returns>
public static DataSet GetDataSet(string connectionString, CommandType cmdType, string cmdText, params MySqlParameter[] commandParameters)
{
    //建立一個MySqlCommand物件
    MySqlCommand cmd = new MySqlCommand();
    //建立一個MySqlConnection物件
    MySqlConnection conn = new MySqlConnection(connectionString);

    //在這裡我們用一個try/catch結構執行sql文字命令/儲存過程，因為如果這個方法產生一個異常我們要關閉連線，因為沒有讀取器存在，

    try
    {
        //呼叫 PrepareCommand 方法，對 MySqlCommand 物件設定引數
        PrepareCommand(cmd, conn, null, cmdType, cmdText, commandParameters);
        //呼叫 MySqlCommand  的 ExecuteReader 方法
        MySqlDataAdapter adapter = new MySqlDataAdapter();
        adapter.SelectCommand = cmd;
        DataSet ds = new DataSet();

        adapter.Fill(ds);
        //清除引數
        cmd.Parameters.Clear();
        conn.Close();
        return ds;
    }
    catch (Exception e)
    {
        throw e;
    }
}



/// <summary>
/// 用指定的資料庫連線字串執行一個命令並返回一個數據集的第一列
/// </summary>
/// <remarks>
///例如:
///  Object obj = ExecuteScalar(connString, CommandType.StoredProcedure, "PublishOrders", new MySqlParameter("@prodid", 24));
/// </remarks>
///<param name="connectionString">一個有效的連線字串</param>
/// <param name="cmdType">命令型別(儲存過程, 文字, 等等)</param>
/// <param name="cmdText">儲存過程名稱或者sql命令語句</param>
/// <param name="commandParameters">執行命令所用引數的集合</param>
/// <returns>用 Convert.To{Type}把型別轉換為想要的 </returns>
public static object ExecuteScalar(string connectionString, CommandType cmdType, string cmdText, params MySqlParameter[] commandParameters)
{
    MySqlCommand cmd = new MySqlCommand();

    using (MySqlConnection connection = new MySqlConnection(connectionString))
    {
        PrepareCommand(cmd, connection, null, cmdType, cmdText, commandParameters);
        object val = cmd.ExecuteScalar();
        cmd.Parameters.Clear();
        return val;
    }
}

/// <summary>
/// 用指定的資料庫連線執行一個命令並返回一個數據集的第一列
/// </summary>
/// <remarks>
/// 例如:
///  Object obj = ExecuteScalar(connString, CommandType.StoredProcedure, "PublishOrders", new MySqlParameter("@prodid", 24));
/// </remarks>
/// <param name="connection">一個存在的資料庫連線</param>
/// <param name="cmdType">命令型別(儲存過程, 文字, 等等)</param>
/// <param name="cmdText">儲存過程名稱或者sql命令語句</param>
/// <param name="commandParameters">執行命令所用引數的集合</param>
/// <returns>用 Convert.To{Type}把型別轉換為想要的 </returns>
public static object ExecuteScalar(MySqlConnection connection, CommandType cmdType, string cmdText, params MySqlParameter[] commandParameters)
{

    MySqlCommand cmd = new MySqlCommand();

    PrepareCommand(cmd, connection, null, cmdType, cmdText, commandParameters);
    object val = cmd.ExecuteScalar();
    cmd.Parameters.Clear();
    return val;
}

/// <summary>
/// 將引數集合新增到快取
/// </summary>
/// <param name="cacheKey">新增到快取的變數</param>
/// <param name="commandParameters">一個將要新增到快取的sql引數集合</param>
public static void CacheParameters(string cacheKey, params MySqlParameter[] commandParameters)
{
    parmCache[cacheKey] = commandParameters;
}

/// <summary>
/// 找回快取引數集合
/// </summary>
/// <param name="cacheKey">用於找回引數的關鍵字</param>
/// <returns>快取的引數集合</returns>
public static MySqlParameter[] GetCachedParameters(string cacheKey)
{
    MySqlParameter[] cachedParms = (MySqlParameter[])parmCache[cacheKey];

    if (cachedParms == null)
        return null;

    MySqlParameter[] clonedParms = new MySqlParameter[cachedParms.Length];

    for (int i = 0, j = cachedParms.Length; i < j; i++)
        clonedParms[i] = (MySqlParameter)((ICloneable)cachedParms[i]).Clone();

    return clonedParms;
}

/// <summary>
/// 準備執行一個命令
/// </summary>
/// <param name="cmd">sql命令</param>
/// <param name="conn">OleDb連線</param>
/// <param name="trans">OleDb事務</param>
/// <param name="cmdType">命令型別例如 儲存過程或者文字</param>
/// <param name="cmdText">命令文字,例如:Select * from Products</param>
/// <param name="cmdParms">執行命令的引數</param>
private static void PrepareCommand(MySqlCommand cmd, MySqlConnection conn, MySqlTransaction trans, CommandType cmdType, string cmdText, MySqlParameter[] cmdParms)
{

    if (conn.State != ConnectionState.Open)
        conn.Open();

    cmd.Connection = conn;
    cmd.CommandText = cmdText;

    if (trans != null)
        cmd.Transaction = trans;

    cmd.CommandType = cmdType;

    if (cmdParms != null)
    {
        foreach (MySqlParameter parm in cmdParms)
            cmd.Parameters.Add(parm);
    }
}

}
複製程式碼

MySqlHelper裡面的方法和SqlHelper差不多，就不一一說明了。

除此之外引用DBUTILITY類庫也是一個很好的選擇，DBUTILITY.DLL是一個整合SQLHELPER、MYSQLHELPER以及ORACLEHELPER等眾多資料庫操作類的類庫，新增引用後就可以直接呼叫其中方法對資料庫進行查詢、編輯等操作，十分的方便。

3.配置你的MYSQL資料庫連結字串如下：

//資料庫連線字串
public static string Conn = “Database=‘資料庫名’;Data Source=‘資料庫伺服器地址’;User Id=‘資料庫使用者名稱’;Password=‘密碼’;charset=‘utf8’;pooling=true”;
由於PHPMYADMIN相當於一個小型網站，因此在你的資料庫連線中還要設定下PHPMYADMIN編碼charset=‘utf8’

4.以上準備工作完成後，就可以通過呼叫MySQLHelper類裡面的方法來對MYSQL資料庫進行操作了，這些方法的用法也與SqlHelper類似。

dgv.DataSource=MySqlHelper.GetDataSet(MySqlHelper.Conn, CommandType.Text, “select * from wp_posts”, null).Tables[0].DefaultView;

相關推薦

C#訪問和操作MYSQL資料庫

這裡介紹下比較簡單的方式，引用MySql.Data.dll然後新增一個MySqlHelper類來對MySql資料庫進行訪問和操作。 1.將MySql.Data.dll引用到你的專案中 下載地址：MySql.Data.rar 新增引用後在你的資料庫操作類(如MyS

【C#】C#訪問和操作MYSQL資料庫

這裡介紹下比較簡單的方式，引用MySql.Data.dll然後新增一個MySqlHelper類來對MySql資料庫進行訪問和操作。 1.將MySql.Data.dll引用到你的專案中 新增引用後在你的資料庫操作類(如MySqlHelper.cs)中新增引用宣告

linux下C語言程式設計操作MySQL資料庫

原文地址：http://www.2cto.com/database/201506/407827.html 在實際應用中，我們不可能在命令列登入進資料庫進行資料的查詢、插入等操作，使用者一般是使用一個介面良好的應用程式軟體來對資料進行管理。為了方便應用程式的開發，MySQ

C語言簡單操作MYSQL資料庫的增刪查詢

#include<stdio.h> #include<mysql.h> //所需標頭檔案 #include<string.h> #include<stdlib.h> MYSQL *conn_prt; //創造一個MYSQL控制代碼 MYSQL_RE

用sql語句操作mysql資料庫的增刪改查（命令提示符和引入mysql模組兩種方式）

1:命令提示符方法： 我的 ：mysql.sql檔案。當然首先得開啟本地伺服器（我的是xampp）; 少了一步了：首先要在進入mysql -h127.0.0.1 -u root -p;後引入我的mysql.sql 檔案； 我用的是 source方法：  source

資料庫之ubuntu下如何安裝MySQL？如何管理和操作MySQL？

文章目錄 1. 如何安裝MySQL？ 1.1 安裝資料庫伺服器 1.2 安裝客戶端程式 1.3 安裝一些庫及標頭檔案 2. 如何管理MySQL？開啟、關閉、檢視等 2

Robot Framework操作MySQL資料庫和Oracle資料庫

一、Robot Framework連線MySQL資料庫 1.安裝databaselibrary、pymsql 　　通過cmd命令執行pip install robotframework-databaselibrary==1.1.1，安裝指定版本 　　通過cmd命令執行pip install&n

用C語言操作MySQL資料庫，進行連線、插入、修改、刪除等操作

　　很多人用到MySQL來開發一些專案，有時為了效能，我們會直接用C語言來開發相關的模組，尤其在我們的web應用中，雖然PHP、JSP等指令碼均提供了MySQL的介面，但是顯然直接使用C語言具有更好的安全性和效能，Michael以前用PHP開發的多個專案中就使用了C語言編寫的

用C語言操作mysql資料庫上傳變數

上傳變數文字內容 上傳命令：insert into table_name(list1,list2,...) values("***","***") 當上傳的值為變數時可如此執行 string a="上傳的檔案"； int id=1;//以上變數可隨意定義 char sqlstr[100];

C/C++操作MySQL資料庫——增、刪、改、查

1、資料庫連結 int cppDatebase::DatabaseConnect(sBit8 *uName,sBit8 *pWord,sBit8 *dbName) { 　　dbHandle = mysql_init(NULL); 　　if(NULL == dbHandle ) 　　{ 　　　　cout<

用C語言操作MySQL資料庫

參考MYSQL的幫助文件整理 這裡歸納了C API可使用的函式，並在下一節詳細介紹了它們。請參見“C API函式描述”。 函式 描述 mysql_affected_rows() 返回上次UPDATE、DELETE或INSERT查詢更改／刪除／插入的行數。 mysql_autocommit

php操作MySQL資料庫的方法和解析

對於許多web應用程式而言，資料庫都是其核心所在。資料庫幾乎可以用來儲存所有你想要檢索和更新的任何資訊 下面介紹兩種資料庫的訪問方式： ①. MySQLi 訪問MySQLi (面向物件)資料庫，其中MYSQLi又分為 面向物件 和 面向過程兩種形式 ②. PDO訪問MYSQL資料庫 MySQLi 和

c#操作MySql資料庫

需要mysql.data.dll 資料庫連線 //server資料庫地址，user資料庫使用者名稱，password密碼，database資料庫名 string ConnectString = string.Format("Server={0};User I

C語言操作MySQL資料庫的增刪改查

if( mysql_real_query(&mysql,"select * from user", (unsigned long)strlen("select * from user")))//mysql_real_query函式第一個引數是定義的MYSQL變數；第二個是SQL查詢語句；第三個是查詢語

Python操作MySQL資料庫的兩種方式pymysql和pandas

目錄 第一種 使用pymysql 程式碼如下： import pymysql #開啟資料庫連線 db=pymysql.connect(host='1.1.1.1',port=3306,user='root',passwd='123123',db='te

c#操作MySQL資料庫中文出現亂碼（很多問號）的解決方法

前題：修改discuz論壇帖子老連線（從NT版轉到PHP版的discuzX3）,帖子裡有很多引用，有連結都是.aspx這樣的連結。 需要將這些連結改到當前論壇的連結。 思路：用asp.net程式獲取含.aspx的帖子內容，用正則替換舊連結，本地測試OK？在伺服器上就出現了一

Ubuntu下用C直接操作Mysql資料庫的方法

ubuntu下用C直接操作Mysql資料庫的方法 轉載自：http://hi.baidu.com/wdr_cloud/item/7d87e609102b24943d42e251 以下內容僅供個人學習之用，切勿挪用他途。 首先安裝好mysql，一般情況下是沒有mysql.

linux下C語言操作mysql資料庫（系統自帶版本3.23.54）

      我的上一篇blog介紹了在linux環境下如何安裝配置系統自帶的mysql資料庫，並列舉了mysql的一些簡單的操作。接下來我將介紹一下如何利用mysql提供給我們的API來訪問並操作mysql資料庫（C語言）。 首先，我們需要安裝mysql-devel-3.23

C#操作Mysql資料庫的儲存過程

近期在工作中接觸了一套遊戲服務端的程式碼，它是用C#寫的邏輯，其中發現在客戶端登陸的時候，服務端中處理登陸驗證的模組沒有先對賬戶名的合法性進行驗證，而且還直接用sql語句拼接賬戶名的方法去查詢資料庫，很明顯者存在一個SQL注入漏洞，為此我對寫這程式碼的同胞

C#連接操作 MySQL 數據庫實例(使用官方驅動)

mysql 回滾 object 解釋 span 原創 語音合成 tostring 目錄 MySQL 以其免費和足夠的性能受到很大的青睞，當然對於國內小公司，甚至是大公司如果對版權看得薄，敢冒險的話，隨便裝個 SqlServer、DB2、Oracle 都行。對於 SqlSe