使用 SQLAlchemy 更新数据集的 pythonic 方式是什么？

Question

我想在我的 utils 中实现一个简单的流程：

1. 从数据库中获取rs=Query()
2. 遍历rs并发送请求requests.get(rs['http'])
3. 解析响应并获取logo_url值
4. 更新rs数据集

import requests

from sqlalchemy import create_engine

engine = create_engine("mssql://me:pass@server/db")

md = sqlalchemy.MetaData(engine)
table = sqlalchemy.Table('stations', md, autoload=True)

station = engine.execute("select * from stations")
for row in station:
    upd = table.filter_by(id=5).update(values={'STATION_LOGO_URL': 'http://test.com/img.png'})
    engine.execute(upd)

SQLAlchemy 可以做这样的事情吗？

Answer 1

我不知道不使用SQLAlchemy ORM 的方法。但是使用 ORM 很简单：

class Station(Base):
    __tablename__ = 'stations'
    ...
    station_logo_url = Column('STATION_LOGO_URL', NVARCHAR)
    ...

...

stations = session.query(Station).all()
for station in stations:
    logo_url = get_logo_url(station)
    station.station_logo_url = logo_url
session.commit()