写一个java代码,读取mysql数据库的表数据,输出txt文件,文件名以现在的日期改为YYYYMMDD的格式,以逗号为字段分隔符,换行符为/r/n,写入远程ftp文件系统的wj目录中
时间: 2023-09-23 17:06:43 浏览: 239
### 回答1:
以下是一个读取 MySQL 数据库表数据并将其写入 FTP 服务器文件系统的 Java 代码示例。代码使用了 MySQL 的官方 JDBC 驱动程序,以及 Apache Commons Net 库来处理 FTP 操作。
```java
import java.io.*;
import java.sql.*;
import org.apache.commons.net.ftp.*;
public class MysqlToFtp {
public static void main(String[] args) {
// MySQL 数据库连接参数
String url = "jdbc:mysql://localhost:3306/mydatabase";
String user = "myusername";
String password = "mypassword";
String tableName = "mytable";
// FTP 服务器连接参数
String ftpServer = "ftp.example.com";
String ftpUser = "ftpuser";
String ftpPassword = "ftppassword";
String ftpPath = "/wj/";
// 获取当前日期
java.util.Date today = new java.util.Date();
java.text.SimpleDateFormat sdf = new java.text.SimpleDateFormat("yyyyMMdd");
String dateStr = sdf.format(today);
// 文件名
String fileName = dateStr + ".txt";
try {
// 连接 MySQL 数据库
Connection conn = DriverManager.getConnection(url, user, password);
// 查询数据库表数据
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("SELECT * FROM " + tableName);
// 创建输出流
FileWriter fw = new FileWriter(fileName);
// 写入表头
ResultSetMetaData metaData = rs.getMetaData();
int columnCount = metaData.getColumnCount();
for (int i = 1; i <= columnCount; i++) {
fw.write(metaData.getColumnLabel(i));
if (i < columnCount) {
fw.write(",");
}
}
fw.write("\r\n");
// 写入数据
while (rs.next()) {
for (int i = 1; i <= columnCount; i++) {
fw.write(rs.getString(i));
if (i < columnCount) {
fw.write(",");
}
}
fw.write("\r\n");
}
// 关闭输出流和数据库连接
fw.close();
conn.close();
// 上传文件到 FTP 服务器
FTPClient ftpClient = new FTPClient();
ftpClient.connect(ftpServer);
ftpClient.login(ftpUser, ftpPassword);
ftpClient.changeWorkingDirectory(ftpPath);
FileInputStream fis = new FileInputStream(fileName);
ftpClient.storeFile(fileName, fis);
ftpClient.logout();
ftpClient.disconnect();
// 删除本地文件
File file = new File(fileName);
file.delete();
} catch (Exception e) {
e.printStackTrace();
}
}
}
```
在代码中,您需要替换以下值以使其适应您的环境:
- `url`:MySQL 数据库连接字符串,需要包括数据库名称和端口号。
- `user` 和 `password`:MySQL 数据库登录凭据。
- `tableName`:要读取数据的 MySQL 数据表名称。
- `ftpServer`:FTP 服务器主机名或 IP 地址。
- `ftpUser` 和 `ftpPassword`:FTP 服务器登录凭据。
- `ftpPath`:要将文件上传到的 FTP 服务器目录。
此代码还假设您已经在本地安装了 MySQL 的 JDBC 驱动程序和 Apache Commons Net 库,并且已将它们添加到您的项目依赖项中。
### 回答2:
下面是一个使用Java代码从MySQL数据库读取表数据,并将其写入txt文件,文件名为当前日期的YYYYMMDD格式,字段分隔符为逗号,换行符为/r/n,并将其写入远程ftp文件系统的wj目录中的示例代码:
```java
import java.io.FileWriter;
import java.io.IOException;
import java.sql.*;
import java.text.SimpleDateFormat;
import java.util.Date;
public class MySQLToTxt {
public static void main(String[] args) {
// MySQL数据库连接信息
String url = "jdbc:mysql://localhost:3306/database_name";
String username = "root";
String password = "password";
// 文件保存路径
String filePath = "C:/ftp/wj/";
// 获取当前日期
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMdd");
String currentDate = dateFormat.format(new Date());
// 创建连接
try (Connection connection = DriverManager.getConnection(url, username, password)) {
// 执行查询语句
String sql = "SELECT * FROM table_name";
try (Statement statement = connection.createStatement();
ResultSet resultSet = statement.executeQuery(sql)) {
// 创建文件写入流
FileWriter fileWriter = new FileWriter(filePath + currentDate + ".txt");
// 遍历结果集
while (resultSet.next()) {
// 获取每个字段值
String column1 = resultSet.getString("column1");
String column2 = resultSet.getString("column2");
// 写入txt文件,使用逗号分隔字段,使用/r/n作为换行符
fileWriter.write(column1 + "," + column2 + "\r\n");
}
// 关闭文件写入流
fileWriter.close();
}
} catch (SQLException | IOException e) {
e.printStackTrace();
}
}
}
```
请注意将代码中的 `database_name` 替换为你的数据库名称,`table_name` 替换为你的表名,`localhost:3306` 替换为你的数据库地址和端口,`root` 替换为你的数据库用户名,`password` 替换为你的数据库密码。
同时将 `C:/ftp/wj/` 替换为你希望保存txt文件的目录路径。
此代码将使用MySQL Connector/J驱动连接到MySQL数据库,读取指定表的数据,并将数据逐行写入指定目录下的txt文件中。完成后,你可以通过FTP将生成的txt文件上传到远程文件系统的 `wj` 目录中。
请注意,你需要事先导入MySQL Connector/J驱动到你的Java项目中,以及有FTP上传文件的权限和配置。
### 回答3:
首先,需要引入相关的 Java 库,如 `mysql-connector-java` 和 `commons-net`。
```java
import java.io.BufferedWriter;
import java.io.FileWriter;
import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.Date;
import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
public class MySQLToTxtAndFTP {
public static void main(String[] args) {
String driver = "com.mysql.jdbc.Driver";
String url = "jdbc:mysql://localhost:3306/dbname";
String username = "username";
String password = "password";
String ftpHost = "ftp.example.com";
String ftpUser = "ftpusername";
String ftpPass = "ftppassword";
String ftpPath = "/wj/";
String fileName;
SimpleDateFormat formatter = new SimpleDateFormat("yyyyMMdd");
Date now = new Date();
fileName = formatter.format(now) + ".txt";
try {
Class.forName(driver);
Connection conn = DriverManager.getConnection(url, username, password);
Statement stmt = conn.createStatement();
String query = "SELECT * FROM tablename";
ResultSet rs = stmt.executeQuery(query);
BufferedWriter writer = new BufferedWriter(new FileWriter(fileName));
while (rs.next()) {
String line = rs.getString("column1") + ","
+ rs.getString("column2") + ","
+ rs.getString("column3") + "\r\n";
writer.write(line);
}
writer.close();
stmt.close();
conn.close();
FTPClient ftpClient = new FTPClient();
ftpClient.connect(ftpHost);
ftpClient.login(ftpUser, ftpPass);
ftpClient.enterLocalPassiveMode();
ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
ftpClient.changeWorkingDirectory(ftpPath);
ftpClient.storeFile(fileName, new FileInputStream(fileName));
ftpClient.disconnect();
System.out.println("Successfully outputted data to " + ftpPath + fileName);
} catch (ClassNotFoundException | SQLException | IOException ex) {
ex.printStackTrace();
}
}
}
```
请注意修改以下参数:
- `url` - 数据库连接URL,替换 `dbname` 为你的数据库名。
- `username` 和 `password` - 替换为正确的数据库用户名和密码。
- `ftpHost` - 修改为你的FTP服务器地址。
- `ftpUser` 和 `ftpPass` - 修改为正确的FTP用户名和密码。
- `ftpPath` - 修改为你想要保存文件的FTP目录路径。
该程序将查询指定表中的所有数据,并将其写入以当前日期为文件名的文本文件中。然后,将该文件上传到远程FTP服务器中指定的目录。成功执行后,将输出文件的保存路径。
请记得在代码中替换相关的数据库和FTP连接参数,以及表名和字段名来适配你自己的环境。
阅读全文