pentaho½éÉÜ

Éú³ÉµÄÎļþ¡£

8.4.2. ±íÊäÈ루table input£©

¸Ã×é¼þÓÃÀ´´ÓÊý¾Ý¿â»ñÈ¡ÐÅÏ¢¡£Ö÷ÒªµÄÊôÐÔÓÐÊý¾Ý¿âÁ¬½Ó¡¢sqlµÈ¡£ÔÚsqlÖпÉÒÔʹÓñäÁ¿£¬Èç¹ûʹÓÃÁ˱äÁ¿£¬Ôò±ØÐë¹´Ñ¡ÉÏ¡°Ìæ»»sql Óï¾äÖеıäÁ¿¡±Ñ¡Ï·ñÔò±äÁ¿²»ÄÜ´«È룬sqlÓï¾ä½«±¨´í¡£

¡°ÔÊÐíÑÓ³Ùת»»¡±Ñ¡Ïî¿ÉÒÔ±ÜÃâ²»±ØÒªµÄÊý¾ÝÀàÐÍת»»£¬¸ÄÉÆÊý¾Ý´¦ÀíÐÔÄÜ¡£ 8.4.3. »ñȡϵͳÐÅÏ¢£¨get systeminfo£© ¸Ã×é¼þÓÃÀ´»ñÈ¡kettle»·¾³ÖпÉÓõÄÐÅÏ¢¡£ 8.4.4. Ðз¢ÉúÆ÷£¨generaterows£©

²úÉú¶àÐУ¬¾ßÌå²úÉú¶àÉÙÐпÉÒÔͨ¹ýÉèÖÃlimit£¨ÏÞÖÆ£©À´×öÉ趨¡£¿ÉÒÔͨ¹ýfield(×Ö¶Î)ÁбíÀ´Ö¸¶¨×Ö¶ÎÃû³Æ¼°ÀàÐÍ¡£

8.4.5. ÊäÈ루De-serializefrom file£¬Ô­ÃûcubeÊäÈ룩 ´Ó¶þ½øÖƵÄkettlecubeÎļþÖжÁÈ¡¼Ç¼ÐÐÊý¾Ý¡£ 8.4.6. XBaseÊäÈë

ʹÓÃÕâÒ»²½¿ÉÒÔ¶ÁÈ¡´ó¶àÊý±»³ÆÎª XBase familyÅÉÉúµÄ DBFÎļþ¡£ 8.4.7. ExcelÊäÈë

¸Ã×é¼þ¿ÉÒÔ´ÓÒ»¸ö»ò¶à¸öexcelÎļþÖжÁÈ¡Êý¾Ý£¬¿ÉÒÔʹÓÃÕýÔò±í´ïʽÀ´Ö¸¶¨Îļþ¡£ 8.4.8. ²åÈë»ò¸üÐÂ(insert/update)

Õâ¸ö×é¼þÊ×ÏÈʹÓÃÒ»¸ö»ò¶à¸ö¶ÔÕÕkeyÀ´²éѯ±íÖеÄÒ»ÐУ¬Èç¹ûÕÒµ½£¬Ôò¸üУ¬Èç¹ûûÓÐÕÒµ½Ôò²åÈë¡£ Ñ¡Ïî

1¡¢²½ÖèÃû³Æ£º²½ÖèµÄÃû³Æ£¬ÔÚµ¥¸öת»»ÖбØÐëΨһ¡£ 2¡¢Á¬½Ó£ºÄ¿±ê±íËùÔÚµÄÊý¾Ý¿âÁ¬½ÓÃû³Æ¡£

3¡¢Target schema:ҪдÈëÊý¾ÝµÄ±íµÄ Schema Ãû³Æ¡£ ÔÊÐí±íÃûÖаüº¬ ¡°.¡±ÊǺÜÖØÒªµÄ¡£ 4¡¢Ä¿±ê±í£ºÏë²åÈë»òÕ߸üеıíµÄÃû³Æ¡£

5¡¢Commit size:Ìύ֮ǰҪ¸Ä±ä£¨²åÈë/¸üУ©µÄÐÐÊý¡£

