java mysql远程备份数据库

import java.sql.*;

public class MySQLBackup {
    public static void main(String[] args) {
        String url = "jdbc:mysql://remote_host:3306/dbname?useUnicode=true&characterEncoding=utf8mb4";
        String user = "username";
        String password = "password";

        try (Connection conn = DriverManager.getConnection(url, user, password)) {
            // 创建备份文件
            File backupFile = new File("backup.sql");
            try (PrintWriter out = new PrintWriter(new FileWriter(backupFile))) {
                // 获取数据库元数据
                DatabaseMetaData metaData = conn.getMetaData();
                ResultSet tables = metaData.getTables(null, null, "%", new String[] {"TABLE"});

                while (tables.next()) {
                    String tableName = tables.getString("TABLE_NAME");
                    out.println("DROP TABLE IF EXISTS " + tableName + ";");

                    ResultSet columns = metaData.getColumns(null, null, tableName, "%");
                    StringBuilder createTableSQL = new StringBuilder("CREATE TABLE " + tableName + " (\n");

                    while (columns.next()) {
                        String columnName = columns.getString("COLUMN_NAME");
                        String columnType = columns.getString("TYPE_NAME");
                        createTableSQL.append("    ").append(columnName).append(" ").append(columnType).append(",\n");
                    }

                    createTableSQL.setLength(createTableSQL.length() - 2); // 移除最后一个逗号和换行符
                    createTableSQL.append("\n);");
                    out.println(createTableSQL.toString());

                    // 导出数据
                    ResultSet data = conn.createStatement().executeQuery("SELECT * FROM " + tableName);
                    ResultSetMetaData dataMeta = data.getMetaData();
                    int columnCount = dataMeta.getColumnCount();

                    while (data.next()) {
                        out.print("INSERT INTO " + tableName + " VALUES (");
                        for (int i = 1; i <= columnCount; i++) {
                            out.print("'" + data.getString(i) + "'");
                            if (i < columnCount) out.print(", ");
                        }
                        out.println(");");
                    }
                }
            }
        } catch (SQLException | IOException e) {
            e.printStackTrace();
        }
    }
}