So schreiben Sie benutzerdefinierte gespeicherte Prozeduren und Funktionen in MySQL mit C#

So schreiben Sie benutzerdefinierte gespeicherte Prozeduren und Funktionen in MySQL mit C#

Einführung:
MySQL ist ein weit verbreitetes Open-Source-Datenbankverwaltungssystem, während C# eine häufig verwendete objektorientierte Programmiersprache ist. Während des Entwicklungsprozesses müssen wir häufig in Datenbanken gespeicherte Prozeduren und Funktionen verwenden, um die Wiederverwendbarkeit und Leistung des Codes zu verbessern. In diesem Artikel wird erläutert, wie Sie mit C# benutzerdefinierte gespeicherte Prozeduren und Funktionen in einer MySQL-Datenbank schreiben, und es werden spezifische Codebeispiele bereitgestellt.

1. Gespeicherte Prozeduren
Eine gespeicherte Prozedur ist eine Reihe von SQL-Anweisungen, die bestimmte Aufgaben ausführen. Im Folgenden wird detailliert beschrieben, wie Sie mit C# benutzerdefinierte gespeicherte Prozeduren in MySQL schreiben.

1.1 Erstellen Sie eine gespeicherte Prozedur
Erstellen Sie zunächst eine neue Datenbank in MySQL und erstellen Sie eine Datentabelle mit dem Namen „TestDB“. Die Tabellenstruktur ist wie folgt:

CREATE TABLE TestTable (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 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;

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();
    }
}

Der obige Code wird von der CREATE PROCEDURE-Anweisung ausgeführt, um eine gespeicherte Prozedur mit dem Namen „GetAllData“ zu erstellen. Diese gespeicherte Prozedur kann direkt in der Datenbank aufgerufen werden und gibt alle Daten in der TestTable-Tabelle zurück.

1.2 Gespeicherte Prozeduren aufrufen

Basierend auf dem vorherigen Schritt können wir den folgenden Code schreiben, um die gespeicherte Prozedur aufzurufen und die zurückgegebenen Daten abzurufen:

Das obige ist der detaillierte Inhalt vonSo schreiben Sie benutzerdefinierte gespeicherte Prozeduren und Funktionen in MySQL mit C#. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!