6¡¢²»Ö´ÐÐÈκθüУºÈç¹û±»Ñ¡Ôñ£¬Êý¾Ý¿âµÄÖµÓÀÔ¶²»»á±»¸üС£½ö½ö¿ÉÒÔ²åÈë¡£ 7¡¢ÓÃÀ´²éѯµÄ¹Ø¼ü×Ö£º¿ÉÒÔÖ¸¶¨×Ö¶ÎÖµ»òÕ߱ȽϷû¡£¿ÉÒÔÓÃÒÔϱȽϷû£º=£¬ <>,<,<=,>,LIKE,BETWEEN,ISNULL,IS NOT NULL¡£ 8¡¢¸üÐÂ×ֶΣºÖ¸¶¨ÄãÏëÒª²åÈë/¸üеÄ×Ö¶Î 8.4.9. ¸üУ¨Update£©

Õâ¸ö²½ÖèÀàËÆÓÚ²åÈë/¸üв½Ö裬³ýÁ˶ÔÊý¾Ý±í²»×÷²åÈë²Ù×÷Ö®Íâ¡£Ëü½ö½öÖ´ÐиüвÙ×÷¡£ 8.4.10. ɾ³ý(Delete)

Õâ¸ö²½ÖèÀàËÆÓÚÉÏÒ»²½£¬³ýÁ˲»¸üвÙ×÷¡£ËùÓеÄÐоù±»É¾³ý¡£ 8.4.11. XML Êä³ö£¨XMLoutput£©

Õâ¸ö²½ÖèÔÊÐíÄã´ÓÔ´ÖÐдÈëÐе½Ò»¸ö»òÕß¶à¸ö XML Îļþ¡£ Ñ¡Ïî

8.4.12. Êý¾Ý¿â²éѯ(Databaselookup) Õâ¸ö²½ÖèÀàÐÍÔÊÐíÄãÔÚÊý¾Ý¿â±íÖвéÕÒÖµ¡£ Ñ¡Ïî

²½ÖèÃû³Æ£ºÔÚµ¥Ò»×ª»»Öв½ÖèÃû³Æ±ØÐëΨһ¡£ Êý¾Ý¿âÁ¬½Ó£ºÏëҪдÈëÊý¾ÝµÄÁ¬½Ó¡£ ²éѯ±í£ºÏëÒª²éѯµÄ±íÃû¡£

ʹÓûº´æ£ºÊý¾Ý¿â²éѯÊÇ·ñʹÓûº´æ¡£ÕâÒâζ×ÅÔÚijÖÖ²éѯֵµÄÌõ¼þÏ£¬Ã¿´ÎÊý¾Ý

¿â¶¼ÄÜ·µ»ØÍ¬ÑùµÄ½á¹û¡£

8.4.13. Á÷²éѯ£¨Streamlookup£©

Õâ¸ö²½ÖèÀàÐÍÔÊÐíÄã´ÓÆäËü²½ÖèÖвéѯÐÅÏ¢¡£Ê×ÏÈ£¬ ¡°Ô´²½Ö裨lookup step£©¡±µÄÊý¾Ý±»¶Áµ½ÄÚ´æÖУ¬

È»ºó±»ÓÃÀ´´ÓÖ÷ÒªµÄÁ÷ÖвéѯÊý¾Ý¡£ Ñ¡Ïî

²½ÖèÃû³Æ£ºÔÚµ¥¸öת»»Öв½ÖèÃû±ØÐëΨһ¡£ Ô´²½Ö裺Êý¾ÝÀ´Ô´µÄ²½ÖèÃû³Æ

²éѯֵËùÐèÒªµÄ¹Ø¼ü×Ö£ºÔÊÐíÄãÀ´Ö¸¶¨ÓÃÀ´²éѯֵµÄ×Ö¶ÎÃû³Æ¡£Öµ×ÜÊÇÓá°µÈÓÚ¡± ±È½Ï·ûÀ´ËÑË÷¡£

