从Java应用程序中导出MySQL表数据的技术指南

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;

public class MySQLTableExporter {

    /**
     * 导出MySQL数据库中的指定表为SQL文件。
     *
     * @param username     MySQL用户名
     * @param password     MySQL密码
     * @param databaseName 数据库名称
     * @param tableName    要导出的表名称
     * @param outputPath   SQL文件输出路径
     */
    public static void exportTableToSql(String username, String password, String databaseName, String tableName, String outputPath) {
        // 假设mysqldump在系统的PATH中。
        // 如果不在，请替换为mysqldump的完整路径，例如：
        // String mysqldumpExecutable = "C:\Program Files\MySQL\MySQL Server 8.0\bin\mysqldump.exe";
        String mysqldumpExecutable = "mysqldump";

        // 构建mysqldump命令参数数组
        // 注意：-p参数后直接拼接密码，没有空格。
        // 在生产环境中，直接在命令行中暴露密码存在安全风险，应考虑更安全的认证方式。
        String[] command = {
            mysqldumpExecutable,
            "-u", username,
            "-p" + password, // -p和密码之间没有空格
            databaseName,
            tableName
        };

        try {
            // 打印执行的命令（出于安全考虑，隐藏密码）
            System.out.println("Executing command: " + String.join(" ", command).replace(password, "********"));

            ProcessBuilder pb = new ProcessBuilder(command);
            // 可以设置工作目录，如果mysqldump不在PATH中，可以指定其完整路径
            // pb.directory(new File("/path/to/mysql/bin"));

            Process process = pb.start();

            // 将mysqldump的正常输出流（即SQL转储内容）写入到文件
            try (InputStream inputStream = process.getInputStream();
                 FileOutputStream fileOutputStream = new FileOutputStream(outputPath)) {
                byte[] buffer = new byte[1024];
                int bytesRead;
                while ((bytesRead = inputStream.read(buffer)) != -1) {
                    fileOutputStream.write(buffer, 0, bytesRead);
                }
            }

            // 读取进程的错误输出流，以便捕获任何错误信息
            BufferedReader errorReader = new BufferedReader(new InputStreamReader(process.getErrorStream()));
            StringBuilder errorOutput = new StringBuilder();
            String line;
            while ((line = errorReader.readLine()) != null) {
                errorOutput.append(line).append("
");
            }

            // 等待命令执行完成，并获取退出码
            int exitCode = process.waitFor();

            if (exitCode == 0) {
                System.out.println("MySQL table '" + tableName + "' exported successfully to " + outputPath);
            } else {
                System.err.println("Error exporting MySQL table. Exit code: " + exitCode);
                if (errorOutput.length() > 0) {
                    System.err.println("mysqldump error output:
" + errorOutput.toString());
                }
            }

        } catch (IOException | InterruptedException e) {
            System.err.println("Error executing mysqldump command: " + e.getMessage());
            e.printStackTrace();
        }
    }

    public static void main(String[] args) {
        // 替换为你的数据库连接信息和要导出的表信息
        String username = "your_mysql_username";    // 例如 "root"
        String password = "your_mysql_password";    // 例如 "mysecretpassword"
        String databaseName = "your_database_name"; // 例如 "testdb"
        String tableName = "your_table_name";       // 例如 "users"
        String outputPath = "exported_table.sql";   // 导出的SQL文件路径和名称

        exportTableToSql(username, password, databaseName, tableName, outputPath);
    }
}