在数据处理的实际业务中，经常会遇到需要多步骤计算、中间结果需要复用的场景，比如先过滤原始数据，再对过滤后的数据做聚合，最后关联其他维度表输出最终结果。这种场景下使用SQL存储过程搭建流水线，配合临时表暂存中间计算结果，既能拆分复杂逻辑，又能避免重复计算，是提升处理效率的常用方案。
存储过程流水线的基本设计思路
存储过程流水线的核心是将整个复杂计算拆分成多个独立的步骤，每个步骤完成一个明确的子任务，步骤之间通过临时表传递中间结果。设计时需要先梳理完整的计算逻辑，拆分出每个子任务的输入输出，再按顺序组织到存储过程中。
拆分逻辑时可以遵循以下原则：
- 每个步骤只完成单一功能，比如数据过滤、字段计算、聚合统计等
- 中间结果如果会被后续多个步骤使用，就通过临时表暂存
- 步骤之间尽量减少数据量的传递，优先在临时表中完成过滤和裁剪
临时表的类型与选择
SQL中的临时表主要分为本地临时表和全局临时表，在存储过程流水线中通常使用本地临时表，它的生命周期和创建它的会话绑定，会话结束后会自动删除，不会造成数据残留。
本地临时表的命名以#开头，不同会话创建的同名本地临时表互相隔离，非常适合在存储过程内部暂存中间数据。如果需要在多个存储过程之间共享中间结果，可以考虑使用全局临时表，命名以##开头，但要注意并发场景下的数据冲突问题。
完整示例：订单数据多步骤统计流水线
下面以电商订单统计场景为例，实现一个存储过程流水线，完成以下三个步骤的计算：
- 从原始订单表中过滤出近30天的有效订单，暂存到临时表1
- 对临时表1的订单按用户ID分组，统计每个用户的订单金额和订单数，暂存到临时表2
- 关联用户维度表，输出最终的用户消费统计结果
步骤1：创建基础表和测试数据
首先创建原始订单表和用户维度表，插入测试数据：
-- 创建原始订单表
CREATE TABLE order_info (
order_id INT PRIMARY KEY,
user_id INT,
order_amount DECIMAL(10,2),
order_status VARCHAR(20),
create_time DATETIME
);
-- 创建用户维度表
CREATE TABLE user_dim (
user_id INT PRIMARY KEY,
user_name VARCHAR(50),
user_level VARCHAR(20)
);
-- 插入测试订单数据
INSERT INTO order_info VALUES
(1, 101, 199.00, 'paid', DATEADD(DAY, -5, GETDATE())),
(2, 101, 299.00, 'paid', DATEADD(DAY, -10, GETDATE())),
(3, 102, 99.00, 'paid', DATEADD(DAY, -20, GETDATE())),
(4, 103, 399.00, 'refunded', DATEADD(DAY, -3, GETDATE())),
(5, 102, 159.00, 'paid', DATEADD(DAY, -2, GETDATE()));
-- 插入测试用户数据
INSERT INTO user_dim VALUES
(101, '张三', '普通会员'),
(102, '李四', '高级会员'),
(103, '王五', '普通会员');
步骤2：编写存储过程流水线
以下是完整的存储过程代码，包含临时表的创建、中间结果暂存和最终输出：
CREATE PROCEDURE proc_order_statistics
AS
BEGIN
-- 避免返回受影响行数，提升性能
SET NOCOUNT ON;
-- 步骤1：过滤近30天有效订单，暂存到临时表#temp_valid_order
CREATE TABLE #temp_valid_order (
order_id INT,
user_id INT,
order_amount DECIMAL(10,2)
);
INSERT INTO #temp_valid_order (order_id, user_id, order_amount)
SELECT order_id, user_id, order_amount
FROM order_info
WHERE order_status = 'paid'
AND create_time >= DATEADD(DAY, -30, GETDATE());
-- 步骤2：统计每个用户的订单数据，暂存到临时表#temp_user_stat
CREATE TABLE #temp_user_stat (
user_id INT,
total_amount DECIMAL(10,2),
order_count INT
);
INSERT INTO #temp_user_stat (user_id, total_amount, order_count)
SELECT user_id, SUM(order_amount) AS total_amount, COUNT(order_id) AS order_count
FROM #temp_valid_order
GROUP BY user_id;
-- 步骤3：关联用户维度表，输出最终结果
SELECT
u.user_id,
u.user_name,
u.user_level,
s.total_amount,
s.order_count
FROM #temp_user_stat s
INNER JOIN user_dim u ON s.user_id = u.user_id
ORDER BY s.total_amount DESC;
-- 临时表会自动释放，也可以手动删除（可选）
DROP TABLE #temp_valid_order;
DROP TABLE #temp_user_stat;
END;
步骤3：执行存储过程验证结果
执行存储过程查看最终输出：
-- 执行存储过程 EXEC proc_order_statistics;
执行后会得到如下结果：
| user_id | user_name | user_level | total_amount | order_count |
|---|---|---|---|---|
| 101 | 张三 | 普通会员 | 498.00 | 2 |
| 102 | 李四 | 高级会员 | 258.00 | 2 |
注意事项与优化建议
在使用存储过程流水线配合临时表时，需要注意以下几点：
- 临时表的字段尽量只保留后续步骤需要的列，减少临时表的存储开销
- 如果临时表的数据量较大，可以在临时表的关联字段上创建索引，提升后续查询效率
- 存储过程内部尽量使用显式的事务控制，避免中间步骤失败导致数据不一致
- 不要在流水线中频繁创建和删除临时表，尽量在存储过程开头统一创建，结尾统一清理
这种方案尤其适合处理逻辑复杂、中间结果需要复用的ETL场景，相比单条复杂SQL，可读性和可维护性都更高，也方便后续对单个步骤进行优化调整。