½ÓÊÕµÄ×ֶΣºÄã¿ÉÒÔÖ¸¶¨ÓÃÀ´½ÓÊÕ×ֶεÄÃû³Æ£¬»òÕßÔÚֵûÓÐÕÒµ½µÄÇé¿öϵÄȱʡ Öµ£¬»òÕßÄ㲻ϲ»¶¾ÉµÄ×Ö¶ÎÃû³ÆµÄÇé¿öϵÄÐÂ×Ö¶ÎÃû³Æ Preserve Memory:ÅÅÐòµÄʱºò¶ÔÊý¾ÝÐнøÐбàÂëÒÔ±£»¤ÄÚ´æ

Key and value are exactly one integer field: ÅÅÐòµÄʱºò¶ÔÊý¾ÝÐнøÐбàÂë ÒÔ±£»¤ÄÚ´æ

Use sorted list:ÊÇ·ñÓÃÒ»¸öÅÅÐòÁбíÀ´´æ´¢Öµ£¬ËüÌṩ¸üºÃµÄÄÚ´æÊ¹ÓᣠÕâ¸ö²½ÖèµÄʹÓÃÀàËÆÓÚÊý¾Ý¿â²éѯ²½Öè£¬Çø±ðÔÚÓÚÊý¾Ý¿â²éѯʹÓõÄÊÇÊý¾Ý¿â±í£¬¶øÁ÷²éѯÊÇ´ÓÎı¾ÎļþµÈÊý¾ÝÁ÷Öвéѯ¡£

8.4.14. µ÷ÓÃÊý¾Ý¿â´æ´¢¹ý³Ì(Call DBProcedure)

Õâ¸ö²½ÖèÔÊÐíÄãÔËÐÐÒ»¸öÊý¾Ý¿â´æ´¢¹ý³Ì£¬»ñÈ¡·µ»Ø½á¹û¡£ 8.4.15. ×Ö¶ÎÑ¡Ôñ£¨selectvalue£©

¸Ã×é¼þ¶ÔÓÚÑ¡Ôñ¡¢ÖØÃüÃû»òÐÞ¸Ä×ֶεij¤¶ÈºÍ¾«¶È·½ÃæºÜÓÐÓá£Õ⼸·½Ãæ±»·ÅÔÚÁ˲»Í¬µÄcategoryÖУ¬ÔÚ×é¼þÉÏ·Ö±ð·ÅÔÚ²»Í¬µÄtabÖС£ 8.4.16. ¹ýÂ˼Ǽ(Filterrows)

Õâ¸ö²½ÖèÔÊÐíÄã¸ù¾ÝÌõ¼þºÍ±È½Ï·ûÀ´¹ýÂ˼Ǽ¡£

Ò»µ©Õâ¸ö²½ÖèÁ¬½Óµ½ÏÈǰµÄ²½ÖèÖУ¬Äã¿ÉÒÔ¼òµ¥µÄµ¥»÷¡°¡± £¬ ¡°=¡±ºÍ¡°¡± ÇøÓòÀ´¹¹½¨Ìõ¼þ¡£ Ñ¡Ïî

²½ÖèÃû³Æ£º²½ÖèµÄÃû³Æ£¬ÔÚµ¥Ò»×ª»»ÖбØÐëΨһ¡£ ¼¼Êõ×ÊÁÏ£¬ ¡¾Kette3.0Óû§Êֲ᡿ ·¢ËÍ¡°true¡±Êý¾Ý¸ø²½Ö裺ָ¶¨Ìõ¼þ·µ»Ø trueµÄÊý¾Ý½«·¢Ë͵½´Ë²½Öè¡£ ·¢ËÍ¡°false¡±Êý¾Ý¸ø²½Ö裺ָ¶¨Ìõ¼þ·µ»Ø false µÄÊý¾Ý½«·¢Ë͵½´Ë²½Öè¡£ 8.4.17. ¿Õ²Ù×÷£¨Ê²Ã´Ò²²»×ö£©£¨dummy(do nothing)£© ¸Ã×é¼þʲôҲ²»×ö£¬Ö»ÊÇÓÃÀ´×öһЩ²âÊÔʱµÄռλ·û¡£ 8.4.18. Row DeNormalizer(ÐÐתÁÐ)

