//生成文件名（我这里是生成了具体的文件夹名，不知道的话可以遍历取）
Calendar cal=Calendar.getInstance();
cal.add(Calendar.DATE,-1);
Date date = cal.getTime();
String fileName = "test"+ DateUtils.format(date,"yyyyMMdd") + ".txt";
//连接ftp服务器
ftpClient.setConnectTimeout(1000 * 30);
ftpClient.connect(host);
ftpClient.login(userName,passWord);
//这个要加不然会出现一个问题，好像是乱码的问题导致找不到对应的文件
ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
//获取响应code，连接失败就关闭
int replyCode = ftpClient.getReplyCode();
if (!FTPReply.isPositiveCompletion(replyCode)) {
ftpClient.disconnect();
//这个要加不然会出现一个问题，好像是乱码的问题导致找不到对应的文件
ftpClient.enterLocalPassiveMode();
//获取文件流
InputStream is = ftpClient.retrieveFileStream(fileName);
//使用字节流处理
BufferedReader br = new BufferedReader(new InputStreamReader(is));
//将每行数据放入list
List
> list = new ArrayList<>();
String s;
int line = 1;
String[] keys = null;
//不为空就一直读，其中要跳过不要的
while((s = br.readLine()) != null) {
if (line <= 2) {
if(line == 2)keys = s.split("\\|");
line++;
continue;
if (s.contains("111") || s.contains("111")) continue;
//切割str
String[] values = s.split("\\|");
Map record = new HashMap<>();;
for (int i = 0; i < values.length; i++) {
record.put(StringUtil.trimAll(keys[i]),StringUtil.trimAll(values[i]));
list.add(record);
//遍历插入数据库
for (Map tradeRecord : list){
//这里写自己的业务逻辑
//关闭流
br.close();
} catch (Exception e) {
e.printStackTrace();
} finally {
if (ftpClient.isConnected()) {
try {
//关闭ftp连接
ftpClient.disconnect();
} catch (IOException ioe) {
{ FTPClient ftpClient = new FTPClient(); try { //生成文件名（我这里是生成了具体的文件夹名，不知道的话可以遍历取） Calendar cal=Calendar.getInstance(); cal.add(Calendar.DATE,-1); Date date = cal.getTime(); String fileName = "test"+ DateUt...
因为有个导入
数据
的需求，要求是从
ftp
服务器找到
文件
，并将
文件
读到
数据库
的临时表中。
所以写了一个工具类。（注：字段间是用’,‘隔开的）
[code="
java
"]
import
java
.io.BufferedReader;
import
java
.io.FileNotFoundException;
import
java
.io.IOException;
import jav...
背景说明： 某b/s系统，支持用户上传图片
文件
等附件
文件
，上传后的
文件
存到了某一个web服务器的特定路径下，然后
数据库
的表里面记录了web访问的url路径和
文件
在本地物理磁盘存储的路径，这里不考虑
文件
服务器、对象存储等来讲对于小项目来讲是够用的。
数据库
表的结构示例为
file_id
file_url
file_path
http://x.x.x.x/static/xxx.jpg
d:/xxx/xxx/xxx.jpg
http://x.x.x.x/static/
最近公司要使用kettle从另一台服务器上的
ftp
上下载txt
文件
到本地 然后将
数据
插入
到
数据库
中
ftp
的目录是动态的 每天都会生成一个时间目录 如20180510
文件
就放在这下面 我们
文件
名是不变的 所以整个kjb的思路就是先
获取
动态时间作为变量在
ftp
组件中使用 下载到本地后 清空表（我们是全量导入 所以清空） 然后再导入
数据
折腾了半天 特此记录
首先 ...
这个实践其实不难，主要是有一个地方要注意，就是
文件
名通配符的写法，如果
文件
名格式为“TRANS_yyyymmdd.txt”，如TRANS_20081101.txt。如果想匹配所有以TRANS开头的文本
文件
，在kettle中要写成这样：TRANS_.*[0-9].txt。
最后在windows操作系统中配置定时任务就可以定期执行该Job了。
Job的图：
[img]http://www...
利用kettle实现从
数据库
获取
数据
生成Excel上传到
ftp
中文目录下新建一个转换，设置一个变量用来生成
文件
名再建一个转换，从
数据库
获取
当日
数据
，生成Excel到本地。因为用户要求上传到
ftp
的中文目录下，用kettle的
ftp
上传组件一直有乱码问题，所以这里采用了shell脚本的方式。然后再创建作业最后再建一个bat
文件
用于执行windows定时任务。
工作中有个简单的需求，需要每天把
数据库
的...
@ConfigurationProperties(prefix = "
ftp
.server")
@Data
public class
Ftp
PropertiesConfig {
* IP地址
private String host;
从
FTP
服务器下载TXT
文件
传到
数据库
服务器并导入需要以下步骤：
1. 首先，需要在
FTP
服务器上找到目标TXT
文件
，登录
FTP
服务器并定位到目标
文件
所在的目录。
2. 然后，需要将TXT
文件
下载到本地计算机。使用
FTP
客户端，连接到
FTP
服务器并下载TXT
文件
。
3. 下一步，将TXT
文件
上传到
数据库
服务器。通过
文件
传输协议（
FTP
或其他），将下载的TXT
文件
传输到
数据库
服务器。
4. 现在，可以将TXT
文件
导入
数据库
。使用
数据库
管理系统，打开表格编辑器并选择要导入的表格。
5. 然后，选择导入选项并选择TXT
文件
。确认
文件
字段与
数据库
表格字段匹配，并按照提示进行设置。
6. 最后，导入TXT
文件
。检查
数据
是否正确导入，如果出现问题，排除错误并重试。
以上就是从
FTP
服务器下载TXT
文件
传到
数据库
服务器并导入的步骤。这个过程需要熟悉
FTP
和
数据库
管理的相关技术，同时需要仔细检查和
处理
任何错误或异常。
CSDN-Ada助手:
插入数据成功但是数据库无变化
lllllliiiiisssa:
获得包下所有类命
秃了也弱了。:
