// /**mysql的方式*/
// if(resourcein.getrtype().touppercase().equals("mysql"))
resultset resultset;
resultset = database.openquery(customsql);
listlist = new arraylist();
while(resultset.next())
return list;
}下面為引數1的屬性**
public class kettleresource implements serializable
/*** @param id
*/public void setid(integer id)
/*** 獲取資源庫描述
** @return r_name - 資源庫描述
*/public string getrname()
/*** 設定資源庫描述
** @param rname 資源庫描述
*/public void setrname(string rname)
/*** 獲取主機位址
** @return r_server - 主機位址
*/public string getrserver()
/*** 設定主機位址
** @param rserver 主機位址
*/public void setrserver(string rserver)
/*** 獲取資料庫型別
** @return r_type - 資料庫型別
*/public string getrtype()
/*** 設定資料庫型別
** @param rtype 資料庫型別
*/public void setrtype(string rtype)
/*** 獲取連線方式
** @return r_access - 連線方式
*/public string getraccess()
/*** 設定連線方式
** @param raccess 連線方式
*/public void setraccess(string raccess)
/*** 獲取資料庫名
** @return r_database - 資料庫名
*/public string getrdatabase()
/*** 設定資料庫名
** @param rdatabase 資料庫名
*/public void setrdatabase(string rdatabase)
/*** 獲取埠號
** @return r_port - 埠號
*/public integer getrport()
/*** 設定埠號
** @param rport 埠號
*/public void setrport(integer rport)
/*** 獲取使用者名稱
** @return r_username - 使用者名稱
*/public string getrusername()
/*** 設定使用者名稱
** @param rusername 使用者名稱
*/public void setrusername(string rusername)
/*** 獲取密碼
** @return r_password - 密碼
*/public string getrpassword()
/*** 設定密碼
** @param rpassword 密碼
*/public void setrpassword(string rpassword)
}
kettle 分頁抽數
1 分頁 2 變數設定 全域性 區域性 3 查詢總資料量，並設定變數 select count 1 total page from dmlog policy t where 1 1 and t.trans status in 0 3 and contractid between and and ri...
kettle鏈結hive的環境配置
1 首先將hive lib目錄的包匯入到kettle目錄d software data integration plugins pentaho big data plugin hadoop configurations cdh510 lib下 找到你安裝的目錄 2 找到d software data...
php傳參呼叫kettle指令碼
php 4,php 5,php 7 system 執行外部程式，並且顯示輸出 system string command,int return var string 同 c 版本的system 函式一樣，本函式執行command引數所指定的命令，並且輸出執行結果。如果 php 執行在伺服器模組中，s...