如何在MySQL中使用C#編寫自訂預存程序和函數

如何在MySQL中使用C#來寫自訂儲存程序與函數

引言：
MySQL是一個廣泛使用的開源資料庫管理系統，而C#是一種常用的物件導向的程式語言。在開發過程中，我們經常需要使用資料庫預存程序和函數來提高程式碼的複用性和效能。本文將介紹如何在MySQL資料庫中使用C#編寫自訂預存程序和函數，並提供具體的程式碼範例。

一、預存程序
預存程序是一組為執行特定任務的SQL語句集合。以下將詳細介紹如何在MySQL中使用C#編寫自訂預存程序。

1.1 建立預存程序
首先，在MySQL中建立一個新的資料庫並建立一個名為"TestDB"的資料表。表格結構如下所示：

CREATE TABLE TestTable (
id int(11) NOT NULL AUTO_INCREMENT,
name# varchar(100) DEFAULT NULL,
age int(11) DEFAULT NULL,
PRIMARY KEY (id)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

接下來，在Visual Studio中建立一個新的C#控制台應用程式。透過MySQL連接字串連接到資料庫，然後執行以下程式碼來建立一個名為"GetAllData"的預存程序：

using MySql.Data.MySqlClient;

namespace MySQLExample
{

class Program
{
    static void Main(string[] args)
    {
        string connectionString = "server=localhost;username=root;password=password;database=TestDB";
        MySqlConnection connection = new MySqlConnection(connectionString);
        MySqlCommand cmd = new MySqlCommand();
        cmd.Connection = connection;

        cmd.CommandText = "CREATE PROCEDURE GetAllData() " +
                           "BEGIN " +
                           "SELECT * FROM TestTable; " +
                           "END";

        try
        {
            connection.Open();
            cmd.ExecuteNonQuery();
            Console.WriteLine("存储过程创建成功！");
        }
        catch (Exception ex)
        {
            Console.WriteLine(ex.Message);
        }
        finally
        {
            connection.Close();
        }

        Console.ReadKey();
    }
}

}

以上程式碼透過執行CREATE PROCEDURE語句來建立了一個名為"GetAllData"的預存程序。這個預存程序在資料庫中可以直接調用，將會傳回TestTable表中的所有資料。

1.2 呼叫預存程序
接下來，我們來示範如何在C#中呼叫剛剛建立的預存程序。

在前一步的基礎上，我們可以編寫以下程式碼來呼叫預存程序並取得傳回的資料：

using MySql.Data.MySqlClient;

#namespace MySQLExample
{

class Program
{
    static void Main(string[] args)
    {
        string connectionString = "server=localhost;username=root;password=password;database=TestDB";
        MySqlConnection connection = new MySqlConnection(connectionString);
        MySqlCommand cmd = new MySqlCommand();
        cmd.Connection = connection;

        cmd.CommandText = "GetAllData";
        cmd.CommandType = CommandType.StoredProcedure;

        try
        {
            connection.Open();
            MySqlDataReader reader = cmd.ExecuteReader();

            while (reader.Read())
            {
                Console.WriteLine(reader["id"].ToString() + " " + reader["name"].ToString() + " " + reader["age"].ToString());
            }

            reader.Close();
        }
        catch (Exception ex)
        {
            Console.WriteLine(ex.Message);
        }
        finally
        {
            connection.Close();
        }

        Console.ReadKey();
    }
}

}

以上程式碼透過執行"GetAllData"預存程序來取得TestTable表中的所有數據，並將結果輸出到控制台。

二、函數
函數是一個可重複使用的SQL程式碼區塊，它將輸入參數的值計算後傳回一個值。以下將詳細介紹如何在MySQL中使用C#編寫自訂函數。

2.1 建立函數
在MySQL中建立一個名為"GetAverageAge"的函數，它將計算TestTable表中所有人的平均年齡並回傳。

建立函數的程式碼如下所示：

##CREATE FUNCTION

GetAverageAge() RETURNS INT(11)BEGIN
DECLARE avg_age INT(11);
SELECT AVG(age) INTO avg_age FROM TestTable;
RETURN avg_age;
END

2.2 呼叫函數

透過下列程式碼來呼叫剛剛建立的函數並取得傳回的值：

using MySql.Data.MySqlClient;

namespace MySQLExample

{

class Program
{
    static void Main(string[] args)
    {
        string connectionString = "server=localhost;username=root;password=password;database=TestDB";
        MySqlConnection connection = new MySqlConnection(connectionString);
        
        try
        {
            connection.Open();
            MySqlCommand cmd = new MySqlCommand("SELECT GetAverageAge()", connection);
            int averageAge = Convert.ToInt32(cmd.ExecuteScalar());

            Console.WriteLine("平均年龄：" + averageAge);
        }
        catch (Exception ex)
        {
            Console.WriteLine(ex.Message);
        }
        finally
        {
            connection.Close();
        }

        Console.ReadKey();
    }
}

}

##以上程式碼透過執行SELECT GetAverageAge()語句來呼叫"GetAverageAge"函數，並取得函數傳回的平均年齡。

結論：

本文介紹如何在MySQL中使用C#編寫自訂預存程序和函數，並提供了具體的程式碼範例。預存程序和函數可以提高程式碼的複用性和效能，適用於各種複雜的資料處理需求。透過使用C#連接MySQL資料庫，我們可以靈活地進行預存程序和函數的編寫和調用，從而充分發揮MySQL資料庫的優勢。

以上是如何在MySQL中使用C#編寫自訂預存程序和函數的詳細內容。更多資訊請關注PHP中文網其他相關文章！