C# 在 MySQL 中编写自定义触发器与存储过程的方法

在 C# 开发与 MySQL 数据库交互的应用程序时，掌握编写自定义触发器与存储过程的方法能极大地提升数据库操作的效率和灵活性。

首先来了解一下触发器。触发器是一种特殊的存储过程，它会在特定的数据库事件发生时自动执行。在 MySQL 中创建触发器，语法结构相对清晰。例如，当我们想要在向某一表插入新数据时执行特定操作，可按如下步骤操作。先使用 CREATE TRIGGER 语句，指定触发器的名称，接着定义触发的时机（如 BEFORE INSERT 或 AFTER INSERT）、针对的表。然后在 BEGIN 和 END 之间编写触发后要执行的 SQL 语句。

比如，假设有一个 employees 表，每当插入新员工记录时，我们希望自动更新一个记录插入次数的日志表。代码如下：

CREATE TRIGGER new_employee_insert
AFTER INSERT ON employees
FOR EACH ROW
BEGIN
    INSERT INTO insert_log (insert_time) VALUES (NOW());
END;

接下来谈谈存储过程。存储过程是一组预编译的 SQL 语句集合，它可以接收参数、执行逻辑并返回结果。在 C# 中调用 MySQL 存储过程，首先要在 MySQL 中创建存储过程。例如，创建一个根据员工 ID 查询员工信息的存储过程：

DELIMITER //
CREATE PROCEDURE get_employee_by_id(IN emp_id INT)
BEGIN
    SELECT * FROM employees WHERE id = emp_id;
END //
DELIMITER ;

在 C# 代码中调用该存储过程时，需要借助 MySqlConnection 和 MySqlCommand 类。示例代码如下：

using MySql.Data.MySqlClient;
using System;

class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;database=your_database;uid=your_username;pwd=your_password;";
        using (MySqlConnection connection = new MySqlConnection(connectionString))
        {
            connection.Open();
            MySqlCommand command = new MySqlCommand("get_employee_by_id", connection);
            command.CommandType = System.Data.CommandType.StoredProcedure;
            command.Parameters.AddWithValue("@emp_id", 1);

            using (MySqlDataReader reader = command.ExecuteReader())
            {
                while (reader.Read())
                {
                    Console.WriteLine(reader.GetString("name"));
                }
            }
        }
    }
}

通过合理运用自定义触发器与存储过程，我们能够将复杂的业务逻辑封装在数据库层面，减少 C# 应用程序与数据库之间的数据传输量，提高系统的整体性能。无论是数据的一致性维护，还是复杂查询的处理，它们都能发挥重要作用。