表輸入步驟用于將數(shù)據(jù)源的數(shù)據(jù)加載到Kettle轉(zhuǎn)換中的行集，可以說(shuō)是數(shù)據(jù)從持久化到內(nèi)存的一種加載變換，故名為輸入。加載內(nèi)部過(guò)程，就是通過(guò)JDBC連接到數(shù)據(jù)源執(zhí)行SQL語(yǔ)句，將返回結(jié)果解析為行集，傳遞給下一個(gè)步驟。注意，上文中數(shù)據(jù)源并不一定是關(guān)系數(shù)據(jù)庫(kù)，可以是任何支持JDBC驅(qū)動(dòng)的存儲(chǔ)方式，例如HadoopHive、Impala、LucidDB、SAP等。SQL語(yǔ)句可以固定不帶參數(shù)，也可以通過(guò)變量來(lái)進(jìn)行動(dòng)態(tài)替換；可以只執(zhí)行一次SQL，也可以根據(jù)輸入行數(shù)多次執(zhí)行SQL。步驟配置信息如圖1所示。

圖1：表輸入插件整體信息

下文詳細(xì)說(shuō)明各配置項(xiàng)的含義：

1、轉(zhuǎn)換步驟名稱(chēng)：步驟的名稱(chēng)，在單一的轉(zhuǎn)換中，名稱(chēng)必須唯一。2、數(shù)據(jù)庫(kù)連接：讀取數(shù)據(jù)的JDBC連接名稱(chēng)，右側(cè)第一個(gè)“編輯”可以對(duì)連接信息進(jìn)行編輯；第二個(gè)“新建”按鈕可以新建JDBC連接；第三個(gè)“向?qū)А卑粹o可以根據(jù)指引分步去建立連接。3、SQL：SQL 語(yǔ)句用來(lái)從數(shù)據(jù)庫(kù)連接中讀取數(shù)據(jù)，可以手動(dòng)在SQL框里面寫(xiě)出需要運(yùn)行的SQL語(yǔ)句；也可以在SQL框右上角點(diǎn)擊“獲取SQL查詢(xún)語(yǔ)句”按鈕，通過(guò)選擇模式與表來(lái)獲取表查詢(xún)語(yǔ)句。4、允許簡(jiǎn)易轉(zhuǎn)換：如勾選，則針對(duì)行集中的String類(lèi)型，將按照二進(jìn)制字節(jié)流的形式(如果讀者有Java語(yǔ)言開(kāi)發(fā)背景，可以理解為byte[])，從數(shù)據(jù)源讀取數(shù)據(jù)，性能比直接讀取字符串略高。所以，這里翻譯為“允許以字節(jié)流的形式讀取字符串”更為準(zhǔn)確。從實(shí)際測(cè)試情況看，該參數(shù)針對(duì)非常長(zhǎng)的字符串能夠提速3%左右；對(duì)于一般長(zhǎng)度的字符串，觀測(cè)不到差別。5、替換SQL語(yǔ)句里的變量：將SQL語(yǔ)句中的參數(shù)進(jìn)行位置與值的替換，值來(lái)自配置的輸入行集(第6個(gè)控件)。因此若此控件啟用，必須與第6、第7控件結(jié)合使用。例如第3個(gè)控件中的SQL語(yǔ)句改為select id,info,c_time from test1.table1 where id>? or info like ?，那么執(zhí)行SQL語(yǔ)句前，Kettle自動(dòng)將輸入行集中的第一個(gè)字段值替換為第一個(gè)問(wèn)號(hào)、第二個(gè)字段值替換為第二個(gè)問(wèn)號(hào)。所以務(wù)必確保位置對(duì)應(yīng)，且類(lèi)型匹配。6、從步驟插入數(shù)據(jù)：從輸入行集中選擇一個(gè)，作為第5個(gè)控件的數(shù)據(jù)來(lái)源。7、執(zhí)行每一行？：勾選之后，Kettle將對(duì)輸入行集中的每一行執(zhí)行一次第3個(gè)控件指定SQL，并將所有結(jié)果合并傳遞給后續(xù)步驟。8、記錄數(shù)量限制：設(shè)置從數(shù)據(jù)庫(kù)中讀取的最大行數(shù)。如果設(shè)置值≤0，那么將查詢(xún)所有記錄，不限制返回行數(shù)；如果設(shè)置其他值，則返回行數(shù)不超過(guò)設(shè)置值。備注：在信息框最下方有一個(gè)“預(yù)覽”按鈕，點(diǎn)擊之后可以顯示出根據(jù)當(dāng)前SQL查詢(xún)出來(lái)的結(jié)果，可以檢查是否符合預(yù)期。

內(nèi)部供稿 CCSAII037

總結(jié)

以上是生活随笔為你收集整理的kettle 表输入 显示重复_表输入插件详解的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。