0

sqlalchemyを用いてクエリを実行、postgresSQLサーバーで2つのテーブルから片方のテーブルのアップデートをしています。
エラーは出ませんが、実行もされておらず、ご教示いただけますでしょうか?
同じengineでread_sqlは問題なく実行されます。

connection_config = {
    'user': 'user',
    'password': 'Pass',
    'host': 'xxx.x.x.x',
    'port': 'xxxx',
    'database': 'database1'
}
engine = create_engine('postgresql://{user}:{password}@{host}:{port}/{database}'
                      .format(**connection_config))

session = scoped_session(
    sessionmaker(autocommit=False, autoflush=False, bind=engine)
)

sql = """
    UPDATE "TableA"
    SET "ColumnA" = "Table2"."ColumnA" FROM "Table2"
    WHERE "Table2"."ColumnB" = "TableA"."ColumnB"
    """ 

session.execute(sql)
2
  • autocommit=Falseautocommit=Trueに書き換え、またはsession.execute()の後にsession.commit()を入れると解決しますか?
    – payaneco
    2022年7月21日 23:59
  • autocommit=Trueで解決しました。大変ありがとうございます!
    – Bill
    2022年7月22日 11:10

0

この質問に回答するには、ログインする必要があります。

のタグが付いた他の質問を参照する。