SQL进阶知识：五、存储过程和函数

今天介绍下关于存储过程和函数的详细介绍，并结合MySQL数据库提供实际例子。

在MySQL中，存储过程（Stored Procedures）和函数（Functions）是数据库编程的重要组成部分，它们可以封装SQL语句，提高代码的复用性和安全性，同时减少网络传输。以下是关于存储过程和函数的详细介绍，以及基于MySQL的实际例子。

一、存储过程（Stored Procedures）

1. 存储过程的基本概念

存储过程是一组SQL语句的集合，封装在一个名称下，可以带参数调用。存储过程可以包含复杂的逻辑，支持条件语句、循环语句和变量声明。

2. 存储过程的优点

代码复用：存储过程可以被多次调用，避免重复编写SQL语句。
性能提升：存储过程在服务器端执行，减少了网络传输。
安全性：通过存储过程可以限制用户直接访问表，提高数据的安全性。
事务管理：存储过程可以包含事务控制语句，确保操作的原子性。

3. 创建存储过程

语法：

CREATE PROCEDURE procedure_name (IN|OUT|INOUT param1 type, ...)
BEGIN-- SQL语句
END;

IN参数：输入参数，用于传递值到存储过程。
OUT参数：输出参数，用于返回值。
INOUT参数：既可以输入也可以输出。

4. 调用存储过程

CALL procedure_name(param1, param2, ...);

5. 删除存储过程

DROP PROCEDURE procedure_name;

二、函数（Functions）

1. 函数的基本概念

函数是一组SQL语句的集合，封装在一个名称下，可以带参数调用，并返回一个值。函数通常用于计算和返回单个值。

2. 函数的优点

代码复用：函数可以被多次调用，避免重复编写SQL语句。
性能提升：函数在服务器端执行，减少了网络传输。
逻辑封装：函数可以封装复杂的计算逻辑。

3. 创建函数

语法：

CREATE FUNCTION function_name (param1 type, ...)
RETURNS return_type
BEGIN-- SQL语句RETURN value;
END;

4. 调用函数

SELECT function_name(param1, param2, ...);

5. 删除函数

DROP FUNCTION function_name;

三、实际例子

示例1：存储过程（插入数据并返回插入的行数）

场景：插入一条用户数据，并返回插入的行数

-- 创建存储过程
DELIMITER //CREATE PROCEDURE InsertUser(IN username VARCHAR(50), IN email VARCHAR(100), OUT rows_affected INT)
BEGININSERT INTO users (username, email) VALUES (username, email);SET rows_affected = ROW_COUNT();
END //DELIMITER ;-- 调用存储过程
CALL InsertUser('Alice', 'alice@example.com', @rows_affected);-- 查看返回的行数
SELECT @rows_affected;

解释：

创建了一个存储过程InsertUser，接收用户名和邮箱作为输入参数，返回插入的行数。
使用ROW_COUNT()函数获取插入的行数。
调用存储过程时，使用OUT参数rows_affected接收返回值。

示例2：存储过程（更新数据并返回受影响的行数）

场景：更新用户邮箱，并返回受影响的行数

-- 创建存储过程
DELIMITER //CREATE PROCEDURE UpdateUserEmail(IN user_id INT, IN new_email VARCHAR(100), OUT rows_affected INT)
BEGINUPDATE users SET email = new_email WHERE id = user_id;SET rows_affected = ROW_COUNT();
END //DELIMITER ;-- 调用存储过程
CALL UpdateUserEmail(1, 'new_email@example.com', @rows_affected);-- 查看返回的行数
SELECT @rows_affected;

解释：

创建了一个存储过程UpdateUserEmail，接收用户ID和新邮箱作为输入参数，返回受影响的行数。
使用ROW_COUNT()函数获取受影响的行数。
调用存储过程时，使用OUT参数rows_affected接收返回值。

示例3：存储过程（事务控制）

场景：从用户A的账户转账到用户B的账户

-- 创建存储过程
DELIMITER //CREATE PROCEDURE TransferMoney(IN from_id INT, IN to_id INT, IN amount DECIMAL(10, 2))
BEGINDECLARE from_balance DECIMAL(10, 2);DECLARE to_balance DECIMAL(10, 2);-- 开始事务START TRANSACTION;-- 检查用户A的余额是否足够SELECT balance INTO from_balance FROM accounts WHERE id = from_id FOR UPDATE;IF from_balance < amount THENSIGNAL SQLSTATE '45000' SET MESSAGE_TEXT = 'Insufficient balance';END IF;-- 扣款UPDATE accounts SET balance = balance - amount WHERE id = from_id;-- 加款UPDATE accounts SET balance = balance + amount WHERE id = to_id;-- 提交事务COMMIT;
END //DELIMITER ;-- 调用存储过程
CALL TransferMoney(1, 2, 100.00);

解释：

创建了一个存储过程TransferMoney，接收转账的用户ID、收款的用户ID和转账金额。
使用START TRANSACTION和COMMIT管理事务。
使用FOR UPDATE锁定用户A的账户，防止并发问题。
如果用户A的余额不足，抛出异常。

示例4：函数（计算用户年龄）

场景：根据用户的出生日期计算年龄

-- 创建函数
DELIMITER //CREATE FUNCTION CalculateAge(birthdate DATE)
RETURNS INT
BEGINDECLARE age INT;SET age = TIMESTAMPDIFF(YEAR, birthdate, CURDATE());RETURN age;
END //DELIMITER ;-- 调用函数
SELECT id, name, birthdate, CalculateAge(birthdate) AS age FROM users;

解释：

创建了一个函数CalculateAge，接收出生日期作为参数，返回年龄。
使用TIMESTAMPDIFF函数计算当前日期与出生日期之间的年数。
调用函数时，可以直接在SELECT语句中使用。

示例5：函数（计算订单总价）

场景：根据订单中的商品数量和单价计算总价

-- 创建函数
DELIMITER //CREATE FUNCTION CalculateOrderTotal(quantity INT, unit_price DECIMAL(10, 2))
RETURNS DECIMAL(10, 2)
BEGINDECLARE total DECIMAL(10, 2);SET total = quantity * unit_price;RETURN total;
END //DELIMITER ;-- 调用函数
SELECT order_id, quantity, unit_price, CalculateOrderTotal(quantity, unit_price) AS total_price
FROM order_items;