MySQL存储过程是一组为了完成特定功能的SQL语句集合,被存储在数据库中,用户可以通过指定存储过程的名字并给定参数来调用执行。除了基础的变量声明、赋值和简单查询外,很多高级SQL语句能让存储过程处理更复杂的业务场景。

游标相关高级语句
游标用于处理存储过程中查询返回的多行结果集,让我们可以逐行遍历数据进行处理。核心语句包括游标声明、打开、取值、关闭,以及对应的循环处理语句。
游标基本使用语句
首先声明游标,关联一个查询语句,然后通过循环遍历游标中的每一行数据:
-- 创建测试表
CREATE TABLE IF NOT EXISTS user_info (
id INT PRIMARY KEY AUTO_INCREMENT,
user_name VARCHAR(50) NOT NULL,
age INT NOT NULL
);
-- 插入测试数据
INSERT INTO user_info (user_name, age) VALUES ('张三', 20), ('李四', 25), ('王五', 30);
-- 创建存储过程,遍历用户表并输出年龄大于22的用户名
DELIMITER //
CREATE PROCEDURE process_user_cursor()
BEGIN
-- 声明变量,存储游标取出的数据
DECLARE v_user_name VARCHAR(50);
DECLARE v_age INT;
-- 声明循环结束标志
DECLARE done INT DEFAULT 0;
-- 声明游标,关联查询语句
DECLARE user_cursor CURSOR FOR SELECT user_name, age FROM user_info;
-- 声明异常处理,当游标遍历完所有数据时会触发NOT FOUND,设置done为1
DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = 1;
-- 打开游标
OPEN user_cursor;
-- 循环遍历游标
read_loop: LOOP
-- 从游标中取出一行数据,赋值给变量
FETCH user_cursor INTO v_user_name, v_age;
-- 如果遍历结束,退出循环
IF done = 1 THEN
LEAVE read_loop;
END IF;
-- 处理取出的数据,这里判断年龄大于22则输出
IF v_age > 22 THEN
SELECT v_user_name AS eligible_user;
END IF;
END LOOP;
-- 关闭游标
CLOSE user_cursor;
END //
DELIMITER ;
-- 调用存储过程
CALL process_user_cursor();
条件控制与异常处理语句
存储过程中可以通过条件判断语句处理不同分支逻辑,同时配合异常处理语句捕获执行过程中的错误,保证存储过程的稳定性。
条件判断语句
除了基础的IF语句,还可以使用CASE语句处理多分支场景:
-- 创建存储过程,根据用户年龄返回对应的等级
DELIMITER //
CREATE PROCEDURE get_user_level(IN p_age INT, OUT p_level VARCHAR(20))
BEGIN
CASE
WHEN p_age < 18 THEN SET p_level = '未成年';
WHEN p_age >= 18 AND p_age <= 40 THEN SET p_level = '青年';
WHEN p_age > 40 AND p_age <= 60 THEN SET p_level = '中年';
ELSE SET p_level = '老年';
END CASE;
END //
DELIMITER ;
-- 调用存储过程
SET @age = 28;
SET @level = '';
CALL get_user_level(@age, @level);
SELECT @level AS user_level;
异常处理语句
使用DECLARE HANDLER语句定义异常触发时的处理逻辑,常见的异常类型包括NOT FOUND、SQLEXCEPTION等:
-- 创建存储过程,插入用户数据,处理主键冲突异常
DELIMITER //
CREATE PROCEDURE insert_user_with_handler(IN p_id INT, IN p_name VARCHAR(50), IN p_age INT, OUT p_result VARCHAR(50))
BEGIN
-- 声明异常处理器,捕获主键重复异常
DECLARE CONTINUE HANDLER FOR 1062 SET p_result = '插入失败,用户ID已存在';
-- 初始化结果
SET p_result = '插入成功';
-- 执行插入操作
INSERT INTO user_info (id, user_name, age) VALUES (p_id, p_name, p_age);
END //
DELIMITER ;
-- 第一次调用,正常插入
SET @res1 = '';
CALL insert_user_with_handler(4, '赵六', 35, @res1);
SELECT @res1 AS result1;
-- 第二次调用,ID重复,触发异常处理
SET @res2 = '';
CALL insert_user_with_handler(4, '孙七', 36, @res2);
SELECT @res2 AS result2;
动态SQL语句
当存储过程中需要执行的SQL语句在编写时无法确定,需要根据参数动态拼接时,就需要使用动态SQL,核心语句是PREPARE、EXECUTE和DEALLOCATE PREPARE。
-- 创建存储过程,动态查询指定表的指定字段数据
DELIMITER //
CREATE PROCEDURE dynamic_query(IN p_table_name VARCHAR(50), IN p_column_name VARCHAR(50))
BEGIN
-- 声明变量存储动态SQL语句
SET @sql_str = CONCAT('SELECT ', p_column_name, ' FROM ', p_table_name);
-- 预处理动态SQL
PREPARE stmt FROM @sql_str;
-- 执行预处理语句
EXECUTE stmt;
-- 释放预处理语句
DEALLOCATE PREPARE stmt;
END //
DELIMITER ;
-- 调用存储过程,查询user_info表的user_name字段
CALL dynamic_query('user_info', 'user_name');
事务控制语句
存储过程中可以使用事务相关语句保证一组SQL操作的原子性,要么全部执行成功,要么全部回滚。
-- 创建存储过程,实现用户年龄批量更新,使用事务保证原子性
DELIMITER //
CREATE PROCEDURE batch_update_age(IN p_id_list VARCHAR(100), IN p_age_increment INT, OUT p_result VARCHAR(50))
BEGIN
-- 声明异常处理器,出现异常则回滚事务
DECLARE EXIT HANDLER FOR SQLEXCEPTION
BEGIN
ROLLBACK;
SET p_result = '更新失败,已回滚所有操作';
END;
-- 开启事务
START TRANSACTION;
-- 这里简化逻辑,实际场景可以解析p_id_list逐个更新,此处演示事务流程
UPDATE user_info SET age = age + p_age_increment WHERE id IN (1,2);
-- 提交事务
COMMIT;
SET p_result = '更新成功,事务已提交';
END //
DELIMITER ;
-- 调用存储过程
SET @res = '';
CALL batch_update_age('1,2', 1, @res);
SELECT @res AS update_result;
-- 查看更新后的数据
SELECT * FROM user_info WHERE id IN (1,2);
常用高级语句总结
以下是MySQL存储过程中常用的高级SQL语句汇总:
| 语句类型 | 核心语句 | 作用 |
|---|---|---|
| 游标相关 | DECLARE CURSOR, OPEN, FETCH, CLOSE, DECLARE HANDLER FOR NOT FOUND | 遍历多行结果集,处理逐行数据 |
| 条件控制 | CASE...WHEN, IF...THEN...ELSE | 处理多分支业务逻辑 |
| 异常处理 | DECLARE HANDLER FOR 异常类型 | 捕获执行过程中的错误,执行对应处理逻辑 |
| 动态SQL | PREPARE, EXECUTE, DEALLOCATE PREPARE | 执行运行时动态拼接的SQL语句 |
| 事务控制 | START TRANSACTION, COMMIT, ROLLBACK | 保证一组SQL操作的原子性 |
掌握这些高级SQL语句后,我们可以编写出功能更强大、适配复杂业务场景的MySQL存储过程,减少应用层和数据库层的交互次数,提升整体系统的执行效率。