使用 CASE 作为 dblink 的一部分来获取数据

Posted

技术标签:

【中文标题】使用 CASE 作为 dblink 的一部分来获取数据【英文标题】:Using CASE as part of a dblink to get data 【发布时间】:2019-01-07 16:37:55 【问题描述】:

我正在尝试使用 CASE 从带有子查询的 dblink 返回值。但是,结果并没有显示我所期望的。它不是遍历每个 WHEN,而是从第一个 WHEN 返回值(即使它不符合条件)。我确定这与我在子查询中使用 CASE 的方式有关。

我自己运行了子查询,它返回了预期的结果。

select su.shp_filter as "User_Type", su.shp_access_id as "RAD_ID", su.shp_name as "User_Name", rg.rad_stu_level as "Student_Level",
case
    when su.shp_filter = 'STU' then 
        case
            when rgd.rad_goal_value like 'HP%' then 'HP'
            when rgd.rad_goal_value like 'AS%' then 'AS'
            when rgd.rad_goal_value like 'BU%' then 'BU'
            when rgd.rad_goal_value like 'ED%' then 'ED'
            when rgd.rad_goal_value like 'TE%' then 'TE'
            when rgd.rad_goal_value like 'UN%' then 'UN'
            when rgd.rad_goal_value like 'KE%' then 'KE'
            when rgd.rad_goal_value like 'PH%' then 'PH'
            when rgd.rad_goal_value like 'OP%' then 'OP'
            when rgd.rad_goal_value like 'CP%' then 'CP'
        end
    when su.shp_filter in ('ADV','REG','DEAN','DEPT','ATHL') then
        case
            when exists (select pebempl.pebempl_orgn_code_home, su.shp_access_id, spriden.spriden_id from pebempl@dblink pebempl
            join spriden@gold.ferris.edu spriden
            on pebempl.pebempl_pidm=spriden.spriden_pidm
            join DWSCHEMA.SHP_USER_MST su
            on substr(su.shp_access_id,1,8) = substr(spriden.SPRIDEN_ID,1,8)
            where spriden.spriden_change_ind is null
            and pebempl.pebempl_orgn_code_home like '11%') then 'Office 1'
            when exists (select pebempl.pebempl_orgn_code_home, su.shp_access_id, spriden.spriden_id from pebempl@dblink pebempl
            join spriden@gold.ferris.edu spriden
            on pebempl.pebempl_pidm=spriden.spriden_pidm
            join DWSCHEMA.SHP_USER_MST su
            on substr(su.shp_access_id,1,8) = substr(spriden.SPRIDEN_ID,1,8)
            where spriden.spriden_change_ind is null
            and pebempl.pebempl_orgn_code_home like '21%') then 'Office 2'
            when exists (select pebempl.pebempl_orgn_code_home, su.shp_access_id, spriden.spriden_id from pebempl@dblink pebempl
            join spriden@gold.ferris.edu spriden
            on pebempl.pebempl_pidm=spriden.spriden_pidm
            join DWSCHEMA.SHP_USER_MST su
            on substr(su.shp_access_id,1,8) = substr(spriden.SPRIDEN_ID,1,8)
            where spriden.spriden_change_ind is null
            and pebempl.pebempl_orgn_code_home like '22%') then 'Office 3'
            when exists (select pebempl.pebempl_orgn_code_home, su.shp_access_id, spriden.spriden_id from pebempl@dblink pebempl
            join spriden@gold.ferris.edu spriden
            on pebempl.pebempl_pidm=spriden.spriden_pidm
            join DWSCHEMA.SHP_USER_MST su
            on substr(su.shp_access_id,1,8) = substr(spriden.SPRIDEN_ID,1,8)
            where spriden.spriden_change_ind is null
            and pebempl.pebempl_orgn_code_home like '31%') then 'Academic Affairs'
end "College"

【问题讨论】:

这是一个 Oracle 数据库,我正在使用 Toad。 您的很多查询都丢失了...这是故意的吗? CASE 语句之一缺少其 END。 它只能让我粘贴这么多。在 END "College" 之前,实际上有一个未包含在上述代码中的 END。 【参考方案1】:

哦 - 我想我看到了你的问题。您的 exists 子查询根本没有加入您的外部查询,因此它们总是返回数百行。如果将 SHP_USER_MST 的每个实例重命名为 su1、su2、su3 等,这将更加清楚:

when su.shp_filter in ('ADV','REG','DEAN','DEPT','ATHL') then
    case
        when exists (select pebempl.pebempl_orgn_code_home, su1.shp_access_id, spriden.spriden_id from pebempl@dblink pebempl
            join spriden@gold.ferris.edu spriden
            on pebempl.pebempl_pidm=spriden.spriden_pidm
            join DWSCHEMA.SHP_USER_MST su1 
            on substr(su1.shp_access_id,1,8) = substr(spriden.SPRIDEN_ID,1,8)
            where spriden.spriden_change_ind is null
            and pebempl.pebempl_orgn_code_home like '11%') then 'Office 1'
        when exists (select pebempl.pebempl_orgn_code_home, su2.shp_access_id, spriden.spriden_id from pebempl@dblink pebempl
            join spriden@gold.ferris.edu spriden
            on pebempl.pebempl_pidm=spriden.spriden_pidm
            join DWSCHEMA.SHP_USER_MST su2 
            on substr(su2.shp_access_id,1,8) = substr(spriden.SPRIDEN_ID,1,8)
            where spriden.spriden_change_ind is null
            and pebempl.pebempl_orgn_code_home like '21%') then 'Office 2'

如果您看这里,子查询中的任何内容都没有引用 su 中的当前行 - 因此您正在检查您的子查询中是否存在任何用户。他们总是这样做,所以它总是返回“Office 1”。

我想你想要的东西更像

when su.shp_filter in ('ADV','REG','DEAN','DEPT','ATHL') then
    case
        when exists (select pebempl.pebempl_orgn_code_home, su.shp_access_id, spriden.spriden_id from pebempl@dblink pebempl
            join spriden@gold.ferris.edu spriden
            on pebempl.pebempl_pidm=spriden.spriden_pidm
            where spriden.spriden_change_ind is null
            and substr(su.shp_access_id,1,8) = substr(spriden.SPRIDEN_ID,1,8) -- Link subquery to outer query
            and pebempl.pebempl_orgn_code_home like '11%') then 'Office 1'
        when exists (select pebempl.pebempl_orgn_code_home, su.shp_access_id, spriden.spriden_id from pebempl@dblink pebempl
            join spriden@gold.ferris.edu spriden
            on pebempl.pebempl_pidm=spriden.spriden_pidm
            where spriden.spriden_change_ind is null
            and substr(su.shp_access_id,1,8) = substr(spriden.SPRIDEN_ID,1,8) -- Link subquery to outer query
            and pebempl.pebempl_orgn_code_home like '21%') then 'Office 2'
...etc

我认为这对你有用,但作为一个额外的建议,我认为你也可以重写该部分以提高效率和可读性。

case (select substr(min(pebempl.pebempl_orgn_code_home),1,2) from pebempl@dblink pebempl
        join spriden@gold.ferris.edu spriden
        on pebempl.pebempl_pidm=spriden.spriden_pidm
        where spriden.spriden_change_ind is null
        and substr(su.shp_access_id,1,8) = substr(spriden.SPRIDEN_ID,1,8))
    when '11' then 'Office 1'
    when '21' then 'Office 2'
    when '22' then 'Office 3'
    when '31' then 'Academic Affairs'
end

【讨论】:

成功了。它还减少了查询的长度,这很好。我以为我尝试过类似的方法,但显然没有。

以上是关于使用 CASE 作为 dblink 的一部分来获取数据的主要内容,如果未能解决你的问题,请参考以下文章

如何检查Case When Statement中的重复值

可以使用 PostgreSQL 类型来定义 dblink 表吗?

使用 CASE 条件作为结果值

同义词或查看 dblink

iBATIS 和 dblink?

expdp 只导出dblink