SQLAlchemy 执行查询但不更新，尽管原始查询在 SQL IDE 中工作正常

Question

我有一个在 SQL 编辑器中运行良好的查询：

UPDATE users mu 
JOIN (SELECT 
        min.user_id as user_id, 
        (max.total_followers - min.total_followers) as progression
    FROM(select user_id, measurement_date, total_followers
    from followers_totals ft 
        where measurement_date = (select max(measurement_date) from followers_totals as f where f.user_id = ft.user_id
        and date_format(ft.measurement_date, '%%Y-%%m-%%d') >= date_format(date_sub(CURDATE(), interval 7 day), '%%Y-%%m-%%d'))) max
    JOIN (select user_id, measurement_date, total_followers
        from followers_totals ft 
        where measurement_date = (select min(measurement_date) from followers_totals as f where f.user_id = ft.user_id
        and date_format(ft.measurement_date, '%%Y-%%m-%%d') >= date_format(date_sub(CURDATE(), interval 7 day), '%%Y-%%m-%%d'))) min
    ON max.user_id = min.user_id
    WHERE min.user_id = '123456' and max.user_id = '123456') progression 
ON progression.user_id = mu.user_id
SET mu.followers_count_progress_7D = progression.progression
WHERE progression.user_id is not null;

我尝试使用执行函数从 SQLAlchemy 执行相同的查询：

import sqlalchemy
from sqlalchemy import create_engine, Table, MetaData, exc

eng = create_engine('mysql://xxxxxxxxxxxxxxxxxxxxxxxxxxxx')
con = eng.connect()    

try:
    query = """UPDATE users mu 
                JOIN (SELECT 
                        min.user_id as user_id, 
                        (max.total_followers - min.total_followers) as progression
                    FROM(select user_id, measurement_date, total_followers
                    from followers_totals ft 
                        where measurement_date = (select max(measurement_date) from followers_totals as f where f.user_id = ft.user_id
                        and date_format(ft.measurement_date, '%%Y-%%m-%%d') >= date_format(date_sub(CURDATE(), interval 7 day), '%%Y-%%m-%%d'))) max
                    JOIN (select user_id, measurement_date, total_followers
                        from followers_totals ft 
                        where measurement_date = (select min(measurement_date) from followers_totals as f where f.user_id = ft.user_id
                        and date_format(ft.measurement_date, '%%Y-%%m-%%d') >= date_format(date_sub(CURDATE(), interval 7 day), '%%Y-%%m-%%d'))) min
                    ON max.user_id = min.user_id
                    WHERE min.user_id = '123456' and max.user_id = '123456') progression 
                ON progression.user_id = mu.user_id
                SET mu.followers_count_progress_7D = progression.progression
                WHERE progression.user_id is not null;"""
    rs = con.execute(query)
    print(rs)
except exc.SQLAlchemyError as e:
    print (e)

不返回异常，并且 print(rs) 会按预期返回代理。 但是，在使用 SQL 编辑器更新数据库时，不会使用 SQLAlchemy 更新数据库。 SQL Alchemy 是否不支持我的查询的某些部分？

我最初认为这将是日期格式中 % 的转义，但不同的测试表明，使用这种转义写作更简单的查询可以按预期运行。

编辑：按照上面的建议在引擎创建中使用 echo=True 后，我可以看到查询格式被保留，提交完成。我将 echo 的输出复制粘贴到 sql 编辑器，查询运行良好，但使用 sqlalchemy 它根本不会更新。

EDIT2：尝试添加 autocommit=True 并得到相同的结果.... 日志显示：

2021-02-14 11:21:21,387 INFO sqlalchemy.engine.base.Engine ()
2021-02-14 11:21:21,389 INFO sqlalchemy.engine.base.Engine UPDATE users mu 
                JOIN (
                    SELECT min.user_id as user_id, 
                        (max.total_followers - min.total_followers) as progression 
                    FROM(
                        select user_id, measurement_date, total_followers 
                 ....
                ON progression.user_id = mu.user_id 
                SET mu.followers_count_progress_7D = progression.progression 
                WHERE progression.user_id is not null;
2021-02-14 11:21:21,389 INFO sqlalchemy.engine.base.Engine ()
2021-02-14 11:21:21,393 INFO sqlalchemy.engine.base.Engine COMMIT
0

用于连接的用户拥有所有权限：

GRANT ALL ON *.* TO 'user1'@'%';

在 SQLAlchemy 上运行的更简单的更新查询实际上正在运行。

编辑 3： 有趣的是，这似乎只发生在某些 id 上，但不是全部。依赖 ID 的东西如何远程工作而不是本地工作......？

Answer 1

由于调试打印似乎没有提供足够的信息来解决问题，我将假设它确实是实际提交数据库更改的问题，所以，就像其他人在其他各种问题（例如：setting autocommit to 1 in mysql），您应该尝试显式使用autocommit=True。

您可以使用with 语句进行测试，例如：

with engine.connect().execution_options(autocommit=True) as conn:
    conn.execute(query)

或者只是将.execution_options(autocommit=True) 附加到您现有的代码中：

conn.execute(query).execution_options(autocommit=True)

请注意，虽然execution_option 的autocommit 参数将在SQLAlchemy 1.4 中被弃用，并且替换将是设置事务隔离级别，如here 所示。

重申一下，似乎 MySQL 在内部将自动提交值设置为 0，这意味着它使用需要 .commit()ed 的事务将其传播到数据库。希望这能真正解决问题，因为我目前还没有准备好在我的机器上进行测试。