如何使用 ssis 实现以下查询

Question

我们可以讨论如何将下面的查询结果加载到目标 table 中，使用 ssis.I 知道我们可以在 T-sql 中使用它，也可以将其用作 OLEDB 源 query.But还在想怎么实现，只用数据流组件

SELECT
     CLIENTID       = CAST(PER.CLIENTID AS INT)
    ,CASEID         = CAST(CS.CASEID AS INT)
    ,CAST(RIGHT(ev.oid, 10) as int) AS EventID
    ,ev.ServiceSubtypeCode
    ,ev.ServiceSubtypeCode  +' - '+ev.ServiceSubTypeDesc as ServiceSubTypeDesc
    ,WU.ProviderID as WorkunitProviderID
    ,WU.ProviderName as WorkUnitProviderName
    ,ev.eventstartdate as AssessmentStartDate
    ,CONVERT(CHAR(5),ASM.getstarttimestamp,8) as AssessmentStartTime
    ,ev.EVENTENDDATE as AssessmentEndDate
    ,ev.EVENTENDTIME as AssessmentEndTime
    ,CAST(asm.getAssmtTemplateName as nvarchar(200)) as AssessmentTypeDesc
    ,j.providerid
    ,j.ProviderName
    ,j.ProviderRole
    ,EV.ISCOMPLETED
    , EV.ISFINALISED 
    ,EV.ISREVOKED
    , EV.REVOKEDDATE AS REVOKEDDATE
    ,ASM.OID AS ASSESSMENTID

FROM DBO.ASSESSMENT ASM
LEFT OUTER JOIN DBO.INDIVIDUALPERSON PER        ON ASM.MYPERSON = PER.OID
LEFT OUTER JOIN DBO.[CASE] CS       ON ASM.MYCASE = CS.OID
LEFT OUTER JOIN (
                        SELECT CAST(ST.CODE AS VARCHAR(8))AS SERVICETYPECODE
                                , CAST(ST.DESCRIPTION AS VARCHAR(100)) AS SERVICETYPEDESC
                                , CAST(SST.CODE AS VARCHAR(8)) AS SERVICESUBTYPECODE
                                , CAST(SST.DESCRIPTION AS VARCHAR(100)) AS SERVICESUBTYPEDESC
                                , DATEADD(DD,0, DATEDIFF(DD,0,EV.GETRPSSTARTTIMESTAMP)) AS EVENTSTARTDATE
                                , CONVERT(CHAR(5),EV.GETRPSSTARTTIMESTAMP,8) AS EVENTSTARTTIME
                                , DATEADD(DD,0, DATEDIFF(DD,0,EV.GETRPSENDTIMESTAMP)) AS EVENTENDDATE
                                , CONVERT(CHAR(5),EV.GETRPSENDTIMESTAMP,8) AS EVENTENDTIME
                                ,CAST(VEN.DESCRIPTION AS VARCHAR(12)) AS EVENTVENUE
                                ,EV.ISCOMPLETED
                                , EV.ISFINALISED 
                                ,EV.ISREVOKED
                                , DATEADD(DD,0, DATEDIFF(DD,0,EV.REVOKEDON)) AS REVOKEDDATE 
                                , EV.OID 
                                        from Event ev
                                        LEFT OUTER JOIN     ServiceType AS st ON ev.myServiceType = st.oid 
                                        LEFT OUTER JOIN  ServiceSubtype AS sst ON ev.myServiceSubtype = sst.oid
                                        LEFT OUTER JOIN  AllCodes AS ven ON ev.myEventVenueCode = ven.oid 
                                     )as  EV
ON ASM.MYEVENT = EV.OID
LEFT OUTER JOIN     (
                                        select wu.oid
                                        ,CAST(wu.providerid AS VARCHAR(100)) AS providerid
                                        ,CAST(nm.getfullname AS VARCHAR(100)) AS ProviderName
                                        ,wu.contactname
                                        ,wu.activatedate as StartDate
                                        ,wu.deactivatedate as EndDate
                                        ,case when wu.deactivatedate is null then 1 else 0 end as IsActiveToday
                                        from workunitprovider wu
                                        LEFT OUTER JOIN  dbo.allprovidernames nm    ON wu.oid = nm.myprovider
                                        where nm.myNameType in (02245.0000000252)
                                    ) as WU
ON ASM.MYWORKUNITPROVIDER = WU.OID
Left join   (                   
                                select f.myEvent
                                ,f.myProvider
                                ,f.myproviderrolecode
                                ,f.Max_ProvOid
                                ,CAST(g.providerid AS VARCHAR(100)) AS providerid
                                ,CAST( i.description AS VARCHAR(150)) AS ProviderRole
                                ,cast (h.getFullName as nvarchar (150)) as ProviderName
                                    from(           select d.myEvent
                                                        ,myProvider
                                                        ,myproviderrolecode
                                                        ,d.Max_ProvOid
                                                         from (                 select  A.myEvent, max(b.oid) as Max_ProvOid
                                                                                    from alleventitems a
                                                                                    left outer join ProviderEventItemRole as b  on a.oid = b.myeventitem
                                                                                    group by A.myEvent
                                                                        ) as d
                                                                        left join 
                                                                        (                           select  A.myEvent,b.myProvider,b.myproviderrolecode,a.oid as a_oid,b.oid as b_oid
                                                                                                    from alleventitems a
                                                                                                    left outer join ProviderEventItemRole as b  on a.oid = b.myeventitem
                                                                        )as e on d.myevent = e.myevent and max_provOid = b_oid
                                ) as f
                                left join dbo.allproviders as g on f.myProvider = g.oid
                                left join (
                                                    select * 
                                                    from dbo.AllProviderNames 
                                                    where mynametype ='02245.0000000252'
                                                )as h on f.myprovider =h.myprovider
                                left join dbo.allcodes as i on f.myproviderrolecode = i.oid 
    )as j on ASM.myevent = j.myevent;

Answer 1

在我们开始之前，免责声明：

复杂的 SELECT 查询最好用 T-SQL 表示。 SSIS 最适合用于 ETL 任务。

现在...把那个挡在一边。让我们看看我们有什么。该查询有十五个 LEFT JOINS 嵌套在三个级别：五个在顶部，七个在中间，两个在底部。贯穿始终的是一些 CAST()s 和 GROUP BYs。所有这些 SQL 命令都可以使用 SSIS 组件完成。

JOIN = 合并联接组件。
GROUP BY = 聚合组件。
CAST = 派生列组件。

既然您有如此大的查询，我建议您将其分成更小的块。从最内层连接开始。

    select 
        d.myEvent
        ,myProvider
        ,myproviderrolecode
        ,d.Max_ProvOid
    from (                 
        select  A.myEvent, max(b.oid) as Max_ProvOid
        from alleventitems a
        left outer join ProviderEventItemRole as b  
        on a.oid = b.myeventitem
        group by A.myEvent
    ) as d
    left join (                           
        select  A.myEvent,b.myProvider,b.myproviderrolecode,a.oid as a_oid,b.oid as b_oid
        from alleventitems a
        left outer join ProviderEventItemRole as b  
        on a.oid = b.myeventitem
    ) as e

将其转换为 SSIS 将如下所示。

在上面，我们将四个表合并为一个。您可以了解有关如何配置合并连接的更多信息 here。对剩余的 JOINS 重复上述模式并将它们连接在一起，您将把整个查询转换为 SSIS！

现在我们可以看到如何它可以完成，请问我们为什么要在 SSIS 中这样做？

如何使用 ssis 实现以下查询

How to implement the below query using ssis

ssis

etl

ssis-2005

ssis-2008

ssis-2012