如何在SQLAlchemy中从PostgreSQL返回行的函数中查询Post模型对象？

你的问题在于SQLAlchemy默认不会自动将自定义函数返回的行集直接映射到Post模型，需要明确告诉它如何处理函数的返回结果。这里有几种可行的解决方案：

方法1：使用from_statement直接执行SQL语句 #

这种方式最直观，直接调用PostgreSQL函数并将结果映射到Post模型：

from sqlalchemy import text

# 替换成你的实际参数值
ss_value = "your_ss_text"
tt_value = 123  # 或者None如果要使用默认值

post = session.query(Post).from_statement(
    text("SELECT * FROM aaa.bbb(:ss, :tt)")
).params(ss=ss_value, tt=tt_value).first()

如果tt要使用默认值，可以直接省略参数：

post = session.query(Post).from_statement(
    text("SELECT * FROM aaa.bbb(:ss)")
).params(ss=ss_value).first()

方法2：使用session.execute直接调用函数并映射结果 #

因为你的函数返回的是test.posts的行结构，SQLAlchemy可以自动将执行结果转换为Post对象：

# 调用函数并获取结果
result = session.execute(func.aaa.bbb(ss_value, tt_value))
# 获取单个对象（如果函数返回多行可以用fetchall()）
post = result.scalar_one_or_none()

如果需要传递None作为tt的参数（使用默认值），直接传None即可：

result = session.execute(func.aaa.bbb(ss_value, None))

方法3：为函数结果创建别名并关联模型 #

如果坚持使用query.select_from的方式，需要给函数的返回结果创建别名，让SQLAlchemy明确它对应Post模型的结构：

from sqlalchemy import alias

func_alias = alias(func.aaa.bbb(ss_value, tt_value), name="posts")
post = session.query(Post).select_from(func_alias).first()

为什么你的原代码无法工作？ #

你的原代码session.query(Post).select_from(func.aaa.bbb(ss, tt)).first()生成的SQL大致是：

SELECT posts.id, posts.column1, ... FROM aaa.bbb(%(ss)s, %(tt)s)

但SQLAlchemy没有明确识别aaa.bbb()返回的列与Post模型列的对应关系，尤其是当函数名和表名不一致时，容易出现映射失败。上面的方法都是通过明确语句结构或直接利用模型与返回行的结构匹配来解决这个问题。

注意事项 #

• 确保Post模型的__tablename__设置为test.posts，且所有字段与表结构完全对应；
• 如果函数返回的是部分列而非全表，需要调整query中的字段，或者确保模型中对应的字段都存在。

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