sqlite 连接两个SQL查询

wfypjpf4 于 2023-05-18 发布在 SQLite

关注(0)|答案(1)|浏览(190)

编辑：我删除了前面的SQL查询，使事情更容易-不需要像我前面说的那样连接两个查询。
stock_tracking_negociacao表（为了简化，我只过滤了一个代码“LEVE 3”）：

#;data;tipo;mercado;ticker;quantidade;preco;valor
606;2019/12/02;Compra;Mercado à Vista;LEVE3;400;24.95;9980
437;2020/03/19;Compra;Mercado à Vista;LEVE3;100;18.05;1805
775;2021/06/10;Venda;Mercado à Vista;LEVE3;200;35.74;7148
716;2021/08/11;Venda;Mercado à Vista;LEVE3;300;33.6;10080
1214;2022/07/21;Compra;Mercado à Vista;LEVE3;600;23.7;14220
1564;2023/03/13;Compra;Mercado à Vista;LEVE3;200;32;6400

其中：

数据=日期
tipo：'Compra' = 'Buy' and 'Venda' = 'Sell'
quantidade =数量
preco =价格
价值=金额 * 价格

我需要用相同的stock_tracking_negociacao表构建一个查询。表必须按日期（data）从最早记录到最新记录排序。
我的目标是为每一行构建两个新列（不管它出现了多次）：balance和avg_price。
解释新列：

balance：如果tipo = Compra，我们需要从以前的记录中添加quantidade。否则，如果tipo = Venda，我们需要从以前的记录中减去quantidade。每个自动收报机的第一条记录有balance = quantidade。
avg_price：如果tipo = Compra，则((preco * quantidade) + ([previous] balance * [previous] avg_price)) / (quantidade + [previous] balance)。如果tipo = Venda，则avg_price = [previous] avg_price。每个自动收报机的第一条记录有avg_price = preco。在MS Excel中，它与SUMPRODUCT非常相似。
预期结果：

谢谢

sqlite

来源：https://stackoverflow.com/questions/76245147/connect-two-sql-queries

1条答案

按热度按时间

juud5qan1#

您现有的查询能够产生想要的结果，我也包含了前面的quantidade，但似乎不需要：

WITH RECURSIVE negociacao
AS (
    SELECT row_number() OVER (
            PARTITION BY ticker ORDER BY ticker, data
            ) AS seq, data, ticker, tipo, preco, quantidade AS qnt
          , coalesce(lag(quantidade) over(partition by ticker
                                 order by data ASC),0) as prev_qnt
    FROM stock_tracking_negociacao
    WHERE tracking IS NULL
    ), adjust_table
AS (
    SELECT *, SUM(CASE WHEN tipo = 'Compra' THEN qnt ELSE - qnt END) OVER (
            PARTITION BY ticker ORDER BY seq
            ) AS balance
    FROM negociacao
    ), recurse
AS (
    SELECT adjust_table.*, preco AS avg
    FROM adjust_table
    WHERE seq = 1
    
    UNION ALL
    
    SELECT n.*, CASE WHEN n.tipo = 'Compra' THEN ((n.preco * n.qnt * 1.0) + (s.balance * s.avg)) / (n.qnt + s.balance) ELSE s.avg END AS avg
    FROM adjust_table n
    INNER JOIN recurse s ON n.seq = s.seq + 1
        AND n.ticker = s.ticker
    )

SELECT
       *
  --, round(balance * medio, 2) AS valor_total
FROM recurse

seq	资料	自动收报机	蒂波	前科	qnt	上一页_qnt	天平	平均
1	2019年12月12日	LEVE3	孔普拉	二十四点九五	四百	0	四百	二十四点九五
二	2020/03/19	LEVE3	孔普拉	十八点零五分	一百	四百	五百	二十三点五十七
三	2021/06/10	LEVE3	文达	35.74	两百	一百	三百	二十三点五十七
四	2021/08/11	LEVE3	文达	三十三点六	三百	两百	0	二十三点五十七
五	2019 - 07 - 21 2019 - 07 - 21	LEVE3	孔普拉	二十三点七	六百	三百	六百	二十三点七
六	2023年3月13日	LEVE3	孔普拉	三十二	两百	六百	八百	二十五点七七五

fiddle

赞(0）回复(0）举报 2023-05-18

我来回答

sqlite 连接两个SQL查询

1条答案

相关问题

热门标签

最新问答