1. 从一次存储过程调试说起游标遍历结果集执行动态 SQL 到底难在哪MySQL 存储过程里用游标遍历结果集、再对每一行拼出动态 SQL 执行是很多数据清洗、批量建表、按配置表驱动任务的常见套路。它看起来只是「循环 拼字符串 PREPARE」但真正写起来坑集中在三处游标循环什么时候退出、动态语句里的引号怎么拼、以及执行结果到底有没有按预期生效。我见过太多人在fetch之后忘了判断done结果最后一行被重复执行两次也见过拼出来的 SQL 里字段名带了反引号却被当成字符串报Unknown column。这篇聚焦一个具体场景你有一张配置表tb_test里面每行存一条待执行的 SQL 文本需要用游标逐行取出、预处理、执行、释放并且能在本地调试环境里验证每一步。同时把 TaoToken 作为统一 Key/API 通道接进来让本地调试时调用模型辅助排查报错、生成校验 SQL 更顺手。核心检索词就是mysql 游标执行动态语句适合已经会写基础存储过程、但在动态拼接和循环控制上反复踩坑的开发者。先说清楚游标 动态语句的本质。游标CURSOR是 MySQL 服务端提供的一种逐行读取结果集的机制它不像SELECT那样一次性把结果全给你而是像手指点着清单一行行往下读。动态语句则是把「要执行的 SQL」本身当成数据先存进一个字符串变量再用PREPARE ... FROM编译、EXECUTE执行。两者结合就是「读一行配置 → 拼一条 SQL → 执行 → 读下一行」。难点不在语法而在控制流游标读到末尾时 MySQL 会抛一个NOT FOUND条件你必须用CONTINUE HANDLER捕获它并设置退出标志否则循环要么死循环要么最后一行处理两次。下面给出一套可直接复制的模板再逐段拆解为什么这么写。整个调试过程我会用 TaoToken 的 API 通道来辅助把报错信息丢给模型对话接口让它帮我判断是拼接问题还是游标问题。这样比纯靠肉眼盯 SQL 快很多尤其是引号嵌套多的时候。2. TaoToken 前置准备统一 Key 与 API 通道在本地调试中的定位在动手写存储过程之前先把调试辅助通道搭好。TaoToken 在这里的角色不是替代 MySQL而是提供一个统一的 API 入口让你在本地调试时能调用模型能力做几件事解释报错、检查动态 SQL 拼接、生成对照的校验语句。它的官网是 https://taotoken.net/?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_content API 基址是 https://taotoken.net/api 这个地址不加 UTM 参数。你需要准备三样东西我把它叫做「三件套」Base URL、API Key、Model ID。Base URL 就是上面那个 API 地址API Key 在控制台的 API Keys 页面创建地址是 https://taotoken.net/api-keys?utm_sourcetaotoken_aicg_blog_endutm_contentapi_keysutm_campaignrewrite Model ID 则根据你用的模型填比如对话类模型或代码类模型各有对应标识。这三件套在后面的配置片段里会反复出现缺一个都调不通。为什么调试存储过程要接这个因为动态 SQL 报错信息往往很含糊。比如PREPARE stmt FROM v_sql失败时MySQL 只告诉你语法错误在第几个字符但不会告诉你拼接出来的完整语句长什么样。这时候你可以把v_sql的值打印出来连同报错一起发给模型对话接口让它帮你定位是少了空格、引号不匹配还是变量没展开。模型对话入口在 https://taotoken.net/chat?utm_sourcetaotoken_aicg_blog_endutm_contentmodel_chatutm_campaignrewrite 本地调试时开一个窗口备用。如果你打算长期做这类数据驱动任务甚至用 Agent 方式批量处理可以了解 Coding Plan地址是 https://taotoken.net/coding-plan?utm_sourcetaotoken_aicg_blog_endutm_contentcoding_planutm_campaignrewrite 。不过本篇的重点还是存储过程本身TaoToken 只是辅助排查的工具不要本末倒置。接入文档在 https://taotoken.net/doc?utm_sourcetaotoken_aicg_blog_endutm_contentdocutm_campaignrewrite 遇到接口参数不清楚时查这里。有一点要提醒本地调试环境里API Key 不要硬编码进存储过程或提交到代码仓库。存储过程里只放业务逻辑模型调用放在外部脚本或客户端里通过环境变量读取 Key。这样即使存储过程被导出也不会泄露凭证。下面进入正题先建测试表和配置数据。3. 可复制配置游标 PREPARE/EXECUTE 存储过程模板与 settings 片段先建一张配置表模拟「每行一条待执行 SQL」的场景。字段str存 SQL 文本id做排序保证游标读取顺序可控。CREATE TABLE tb_test ( id INT PRIMARY KEY AUTO_INCREMENT, str VARCHAR(1000) NOT NULL ) ENGINEInnoDB DEFAULT CHARSETutf8mb4; INSERT INTO tb_test (str) VALUES (CREATE TABLE IF NOT EXISTS t_result_1 (id INT PRIMARY KEY, note VARCHAR(50))), (INSERT INTO t_result_1 (id, note) VALUES (1, first row)), (INSERT INTO t_result_1 (id, note) VALUES (2, second row));注意第二条和第三条里的单引号用了两个单引号转义这是 SQL 字符串里表示单引号的写法。如果你从外部导入配置这一步最容易出错后面排障会专门讲。接下来是完整的存储过程模板。我把它拆成声明区、游标区、循环区三块方便你对照修改。DELIMITER $$ CREATE PROCEDURE sp_test() BEGIN DECLARE tmp VARCHAR(1000); DECLARE done INT DEFAULT 0; DECLARE v_sql VARCHAR(2000); DECLARE myCursor CURSOR FOR SELECT str FROM tb_test ORDER BY id; DECLARE CONTINUE HANDLER FOR NOT FOUND SET done 1; OPEN myCursor; myLoop: LOOP FETCH myCursor INTO tmp; IF done 1 THEN LEAVE myLoop; END IF; SET v_sql tmp; PREPARE stmt FROM v_sql; EXECUTE stmt; DEALLOCATE PREPARE stmt; END LOOP myLoop; CLOSE myCursor; END $$ DELIMITER ;调用它CALL sp_test();执行后应该生成t_result_1表并插入两行。这里有几个关键点必须说清楚。第一done的初始值。原示例里用DEFAULT -1我用DEFAULT 0效果一样只要不是 1 就行。CONTINUE HANDLER FOR NOT FOUND会在FETCH读不到行时触发把done置 1。注意这个 handler 是「继续」型触发后不会中断存储过程而是继续往下走所以你必须紧接着判断done并LEAVE。第二FETCH和判断的顺序。必须先FETCH再判断done。因为 handler 是在FETCH语句执行时触发的如果你先判断再FETCH第一次循环时done还是 0会正常处理但最后一次FETCH失败后done变 1如果不立即退出就会拿着上一轮的tmp再执行一次。这就是「最后一行重复执行」的根因。第三PREPARE的目标。PREPARE stmt FROM v_sql里的stmt是预处理语句的名字不是变量不需要声明。而v_sql是用户变量必须以开头。很多人写成DECLARE v_sql然后PREPARE stmt FROM v_sql这会报错因为PREPARE只接受用户变量或字符串字面量不接受局部变量。这是动态语句里最常见的坑之一。如果你要把模型调用也纳入调试流程可以在外部用一个settings.json管理三件套避免散落各处。下面是一个可复制的配置片段路径按你本地项目实际位置放{ taotoken: { base_url: https://taotoken.net/api, api_key: ${TAOTOKEN_API_KEY}, model_id: your-model-id, chat_endpoint: https://taotoken.net/chat?utm_sourcetaotoken_aicg_blog_endutm_contentmodel_chatutm_campaignrewrite }, mysql: { host: 127.0.0.1, port: 3306, database: debug_db, user: root } }api_key用环境变量占位实际运行时从TAOTOKEN_API_KEY读取。这样存储过程只管执行 SQL模型调用由外部脚本负责职责清晰。如果你用的是 Codex 类工具认证信息通常放在auth.json同样遵循 Base URL Key Model ID 三件套的结构不要只填 Key 漏掉 Model ID。4. 验证请求与成功结果用 EXPLAIN 和日志确认动态语句真的执行了存储过程跑完不报错不代表结果对。你需要三层验证语法层、执行层、结果层。语法层验证靠PREPARE本身。如果拼接的 SQL 有语法错误PREPARE stmt FROM v_sql会直接报错错误信息里会带出错位置。这时候把v_sql的值SELECT出来看SELECT v_sql;执行层验证靠EXPLAIN。对于SELECT类动态语句你可以在执行前先EXPLAIN一下确认它走的是预期索引、扫描行数合理。把EXECUTE换成SET explain_sql CONCAT(EXPLAIN , v_sql); PREPARE stmt FROM explain_sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;注意EXPLAIN只对SELECT、INSERT、UPDATE、DELETE有效对CREATE TABLE这类 DDL 不适用。所以如果你的配置表里混了 DDL 和 DML要加判断分流。结果层验证靠查询目标表。执行完CALL sp_test();后SELECT * FROM t_result_1;应该看到两行数据。如果只有一行说明游标循环提前退出了如果有三行且第三行重复说明done判断位置不对。这两种现象对应不同的排障方向。日志验证方面MySQL 本身没有存储过程内的PRINT但你可以用一张日志表记录每轮执行的 SQL 和时间CREATE TABLE sp_log ( id INT PRIMARY KEY AUTO_INCREMENT, step_no INT, sql_text VARCHAR(2000), created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP );在循环里插入日志INSERT INTO sp_log (step_no, sql_text) VALUES (step_no, v_sql);step_no用一个自增变量维护每轮加一。这样执行完查sp_log就能看到实际执行的每一条 SQL和配置表逐行对照拼接错误一目了然。如果你在调试时遇到报错可以把sp_log里的sql_text和 MySQL 返回的错误码一起发给 TaoToken 的模型对话接口让它帮你判断是引号问题、变量未展开还是权限问题。模型对话入口前面给过这里不重复。实测下来引号嵌套和CONCAT拼接顺序这两类问题模型判断得比人快尤其是多层嵌套的时候。成功的结果应该是CALL sp_test();无报错返回t_result_1有预期行数sp_log里每条 SQL 都能单独复制出来手动执行成功。三个条件都满足才算真正跑通。5. 本篇常见错排查401、local proxy failed、reading choices 与游标异常对照调试过程中报错五花八门这里按真实遇到的顺序列几个高频的对照排查。401 Unauthorized。这个通常出现在模型调用侧不是 MySQL 侧。原因一般是 API Key 没填、填错或者环境变量没生效。检查TAOTOKEN_API_KEY是否在当前 shell 会话里export过echo $TAOTOKEN_API_KEY看有没有值。如果用的是settings.json里的${TAOTOKEN_API_KEY}占位确认你的加载逻辑真的做了变量替换。三件套里 Base URL 和 Model ID 也要一起核对只对 Key 不对地址同样会 401。local proxy failed。这个报错说明请求根本没发出去卡在本地网络层。常见原因是本地代理配置指向了一个不可用的地址或者端口被占用。检查你的环境变量里有没有HTTP_PROXY、HTTPS_PROXY之类的设置如果有但指向的服务没启动就会报这个。清掉这些变量再试。注意这里说的是本地网络配置排查不涉及任何跨境访问手段。reading choices 相关报错。这类错误通常出现在解析模型返回时返回体结构和预期不符。可能是 Model ID 填错导致返回了非预期格式也可能是请求参数里stream设置和解析逻辑不匹配。先把请求改成非流式拿到完整 JSON 看结构确认choices字段存在且格式正确再改回流式。游标循环异常。分三种表现死循环、少执行一行、多执行一行。死循环一般是done没被置 1检查CONTINUE HANDLER FOR NOT FOUND有没有写、FETCH有没有真的读到空。少执行一行通常是done初始值就是 1或者LEAVE判断写在了FETCH之前。多执行一行就是前面说的FETCH后没立即判断done。动态语句拼接错误。典型报错是You have an error in your SQL syntax或Unknown column。前者多半是少了空格或引号不匹配后者多半是字段名被当成了字符串。排查方法就是把v_sql打印出来肉眼对照。如果 SQL 很长用SELECT LENGTH(v_sql)看长度是否符合预期再用SUBSTRING分段看。PREPARE 报「Incorrect arguments to EXECUTE」。这通常是EXECUTE stmt USING var里的变量个数和?占位符个数不匹配。如果你用的是直接拼接而非占位符检查拼接后的语句里有没有残留的?。权限问题。存储过程执行动态 SQL 时用的是定义者的权限。如果定义者没有目标表的操作权限EXECUTE会失败。用SHOW GRANTS FOR userhost;确认权限必要时用SQL SECURITY INVOKER改成调用者权限。把上面这些对照着sp_log里的实际 SQL 看大部分问题十分钟内能定位。如果实在卡住把报错原文、v_sql的值、以及你的存储过程定义一起整理好再走模型对话排查信息越全判断越准。6. 把调试通道固定下来从存储过程到统一 Key 的日常用法跑通一次之后建议把调试流程固化。我的做法是存储过程只负责「读配置、拼 SQL、执行、写日志」四件事所有模型调用和报错分析放在外部脚本里通过统一 Key 走 API 通道。这样存储过程可以独立测试模型通道也可以独立测试出问题时能快速判断是哪一层的问题。具体来说本地建一个debug.sh里面做三件事调用CALL sp_test();、查询sp_log最近几条、把异常 SQL 发给模型对话接口。三件套从settings.json读Key 从环境变量读。这样每次调试只需要跑一个脚本日志和模型分析一起出来。如果你后续要做更复杂的批量任务比如按配置表驱动上百条 DDL可以考虑用 Coding Plan 把这类重复调试流程做成 Agent 任务地址在 https://taotoken.net/coding-plan?utm_sourcetaotoken_aicg_blog_endutm_contentcoding_planutm_campaignrewrite 。但前提是单条存储过程已经稳定不要一上来就上批量否则报错定位会非常痛苦。最后留一个实用技巧在存储过程里加一个「干跑」开关。用一个用户变量dry_run控制为 1 时只写sp_log不真正EXECUTE。这样你可以先看拼接出来的 SQL 对不对确认无误再关掉干跑真正执行。这个开关在批量任务里能救命尤其是 DDL 不可回滚的场景。IF dry_run 1 THEN INSERT INTO sp_log (step_no, sql_text) VALUES (step_no, v_sql); ELSE PREPARE stmt FROM v_sql; EXECUTE stmt; DEALLOCATE PREPARE stmt; INSERT INTO sp_log (step_no, sql_text) VALUES (step_no, v_sql); END IF;把这段嵌进循环体配合SET dry_run 1;先跑一遍看日志确认每条 SQL 都能手动执行成功再SET dry_run 0;正式跑。游标和动态语句的坑八成都能在这个阶段暴露出来不用等到数据被改坏才发现。