SQLAlchemy 通过 JSON 子字段连接

jav*_*web 6 python postgresql json join sqlalchemy

我有一个现有的 SQLAlchemy 模型,应该与另一个模型有关系,但遗憾的是,连接点是 JSON PostgreSQL 列的(子)字段。

假设一个表“类别”是:

id(bigint) | name(string)
-------------------------
         5 | Comics
Run Code Online (Sandbox Code Playgroud)

...第二个表“英雄”是:

id(bigint) | name(string) | info(JSON)
-------------------------------------------------------------
         2 | Tranquility  | {"category_id":5, "genre_id": 17}
Run Code Online (Sandbox Code Playgroud)

在 python SQLAlchemy& PostgreSQL9.5中,我如何通过 加入categoryhero获得以下结果?heroinfo["category_id"]

id(bigint) | name(string) | category_name | info(JSON)
-------------------------------------------------------------
         2 | Tranquility  | Comics        | {"category_id":5, "genre_id": 17}
Run Code Online (Sandbox Code Playgroud)

根据这个答案,我知道 PostgreSQL 本身有可能发生这样的事情

https://dba.stackexchange.com/a/83935 ( http://sqlfiddle.com/#!15/226c33/1 )

并且可能需要一些转换或绕过默认方式的技巧, 如sqlalchemy filter by json field
中所述

注意:请注意,我无法更改数据库结构或模型的现有部分,而且我也不是在寻找我已经知道的双重查询绕过。

Tal*_*aid 6

您可以使用它json_to_record创建一个内存表,然后加入该表。

https://www.postgresql.org/docs/9.4/functions-json.html

另一个问题已经回答了这个问题,但使用的json_to_recordset数据是对象列表 /sf/answers/2193365611/

这是您可以根据需要转换为 sqlalchemy 的 SQL,

SELECT hero.id as hero_id, hero.name as name, d.name as category_name, info
FROM hero,
     json_to_record(hero.info) AS x(category_id int)
         JOIN category d on d.id = category_id
Run Code Online (Sandbox Code Playgroud)

这里 db fiddle 为您提供 https://www.db-fiddle.com/f/7ops4KXVDF6KpY5JZau7vG/1

另一种更简单的方法是访问连接和类型种姓中的 JSON 值category_id

SELECT hero.id       AS hero_id,
       hero.name     AS hero_name,
       category.name AS category_name,
       category.id   AS category_id,
       hero.info     AS hero_info
FROM hero
     JOIN category ON category.id = CAST(hero.info ->> 'category_id' AS INTEGER)
Run Code Online (Sandbox Code Playgroud)

等效的 sqalchemy 将变成,

category_id = cast(Hero.info.op("->>")("category_id"), Integer)
query = (db.session.query(Hero.id, Hero.name, Category.name, Category.id, Hero.info)
         .join(Category, Category.id == category_id))
data = query.all()
Run Code Online (Sandbox Code Playgroud)