¸Ã×é¼þ×öÐÐתÁС£ÔÚ¡°¹¹³É·Ö×éµÄ×ֶΡ±ÖÐÖ¸¶¨·Ö×é×ֶΣ¬ÔÚ¡°Ä¿±ê×ֶΡ±ÖÐÖ¸¶¨¡°Ä¿±ê×ֶΡ±µÄÃû³Æ£¬Ä¿±ê×ֶεÄÖµ×ֶΣ¨´ÓÄĸö×Ö¶ÎÖлñȡֵ£©ºÍ¡°¹Ø¼ü×ÖÖµ¡±¡£ÈçÏÂͼËùʾµÄÑùÀý£º

8.4.19. ÁÐתÐУ¨Rownormaliser£© ÓÃÓÚ½«ÁÐתÐÐ ÀýÈçϱíµÄÊý¾Ý

ת»»³ÉϱíËùʾµÄÊý¾Ý

Row normaliser²½ÖèµÄÉèÖÃÈçÏÂͼ 8.4.20. ²ð·Ö×ֶΣ¨split field£©

»ùÓÚÖ¸¶¨µÄ·Ö¸î·ûÐÅÏ¢½øÐÐ×ֶβð·Ö¡£ 8.4.21. È¥ÖØ£¨Unique Rows£©

´ÓÊäÈëÁ÷ÖÐÈ¥³ýÖØ¸´µÄ¼Ç¼¡£ÐèҪȷ±£ÊäÈëÁ÷ÊÇÅÅÁËÐòµÄ£¬·ñÔòÖ»ÓÐÏàÁÚÁ¬ÐøµÄ¼Ç¼»áÈ¥ÖØ¡£

8.4.22. ·Ö×飨group by£©

Õâ¸ö×é¼þÓÃÀ´¸ù¾ÝÒ»×é·Ö×é×ֶνøÐмÆËã¡£ Ñ¡Ïî

²½ÖèÃû³Æ£º²½ÖèµÄÃû³Æ£¬ÔÚµ¥Ò»×ª»»ÖбØÐëΨһ¡£ ·Ö×é×ֶΣºÖ¸¶¨·Ö×éµÄ×ֶΡ£

¾ÛºÏ£ºÖ¸¶¨ÐèÒª¾ÛºÏµÄ×ֶΡ¢·½·¨ÒÔ¼°ÐÂ×ֶνá¹ûµÄÃû³Æ

°üº¬ËùÓеÄÐУºÈç¹ûÑ¡ÔñÕâ¸ö£¬Êä³öÖоͰüº¬ËùÓеÄÐУ¬²»½ö½öÊǾۺϡ£ ÁÙʱÎļþĿ¼£ºÁÙʱÎļþ´æ´¢µÄĿ¼¡£

ÁÙʱÎļþǰ׺£ºÖ¸¶¨ÃüÃûÁÙʱÎļþʱµÄÎļþÎļþǰ׺¡£

Ìí¼ÓÐкţ¬Ã¿Ò»¸ö·Ö×éÖØÆô£ºÈç¹ûÄãÏëÌí¼ÓÐкţ¬¾ÍÑ¡ÔñÕâ¸ö¡£ ×Ö¶ÎÃûÐÐÊý£ºÖ¸¶¨ÐкŽ«²åÈëµÄ×ֶεÄÃû³Æ¡£ 8.4.23. ÉèÖÃΪ¿ÕÖµ(Null if)

Èç¹ûij¸ö×Ö·û´®µÄÖµµÈÓÚÖ¸¶¨µÄÖµ£¬ÉèÖÃÄǸöֵΪ¿Õ¡£ 8.4.24. ¼ÆËãÆ÷£¨Calculator£©

Õâ¸ö²½ÖèÌṩһ¸ö¹¦ÄÜÁÐ±í£¬¿ÉÒÔÔÚ×Ö¶ÎÖµÉÏÔËÐС£

¼ÆËãÆ÷µÄÒ»¸öÖØÒªÓÅÊÆÊÇ£¬ËüÓÐ׿¸±¶ÓÚ³£ÓÃµÄ JavaScript ½Å±¾µÄËÙ¶È¡£ 8.4.25. ÐÐ±âÆ½»¯£¨flattener£©

Õâ¸ö²Ù×÷ÀàËÆÐÐתÁУ¨·Ö×é×ֶΣ¬¶ÔijһÁнøÐÐÐÐתÁУ© 8.4.26. ÖµÓ³É䣨value mapper£©

¸Ã×é¼þ½«Öµ´ÓÒ»¸öÖµÓ³Éäµ½ÁíÒ»¸öÖµ¡£Í¨³£ÄãÏë½â¾ö´æ´¢Ò»¸öÊý¾Ý¿âÖÐת»»±íµÄÎÊÌâ,²»¹ÜÔõô˵£¬ÕâÊÇÒ»ÖÖ¿ÉÑ¡µÄ·½°¸£º¼òµ¥µÄ½«×ª»»±í×÷ΪֵӳÉä¶Ô»°¿òµÄÒ»²¿·Ö¡£ ÀýÈ罫1Ó³ÉäΪÄУ¬0Ó³ÉäΪŮµÈ¡£

8.4.27. Êý¾Ý¿âÁ¬½Ó£¨DatabaseJoin£©

Õâ¸ö²½ÖèÔÊÐíÄãʹÓÃÏÈǰ²½ÖèµÄÊý¾Ý£¬ÔËÐÐÒ»¸öÊý¾Ý¿â²éѯ¡£ Äܹ»Ö¸¶¨²éѯ²ÎÊý£º

ÔÚ SQL ²éѯÖÐʹÓá°£¿¡±

ÔÚ SQL ²éѯÖÐʹÓÃÊý¾ÝÍø¸ñÖеÄ×Ö¶Î

8.4.28. ºÏ²¢¼Ç¼£¨Merge rows£© ¸Ã×é¼þ¿ÉÒÔÓÃÀ´±È½ÏÁ½¸ö¼Ç¼Á÷¡£¶ÔÓڱȽÏÁ½¸ö²»Í¬Ê±¼äµãµÄ¼Ç¼Á÷ÊǺÜÓÐÓõġ£³£Ê¹ÓÃÔÚûÓаüº¬×îºó¸üÐÂʱ¼äµÄÊý¾Ý²Ö¿âԴϵͳ״̬ÖС£Á½¸ö¼Ç¼Á÷£¬²ÎÕÕÁ÷ºÍ±È½ÏÁ÷½øÐкϲ¢£¬¼Ç¼µÄ×îºó¸üа汾Êý¾Ý±»´«¸øÏÂÒ»¸ö×é¼þ£¬¼Ç¼±»±ê¼ÇΪ£º identical ¨C ÔÚÁ½¸öÁ÷Öж¼·¢ÏÖÁËkey£¬²¢ÇÒÖµÊÇÒ»Öµġ£

changed¡ªÔÚÁ½¸öÁ÷Öж¼·¢ÏÖÁËkey£¬µ«ÊÇÒ»¸ö»ò¶à¸öÖµ²»Ò»Ö¡£ new ¨CkeyÔÚ²ÎÕÕÁ÷£¨¾ÉÊý¾ÝÔ´£©ÖÐûÓз¢ÏÖ

deleted ¨C keyÔڱȽÏÁ÷£¨ÐÂÊý¾ÝÔ´£©ÖÐûÓз¢ÏÖ¡£

³ýÁËdeleted״̬Çé¿ö£¬±È½ÏÁ÷µÄÊý¾Ý´«µ½ÏÂÒ»¸ö×é¼þÖС£ ÐèҪעÒâµÄÊÇ£¬Á½¸öÁ÷¶¼ÐèÒªÔÚÖ¸¶¨µÄkeyÉÏÅÅÐò¡£ 8.4.29. Merge join

¶ÔÁ½¸ö²»Í¬µÄÊäÈë×é¼þµÄÊý¾Ý¼¯×öºÏ²¢¹ØÁª¡£¹ØÁªÀàÐÍ¿ÉÒÔÊÇÄÚÁª¡¢×óÍâÁª¡¢ÓÒÍâÁªºÍÈ«Íâ

Áª¡£

ÐèҪעÒâµÄÊÇ£¬ºÏ²¢joinµÄÊý¾Ý¼Ç¼ÐèÒªÔÚÖ¸¶¨µÄkeyÉÏ×öÅÅÐò¡£ 8.4.30. Java Script Öµ£¨JavaScript Value£©

