SQLAlchemy向反射PostgreSQL表插入数据出现全字段NULL问题

• Insert.values() 方法不会修改原有的Insert实例，而是返回一个携带了赋值参数的新Insert实例。你调用query.values()后没有接收返回值，最终传给session.execute()执行的仍然是未绑定任何字段值的空插入语句，所以所有自定义赋值的字段都保持默认空值。
• 你在执行查询操作前就调用了session.close()关闭了会话，后续用已关闭的会话执行查询属于错误用法，返回的结果属于会话异常状态下的输出。

1. 接收values()方法返回的新Insert实例，或者直接在调用insert()时传入字段参数。
2. 调整会话操作顺序，所有数据库操作完成后再关闭会话。
3. 针对jsonb类型字段，可直接传入Python字典，SQLAlchemy会自动完成序列化，无需手动转JSON字符串。

修正后代码示例 #

from sqlalchemy import *
from sqlalchemy.orm import Session

# 创建引擎、元数据、会话
engine = create_engine('postgresql://postgres:password@database/db', future=True)
metadata = MetaData(bind=engine)
session = Session(engine)

# 反射加载表结构
customers = Table('customers', metadata, autoload_with=engine)

# 方式1：调用insert时直接传值
query = customers.insert().values(
    email="test@test.com",
    name="testy testarosa",
    phone="+12125551212",
    # 直接传字典即可，无需手动转JSON
    address={"city": "Cities", "street": "123 Main St", "state": "CA", "zip": "10001"}
)

# 方式2：接收values返回的新实例
# query = customers.insert()
# query = query.values(email="test@test.com", name="testy testarosa", ...)

session.execute(query)
session.commit()

# 先执行查询，再关闭会话
stmt = text("SELECT * FROM customers")
response = session.execute(stmt)

for result in response:
    print(result)

session.close()

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