Java中直接导出MySQL表为SQL文件教程

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.IOException;
import java.io.File;

public class MySQLTableExporter {

    public static void main(String[] args) {
        // 数据库连接信息
        String username = "your_username";     // MySQL用户名
        String password = "your_password";     // MySQL密码
        String databaseName = "your_database"; // 数据库名
        String tableName = "your_table";       // 要导出的表名
        String outputPath = "exported_table.sql"; // SQL文件输出路径

        // 构造 mysqldump 命令
        // 注意：在生产环境中，将密码直接嵌入命令行存在安全风险。
        // 建议使用 .my.cnf 配置文件或通过 stdin 安全地传递密码（如果 mysqldump 支持）。
        String command = String.format("mysqldump -u %s -p%s %s %s > %s",
                                       username, password, databaseName, tableName, outputPath);

        // 如果在Windows上遇到问题，可能需要通过 cmd.exe /c 或 powershell /c 执行
        // String[] windowsCommand = {"cmd.exe", "/c", command};

        System.out.println("正在执行命令: " + command);

        try {
            // 执行命令
            Process process = Runtime.getRuntime().exec(command);

            // 读取 mysqldump 命令的标准错误输出，以捕获任何错误信息
            BufferedReader errorReader = new BufferedReader(new InputStreamReader(process.getErrorStream()));
            String line;
            StringBuilder errorOutput = new StringBuilder();
            while ((line = errorReader.readLine()) != null) {
                errorOutput.append(line).append("\n");
            }

            // 等待进程执行完成
            int exitCode = process.waitFor();

            if (exitCode == 0) {
                System.out.println("MySQL表 '" + tableName + "' 已成功导出到 " + outputPath);
            } else {
                System.err.println("导出MySQL表时发生错误。退出码: " + exitCode);
                System.err.println("错误输出:\n" + errorOutput.toString());
            }

        } catch (IOException e) {
            System.err.println("执行 mysqldump 命令时发生IO错误: " + e.getMessage());
            e.printStackTrace();
        } catch (InterruptedException e) {
            System.err.println("进程被中断: " + e.getMessage());
            Thread.currentThread().interrupt(); // 恢复中断状态
            e.printStackTrace();
        }
    }
}

import java.sql.*;
import java.io.FileWriter;
import java.io.IOException;

public class ProgrammaticSQLExporter {

    public static void main(String[] args) {
        // 数据库连接信息
        String url = "jdbc:mysql://localhost:3306/your_database?serverTimezone=UTC"; // 数据库URL
        String username = "your_username";     // MySQL用户名
        String password = "your_password";     // MySQL密码
        String tableName = "your_table";       // 要导出的表名
        String outputPath = "exported_data_programmatic.sql"; // SQL文件输出路径

        try (Connection connection = DriverManager.getConnection(url, username, password);
             FileWriter writer = new FileWriter(outputPath)) {

            // 1. 获取并写入 CREATE TABLE 语句 (复杂部分，此处简化)
            // 实际操作中，可以通过执行 'SHOW CREATE TABLE your_table;' 获取
            // 或者查询 INFORMATION_SCHEMA.COLUMNS 等元数据表来构建。
            // 这里仅作示意，实际代码会更复杂。
            try (Statement stmt = connection.createStatement();
                 ResultSet rs = stmt.executeQuery("SHOW CREATE TABLE " + tableName)) {
                if (rs.next()) {
                    writer.write("-- Table structure for table `" + tableName + "`\n");
                    writer.write("DROP TABLE IF EXISTS `" + tableName + "`;\n");
                    writer.write(rs.getString("Create Table") + ";\n\n");
                }
            }

            // 2. 导出数据为 INSERT 语句
            String selectSQL = "SELECT * FROM " + tableName;
            try (Statement statement = connection.createStatement();
                 ResultSet resultSet = statement.executeQuery(selectSQL)) {

                ResultSetMetaData metaData = resultSet.getMetaData();
                int columnCount = metaData.getColumnCount();

                writer.write("-- Dumping data for table `" + tableName + "`\n");
                // 禁用外键检查以避免导入顺序问题
                writer.write("SET FOREIGN_KEY_CHECKS=0;\n");
                writer.write("LOCK TABLES `" + tableName + "` WRITE;\n");

                // 逐行构建 INSERT 语句
                while (resultSet.next()) {
                    StringBuilder insertStatement = new StringBuilder("INSERT INTO `")
                            .append(tableName)
                            .append("` VALUES (");

                    for (int i = 1; i <= columnCount; i++) {
                        Object value = resultSet.getObject(i);
                        if (value == null) {
                            insertStatement.append("NULL");
                        } else {
                            // 根据数据类型进行适当的格式化和转义
                            if (value instanceof String || value instanceof Date ||
                                value instanceof Timestamp || value instanceof Time) {
                                // 转义单引号
                                insertStatement.append("'").append(value.toString().replace("'", "''")).append("'");
                            } else if (value instanceof byte[]) {
                                // 对于BLOB/BINARY类型，可能需要特殊处理，例如转换为十六进制字符串
                                // 简化处理，直接转换为字符串，实际需更严谨
                                insertStatement.append("'").append(new String((byte[]) value)).append("'");
                            }
                            else {
                                insertStatement.append(value.toString());
                            }
                        }
                        if (i < columnCount) {
                            insertStatement.append(", ");
                        }
                    }
                    insertStatement.append(");\n");
                    writer.write(insertStatement.toString());
                }
                writer.write("UNLOCK TABLES;\n");
                writer.write("SET FOREIGN_KEY_CHECKS=1;\n");
                System.out.println("MySQL表 '" + tableName + "' 数据已成功导出到 " + outputPath);
            }

        } catch (SQLException e) {
            System.err.println("数据库操作错误: " + e.getMessage());
            e.printStackTrace();
        } catch (IOException e) {
            System.err.println("文件写入错误: " + e.getMessage());
            e.printStackTrace();
        }
    }
}