kettle6.0使用手册

1、- G SEviH-intugraAaan' F法自埴比政1- mr第k*H,ta上口 WFg 卜一审目女南二事正：1j装且为蛔产品lF:lj 野tW IGO即5哂4 ip9”jk XA、pirvp-i_i. 51岸CEA-Q Cartr.batCO描骷党国 EiHr.bitfl_ «ner.ih国 Impixtbjt而 gruh impart-ruhn-KTrJSI <>khlMtElxMnjhUCENSE.trt国轴nbslparish nlahaDar«»gritiDn_O£5_LK«nu_犯口M("O睡IM

2、trt REDME.UNUXJWi“ README_D£9CLe£_ READM(_UhilX_*WOw国 "<unSwnclMt :unEdmp«i.ah 工FlfEjIi中日rwJfe列日绢2Q1&WC1ME 2D1WIT I MT 2D1WH ISi JQ1国取仆i!M7督郎” 19 « aniwn imt 2D15/1J/3 1 汨1 3015/12/3 Udi aon/iz/i iui 201*1 和3 131 2015/12/H 1M1 a 口 1J 门卒 13U120115/3 13d1 2015/12/J 131

3、2011/123 1131 2D1S/12V3 13d1 2015/12/3 131 aniifi5q wi2015/12V3 11J3 和加¥ 1X130131 Z/3 19J1 2D1S/123 1 主312Q1加即3i同I 2D11fl2/3 1331 2D1S/13 13J1 2015/12/3111 3D13/1Z/3 13:1144个耳目 通El个底自u® DasDDR型的泪、田 2015/12/3 1J:11 即11内而13J1 2D15/1J/3 15=31 2015/12/3 Udi 30«/1273 1U1 2D15/1J/3 1M 20l5f

4、l£rt Ddl大小Sw*交修史stm势怏免修变S*MI.出EnHcvn ft5tflt-1胆SHX4t13WindM 峰理1 KB.1 KB,1 KBEHmt1 KBKML文件M RRWindow tt5t3-1 口EHlT«t1 KB-文蠢文修14 KB-Wind cw 1ttlit珏-1 KBEHltet1 KB.HTMLRM KB-a EH1 KBa*fia1 KB-文gl1 KB.Ei Sts1幅Vndwrt ItSt 拜.1 KB-EH文片1 KB科Endous就胜3g-5 KB5H fi*t4 KftWindtm 中电1-4 KB.CQ<MHAN口尺洋1

5、。裂5 KB-PNG fi«3 KB.讦1如fti码WindwM-tlEtH.n1 3WindM Et建理.2 KB.iH立安2 RRSHJW9Spoon -3K®用个产<1焦和 FIm* IriiiriMiaft v53 / 52Spoon -碘!文甘阳祠南祖囹B H向口导姿源库向导w -Hadocp Distribution.维n作业Capability ManagerShow plugin inffoinKnation.Marketplacene/indeK-hrtmlIntegraWelcomeMeet the FamilySelect the reposit

6、oiry typeMQSelect the rspositcry type to createSettle database repository ! This repository uses a central relational dtabse to store ETL metadata.Kettle file repo&itary : This is a repository stored in a file in a certain Felder取后.Qkettle/kettle确定I你谪唱要郭建逶个造源库在这个指定数据库"?Dry run?Do you want t

7、o do a dry run to evaluate the generated SQL before execution?建立数据交换数据库连接Spoan -向IE案列哂1五曲Fl “通版后二 上由NElil图B EHfctX 否 me口 54所：由10 H ,二日：!口 n3t«sa«iwwD拜师口 K.lLHIBm?«州口 Hadoop diMtini口 :眄如十七wrx_dc/wrx_dc数泥库连接蛇 加列裹 更量wrx_jw/wrx_jw数倨库连接集群学工资据套设宣W特征列裹更览wrx_xg/wrx_xgFwip«ci-kiK Rma Ir-i

8、Hriidan v，Spaon -傅通定班:牝帙1由金利充南Fi " E 和5 UI .Jt 且回巨a is > = 3t*iE- .- H II 口'界出 MSHS S * T 口 0a D Mfe* -a»'日军1M4国口 Uapii；V|口 H I WiS I口 EM甘区H-口刃mr-l K«HaVhatf>irr«i口出收由博D匕曲幺Drag & Drop a StepR顿（中加印+由glhk- - Repository creation/upgrade DDL:- - Nothing was created

9、nor modified in the target repository database.- - Hit the OK button to execute the generated SQL or Close to reject the changes.- - Please note that it is possible to change/edit the generated SQL before execution. -CREATE TABLE R_REPOSITORY_LOG(ID_REPOSITORY_LOG INTEGER, REP_VERSION VARCHAR2(255),

10、 LOG_DATE DATE, LOG_USER VARCHAR2(255), OPERATION_DESC CLOB, PRIMARY KEY (ID_REPOSITORY_LOG) );ALTER TABLE R_VERSION ADD ( UPGRADE_DATE_KTL DATE ) ; UPDATE R_VERSION SET UPGRADE_DATE_KTL=UPGRADE_DATE;ALTER TABLE R_VERSION DROP ( UPGRADE_DATE )JALTER TABLE R_VERSION ADD ( UPGRADE_DATE DATE ) ;UPDATE

11、R_VERSION SET UPGRADE_DATE=UPGRADE_DATE_KTL;ALTER TABLE R_VERSION DROP ( UPGRADE_DATE_KTL )JINSERT INTO R_VERSION(ID_VERSION, MAJOR_VERSION, MINOR_VERSION, UPGRADE_DATE, IS_UPGRADE) VALUES (1,5,0,TO_DATE('2016/08/20 10:16:49', 'YYYY/MM/DDHH24:MI:SS' ), 'N' );CREATE TABLE R_DA

12、TABASE_TYPE(ID_DATABASE_TYPE INTEGER, CODE VARCHAR2(255), DESCRIPTION VARCHAR2(255), PRIMARY KEY (ID_DATABASE_TYPE) ;INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (1, 'ORACLERDB' , 'Oracle RDB' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTIO

13、N) VALUES (2, 'INFINIDB' , 'Calpont InfiniDB');INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (3, 'INFOBRIGHT' , 'Infobright' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (4, 'PALO' , 'Palo MOLAP Server

14、' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (5, 'GENERIC' , 'Generic database' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES(6, 'AS/400', 'AS/400');INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESC

15、RIPTION) VALUES (7, 'SYBASEIQ' , 'SybaseIQ' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (8, 'HIVE2' , 'Hadoop Hive 2');INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (9, 'SQLITE' , 'SQLite' );INSER

16、T INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (10, 'DERBY' , 'Apache Derby' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (11, 'INFORMIX' , 'Informix' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) V

17、ALUES (12, 'INGRES' , 'Ingres' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (13, 'HIVE' , 'Hadoop Hive' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (14, 'IMPALASIMBA' , 'Cloudera Impala' );INSE

18、RT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (15, 'REMEDY-AR-SYSTEM' , 'Remedy Action Request System');INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (16, 'POSTGRESQL' , 'PostgreSQL' );INSERT INTO R_DATABASE_TYPE(ID_DATA

19、BASE_TYPE, CODE, DESCRIPTION) VALUES (17, 'SAPR3' , 'SAP ERP System' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (18, 'REDSHIFT' , 'Redshift' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (19, 'CACHE' ,

20、 'Intersystems Cache');INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (20, 'MSSQL' , 'MS SQL Server' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (21, 'TERADATA' , 'Teradata' );INSERT INTO R_DATABASE_TYPE(I

21、D_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (22, 'DB2' , 'IBM DB2' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (23, 'SQLBASE' , 'Gupta SQL Base' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (24, 'MYSQL'

22、 , 'MySQL' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (25, 'FIREBIRD' , 'Firebird SQL');INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (26, 'HYPERSONIC' , 'Hypersonic');INSERT INTO R_DATABASE_TYPE(ID_DATA

23、BASE_TYPE, CODE, DESCRIPTION) VALUES (27, 'MSACCESS' , 'MS Access' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (28, 'KINGBASEES' , 'KingbaseES' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (29, 'INTERBASE&

24、#39; , 'Borland Interbase');INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (30, 'VERTICA5' , 'Vertica 5+');INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (31, 'MSSQLNATIVE' , 'MS SQL Server (Native)');INSERT IN

25、TO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (32, 'EXASOL4' , 'Exasol 4');INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (33, 'EXTENDB' , 'ExtenDB' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (34

26、, 'KettleThin' , 'Pentaho Data Services');INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (35, 'OpenERPDatabaseMeta' , 'OpenERP Server' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (36, 'UNIVERSE' , 'Uni

27、Verse database' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (37, 'NEOVIEW' , 'Neoview');INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (38, 'LucidDB' , 'LucidDB');INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE,

28、CODE, DESCRIPTION) VALUES (39, 'SAPDB' , 'MaxDB (SAP DB)' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (40, 'VERTICA' , 'Vertica' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (41, 'DBASE' , 'dBase I

29、II, IV or 5');INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (42, 'H2' , 'H2' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (43, 'VECTORWISE' , 'Ingres VectorWise');INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE,

30、CODE, DESCRIPTION) VALUES (44, 'SYBASE' , 'Sybase' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (45, 'ORACLE' , 'Oracle');INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (46, 'MONDRIAN' , 'Native Mondria

31、n' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (47, 'NETEZZA' , 'Netezza' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES (48, 'IMPALA' , 'Impala' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIP

32、TION) VALUES (49, 'GREENPLUM' , 'Greenplum' );INSERT INTO R_DATABASE_TYPE(ID_DATABASE_TYPE, CODE, DESCRIPTION) VALUES(50, 'MONETDB' , 'MonetDB' );CREATE TABLE R_DATABASE_CONTYPE(ID_DATABASE_CONTYPE INTEGER, CODE VARCHAR2(255), DESCRIPTION VARCHAR2(255), PRIMARY KEY (I

33、D_DATABASE_CONTYPE) ;INSERT INTO R_DATABASE_CONTYPE(ID_DATABASE_CONTYPE, CODE, DESCRIPTION) VALUES (1, 'Native' , 'Native (JDBC)' );INSERT INTO R_DATABASE_CONTYPE(ID_DATABASE_CONTYPE, CODE, DESCRIPTION) VALUES (2, 'ODBC' , 'ODBC' );INSERT INTO R_DATABASE_CONTYPE(ID_DA

34、TABASE_CONTYPE, CODE, DESCRIPTION) VALUES (3, 'OCI' , 'OCI' );INSERT INTO R_DATABASE_CONTYPE(ID_DATABASE_CONTYPE, CODE, DESCRIPTION) VALUES (4, 'Plugin' , 'Plugin specific access method');INSERT INTO R_DATABASE_CONTYPE(ID_DATABASE_CONTYPE, CODE, DESCRIPTION) VALUES (5

35、, 'JNDI' , 'JNDI' );INSERT INTO R_DATABASE_CONTYPE(ID_DATABASE_CONTYPE, CODE, DESCRIPTION) VALUES (6, ',', 'Custom' );CREATE TABLE R_NOTE(ID_NOTE INTEGER, VALUE_STR CLOB, GUI_LOCATION_X INTEGER, GUI_LOCATION_Y INTEGER, GUI_LOCATION_WIDTH INTEGER, GUI_LOCATION_HEIGHT I

36、NTEGER, FONT_NAME CLOB, FONT_SIZE INTEGER, FONT_BOLD CHAR(1), FONT_ITALIC CHAR(1), FONT_COLOR_RED INTEGER, FONT_COLOR_GREEN INTEGER, FONT_COLOR_BLUE INTEGER, FONT_BACK_GROUND_COLOR_RED INTEGER, FONT_BACK_GROUND_COLOR_GREEN INTEGER, FONT_BACK_GROUND_COLOR_BLUE INTEGER, FONT_BORDER_COLOR_RED INTEGER,

37、FONT_BORDER_COLOR_GREEN INTEGER, FONT_BORDER_COLOR_BLUE INTEGER, DRAW_SHADOW CHAR(1), PRIMARY KEY (ID_NOTE) ;CREATE TABLE R_DATABASE(ID_DATABASE INTEGER, NAME VARCHAR2(255), ID_DATABASE_TYPE INTEGER, ID_DATABASE_CONTYPE INTEGER, HOST_NAME VARCHAR2(255), DATABASE_NAME CLOB, PORT INTEGER, USERNAME VAR

38、CHAR2(255), PASSWORD VARCHAR2(255), SERVERNAME VARCHAR2(255), DATA_TBS VARCHAR2(255), INDEX_TBS VARCHAR2(255), PRIMARY KEY (ID_DATABASE) ;CREATE TABLE R_DATABASE_ATTRIBUTE(ID_DATABASE_ATTRIBUTE INTEGER, ID_DATABASE INTEGER, CODE VARCHAR2(255), VALUE_STR CLOB, PRIMARY KEY (ID_DATABASE_ATTRIBUTE) ;CRE

39、ATE UNIQUE INDEX IDX_RDAT ON R_DATABASE_ATTRIBUTE(ID_DATABASE, CODE) ;CREATE TABLE R_DIRECTORY (ID_DIRECTORY INTEGER, ID_DIRECTORY_PARENT INTEGER, DIRECTORY_NAME VARCHAR2(255), PRIMARY KEY (ID_DIRECTORY) ;CREATE UNIQUE INDEX IDX_RDIR ON R_DIRECTORY(ID_DIRECTORY_PARENT, DIRECTORY_NAME) ;CREATE TABLE

40、R_TRANSFORMATION(ID_TRANSFORMATION INTEGER, ID_DIRECTORY INTEGER, NAME VARCHAR2(255), DESCRIPTION CLOB, EXTENDED_DESCRIPTION CLOB, TRANS_VERSION VARCHAR2(255), TRANS_STATUS INTEGER, ID_STEP_READ INTEGER, ID_STEP_WRITE INTEGER, ID_STEP_INPUT INTEGER, ID_STEP_OUTPUT INTEGER, ID_STEP_UPDATE INTEGER, ID

41、_DATABASE_LOG INTEGER, TABLE_NAME_LOG VARCHAR2(255), USE_BATCHID CHAR(1), USE_LOGFIELD CHAR(1), ID_DATABASE_MAXDATE INTEGER, TABLE_NAME_MAXDATE VARCHAR2(255), FIELD_NAME_MAXDATE VARCHAR2(255), OFFSET_MAXDATE NUMBER(12, 2), DIFF_MAXDATE NUMBER(12, 2), CREATED_USER VARCHAR2(255), CREATED_DATE DATE, MO

42、DIFIED_USER VARCHAR2(255), MODIFIED_DATE DATE, SIZE_ROWSET INTEGER, PRIMARY KEY (ID_TRANSFORMATION) ;CREATE TABLE R_TRANS_ATTRIBUTEID_TRANS_ATTRIBUTE INTEGER, ID_TRANSFORMATION INTEGER, NR INTEGER, CODE VARCHAR2(255), VALUE_NUM INTEGER, VALUE_STR CLOB, PRIMARY KEY (ID_TRANS_ATTRIBUTE) );CREATE UNIQU

43、E INDEX IDX_TATT ON R_TRANS_ATTRIBUTE(ID_TRANSFORMATION, CODE, NR)CREATE TABLE R_JOB_ATTRIBUTE(ID_JOB_ATTRIBUTE INTEGER, ID_JOB INTEGER, NR INTEGER, CODE VARCHAR2(255), VALUE_NUM INTEGER, VALUE_STR CLOB, PRIMARY KEY (ID_JOB_ATTRIBUTE);CREATE UNIQUE INDEX IDX_JATT ON R_JOB_ATTRIBUTE(ID_JOB, CODE, NR)

44、 ;CREATE TABLE R_DEPENDENCY(ID_DEPENDENCY INTEGER, ID_TRANSFORMATION INTEGER, ID_DATABASE INTEGER, TABLE_NAME VARCHAR2(255), FIELD_NAME VARCHAR2(255), PRIMARY KEY (ID_DEPENDENCY);CREATE TABLE R_PARTITION_SCHEMA(ID_PARTITION_SCHEMA INTEGER, NAME VARCHAR2(255), DYNAMIC_DEFINITION CHAR(1), PARTITIONS_P

45、ER_SLAVE VARCHAR2(255), PRIMARY KEY (ID_PARTITION_SCHEMA) ;CREATE TABLE R_PARTITION(ID_PARTITION INTEGER, ID_PARTITION_SCHEMA INTEGER, PARTITION_ID VARCHAR2(255), PRIMARY KEY (ID_PARTITION);CREATE TABLE R_TRANS_PARTITION_SCHEMA(ID_TRANS_PARTITION_SCHEMA INTEGER, ID_TRANSFORMATION INTEGER, ID_PARTITI

46、ON_SCHEMA INTEGER, PRIMARY KEY (ID_TRANS_PARTITION_SCHEMA) );CREATE TABLE R_CLUSTER(ID_CLUSTER INTEGER, NAME VARCHAR2(255), BASE_PORT VARCHAR2(255), SOCKETS_BUFFER_SIZE VARCHAR2(255), SOCKETS_FLUSH_INTERVAL VARCHAR2(255), SOCKETS_COMPRESSED CHAR(1), DYNAMIC_CLUSTER CHAR(1), PRIMARY KEY (ID_CLUSTER);

47、CREATE TABLE R_SLAVE(ID_SLAVE INTEGER, NAME VARCHAR2(255), HOST_NAME VARCHAR2(255), PORT VARCHAR2(255), WEB_APP_NAME VARCHAR2(255), USERNAME VARCHAR2(255), PASSWORD VARCHAR2(255), PROXY_HOST_NAME VARCHAR2(255), PROXY_PORT VARCHAR2(255), NON_PROXY_HOSTS VARCHAR2(255), MASTER CHAR(1), PRIMARY KEY (ID_

48、SLAVE);CREATE TABLE R_CLUSTER_SLAVE(ID_CLUSTER_SLAVE INTEGER, ID_CLUSTER INTEGER, ID_SLAVE INTEGER, PRIMARY KEY (ID_CLUSTER_SLAVE) );CREATE TABLE R_TRANS_SLAVE(ID_TRANS_SLAVE INTEGER, ID_TRANSFORMATION INTEGER, ID_SLAVE INTEGER, PRIMARY KEY (ID_TRANS_SLAVE);CREATE TABLE R_TRANS_CLUSTER(ID_TRANS_CLUS

49、TER INTEGER, ID_TRANSFORMATION INTEGER, ID_CLUSTER INTEGER, PRIMARY KEY (ID_TRANS_CLUSTER) );CREATE TABLE R_TRANS_HOP(ID_TRANS_HOP INTEGER, ID_TRANSFORMATION INTEGER, ID_STEP_FROM INTEGER, ID_STEP_TO INTEGER, ENABLED CHAR(1), PRIMARY KEY (ID_TRANS_HOP);CREATE TABLE R_TRANS_STEP_CONDITION(ID_TRANSFOR

50、MATION INTEGER, ID_STEP INTEGER, ID_CONDITION INTEGER);CREATE TABLE R_CONDITION(ID_CONDITION INTEGER, ID_CONDITION_PARENT INTEGER, NEGATED CHAR(1), OPERATOR VARCHAR2(255), LEFT_NAME VARCHAR2(255), CONDITION_FUNCTION VARCHAR2(255), RIGHT_NAME VARCHAR2(255), ID_VALUE_RIGHT INTEGER, PRIMARY KEY (ID_CON

51、DITION);CREATE TABLE R_VALUE(ID_VALUE INTEGER, NAME VARCHAR2(255), VALUE_TYPE VARCHAR2(255), VALUE_STR VARCHAR2(255), IS_NULL CHAR(1), PRIMARY KEY (ID_VALUE);CREATE TABLE R_STEP_TYPE(ID_STEP_TYPE INTEGER, CODE VARCHAR2(255), DESCRIPTION VARCHAR2(255), HELPTEXT VARCHAR2(255), PRIMARY KEY (ID_STEP_TYP

52、E)INSERT INTO R_STEP_TYPE(ID_STEP_TYPE, CODE, DESCRIPTION, HELPTEXT) VALUES(1, 'MappingInput' , ' 映射输入规范' , ' 指定一个映射的字段输入 ' );INSERT INTO R_STEP_TYPE(ID_STEP_TYPE, CODE, DESCRIPTION, HELPTEXT) VALUES(2, 'SystemInfo' , ' 获取系统信息' , ' 获取系统信息，例如时间、日期.' );I

53、NSERT INTO R_STEP_TYPE(ID_STEP_TYPE, CODE, DESCRIPTION, HELPTEXT) VALUES (3, 'OpenERPObjectOutputImport', 'OpenERP Object Output' , 'Writes data intoOpenERP objects using the object import procedure');INSERT INTO R_STEP_TYPE(ID_STEP_TYPE, CODE, DESCRIPTION, HELPTEXT) VALUES(4

54、, 'SASInput' , 'SAS 输入 ' , 'This step reads files in sas7bdat (SAS) native format' );INSERT INTO R_STEP_TYPE(ID_STEP_TYPE, CODE, DESCRIPTION, HELPTEXT) VALUES(5, 'GPBulkLoader' , 'Greenplum Bulk Loader', 'Greenplum Bulk Loader');INSERT INTO R_STEP_TYPE

55、(ID_STEP_TYPE, CODE, DESCRIPTION, HELPTEXT) VALUES (6, 'MergeJoin' , ' 记录集连接' , 'Joinstwo streams on a given key and outputsset. The input streams must be sorted on the join key');INSERT INTO R_STEP_TYPE(ID_STEP_TYPE, CODE, DESCRIPTION, HELPTEXT) VALUES (7, 'ExecSQLRow

56、9; , ' 执行 SQL 脚本 ( 字段流替换)' , 'Execute SQL script extracted from afield' |chr(13)| 'created in a previous step.');INSERT INTO R_STEP_TYPE(ID_STEP_TYPE, CODE, DESCRIPTION, HELPTEXT) VALUES (8, 'TableExists' , ' 检查表是否存在 ' , 'Check if a table exists on a speci

57、fied connection' );INSERT INTO R_STEP_TYPE(ID_STEP_TYPE, CODE, DESCRIPTION, HELPTEXT) VALUES(9, 'GetFileNames' , ' 获取文件名 ' , 'Get file names from the operating system them to the next step.');INSERT INTO R_STEP_TYPE(ID_STEP_TYPE, CODE, DESCRIPTION, HELPTEXT) VALUES(10, &#

58、39;SocketWriter' , 'Socket 写 ' , 'Socket writer. A socket server that can send rows of data to a socket reader.');INSERT INTO R_STEP_TYPE(ID_STEP_TYPE, CODE, DESCRIPTION, HELPTEXT) VALUES (11, 'MongoDbInput' , 'MongoDB Input' , 'Reads from a Mongo DB collectio

59、n'a joinedand send);INSERT INTO R_STEP_TYPE(ID_STEP_TYPE, CODE, DESCRIPTION, HELPTEXT) VALUES(12, 'Injector' , ' 记录注射 ' , 'Injector step to allow to inject rows into the);transformation through the java APIINSERT INTO R_STEP_TYPE(ID_STEP_TYPE, CODE, DESCRIPTION, HELPTEXT) VALUES (13, 'SingleThreader' , 'Single Threader&#