SQLAlchemy调用MySQL存储过程返回成功但未实际插入数据的问题

1. 核心是SQLAlchemy的事务控制逻辑和你手动测试MySQL客户端的行为不一致
   MySQL客户端默认开启自动提交（autocommit），每条SQL执行后会立刻把改动持久化，所以手动测存储过程时插入能正常落地。排除权限因素，你当前的数据库账号具备全量操作权限，不存在权限不足导致插入失败的问题。
   但SQLAlchemy建立的数据库连接默认关闭自动提交，所有写操作（包括存储过程内的INSERT）只会暂存在当前连接的未提交事务里，只要没显式执行commit()，不管代码看起来执行得多“正常”，数据库都会在连接关闭时自动回滚所有未提交的改动，这就是接口返回1但表无数据的核心原因。
   你其他路由的查询操作之所以正常，是因为只读查询不需要依赖事务提交就能返回结果，这种正常表现让你忽略了写操作必须提交的规则。
2. 代码执行顺序存在硬伤
   原代码在调用存储过程拿到执行句柄后，立刻执行connection.close()关闭连接，之后才遍历结果集获取返回值。这种写法哪怕因为小结果集提前缓存侥幸拿到了1的返回值，也会因为连接提前中断导致事务直接回滚，插入操作根本没机会提交。
3. 现象匹配验证
   你遇到的「重复传入相同新书参数依然返回1」的表现，刚好是未提交事务的典型特征：因为之前的插入从未被持久化到数据库，每次新的连接调用存储过程时，查询book表都找不到对应的书名，自然一直走插入分支返回1；只有已经持久化存在的书名，才能触发返回0的逻辑。

1. 调整代码逻辑，显式控制事务边界
   正确的执行顺序是：建立连接→执行存储过程→加载结果集拿到返回值→显式提交事务→出错时回滚→最终关闭连接。修正后的add_book函数参考：

   def add_book(info):
       result = None
       connection = None
       try:
           connection = db.connect()
           title = info['bookTitle']
           url = info['bookUrl']
           isbn = info['isbn']
           author = info['author']
           # 用参数化查询替代字符串拼接，避免SQL注入
           query = 'CALL add_book(%s, %s, %s, %s);'
           query_results = connection.execute(query, (title, url, isbn, author))
           # 先加载全量结果集，拿到返回值
           result_list = [row for row in query_results]
           result = result_list[0][0]
           # 关键步骤：提交事务，让存储过程内的插入操作持久化
           connection.commit()
       except Exception as err:
           print(type(err))
           print(err.args)
           # 异常时回滚，避免脏事务
           if connection:
               connection.rollback()
       finally:
           # 确保连接无论成功失败都被释放
           if connection:
               connection.close()
       return result
   

2. 可选配置说明
   如果不想每次写操作都手动写commit()，可以在初始化SQLAlchemy引擎时配置isolation_level="AUTOCOMMIT"开启自动提交，但这种方式会失去多步操作的事务一致性保障，不推荐在涉及多表写入的业务场景使用，核心业务还是需要显式控制事务边界。
3. 存储过程的小笔误修正
   查看你定义的存储过程，异常处理逻辑里取诊断信息时有个笔误：SELECT @pa1, @p2; 里的@pa1是未定义的变量，应该是@p1，修正后才能在触发异常时拿到正确的错误信息，方便后续排查问题。

内容的提问来源于stack exchange，提问作者Kabocha Porter