Informatica 常用组件使用方法

常用组件使用方法表1中列出的是informatica中的所有组件。不会在本文档中出现的会在组件名后标出。表1AggregatorActive/ConnectedPerformsaggregatecalculations.ApplicationSourceQualifierActive/ConnectedRepresentstherowsthattheIntegrationServicereadsfromanapplication,suchasanERPsource,whenitrunsasession.CustomActiveorPassive/ConnectedCallsaprocedureinasharedlibraryorDLL.ExpressionPassive/ConnectedCalculatesavalue.ExternalProcedurePassive/ConnectedorUnconnectedCallsaprocedureinasharedlibraryorintheCOMlayerofWindows.FilterActive/ConnectedFiltersdata.HTTPTransformationPassive/ConnectedConnectstoanHTTPservertoreadorupdatedata.InputPassive/ConnectedDefinesmappletinputrows.AvailableintheMappletDesigner.JavaActiveorPassive/ConnectedExecutesuserlogiccodedinJava.Thebytecodefortheuserlogicisstoredintherepository.JoinerActive/ConnectedJoinsdatafromdifferentdatabasesorflatfilesystems.LookupPassive/ConnectedorUnconnectedLooksupvalues.NormalizerActive/ConnectedSourcequalifierforCOBOLsources.Canalsouseinthepipelinetonormalizedatafromrelationalorflatfilesources.OutputPassive/ConnectedDefinesmappletoutputrows.AvailableintheMappletDesigner.RankActive/ConnectedLimitsrecordstoatoporbottomrange.RouterActive/RoutesdataintomultipletransformationsbasedonConnectedgroupconditions.SequenceGeneratorPassive/ConnectedGeneratesprimarykeys.SorterActive/ConnectedSortsdatabasedonasortkey.SourceQualifierActive/ConnectedRepresentstherowsthattheIntegrationServicereadsfromarelationalorflatfilesourcewhenitrunsasession.SQLActiveorPassive/ConnectedExecutesSQLqueriesagainstadatabase.StoredProcedurePassive/ConnectedorUnconnectedCallsastoredprocedure.TransactionControlActive/ConnectedDefinescommitandrollbacktransactions.UnionActive/ConnectedMergesdatafromdifferentdatabasesorflatfilesystems.UpdateStrategyActive/ConnectedDetermineswhethertoinsert,delete,update,orrejectrows.XMLGeneratorActive/ConnectedReadsdatafromoneormoreinputportsandoutputsXMLthroughasingleoutputport.XMLParserActive/ConnectedReadsXMLfromoneinputportandoutputsdatatooneormoreoutputports.XMLSourceQualifierActive/ConnectedRepresentstherowsthattheIntegrationServicereadsfromanXMLsourcewhenitrunsasession.Lookup概要描述获得一个关联的值。例如：源里包含employeeID，但你还需要employeename。用于计算的植。例如：只是汇率或者个人所得税之类的固定数值，不是计算得出来的数据。Updateslowlychangingdimensiontables。主要是根据条件查出原表，若查出了，就把自己添加的标志位设为真，否则就设置为假。ConnectedorunconnectedConnected和unconnected的transformations的输入和输出是不同的，不同点如表2列出的。表2ConnectedLookupUnconnectedLookup从pipeline获得输入。从另一个transformation的:LKP的表达式获得输入。使用静态或者动态cache。使用静态cache。Cache中包括所有的mapping中使用到的lookupcolumns（就是condition中的和被标记为输出的columns）。Cache中包括所有condition中的、被标记为输出的columns以及被标记为returnport的。同行能够返回多个columns或者加载到动态lookupcache中。每行只能返回一个returnport(R)。如果没有匹配的数据，IntegrationService会返回一个默认值。如果是动态缓存（cache），会加入一个新的行或者放着他不管。如果没有匹配的数据，IntegrationService会返回一个NULL。如果有匹配的数据，IntegrationService回返回一个结果包括所有被设置为输出的值。如果是动态缓存，IntegrationService会任意的修改一行或者放着它不管。如果有匹配的数据，IntegrationService会返回一个被设置为returnport的值。输出所有的被标记为output的符合条件的数据。返回一个值到使用:LKP调用它的表达式。用户可以设置默认值。用户不可以设置默认值。Connected下面是IntegrationService处理connectedLookuptransformation的过程：1.一个connectedLookuptransformation通过pipeline从其他的transformation获得输入值。2.为每个输入行，IntegrationService会通过lookupports和condition从源或者缓存中查询。3.如果组件没有使用缓存或者使用的静态缓存，IntegrationService会使用lookupquery来返回值。4.如果组件使用的动态缓存，当IntegrationService在缓存找不到这行，它会把这行插入到缓存中。当IntegrationService找到这行，它会修改这行在缓存中或者什么都不做。它标记这行是插入、修改或者是不做变动。5.IntegrationService从查询中返回值到下一个transformation。如果transformation使用动态缓存，你可以把这行通过Filter或者Routertransformation来过滤后在到目标中。unconnected你可以在一个mapping中调用这个Lookuptransformation多次。下面的步骤描述了IntegrationService处理一个unconnectedLookuptransformation的过程：1.一个unconnectedLookuptransformation从另一个transformation的一个:LKP表达式的结果中获得输入值，例如一个UpdateStrategytransformation。2.IntegrationService通过transformation中的lookupports和condition来查询。3.IntegrationService返回一个值到Lookuptransformation的returnport中。4.IntegrationService把值返回到:LKP表达式中。步骤1.添加inputports。2.添加查询条件。3.指定返回值。4.从其他的组件中调用该lookup。用途unconnectedlookups多数用于：1.在一个表达式测试一个lookup的值。2.在查询的基础上过滤。3.标记行基于查询的结果，例如：updatingslowlychangingdimensiontables。4.调用同一个查找多次在一个mapping中。Relationalorflatfilelookup当你在建立一个Lookuptransformation时，你可以选择查询flatfile或者relationaltable。Relational你可以通过SQL的来override默认的SQL，这样可以你可以加where或者查询多个表。flatfile使用下面选项在使用flatfile时：1.指定源是indirectfiles的。2.使用sorted输入。Tips使用这些技巧在你配置一个Lookuptransformation的时候：给被用于查询条件的列加一个索引。把=号放在条件的第一位。查询的时候，完全加载小的表。在数据库中Jointables比使用查询要高校的多。为静态cache设置固定的大小。使用:LKP来调用unconnectedLookuptransformations。Cachedoruncached有时，你可以在使用lookup组件查询表的时候，把组件设置成Cached的来提高session的速度。如果你选择了Cached，你可以选择使用动态的还是静态的。默认的是使用静态的。Cached我们可以在一个lookup组件中为要查询的表配置cache。当第一行数据进入lookup组件的时候，IntegrationService会在内存为它建立一个cache。它分配内存基于你在组件或者session的属性中配置的数量。IntegrationService把条件值保存索引cache，把output值保存在数据cache。IntegrationService会为每一条进入这个组件的行查询cache。IntegrationService也同样会建立cachefiles用$PMCacheDir（相对路径，在consol中可以配置）中默认的。如果数据不适合内存cache时，IntegrationService把超出的数据保存到cachefiles中。当seesion结束，IntegrationService会释放cache记忆和删除cachefiles，除非你配置组件使用持久化的cache。如果你使用flatfilelookup，IntegrationService总是会把它放在cache中。如果你配置flatfilelookup为sortedinput，IntegrationService不会把它放