1. 订单统计场景为什么存储过程值得你花时间订单表数据一多每天跑统计就成了体力活。你可能写过这样的脚本先查当天订单总额再按用户分组算客单价最后把结果插到报表表里。三段 SQL 分散在应用代码里改一个字段要重新发版网络来回三四次遇到并发还得加锁。存储过程解决的正是这类「固定套路、反复执行」的问题——它把一组 SQL 编译后存在数据库里调用时只传一个名字和参数数据库内部直接跑完省掉多次网络往返也省掉应用层的拼装逻辑。我拿一个真实的订单统计需求来演示有一张订单表t_order需要按传入的起始日期统计每个用户的订单数和总金额把结果写入t_order_stat报表表。这个场景覆盖了存储过程的核心知识点——建表、参数传递IN/OUT、局部变量、IF 判断、游标循环、异常处理。你跟着敲一遍基本就能把存储过程用到自己的项目里。适合谁看写过基础 SQL、知道SELECT和INSERT但没系统用过存储过程的开发者或者你已经在用存储过程但游标和异常处理总是写不利索。全文的 SQL 都可以直接复制到 MySQL 8.0 客户端执行不需要额外依赖。需要提前说明的是存储过程不是银弹。它把逻辑下沉到数据库调试比应用代码麻烦版本管理也要额外花心思。所以我的建议是统计类、批处理类、多步骤事务类的逻辑适合放进存储过程频繁变更的业务规则还是留在应用层。下面从建表开始一步步把这条链路跑通。2. TaoToken 前置统一 Key 管理多环境数据库连接在写存储过程之前先解决一个容易被忽略的问题连接配置。本地开发连的是127.0.0.1:3306测试环境连的是另一台机器生产又是第三套。每换一个环境就改一次配置文件改错了还容易连到错误的库上执行DROP。我试过用 TaoToken 的统一 Key 通道来管理这类多环境连接配置思路是把数据库连接信息、模型调用 Key 都收敛到一个入口不同环境通过不同的 Key 或配置项区分避免散落在各个.env文件里。TaoToken 的定位是统一 API 通道官网在 https://taotoken.net/?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_content API 入口是 https://taotoken.net/api 。它本身不替代 MySQL 客户端而是帮你把「连接凭证」这件事管起来。比如你在写存储过程时可能同时需要调用模型来生成测试数据或校验 SQL 逻辑这时候统一 Key 就能让数据库连接和模型调用共用一套鉴权体系。具体操作上你需要在控制台创建一个 API Key然后把它写进项目的配置里。控制台地址是 https://taotoken.net/console?utm_sourcetaotoken_aicg_blog_endutm_contentconsoleutm_campaignrewrite 创建 Key 的页面在 https://taotoken.net/api-keys?utm_sourcetaotoken_aicg_blog_endutm_contentapi-keysutm_campaignrewrite 。拿到 Key 之后本地和云端用同一个 Key 的不同环境变量来区分比如TAOTOKEN_KEY_DEV和TAOTOKEN_KEY_PROD这样切换环境时只改变量名不动代码。如果你用的是 Claude Code 这类编码工具可以通过 https://taotoken.net/claude-code-anthropic?utm_sourcetaotoken_aicg_blog_endutm_contentClaudeCodeAnthropicutm_campaignrewrite 配置接入让它在生成存储过程脚本时直接走统一通道。需要提醒的是数据库连接本身仍然由你的 MySQL 客户端或应用框架管理TaoToken 管的是调用凭证这一层两者不冲突。把 Key 配好之后下面进入存储过程的正式编写。3. 可复制配置建表 SQL 与存储过程完整脚本这一节给出可以直接执行的完整脚本。先建两张表t_order存原始订单t_order_stat存统计结果。然后写一个带 IN 参数和 OUT 参数的存储过程内部用游标遍历用户列表逐个统计后插入报表表。先看建表语句。t_order包含订单 ID、用户 ID、金额、创建时间t_order_stat包含统计日期、用户 ID、订单数、总金额。注意金额用DECIMAL(10,2)避免浮点误差。CREATE TABLE IF NOT EXISTS t_order ( id BIGINT PRIMARY KEY AUTO_INCREMENT, user_id BIGINT NOT NULL, amount DECIMAL(10,2) NOT NULL, created_at DATETIME NOT NULL, INDEX idx_created_at (created_at), INDEX idx_user_id (user_id) ) ENGINEInnoDB DEFAULT CHARSETutf8mb4; CREATE TABLE IF NOT EXISTS t_order_stat ( id BIGINT PRIMARY KEY AUTO_INCREMENT, stat_date DATE NOT NULL, user_id BIGINT NOT NULL, order_count INT NOT NULL DEFAULT 0, total_amount DECIMAL(12,2) NOT NULL DEFAULT 0.00, UNIQUE KEY uk_date_user (stat_date, user_id) ) ENGINEInnoDB DEFAULT CHARSETutf8mb4;插入几条测试数据方便后面验证结果INSERT INTO t_order (user_id, amount, created_at) VALUES (1001, 99.50, 2024-06-01 10:00:00), (1001, 200.00, 2024-06-01 11:30:00), (1002, 50.00, 2024-06-01 14:20:00), (1002, 300.00, 2024-06-02 09:10:00), (1003, 150.00, 2024-06-02 16:45:00);接下来是存储过程主体。逻辑是接收起始日期和结束日期两个 IN 参数用游标遍历这个时间段内有订单的用户对每个用户统计订单数和总金额插入t_order_stat。用DECLARE ... HANDLER处理游标取完的情况用IF判断统计结果是否为空。DELIMITER $$ DROP PROCEDURE IF EXISTS sp_order_stat$$ CREATE PROCEDURE sp_order_stat( IN p_start_date DATE, IN p_end_date DATE, OUT p_user_count INT ) BEGIN DECLARE v_done INT DEFAULT 0; DECLARE v_user_id BIGINT; DECLARE v_order_count INT; DECLARE v_total_amount DECIMAL(12,2); DECLARE v_counter INT DEFAULT 0; DECLARE cur_user CURSOR FOR SELECT DISTINCT user_id FROM t_order WHERE created_at p_start_date AND created_at DATE_ADD(p_end_date, INTERVAL 1 DAY); DECLARE CONTINUE HANDLER FOR NOT FOUND SET v_done 1; OPEN cur_user; read_loop: LOOP FETCH cur_user INTO v_user_id; IF v_done 1 THEN LEAVE read_loop; END IF; SELECT COUNT(*), IFNULL(SUM(amount), 0.00) INTO v_order_count, v_total_amount FROM t_order WHERE user_id v_user_id AND created_at p_start_date AND created_at DATE_ADD(p_end_date, INTERVAL 1 DAY); IF v_order_count 0 THEN INSERT INTO t_order_stat (stat_date, user_id, order_count, total_amount) VALUES (p_end_date, v_user_id, v_order_count, v_total_amount) ON DUPLICATE KEY UPDATE order_count VALUES(order_count), total_amount VALUES(total_amount); SET v_counter v_counter 1; END IF; END LOOP; CLOSE cur_user; SET p_user_count v_counter; END$$ DELIMITER ;这段脚本里有几个关键点。DELIMITER $$是为了让 MySQL 客户端把整个存储过程当成一条语句否则遇到内部的分号就会提前结束。游标声明必须在局部变量之后这是 MySQL 的语法要求。CONTINUE HANDLER FOR NOT FOUND捕获游标取完的情况把v_done置为 1循环里据此退出。ON DUPLICATE KEY UPDATE保证重复执行同一天统计时不会报唯一键冲突而是更新已有记录。如果你在项目里用配置文件管理连接可以配合 TaoToken 的 Key 做环境区分。比如一个settings.json片段{ database: { dev: { host: 127.0.0.1, port: 3306, user: dev_user, taotoken_key_env: TAOTOKEN_KEY_DEV }, prod: { host: db.prod.internal, port: 3306, user: prod_user, taotoken_key_env: TAOTOKEN_KEY_PROD } } }这样切换环境时只改变量引用不硬编码凭证。配置好之后进入调用和验证环节。4. 验证请求调用存储过程并检查结果存储过程写完了得实际跑一次看结果。调用语法是CALL 过程名(参数...)OUT 参数需要用用户变量接收。执行下面这条语句统计 2024-06-01 到 2024-06-02 的订单CALL sp_order_stat(2024-06-01, 2024-06-02, user_count); SELECT user_count AS affected_users;预期结果是affected_users 3因为测试数据里有 1001、1002、1003 三个用户。接着查报表表确认数据落库SELECT * FROM t_order_stat ORDER BY user_id;你应该看到三行记录1001 有 2 笔订单共 299.501002 有 2 笔共 350.001003 有 1 笔共 150.00。如果结果对不上先检查created_at的边界条件——脚本里用的是 p_start_date AND DATE_ADD(p_end_date, INTERVAL 1 DAY)这样能把结束日期当天 23:59:59 的数据也包含进来。再验证一下重复执行的行为。把同一条CALL再跑一次然后查t_order_stat记录数应该还是 3 行但order_count和total_amount被更新为相同值不会出现重复行。这就是ON DUPLICATE KEY UPDATE的作用。如果你想看存储过程的定义可以用SHOW CREATE PROCEDURE sp_order_stat;查看当前库下所有存储过程SELECT routine_name, routine_type, created FROM information_schema.routines WHERE routine_schema DATABASE();删除存储过程用DROP PROCEDURE IF EXISTS sp_order_stat;。这里有个容易踩的坑DROP PROCEDURE后面不能加库名以外的限定如果你在错误的数据库下执行会提示过程不存在。执行前先用SELECT DATABASE();确认当前库。验证通过后你可以把这个调用封装到定时任务里比如每天凌晨跑一次前一天的统计。如果应用层需要拿到user_count做日志记得在连接池里每次调用后读取用户变量或者改用结果集返回的方式。5. 常见报错排查从 1064 到游标不退出存储过程调试比普通 SQL 麻烦因为报错信息往往只给一个行号。下面列几个我实际遇到过的错误和排查方法。报错 1064You have an error in your SQL syntax最常见的原因是DELIMITER没设置或者设置后忘记改回来。如果你在 MySQL Workbench 里执行它可能不认DELIMITER命令需要改用「创建存储过程」的图形界面或者把分隔符临时改成//。另一个原因是存储过程内部用了保留字做变量名比如把变量叫order、group改成v_order_count这类带前缀的名字就没事。报错 1329No data - zero rows fetched这个通常出现在游标FETCH之后没有正确退出循环。检查你的HANDLER是不是写成了EXIT而不是CONTINUE。用EXIT HANDLER FOR NOT FOUND会在游标取完时直接退出整个BEGIN...END块导致CLOSE cur_user不执行。推荐用CONTINUE HANDLER配合v_done标志位在循环里判断后LEAVE。报错 1452Cannot add or update a child row如果t_order_stat上有外键指向用户表而测试数据里的user_id在用户表不存在插入就会失败。排查方法是先SELECT DISTINCT user_id FROM t_order看有哪些用户再对照用户表。临时方案是去掉外键约束长期方案是保证数据一致性。游标循环不退出一直插入重复数据这种情况多半是v_done没有在每次循环开始时重置或者HANDLER的作用域不对。DECLARE CONTINUE HANDLER必须放在BEGIN...END块内、游标声明之后。另外注意FETCH语句要放在循环体开头IF v_done 1 THEN LEAVE紧跟其后。连接层面的报错local proxy failed / 401如果你在通过统一通道调用模型辅助生成 SQL 时遇到401先检查 API Key 是否过期或环境变量名写错。local proxy failed一般是本地代理配置和实际网络环境不匹配检查settings.json里的taotoken_key_env指向的变量是否在当前 shell 里已导出。可以用echo $TAOTOKEN_KEY_DEV确认。如果报错里出现reading choices说明请求体格式不对检查 JSON 里model和messages字段是否齐全。OAuth 相关报错在 Claude Code 里配置接入时如果提示 OAuth 失败通常是回调地址和配置的不一致。参考 https://taotoken.net/doc?utm_sourcetaotoken_aicg_blog_endutm_contentdocutm_campaignrewrite 里的接入说明确认Base URL、Key、Model ID三件套都填对了。Base URL 用 https://taotoken.net/api 不要多加路径。排查存储过程问题时一个实用技巧是把中间结果SELECT出来。比如在循环里临时加SELECT v_user_id, v_order_count;执行时就能看到每次迭代的值。调试完记得删掉否则会影响性能。6. 把存储过程接入你的工作流到这里建表、写过程、调用、验证、排障这条链路已经跑通了。回到实际项目你可以把这个sp_order_stat挂到定时任务上每天凌晨统计前一天的数据。如果统计维度要扩展比如按商品分类分组只需要改游标里的SELECT DISTINCT和内部的聚合 SQL调用方不用动。关于连接配置我的建议是把数据库凭证和 TaoToken Key 都通过环境变量注入不要写死在代码或 SQL 文件里。本地开发用TAOTOKEN_KEY_DEV云端用TAOTOKEN_KEY_PROD切换时只改环境变量。需要长期跑编码任务或 Agent 的话可以看看 Coding Plan 的配置方式https://taotoken.net/coding-plan?utm_sourcetaotoken_aicg_blog_endutm_contentcoding-planutm_campaignrewrite 。如果只是想先验证模型输出是否符合预期用模型对话页面快速试一下https://taotoken.net/chat?utm_sourcetaotoken_aicg_blog_endutm_contentmodel-chatutm_campaignrewrite 。最后留一个实用技巧存储过程写完后用SHOW CREATE PROCEDURE把定义导出到版本控制里和建表 SQL 放在一起。这样换环境部署时直接执行脚本不用手动在客户端里敲。下次统计逻辑要改先改脚本文件再执行避免「线上过程定义和代码库不一致」这种经典问题。
)
