package org.jeecg.modules.xczxhhr.job;

import lombok.extern.slf4j.Slf4j;
import org.quartz.Job;
import org.quartz.JobExecutionContext;

import java.io.BufferedReader;
import java.io.File;
import java.io.IOException;
import java.io.InputStreamReader;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.TimeUnit;
@Slf4j
public class SyncDatabaseBackupJob implements Job {
    @Override
    public void execute(JobExecutionContext jobExecutionContext) {
        String mysqlUser = "root";
        String mysqlPassword = "你的密碼";
        String dbname = "你的數(shù)據(jù)庫名字";
        String backupDir = "備份文件存儲地址";

        int expireDays = 15;

        String backupTime = new SimpleDateFormat("yyyyMMddHHmm").format(new Date());
        String backupFileName = dbname + "-" + backupTime + ".sql";

        String[] command = new String[]{"mysqldump", "-u" + mysqlUser, "-B", dbname};

        ProcessBuilder processBuilder = new ProcessBuilder(command);
        processBuilder.environment().put("MYSQL_PWD", mysqlPassword);

        File backupFile = new File(backupDir, backupFileName);
        processBuilder.redirectOutput(backupFile);

        try {
            Process process = processBuilder.start();
            int exitStatus = process.waitFor();

            if (exitStatus == 0) {
                // 備份成功，可以繼續(xù)實現(xiàn)刪除過期備份的邏輯
                log.info("數(shù)據(jù)庫備份成功");
                cleanupOldBackups(backupDir, expireDays);
            } else {
                // 備份失敗，可以記錄日志或者進行其他處理
                log.error("數(shù)據(jù)庫備份失敗:" + exitStatus);
                // 輸出錯誤信息
                BufferedReader errorReader = new BufferedReader(new InputStreamReader(process.getErrorStream()));
                String line;
                while ((line = errorReader.readLine()) != null) {
                    log.error(line);
                }
            }
        } catch (IOException | InterruptedException e) {
            // 異常處理
            e.printStackTrace();
            log.error("備份數(shù)據(jù)庫出現(xiàn)異常：" + e.getMessage());
        }
    }

    private void cleanupOldBackups(String backupDir, int expireDays) {
        File dir = new File(backupDir);
        File[] files = dir.listFiles();

        if (files != null) {
            for (File file : files) {
                long diffInMillies = System.currentTimeMillis() - file.lastModified();
                long diffInDays = TimeUnit.DAYS.convert(diffInMillies, TimeUnit.MILLISECONDS);

                if (diffInDays > expireDays) {
                    if (file.delete()) {
                        log.info("已刪除舊備份文件:" + file.getName());
                    } else {
                        log.info("未能刪除舊備份文件："+ file.getName());
                    }
                }
            }
        }
    }
}

#!/bin/bash
# 設(shè)置mysql的登錄用戶名和密碼(根據(jù)實際情況填寫)
mysqlUser="root"
mysqlPassword="密碼"
dbname='數(shù)據(jù)庫名字'

# 備份文件存放地址(根據(jù)實際情況填寫)
backup_dir=/data/depFile/bakdb

# 判斷目錄是不是已經(jīng)存在，如果不存在則創(chuàng)建
if [ ! -d $backup_dir ]; then
  mkdir -p $backup_dir
fi
#===================================
# 是否刪除過期數(shù)據(jù)
expire_backup_delete="ON"
expire_days=15
backup_time=$(date +%Y%m%d%H%M)
welcome_msg="Welcome to use MySQL backup tools!"
#===========================================
# 備份指定數(shù)據(jù)庫中數(shù)據(jù)(此處假設(shè)數(shù)據(jù)庫是mysql_backup_test)
mysqldump -u$mysqlUser -p$mysqlPassword -B $dbname >$backup_dir/$dbname-$backup_time.sql

#刪除過期數(shù)據(jù)
if [ "$expire_backup_delete" == "ON" -a "$backup_dir" != "" ]; then
  # $(find $backup_dir/ -type f -mtime +$expire_days | xargs rm -rf)
  find $backup_dir/ -type f -mtime +$expire_days -exec rm -f {} \;
  echo "Expired backup data delete complete!"
fi

crontab -e

0 1 * * * /bin/bash /path/to/your/backup_script.sh