傻瓜式Java操作MySQL数据库备份(使用mysqldump命令)

作者: cnpim CNPIM 2023年06月09日

傻瓜式Java操作MySQL数据库备份(使用mysqldump命令)

注释都是由chatGPT生成,有什么问题可以评论交流

    @Value("${backup.sql.database}")    private String databases;    @Value("${backup.sql.host}")    private String host;    @Value("${backup.sql.username}")    private String username;    @Value("${backup.sql.password}")    private String password;    private static final int MAX_BACKUP_COUNT = 7; // 最多保存备份文件的数量/** * 备份MySQL数据库 * * @return 备份文件的绝对路径 */public void backupSql() { // 定义备份 MySQL 数据库的方法    String[] split = databases.split(","); // 根据逗号分隔符,将要备份的数据库名称拆分成数组    for (String database : split) { // 遍历每个数据库名称        String backup_path = ContentsUtil.TEMP_BACKUPSQL + database + "/"; // 备份文件存放目录        String currentDate = new SimpleDateFormat("yyyy-MM-dd").format(new Date()); // 当前日期        String currentTime = new SimpleDateFormat("HH-mm-ss").format(Calendar.getInstance().getTime()); // 当前时间        String backupFileName = database + "-" + currentDate + "-" + currentTime + ".sql"; // 备份文件名        String backupFilePath = backup_path + backupFileName; // 备份文件路径        new File(backup_path).mkdirs(); // 创建备份文件存放目录,如果已经存在则不创建        try { // 尝试备份数据库            List<String> command = new ArrayList<>(); // 新建命令列表            command.add("mysqldump"); // 添加命令:备份 MySQL 数据库            command.add("--host=" + host); // 添加命令参数:MySQL 服务器地址            command.add("--user=" + username); // 添加命令参数:MySQL 用户名            command.add("--result-file=" + backupFilePath); // 添加命令参数:备份文件路径            command.add("--databases"); // 添加命令参数:指定要备份的数据库            command.add(database); // 添加要备份的数据库名称            ProcessBuilder pb = new ProcessBuilder(command); // 创建进程构建器            pb.environment().put("MYSQL_PWD", password); // 设置 MySQL 密码            pb.redirectErrorStream(true); // 合并标准错误输出和标准输出            Process runtimeProcess = pb.start(); // 启动进程            InputStream inputStream = runtimeProcess.getInputStream(); // 读取进程的标准输出            BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream)); // 创建输入流读取器            int processComplete = runtimeProcess.waitFor(); // 等待进程结束            if (processComplete == 0) { // 如果进程成功结束                deleteOldBackups(backup_path); // 删除多余的备份文件                System.out.println("Backup Success: " + backupFilePath); // 输出备份成功信息            } else { // 如果进程没有成功结束                System.out.println("Backup Failed"); // 输出备份失败信息            }        } catch (IOException | InterruptedException ex) { // 如果出现异常            System.out.println("Error: " + ex.getMessage()); // 输出异常信息        }    }}
只保留七个周期内的备份数据
/** * 删除多余的备份文件,最多只保留 MAX_BACKUP_COUNT 个文件 */private static void deleteOldBackups(String backup_path) {    // 创建文件夹对象    File backupDir = new File(backup_path);    // 获取该文件夹下的所有文件对象    File[] backupFiles = backupDir.listFiles();    // 将文件对象数组转换成 List,方便排序和删除    List<File> backupList = Arrays.asList(backupFiles);    // 对 List 中的文件对象按照修改时间进行升序排序    Collections.sort(backupList, new Comparator<File>() {        public int compare(File f1, File f2) {            return Long.compare(f1.lastModified(), f2.lastModified());        }    });    // 计算需要删除的文件数量    int excessCount = backupList.size() - MAX_BACKUP_COUNT;    // 如果需要删除的文件数量大于 0,则循环删除文件    if (excessCount > 0) {        for (int i = 0; i < excessCount; i++) {            backupList.get(i).delete();        }    }}

本文阅读量:

上一篇:google插件
下一篇:OpenAI介绍

声明:本信息来源于网络,仅用于学习和技术交流,如有侵权或其他问题,请联系本站处理。

技术支持:CNPIM.COM