Õâ¸ö²½ÖèÔÊÐíÄãÓÃJavaScript ÓïÑÔ×ö¸´ÔÓµÄÔËË㡣ʹÓÃµÄ JavaScript ÒýÇæÊÇ Rhino 1.5R5¡£ Ñ¡Ïî

²½ÖèÃû³Æ£º²½ÖèµÄÃû³Æ£¬ÔÚµ¥¸öת»»ÖбØÐëΨһ Java Script:²½ÖèÖеĽű¾¡£

×ֶΣºÒªÌí¼Óµ½Êä³öÁ÷ÖеÄ×ֶΡ£ 8.4.31. Excute SQL Script

¿ÉÒÔʹÓøÃ×é¼þÖ´ÐÐsql ½Å±¾¡£¿ÉÒÔÔÚÕû¸öTransformation³õʼ»¯ÖÐÖ´ÐÐÒ»´Î£¨Ò»°ãÕâÖÖÇé¿öÓÃÓÚDDLÓï¾ä£©»òÔÚûÊäÈë¸Ã×é¼þÒ»ÐмǼʱִÐÐÒ»´Î£¨ÕâÖÖÇé¿öÒ»°ãÓÃÓÚ´ø²ÎµÄDMLÓï¾ä£©¡£

×¢Ò⣺Èç¹ûsqlÓï¾äÖеĽű¾Ê§°Ü£¬Õû¸öTransformationµÄÖ´Ðн«¹ÒÆð¡£ 8.4.32. ά¶È¸üÐÂ/²éѯ£¨dimensionlookup/update£©

¸Ã×é¼þÔÊÐíÄãÖ´ÐÐRalphkimballµÄÁ½À໺Âý±ä»¯Î¬£ºµÚÒ»Àࣨupdate£©ºÍµÚ¶þÀࣨinsert£©¡£Ê¹ÓøÃ×é¼þ²»½ö¿ÉÒÔ¸üÐÂά±í£¬»¹¿ÉÒÔ²éѯά±íÖµ¡£ 8.4.33. OracleÅúÁ¿×°ÔØ£¨Oraclebulk loader£©

Õâ¸ö²½ÖèÔÊÐíÄã´óÅúÁ¿¼ÓÔØÊý¾Ýµ½ Oracle Êý¾Ý¿â£¬Ëü½«ÓÃÒ»¸öÕýÈ·µÄ×°ÔØ¸ñʽ£¬È»ºó Óà OracleµÄ SQL*Loader Êý¾Ý¼ÓÔØ¹¤¾ß¼ÓÔØµ½Ö¸¶¨µÄ±íÖС£ Ñ¡Ïî

²½ÖèÃû³Æ£º²½ÖèµÄÃû³Æ£¬ÔÚµ¥¸öת»»ÖбØÐëΨһ¡£ Á¬½Ó£ºÎ¬±íËùÔÚÊý¾Ý¿âµÄÁ¬½Ó¡£

Ä¿±êschema: ҪдÈëÊý¾ÝµÄ±íµÄ schema Ãû³Æ£¬±íÃûÖпÉÒÔ°üº¬¡±.¡±¡£ Sqlldr path: SQL*Loader Êý¾Ý¼ÓÔØ¹¤¾ßµÄȫ·¾¶¡£

×°ÔØ·½Ê½: ¡°×Ô¶¯¼ÓÔØ¡±»òÕß¡°ÊÖ¶¯¼ÓÔØ¡± ¡£Èç¹ûÊÇ¡°×Ô¶¯¼ÓÔØ¡±£¬²½Ö轫ÔÚÓÃÖ¸ ¶¨µÄ²ÎÊýÊÕµ½ËùÓеÄÊäÈëºóÔËÐÐSqlldr ¹¤¾ß¡£Èç¹ûÊÇ¡°ÊÖ¶¯¼ÓÔØ¡± £¬½«Éú³ÉÒ»¸ö¿É ÒÔ×÷ΪºóÃÅʹÓõĿØÖƺÍÊý¾ÝÎļþ¡£

¼ÓÔØ¶¯×÷£ºAppend¡¢Insert¡¢Replace¡¢Truncate¡£ÕâЩ»áÓ³Éäµ½ sqlddr µÄ¶¯×÷ À´Ö´ÐС£

