# 定時備份設(shè)置彈窗
class ScheduleDialog(QDialog):
    def __init__(self):
        super().__init__()
        self.setWindowTitle("? 定時設(shè)置")
        self.setFixedSize(300, 200)
        # ...具體實現(xiàn)代碼...

   pip install PyQt5 pymysql schedule pycryptodome appdirs

def encrypt_file(self, file_path, password):
    """使用AES-CBC模式加密文件"""
    key = hashlib.sha256(password.encode()).digest()  # 256位密鑰
    cipher = AES.new(key, AES.MODE_CBC)  # 初始化加密器
    iv = cipher.iv  # 獲取初始向量
    
    with open(file_path, 'rb') as f:
        plaintext = pad(f.read(), AES.block_size)  # PKCS7填充
        
    ciphertext = cipher.encrypt(plaintext)
    with open(file_path + '.enc', 'wb') as f:
        f.write(iv + ciphertext)  # 存儲IV+密文

with open(backup_file, 'w') as f_out:
    process = subprocess.Popen(
        ['mysqldump', f"-h{host}"...],
        stdout=subprocess.PIPE,
        stderr=subprocess.PIPE,
        universal_newlines=True
    )
    # 實時處理輸出避免內(nèi)存暴漲
    while True:
        output = process.stdout.readline()
        if not output and process.poll() is not None:
            break
        if output:
            f_out.write(output)
            f_out.flush()

def start_backup(self):
    """使用QThread避免界面凍結(jié)"""
    self.worker = BackupThread(self.get_parameters())
    self.worker.finished.connect(self.on_backup_finished)
    self.worker.start()

???????class BackupThread(QThread):
    """專用備份線程類"""
    def __init__(self, params):
        super().__init__()
        self.params = params
        
    def run(self):
        try:
            # 執(zhí)行實際備份操作...
            self.finished.emit(True, "")
        except Exception as e:
            self.finished.emit(False, str(e))

import subprocess
import pymysql
import datetime
import os
import gzip
import tkinter as tk
from tkinter import ttk, messagebox, filedialog
import threading
import schedule
import time
from Crypto.Cipher import AES
from Crypto.Util.Padding import pad, unpad
import base64
import hashlib
import logging
from logging.handlers import RotatingFileHandler
 
