1.將jar包導入到kettle的lib目錄

下載地址：https://mvnrepository.com/artifact/jcifs/jcifs/1.3.17

2.建立轉換

java代碼如下：

import java.io.BufferedInputStream; import java.io.BufferedOutputStream; import java.io.File; import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream;import org.slf4j.Logger; import org.slf4j.LoggerFactory;import jcifs.smb.NtlmPasswordAuthentication; import jcifs.smb.SmbFile; import jcifs.smb.SmbFileInputStream; import jcifs.smb.SmbFileOutputStream;public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException {if (first) {first = false;}Object[] r = getRow();if (r == null) {setOutputDone();return false;}// It is always safest to call createOutputRow() to ensure that your output row's Object[] is large// enough to handle any new fields you are creating in this step.r = createOutputRow(r, data.outputRowMeta.size());//我的代碼//smb://xxx:xxx/xxxx.xlsx //xxx:xxx是共享機器的用戶名密碼try{smbGet("smb://xxx:xxx/xxxx.xlsx", "D:/");} catch (Exception e){}putRow(data.outputRowMeta, r);return true; }/*** @Title smbGet* @Param shareUrl 共享目錄中的文件路徑，如smb://xxx:xxx/xxxx.xlsx* @Param localDirectory 本地目錄，如D:/*/ public static void smbGet(String shareUrl, String localDirectory) throws Exception {String USER_DOMAIN = null;String USER_ACCOUNT = null;String USER_PWS = null;NtlmPasswordAuthentication auth = new NtlmPasswordAuthentication(USER_DOMAIN, USER_ACCOUNT,USER_PWS);SmbFile remoteFile = new SmbFile(shareUrl, auth);if (!remoteFile.exists()) {return;}// 有文件的時候再初始化輸入輸出流InputStream in = null;OutputStream out = null;try {String fileName = remoteFile.getName();File localFile = new File(localDirectory + File.separator + fileName);File fileParent = localFile.getParentFile();if (null != fileParent && !fileParent.exists()) {fileParent.mkdirs();}in = new BufferedInputStream(new SmbFileInputStream(remoteFile));out = new BufferedOutputStream(new FileOutputStream(localFile));byte[] buffer = new byte[1024];while (in.read(buffer) != -1) {out.write(buffer);buffer = new byte[1024];}out.flush(); //刷新緩沖區輸出流} catch (Exception e) {e.printStackTrace();} finally {out.close();in.close();}}/*** * @Title smbPut* @Description 向共享目錄上傳文件* @Param shareDirectory 共享目錄* @Param localFilePath 本地目錄中的文件路徑* @date 2019-01-10 20:16*/public static void smbPut(String shareDirectory, String localFilePath) {InputStream in = null;OutputStream out = null;try {File localFile = new File(localFilePath);String fileName = localFile.getName();SmbFile remoteFile = new SmbFile(shareDirectory + "/" + fileName);in = new BufferedInputStream(new FileInputStream(localFile));out = new BufferedOutputStream(new SmbFileOutputStream(remoteFile));byte[] buffer = new byte[1024];while (in.read(buffer) != -1) {out.write(buffer);buffer = new byte[1024];}out.flush();} catch (Exception e) {e.printStackTrace();} finally {try {out.close();in.close();} catch (IOException e) {e.printStackTrace();}}}

java代碼參考：

https://www.cnblogs.com/tianhyapply/p/3721381.html

總結

以上是生活随笔為你收集整理的kettle下载windows共享文件夹到本地的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。