def analyze_connection_error(error_msg):
    """分析連接錯誤原因"""
    error_map = {
        "ORA-12154": "服務名解析失敗",
        "ORA-12541": "監(jiān)聽未啟動或端口不正確",
        "ORA-01017": "用戶名或密碼錯誤",
        "ORA-01034": "Oracle 服務未啟動",
        # ... 更多錯誤碼
    }
    # 分析錯誤并返回詳細信息

def execute_sql(self):
    """執(zhí)行SQL語句"""
    sql = self.sql_text.get(1.0, tk.END).strip()
    if not sql:
        messagebox.showwarning("提示", "請輸入SQL語句")
        return
    
    # 使用多線程執(zhí)行，避免阻塞界面
    thread = threading.Thread(target=self._execute_sql_thread, args=(sql,))
    thread.start()

def start_backup(self):
    """開始備份"""
    backup_type = self.backup_type.get()
    tables = self.selected_tables if backup_type == "tables" else []
    
    # 生成文件名：用戶名_時間戳_備注.dmp
    timestamp = datetime.now().strftime("%Y%m%d%H%M%S")
    base_name = f"{self.conn.username}_{timestamp}"
    if self.remark_var.get():
        base_name += f"_{self.remark_var.get()}"
    filename = f"{base_name}.dmp"
    
    # 構(gòu)建 exp 或 expdp 命令
    cmd = self._build_backup_command(filename, tables)
    
    # 執(zhí)行備份命令并實時顯示日志
    thread = threading.Thread(target=self._run_backup_command, args=(cmd,))
    thread.start()

def start_import(self):
    """開始導入"""
    import_mode = self.import_mode.get()
    
    if import_mode == "recreate":
        # 刪除用戶重新創(chuàng)建模式
        self._recreate_user_and_import()
    elif import_mode == "append":
        # 追加導入模式
        self._append_import()
    elif import_mode == "tables":
        # 導入指定表模式
        self._import_tables()

def create_user(self):
    """創(chuàng)建用戶"""
    username = self.username_var.get()
    password = self.password_var.get()
    
    # 檢查當前用戶是否有創(chuàng)建用戶的權(quán)限
    if not self._has_sys_privilege():
        messagebox.showerror("錯誤", "只有擁有SYS權(quán)限的用戶才能創(chuàng)建用戶")
        return
    
    # 執(zhí)行創(chuàng)建用戶的SQL
    sql = f"CREATE USER {username} IDENTIFIED BY {password}"
    # ... 執(zhí)行SQL并分配權(quán)限

def _run_backup_command(self, cmd, log_path):
    """執(zhí)行備份命令"""
    process = subprocess.Popen(cmd, shell=True, stdout=subprocess.PIPE, 
                               stderr=subprocess.STDOUT, text=True, bufsize=1)
    
    # 將輸出逐行放入隊列
    for line in iter(process.stdout.readline, ''):
        self.log_queue.put(line)
    
    process.wait(timeout=300)
    self.log_queue.put(None)

def _update_backup_log(self):
    """更新日志顯示"""
    while not self.log_queue.empty():
        line = self.log_queue.get()
        if line is None:
            self._check_backup_result()
            return
        self.append_log(line)
    
    self.top.after(100, self._update_backup_log)

thread = threading.Thread(target=self._run_backup_command, args=(cmd,))
thread.start()

def detect_oracle_version(self):
    """檢測Oracle版本"""
    version = self.conn.version
    if "10g" in version:
        return "10g"
    elif "11g" in version:
        return "11g"
    elif "12c" in version:
        return "12c"
    else:
        return "11g"  # 默認使用expdp/impdp

# Oracle日志默認使用GBK編碼，需要用GBK讀取
try:
    with open(log_path, "r", encoding="gbk", errors='ignore') as f:
        full_log = f.read()
except:
    with open(log_path, "r", encoding="utf-8", errors='ignore') as f:
        full_log = f.read()

# 統(tǒng)一轉(zhuǎn)換為utf-8保存
with open(backup_log_path, "w", encoding="utf-8") as f:
    f.write(full_log)

pyinstaller --onefile --windowed --name oracle_helper src/oracle_helper.py

oracle-helper/
├── src/
│   └── oracle_helper.py    # 主程序
├── bin/
│   └── oracle_helper.exe   # 可執(zhí)行文件
├── dist/
│   └── oracle_helper.exe   # PyInstaller輸出
├── log/
│   ├── 導出日志/           # 備份日志
│   └── 導入日志/           # 導入日志
├── .gitignore              # Git忽略配置
├── README.md               # 項目說明
└── blog.md                 # 本文檔