class MySQLBackupApp:
    """MySQL數(shù)據(jù)庫備份工具主界面"""
     
    def __init__(self, root):
        self.root = root
        self.root.title("MySQL數(shù)據(jù)庫備份工具")
        self.root.geometry("600x700")
        self.root.resizable(False, False)
         
        # 日志文件路徑
        self.log_file = os.path.join(os.path.dirname(os.path.abspath(__file__)), 'log', datetime.datetime.now().strftime('%Y-%m-%d %H_%M_%S') + '.log')
         
        # 設(shè)置樣式
        self.style = ttk.Style()
        self.style.configure('TFrame', background='#f0f0f0')
        self.style.configure('TLabel', background='#f0f0f0', font=('微軟雅黑', 10))
        self.style.configure('TButton', font=('微軟雅黑', 10))
        self.style.configure('TEntry', font=('微軟雅黑', 10))
         
        self.create_widgets()
     
    def create_widgets(self):
        """創(chuàng)建界面控件"""
        main_frame = ttk.Frame(self.root, padding="10 10 10 10")
        main_frame.pack(fill=tk.BOTH, expand=True)
         
        # 連接設(shè)置
        conn_frame = ttk.LabelFrame(main_frame, text="數(shù)據(jù)庫連接設(shè)置", padding="10 5 10 10")
        conn_frame.pack(fill=tk.X, pady=5)
         
        # 使用統(tǒng)一的列寬和間距
        conn_frame.columnconfigure(1, weight=1, minsize=200)
         
        ttk.Label(conn_frame, text="主機:").grid(row=0, column=0, sticky=tk.E, padx=5, pady=5)
        self.host_entry = ttk.Entry(conn_frame)
        self.host_entry.grid(row=0, column=1, sticky=tk.EW, padx=5, pady=5)
        self.host_entry.insert(0, "localhost")
         
        ttk.Label(conn_frame, text="端口:").grid(row=1, column=0, sticky=tk.E, padx=5, pady=5)
        self.port_entry = ttk.Entry(conn_frame)
        self.port_entry.grid(row=1, column=1, sticky=tk.EW, padx=5, pady=5)
        self.port_entry.insert(0, "3306")
         
        ttk.Label(conn_frame, text="用戶名:").grid(row=2, column=0, sticky=tk.E, padx=5, pady=5)
        self.user_entry = ttk.Entry(conn_frame)
        self.user_entry.grid(row=2, column=1, sticky=tk.EW, padx=5, pady=5)
        self.user_entry.insert(0, "root")
         
        ttk.Label(conn_frame, text="密碼:").grid(row=3, column=0, sticky=tk.E, padx=5, pady=5)
        self.pass_entry = ttk.Entry(conn_frame, show="*")
        self.pass_entry.grid(row=3, column=1, sticky=tk.EW, padx=5, pady=5)
         
        # 備份設(shè)置
        backup_frame = ttk.LabelFrame(main_frame, text="備份設(shè)置", padding="10 5 10 10")
        backup_frame.pack(fill=tk.X, pady=5)
         
        # 使用統(tǒng)一的列寬和間距
        backup_frame.columnconfigure(1, weight=1, minsize=200)
         
        # 數(shù)據(jù)庫選擇下拉菜單
        ttk.Label(backup_frame, text="選擇數(shù)據(jù)庫:").grid(row=0, column=0, sticky=tk.E, padx=5, pady=5)
        self.db_combobox = ttk.Combobox(backup_frame, state="readonly")
        self.db_combobox.grid(row=0, column=1, sticky=tk.EW, padx=5, pady=5)
         
        # 刷新數(shù)據(jù)庫按鈕
        self.refresh_btn = ttk.Button(backup_frame, text="刷新數(shù)據(jù)庫", command=self.refresh_databases)
        self.refresh_btn.grid(row=0, column=2, sticky=tk.E, padx=5, pady=5)
         
        ttk.Label(backup_frame, text="備份路徑:").grid(row=1, column=0, sticky=tk.E, padx=5, pady=5)
        self.path_entry = ttk.Entry(backup_frame)
        self.path_entry.grid(row=1, column=1, sticky=tk.EW, padx=5, pady=5)
         
        self.browse_btn = ttk.Button(backup_frame, text="瀏覽...", command=self.browse_path)
        self.browse_btn.grid(row=1, column=2, sticky=tk.E, padx=5, pady=5)
         
        # 壓縮和加密選項放在同一行
        self.compress_var = tk.IntVar(value=0)
        self.compress_cb = ttk.Checkbutton(backup_frame, text="壓縮備份", variable=self.compress_var)
        self.compress_cb.grid(row=2, column=0, sticky=tk.W, padx=5, pady=5)
         
        self.encrypt_var = tk.IntVar(value=0)
        self.encrypt_cb = ttk.Checkbutton(backup_frame, text="加密備份", variable=self.encrypt_var)
        self.encrypt_cb.grid(row=2, column=1, sticky=tk.W, padx=5, pady=5)
         
        self.password_entry = ttk.Entry(backup_frame, show="*")
        self.password_entry.grid(row=4, column=1, sticky=tk.EW, padx=5, pady=5)
        ttk.Label(backup_frame, text="加密密碼:").grid(row=4, column=0, sticky=tk.E, padx=5, pady=5)
         
        # 操作按鈕
        btn_frame = ttk.Frame(main_frame)
        btn_frame.pack(fill=tk.X, pady=10)
         
        # 使用統(tǒng)一的按鈕寬度
        btn_frame.columnconfigure(0, weight=1)
        btn_frame.columnconfigure(1, weight=1)
        btn_frame.columnconfigure(2, weight=1)
         
        self.backup_btn = ttk.Button(btn_frame, text="立即備份", command=self.start_backup)
        self.backup_btn.grid(row=0, column=0, padx=5, sticky=tk.EW)
         
        self.schedule_btn = ttk.Button(btn_frame, text="定時備份", command=self.set_schedule)
        self.schedule_btn.grid(row=0, column=1, padx=5, sticky=tk.EW)
         
        self.exit_btn = ttk.Button(btn_frame, text="退出", command=self.root.quit)
        self.exit_btn.grid(row=0, column=2, padx=5, sticky=tk.EW)
         
        # 日志輸出
        self.log_text = tk.Text(main_frame, height=8, wrap=tk.WORD)
        self.log_text.pack(fill=tk.BOTH, expand=True, padx=5, pady=5)
         
        # 狀態(tài)欄
        self.status_var = tk.StringVar()
        self.status_var.set("準(zhǔn)備就緒")
         
        status_bar = ttk.Label(main_frame, textvariable=self.status_var, relief=tk.SUNKEN)
        status_bar.pack(fill=tk.X)
         
        # 初始化日志系統(tǒng)
        self.setup_logging()
     
    def setup_logging(self):
        """初始化日志系統(tǒng)"""
        # 創(chuàng)建日志記錄器
        self.logger = logging.getLogger('MySQLBackup')
        self.logger.setLevel(logging.INFO)
         
        # 創(chuàng)建文件處理器，設(shè)置日志輪轉(zhuǎn)(每個文件10MB，保留5個備份)
        file_handler = RotatingFileHandler(
            self.log_file, maxBytes=10*1024*1024, backupCount=5, encoding='utf-8')
         
        # 創(chuàng)建控制臺處理器
        console_handler = logging.StreamHandler()
         
        # 設(shè)置日志格式
        formatter = logging.Formatter(
            '%(asctime)s - %(levelname)s - %(message)s', 
            datefmt='%Y-%m-%d %H:%M:%S')
        file_handler.setFormatter(formatter)
        console_handler.setFormatter(formatter)
         
        # 添加處理器
        self.logger.addHandler(file_handler)
        self.logger.addHandler(console_handler)
         
        # 記錄初始化完成
        self.logger.info('日志系統(tǒng)初始化完成')
         
    def log_operation(self, operation, status, details=None, start_time=None, end_time=None, backup_size=None):
        """記錄操作日志
         
        Args:
            operation (str): 操作名稱
            status (str): 操作狀態(tài)(成功/失敗)
            details (str, optional): 操作詳情
            start_time (str, optional): 備份開始時間
            end_time (str, optional): 備份結(jié)束時間
            backup_size (str, optional): 備份文件大小
        """
        log_msg = f"操作: {operation} | 狀態(tài): {status}"
        if start_time:
            log_msg += f" | 開始時間: {start_time}"
        if end_time:
            log_msg += f" | 結(jié)束時間: {end_time}"
        if backup_size:
            log_msg += f" | 備份大小: {backup_size}"
        if details:
            log_msg += f" | 詳情: {details}"
        self.logger.info(log_msg)
     
    def browse_path(self):
        """選擇備份路徑"""
        path = filedialog.askdirectory()
        if path:
            self.path_entry.delete(0, tk.END)
            self.path_entry.insert(0, path)
             
    def set_schedule(self):
        """設(shè)置定時備份"""
        # 創(chuàng)建定時設(shè)置窗口
        schedule_win = tk.Toplevel(self.root)
        schedule_win.title("定時備份設(shè)置")
        schedule_win.geometry("300x200")
         
        # 定時設(shè)置控件
        ttk.Label(schedule_win, text="每天備份時間:").pack(pady=5)
        self.time_entry = ttk.Entry(schedule_win)
        self.time_entry.pack(pady=5)
        self.time_entry.insert(0, "09:00")
         
        ttk.Label(schedule_win, text="備份間隔(天):").pack(pady=5)
        self.interval_entry = ttk.Entry(schedule_win)
        self.interval_entry.pack(pady=5)
        self.interval_entry.insert(0, "1")
         
        # 保存按鈕
        save_btn = ttk.Button(schedule_win, text="保存", 
                             command=lambda: self.save_schedule(schedule_win))
        save_btn.pack(pady=10)
         
    def save_schedule(self, window):
        """保存定時設(shè)置"""
        try:
            backup_time = self.time_entry.get()
            interval = int(self.interval_entry.get())
             
            # 清除現(xiàn)有任務(wù)
            schedule.clear()
             
            # 添加新任務(wù)
            schedule.every(interval).days.at(backup_time).do(self.start_backup)
             
            # 啟動定時任務(wù)線程
            threading.Thread(target=self.run_schedule, daemon=True).start()
             
            messagebox.showinfo("成功", f"已設(shè)置每天{backup_time}執(zhí)行備份")
            window.destroy()
             
        except Exception as e:
            messagebox.showerror("錯誤", f"設(shè)置定時備份失敗: {str(e)}")
             
    def run_schedule(self):
        """運行定時任務(wù)"""
        while True:
            schedule.run_pending()
            time.sleep(1)
             
    def refresh_databases(self):
        """刷新數(shù)據(jù)庫列表"""
        try:
            # 獲取連接參數(shù)
            host = self.host_entry.get()
            port = int(self.port_entry.get())
            user = self.user_entry.get()
            password = self.pass_entry.get()
             
            if not all([host, port, user, password]):
                messagebox.showerror("錯誤", "請先填寫數(shù)據(jù)庫連接信息！")
                return
                 
            # 連接數(shù)據(jù)庫
            conn = pymysql.connect(
                host=host,
                port=port,
                user=user,
                password=password,
                charset='utf8mb4'
            )
             
            # 獲取所有非系統(tǒng)數(shù)據(jù)庫
            cursor = conn.cursor()
            cursor.execute("SHOW DATABASES")
            databases = [db[0] for db in cursor.fetchall() 
                       if db[0] not in ('information_schema', 'performance_schema', 'mysql', 'sys')]
             
            # 更新下拉菜單
            self.db_combobox['values'] = databases
            if databases:
                self.db_combobox.current(0)
                 
            # 啟用多選模式
            self.db_combobox['state'] = 'normal'
             
            conn.close()
            messagebox.showinfo("成功", "數(shù)據(jù)庫列表已刷新！")
             
        except Exception as e:
            messagebox.showerror("錯誤", f"連接數(shù)據(jù)庫失敗: {str(e)}")
     
    def start_backup(self):
        """開始備份"""
        # 驗證輸入
        if not self.path_entry.get():
            messagebox.showerror("錯誤", "請選擇備份路徑")
            return
             
        # 禁用按鈕
        self.backup_btn.config(state=tk.DISABLED)
        self.status_var.set("正在備份...")
         
        # 在新線程中執(zhí)行備份
        backup_thread = threading.Thread(target=self.do_backup)
        backup_thread.daemon = True
        backup_thread.start()
     
    def do_backup(self):
        """執(zhí)行備份操作"""
        try:
            # 獲取連接參數(shù)
            host = self.host_entry.get()
            port = int(self.port_entry.get())
            user = self.user_entry.get()
            password = self.pass_entry.get()
            backup_path = self.path_entry.get()
            compress = self.compress_var.get()
            encrypt = self.encrypt_var.get()
            encrypt_password = self.password_entry.get() if encrypt else None
             
            # 連接數(shù)據(jù)庫
            conn = pymysql.connect(
                host=host,
                port=port,
                user=user,
                password=password,
                charset='utf8mb4'
            )
             
            # 獲取所有數(shù)據(jù)庫
            cursor = conn.cursor()
            cursor.execute("SHOW DATABASES")
            all_databases = [db[0] for db in cursor.fetchall() 
                           if db[0] not in ('information_schema', 'performance_schema', 'mysql', 'sys')]
             
            # 獲取要備份的數(shù)據(jù)庫
            selected_dbs = self.db_combobox.get().split(',') if self.db_combobox.get() else []
            if not selected_dbs:
                messagebox.showerror("錯誤", "請選擇要備份的數(shù)據(jù)庫！")
                return
                 
            databases = [db.strip() for db in selected_dbs if db.strip() in all_databases]
             
            # 記錄要備份的數(shù)據(jù)庫
            self.logger.info(f"正在備份數(shù)據(jù)庫: {', '.join(databases)}")
             
            # 記錄備份開始
            self.logger.info(f"開始備份...")
            self.logger.info(f"備份目錄: {backup_path}")
             
            # 創(chuàng)建備份目錄
            timestamp = datetime.datetime.now().strftime("%Y%m%d_%H%M%S")
            backup_dir = os.path.join(backup_path, f"mysql_backup_{timestamp}")
            os.makedirs(backup_dir, exist_ok=True)
             
            self.log("開始備份...")
            self.log(f"備份目錄: {backup_dir}")
             
            # 備份每個數(shù)據(jù)庫
            for db in databases:
                self.log(f"正在備份數(shù)據(jù)庫: {db}")
                 
                # 生成備份文件名
                backup_file = os.path.join(backup_dir, f"{db}.sql")
                 
                # 使用mysqldump命令備份(流式處理優(yōu)化內(nèi)存)
                try:
                    # 檢查mysqldump路徑
                    mysqldump_path = os.path.join(os.path.dirname(__file__), 'bin', 'mysqldump.exe')
                    if not os.path.exists(mysqldump_path):
                        raise Exception(f"找不到mysqldump.exe，請確保MySQL客戶端工具已安裝并在路徑: {mysqldump_path}")
                         
                    # 使用subprocess.Popen進行流式處理
                    with open(backup_file, 'w') as f_out:
                        process = subprocess.Popen(
                            [mysqldump_path, f"-h{host}", f"-P{port}", f"-u{user}", f"-p{password}", "--databases", db, "--quick", "--single-transaction"],
                            stdout=subprocess.PIPE,
                            stderr=subprocess.PIPE,
                            universal_newlines=True
                        )
                         
                        # 分批讀取數(shù)據(jù)
                        while True:
                            output = process.stdout.readline()
                            if output == '' and process.poll() is not None:
                                break
                            if output:
                                f_out.write(output)
                                f_out.flush()
                                 
                        # 檢查錯誤
                        _, stderr = process.communicate()
                        if process.returncode != 0:
                            raise Exception(f"mysqldump失敗: {stderr}")
                except Exception as e:
                    self.log(f"備份失敗: {str(e)}", error=True)
                    return
                 
                # 如果需要壓縮
                if compress:
                    self.log(f"壓縮備份文件: {backup_file}")
                    with open(backup_file, 'rb') as f_in:
                        with gzip.open(f"{backup_file}.gz", 'wb') as f_out:
                            f_out.writelines(f_in)
                    os.remove(backup_file)
                if encrypt:
                    self.log(f"加密備份文件: {backup_file}")
                    self.encrypt_file(backup_file, encrypt_password)
                     
            self.log("備份完成!")
            # 記錄備份完成
            self.logger.info("備份完成!")
            self.status_var.set("備份完成")
             
        except Exception as e:
            self.log(f"備份失敗: {str(e)}", error=True)
            self.status_var.set("備份失敗")
             
        finally:
            if 'conn' in locals() and conn:
                conn.close()
            self.backup_btn.config(state=tk.NORMAL)
     
    def log(self, message, error=False):
        """記錄日志"""
        timestamp = datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")
        log_msg = f"[{timestamp}] {message}\n"
         
        self.log_text.insert(tk.END, log_msg)
        self.log_text.see(tk.END)
         
        if error:
            self.log_text.tag_add("error", "end-2l", "end-1c")
            self.log_text.tag_config("error", foreground="red")
             
    def encrypt_file(self, file_path, password):
        """加密文件"""
        # 生成密鑰
        key = hashlib.sha256(password.encode()).digest()
        cipher = AES.new(key, AES.MODE_CBC)
         
        with open(file_path, 'rb') as f:
            plaintext = f.read()
             
        # 加密并添加IV
        ciphertext = cipher.encrypt(pad(plaintext, AES.block_size))
        encrypted = cipher.iv + ciphertext
         
        # 保存加密文件
        with open(file_path + '.enc', 'wb') as f:
            f.write(encrypted)
        os.remove(file_path)
 
if __name__ == "__main__":
    root = tk.Tk()
    app = MySQLBackupApp(root)
    root.mainloop()