使用 SQLAlchemy 类,我正在尝试生成类似于
SELECT
DISTINCT(non_unique_key)
FROM
`tablename`,
UNNEST(tasks_dns) AS dns
WHERE
create_date_utc = TIMESTAMP("2020-12-31T23:59:59")
AND dns LIKE "%whatever%"
作为使用 unnest() 的隐式连接,我不知道如何构造我的语句。
结合使用 .label() 和移动 unnest() 调用,我设法将 unnest 子句移动到 SELECT 或 WHERE 子句,但不在 FROM 中。
例如,
session.query(Table.non_unique_key).filter(func.unnest(Table.dns) != '').filter(Table.create_date == "2021-04-22")
留给我
SELECT `tablename`.`non_unique_key` AS `tablename_non_unique_key`
FROM `tablename`
WHERE unnest(`tablename`.`tasks_dns`) IS NOT NULL AND `tablename`.`create_date_utc` = %(create_date_utc_1)s
到目前为止,使用 join() 刚刚导致没有加入列的异常(虽然是的,我理解这意味着什么,但我不知道如何解决这个问题,因为 unnest 基本上是在扩展 a没有要加入的列的嵌套数据类型..这可能是我对如何正确使用 SQLAlchemys join() 方法的无知的原因)
这只是一个 SQLAlchemy / BigQuery 方言问题吗?还是我只是个笨蛋?我知道方言库仍然是婴儿,但即使使用 Postgres,我也会认为这应该是一种常见的查询模式?