执行清理数据库任务(增强版)
(self)
| 100 | self.ide_name = get_ide_display_name(ide_type) |
| 101 | |
| 102 | def run(self): |
| 103 | """执行清理数据库任务(增强版)""" |
| 104 | try: |
| 105 | self.emit_progress(get_text("workers.clean_db.starting", |
| 106 | ide_name=self.ide_name, keyword=self.keyword)) |
| 107 | self.emit_status(get_text("workers.clean_db.cleaning", ide_name=self.ide_name), "info") |
| 108 | |
| 109 | # 使用增强版数据库清理,获取详细结果 |
| 110 | result = clean_ide_database_enhanced(self.ide_type, self.keyword) |
| 111 | |
| 112 | if self.is_cancelled: |
| 113 | return |
| 114 | |
| 115 | if result["success"]: |
| 116 | # 显示详细的清理结果 |
| 117 | if result["entries_removed"] > 0: |
| 118 | self.emit_progress(get_text("workers.clean_db.entries_removed", |
| 119 | count=result['entries_removed'])) |
| 120 | else: |
| 121 | self.emit_progress(get_text("workers.clean_db.no_entries")) |
| 122 | |
| 123 | if result["backup_created"]: |
| 124 | self.emit_progress(get_text("workers.clean_db.backup_created")) |
| 125 | |
| 126 | self.emit_progress(get_text("workers.clean_db.completed")) |
| 127 | self.emit_status(get_text("status.success"), "success") |
| 128 | self.task_completed.emit(True) |
| 129 | else: |
| 130 | error_msg = result.get("error_message", get_text("status.error")) |
| 131 | self.emit_progress(get_text("workers.clean_db.failed", error=error_msg)) |
| 132 | self.emit_status(get_text("status.error"), "error") |
| 133 | self.task_completed.emit(False) |
| 134 | |
| 135 | except Exception as e: |
| 136 | self.emit_progress(get_text("workers.clean_db.error", error=str(e))) |
| 137 | self.emit_status(get_text("status.failed"), "error") |
| 138 | self.task_completed.emit(False) |
| 139 | |
| 140 | |
| 141 | class ModifyIDsWorker(BaseWorker): |
nothing calls this directly
no test coverage detected