´íÎóµÄ×î´óÐÐÊý£º·¢Éú´íÎóµÄÐÐÊý£¬Õâʱ sqlldr ½«±»Öжϡ£Óë sqlldr µÄ¡°ERROR¡± ÊôÐÔÀ´Í¨ÐÅ¡£

Ìá½»£ºÌá½»µÄÐÐÊý£¬Óësqlldr µÄ¡°ROWS¡±ÊôÐÔͨÐÅ¡£ °ó¶¨´óС£ºÓë sqlldr µÄ¡°BINDSIZE¡±ÊôÐÔͨÐÅ¡£ ¶ÁÈ¡´óС£ºÓë sqlldr µÄ¡°READSIZE¡±ÊôÐÔͨÐÅ¡£ ¿ØÖÆÎļþ£ºsqlldr ¿ØÖÆÎļþµÄÃû³Æ¡£

Êý¾ÝÎļþ£ºÊý¾Ý½«±»Ð´ÈëµÄÊý¾ÝÎļþµÄÃû³Æ¡£ ÈÕÖ¾Îļþ£ºÈÕÖ¾ÎļþµÄÃû³Æ£¬¿ÉÑ¡¡£ »µÎļþ£º»µÎļþµÄÃû³Æ£¬¿ÉÑ¡¡£ ·ÏÎļþ£º·ÏÎļþµÄÃû³Æ£¬¿ÉÑ¡¡£

±àÂ룺Êý¾ÝÖ¸¶¨µÄ±àÂë¸ñʽ£¬¿ÉÒÔ´ÓÏÂÀ­Áбí¿òÖÐÑ¡Ôñ¡£

Ö±½Ó·¾¶£ºÖ±½Ó·¾¶¼ÓÔØµÄ¿ª¹Ø£¬Óë sqlldr µÄ¡°DIRECT=TRUE¡±Í¨ÐÅ¡£ ʹÓúóɾ³ýcfg/dat Îļþ£º¼ÓÔØºóÊÇ·ñɾ³ý¿ØÖÆÎļþºÍÊý¾ÝÎļþµÄ¿ª¹Ø¡£ ±í×ֶΣºORACLE ±íÖмÓÔØµÄ±í×ֶΡ£

Á÷×ֶΣºÊäÈëÐÐÖдøÀ´µÄ×ֶΡ£ 8.4.34. ÔËÐв½ÖèµÄ¶à¸ö¸±±¾

ÓÒ¼üµ¥»÷ÿ¸öTransformation²½ºó¶¼»á³öÏÖÒ»¸ö²Ëµ¥¡°¸Ä±ä¿ªÊ¼¸´ÖƵÄÊýÁ¿¡±£¬¿ÉÒÔÉèÖÃÕâ¸ö¸´ÖƵÄÊýÁ¿£¬Õâ¸ö¶ÔÓÚ¡°Êý¾Ý¿â²éѯ¡±×é¼þÀ´Ëµ£¬¿ÉÒÔÌá¸ßÆäÖ´ÐеÄЧÂÊ¡£µ«Èç¹û¶ÔÓÚÆäËûµÄ×é¼þ£¬½«Ê¹Êä³ö½á¹û¼Ç¼Êý·­±¶£¬ÐèÒªÌØ±ð×¢Òâ¡£ÁíÍ⣬¶ÔÓÚ¡°Êý¾Ý¿â²éѯ¡±×é¼þ£¬Èç¹ûǰһ×é¼þ²ÉÓá°Êý¾ÝÇ¨ÒÆ¡±ÊÇ¡°¸´ÖƵ½ÏÂÒ»²½¡±¶ø²»ÊÇ¡°·¢Ë͵½ÏÂÒ»²½¡±Ò²»áÔì³É¡°Êý¾Ý¿â²éѯ¡±×é¼þµÄÊä³ö¼Ç¼·­±¶¡£ 8.4.35. ÎÊÌ⼯

1¡¢ ÔÚ¡°±íÊäÈ롱×é¼þÖУ¬ÈçºÎ´ÓÉÏÒ»²½ÖлñµÃÊý¾ÝÌæ»»sqlÓï¾äÖеIJÎÊý£¿ 2¡¢

