从子查询和CTE中发现数据血缘

SQL非常灵活，可以用许多不同的方式编写SQL语句来实现相同的结果。

下面的SQL语句用于根据CCF_BAK表的PARENT_TABLE列更新CCF表的PARENT_TABLE列。它有三种不同的写法。
第一种方法是在子查询中使用UPDATE语句。第二种方法是使用带有2个子查询的UPDATE语句。第三种方法是使用具有相同结果的CTE（公共表表达式）。
SQLFlow可以从所有3个SQL语句中发现数据沿袭。从子查询和CTE中发现数据血缘。

-- sql server
UPDATE s
SET s.PARENT_TABLE = u.PARENT_TABLE
FROM dwh_user.jv.CCF s
JOIN (
    SELECT TOP 1 *
    FROM dwh_user.jv.CCF_BAK u
    WHERE u.PRODUCT_NAME = 'Business loan'
) u ON 1 = 1
WHERE s.PRODUCT_NAME = 'Business loan'

Data lineage of the first SQL statement in xml format generated by SQLFlow:

<relationship id="10" type="fdd" effectType="update" processId="5" processType="sstupdate">
    <target id="19" column="PARENT_TABLE" parent_id="4" parent_name="dwh_user.jv.CCF" parent_alias="s"/>
    <source id="13" column="PARENT_TABLE" parent_id="11" parent_name="dwh_user.jv.CCF_BAK" parent_alias="u"/>
</relationship>

-- sql server
UPDATE s
SET s.PARENT_TABLE = u.PARENT_TABLE
FROM (
    SELECT *
    FROM dwh_user.jv.CCF s
    WHERE s.PRODUCT_NAME = 'Business loan'
) s
JOIN (
    SELECT TOP 1 *
    FROM dwh_user.jv.CCF_BAK u
    WHERE u.PRODUCT_NAME = 'Business loan'
) u ON 1 = 1

Data lineage of the second SQL statement in xml format generated by SQLFlow:

<relationship id="12" type="fdd" effectType="update" processId="5" processType="sstupdate">
    <target id="24" column="PARENT_TABLE" parent_id="4" parent_name="dwh_user.jv.CCF" parent_alias="s"/>
    <source id="18" column="PARENT_TABLE" parent_id="16" parent_name="dwh_user.jv.CCF_BAK" parent_alias="u"/>
</relationship>

-- sql server
WITH
    s AS (
        SELECT PARENT_TABLE
        FROM dwh_user.jv.CCF s
        WHERE s.PRODUCT_NAME = 'Business loan'
    ),
    u AS (
        SELECT TOP 1 PARENT_TABLE
        FROM dwh_user.jv.CCF_BAK u
        WHERE u.PRODUCT_NAME = 'Business loan'
    )
UPDATE s
SET s.PARENT_TABLE = u.PARENT_TABLE
FROM s
JOIN u ON 1 = 1

Data lineage of the third SQL statement in xml format generated by SQLFlow:

<relationship id="19" type="fdd" effectType="update" processId="5" processType="sstupdate">
    <target id="10" column="PARENT_TABLE" parent_id="4" parent_name="dwh_user.jv.CCF" parent_alias="s"/>
    <source id="24" column="PARENT_TABLE" parent_id="23" parent_name="dwh_user.jv.CCF_BAK" parent_alias="u"/>
</relationship>

原文地址：https://blog.csdn.net/qq_28822933/article/details/142900306

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！