递归CTE sql查询,用于计算滚动返回

问题描述

我第一次用SQL编写递归CTE来计算滚动收益。 公式:第一个值是100 *(1 + Returns),然后是(RollingReturns)*(1 + Returns)

表如下:

+----+--------+--------+----------------+
| ID |  Date  | Return | RollingReturns |
+----+--------+--------+----------------+
|  1 | 1/1/20 | 0.50%  |          100.5 |
|  1 | 1/2/20 | 1.00%  |         101.51 |
|  1 | 1/3/20 | -0.7%  |         100.74 |
|  1 | 1/4/20 | 0.50%  |         101.25 |
+----+--------+--------+----------------+

我尝试编写SQL查询:

    WITH rn_cte AS (
        SELECT ROW_NUMBER() OVER (ORDER BY DATE ASC) AS RN,DATE 
        FROM TABLE WHERE ID = 1
        ORDER BY RN 
    )
    rr_cte
    AS
    (
        SELECT RN,P.DATE,RETURNS,RETURNS AS ROLLINGRETURNS
        FROM TABLE P 
        JOIN rn_cte ON rn_cte.DATE = p.DATE 
        WHERE P.ID = 1 AND RN = 1
        UNION ALL
        SELECT RN,pm.DATE,pm.RETURNS,(rr_cte.ROLLINGRETURNS)*(1+pm.RETURNS) AS ROLLINGRETURNS
        FROM TABLE pm WHERE pm.ID = 1
        JOIN rr_cte ON rr_cte.RN = pm.RN+1
        ORDER BY pm.DATE ASC 
    )
    SELECT *
    FROM rr_cte 

它给我一个错误,不确定其中是什么错误。

Error                                                                     

    ^found "RR_CTE" (at char 145) expecting `SELECT' or `'(''

感谢您的帮助。 预先感谢!

解决方法

您想要这样的东西:

WITH rn AS (
      SELECT ROW_NUMBER() OVER (PARTITION BY id ORDER BY DATE ASC) AS RN,t.* 
      FROM TABLE t
      WHERE ID = 1
     ),cte AS (
      SELECT rn.rn,rn.id,rn.date,return,100 * (1 + rn.return) as rollingreturn
      FROM rn
      UNION ALL
      SELECT rn.rn,rn.return,cte.rollingreturn * (1 + rn.return)
      FROM cte JOIN
           rn
           ON cte.id = rn.id AND rn.rn = cte.rn + 1
     )
SELECT *
FROM cte;

相关问答

错误1:Request method ‘DELETE‘ not supported 错误还原:...
错误1:启动docker镜像时报错:Error response from daemon:...
错误1:private field ‘xxx‘ is never assigned 按Alt...
报错如下,通过源不能下载,最后警告pip需升级版本 Requirem...