8.5 ÈÎÎñÌõÄ¿£¨Job Entries£© 8.5.1 ͼ±ê 8.5.2 Start

Start ÊÇÈÎÎñÖ´ÐеÄÈë¿Ú£¬Ê×ÏȱØÐëÊÇÈÎÎñ¿ÉÒÔÖ´ÐС£Ö»ÓÐÎÞÌõ¼þµÄÈÎÎñÌõÄ¿¿ÉÒÔ´Ó Start Èë¿ÚÁ¬½Ó¡£

8.5.3 Dummy

ÔÚÒ»¸öÈÎÎñÖÐʹÓà DummyÌõÄ¿½«Ê²Ã´Ò²²»×ö¡£Õâ¿ÉÒÔʹһ¸öÈÎÎñ¸üÇåÎúµÄչʾ£¬»òÕßÔÚ Ö´ÐÐÑ­»·ÖÐʹÓá£

8.5.4 ת»»

Äã¿ÉÒÔÓÃÒ»¸öת»»ÈÎÎñÌõĿִÐÐÒ»¸öÏÈǰ¶¨ÒåµÄת»»¡£ Ñ¡Ïî

8.5.5 ÈÎÎñ(Job)

Äã¿ÉÒÔʹÓà Job ÌõÄ¿À´ÔËÐÐÒ»¸öÏÈǰ¶¨ÒåµÄÈÎÎñ¡£ 8.5.6 Shell

Äã¿ÉÒÔʹÓà Shell ÈÎÎñÌõÄ¿ÔÚÈÎÎñÔËÐеÄÖ÷»úÉÏÖ´ÐÐÒ»¶Î Shell ½Å±¾¡£

±¸×¢£ºShell ½Å±¾ÄÜÔÚ¿ØÖÆÌ¨´°¿ÚÊä³öÎı¾£¬Êä³ö½«×ª»»µ½ Kettle ÈÕ־ϵͳ£¬Õâ²»»á Ó°Ïì Shell½Å±¾µÄÔËÐС£

±¸×¢£º Windows ϵͳ£¬ ½Å±¾±» ¡°CMD.EXE/C¡± £¨NT/XP/20000£© »ò ¡°COMMAND.COM/C¡± £¨95/98£©¡£

8.5.7 Mail

Äã¿ÉÒÔʹÓà Mail ÈÎÎñÌõÄ¿À´·¢ËÍ e-Mail¡£ 8.5.8 SQL

Äã¿ÉÒÔʹÓà SQL ÈÎÎñÌõĿִÐÐ SQL ½Å±¾£¬¶àÐнű¾Ö®Ç°Óá°;¡±¸ô¿ª¡£ 8.5.9 FTP

Äã¿ÉÒÔʹÓà FTP ÈÎÎñÌõÄ¿´Ó FTP ·þÎñÆ÷ÉÏ»ñȡһ¸ö»òÕß¶à¸öÎļþ¡£ 8.5.10 Table Exists

Äã¿ÉÒÔʹÓà TableexistsÈÎÎñÌõÄ¿¼ìÑéÊý¾Ý¿âÖÐÊÇ·ñ´æÔÚij¸ö±í¡£ 8.5.11 File Exists

Äã¿ÉÒÔʹÓÃFileexistsÈÎÎñÌõÄ¿¼ìÑéÔÚKettleÔËÐеķþÎñÆ÷ÉÏÖÐÊÇ·ñ´æÔÚij¸öÎļþ¡£ 8.5.12 Evaluation(javascript)

Äã¿ÉÒÔʹÓÃEvaluation ÈÎÎñÌõÄ¿À´¼ÆËãÒ»¸ö²¼¶ûÐ͵ıäÁ¿£¬Õâ¸ö±äÁ¿¿ÉÒÔÔÚ¾ö¶¨ÏÂÒ» ¸ö²½ÖèÊÇ·ñ½«±»Ö´ÐÐʱʹÓá£Óû§¿ÉÒÔʹÓÃÒÔϱäÁ¿£º

ÁªÏµ¿Í·þ£º779662525#qq.com(#Ìæ»»Îª@) ËÕICP±¸20003344ºÅ-4