postgresql – 使用Ecto的递归CTE

在计划与Ecto一起运行的查询中,如何使用递归CTE的结果？例如,假设我有一个表,节点,结构如下：

-- nodes table example --

ID  parent_ID
1   NulL
2   1
3   1
4   1
5   2
6   2
7   3
8   5

我还有另一个表nodes_users结构如下：

-- nodes_users table example --

node_ID   user_iD
1         1
2         2
3         3
5         4

现在,我想抓住具有特定节点或其上方节点的所有用户,为了举例,我们选择具有ID 8的节点.

我可以使用以下递归POSTGResql查询来执行此操作：

WITH REcursIVE nodes_tree AS (
    SELECT *
    FROM nodes
    WHERE nodes.ID = 8
union all
    SELECT n.*
    FROM nodes n
    INNER JOIN nodes_tree nt ON nt.parent_ID = n.ID
)
SELECT u.* FROM users u
INNER JOIN users_nodes un ON un.user_iD = u.id
INNER JOIN nodes_tree nt ON nt.ID = un.node_ID

对于ID为1,2和4的用户,这应该返回用户.*.

我不确定如何使用ecto运行相同的查询,理想情况是以返回可链接输出的方式运行.我知道我可以使用片段宏将原始sql插入到我的查询中,但是我不确定这将用于何种用途,或者这甚至是最合适的路径.

帮助和/或建议将不胜感激！

Repo.all(MyProj.User,from u in MyProj.User,join: un in MyProj.UserNode,on: u.id == un.user_iD,join: nt in fragment("""
  (
    WITH REcursIVE node_tree AS (
      SELECT *
      FROM nodes
      WHERE nodes.ID = ?
    union all
      SELECT n.*
      FROM nodes n
      INNER JOIN node_tree nt ON nt.parent_ID == n.ID
    )
  ) SELECT * FROM node_tree
  """,^node_ID),on: un.node_ID == nt.ID
)