将sql server外部应用查询迁移到雪花查询

z8dt9xmd 于 2021-07-29 发布在 Java

关注(0)|答案(2)|浏览(350)

正在从sql server迁移到snowflake。卡在下面查询。在雪花中找不到任何等价物。对于外部查询中的每一行，我们进入内部查询以获得比外部查询中的datekey小的top datekey。

select a.datekey , a.userid, a.transactionid
    ,cast( cast(b.datekey as varchar(8)) as date) priorone
    from tableA a
    outer apply (select top 1 b.datekey
                  from tableA b where a.userid = b.userid
                  and b.transactionid < a.transactionid and b.datekey < a.datekey
    order by b.transactionid desc) as b

建议回答如下：

create or replace table tableA
   (datekey date , userid int ,transactionid int)
   insert into tableA
   values('2020-06-01',1,101),('2020-06-02',1,102),('2020-06-02',1,103),('2020-06-01',2,104),('2020-06-02',2,105)
    select 
    a.datekey, 
    a.userid, 
    a.transactionid
    ,(
        select b.datekey
        from tableA b 
        where 
            a.userid = b.userid
            and b.transactionid < a.transactionid 
            and b.datekey < a.datekey
        order by b.transactionid desc
        limit 1
    ) priorone
from tableA a

sql Date sql-order-by snowflake-cloud-data-platform sql-limit

来源：https://stackoverflow.com/questions/62292534/migrating-sql-server-outer-apply-query-to-snowflake-query

2条答案

按热度按时间

jhkqcmku1#

我想您要找的是snowflake中的lead（）函数。它将为您保存子查询或连接：

select 
    datekey, 
    userid, 
    transactionid,
    lead(datekey) over (partition by userid order by datekey desc) as priorone
from tableA;

这将根据datekey的降序获得userid的下一条记录。
您还可以使用lag（）并按相反的方式进行排序：

select 
    datekey, 
    userid, 
    transactionid,
    lag(datekey) over (partition by userid order by datekey asc) as priorone
from tableA;

展开查看全部

赞(0）回复(0）举报 2021-07-29

mcdcgff02#

您只能从外部联接获得一列，因此可以将代码重新表述为直接相关的子查询。
雪花不支持 top ，但它具有与实现相同的功能 limit .
最后，你好像想把时间药水去掉 datekey ：您可以使用 date() 为了这个。

select 
    a.datekey, 
    a.userid, 
    a.transactionid
    (
        select date(b.datekey)
        from tableA b 
        where 
            a.userid = b.userid
            and b.transactionid < a.transactionid 
            and b.datekey < a.datekey
        order by b.transactionid desc
        limit 1
    ) priorone
from tableA a

展开查看全部

赞(0）回复(0）举报 2021-07-29

我来回答

将sql server外部应用查询迁移到雪花查询

2条答案

相关问题

热门标签

最新问答