Method migrate_tables

src/database/session.py:269–345

数据库迁移 - 添加缺失的列 用于在不删除数据的情况下更新表结构

(self)

            logger.warning(f"迁移 bind_card_tasks 历史保留结构时出错: {e}")

    def migrate_tables(self):
        """
        数据库迁移 - 添加缺失的列
        用于在不删除数据的情况下更新表结构
        """
        if not self.database_url.startswith("sqlite"):
            logger.info("非 SQLite 数据库，跳过自动迁移")
            return

        # 需要检查和添加的新列
        migrations = [
            # (表名, 列名, 列类型)
            ("accounts", "cpa_uploaded", "BOOLEAN DEFAULT 0"),
            ("accounts", "cpa_uploaded_at", "DATETIME"),
            ("accounts", "source", "VARCHAR(20) DEFAULT 'register'"),
            ("accounts", "priority", "INTEGER DEFAULT 50"),
            ("accounts", "last_used_at", "DATETIME"),
            ("accounts", "subscription_type", "VARCHAR(20)"),
            ("accounts", "subscription_at", "DATETIME"),
            ("accounts", "cookies", "TEXT"),
            ("cpa_services", "proxy_url", "VARCHAR(1000)"),
            ("sub2api_services", "target_type", "VARCHAR(50) DEFAULT 'sub2api'"),
            ("codex2api_services", "admin_key", "TEXT"),
            ("proxies", "is_default", "BOOLEAN DEFAULT 0"),
            ("bind_card_tasks", "checkout_session_id", "VARCHAR(120)"),
            ("bind_card_tasks", "publishable_key", "VARCHAR(255)"),
            ("bind_card_tasks", "client_secret", "TEXT"),
            ("bind_card_tasks", "bind_mode", "VARCHAR(30) DEFAULT 'semi_auto'"),
            ("bind_card_tasks", "account_email", "VARCHAR(255)"),
        ]

        # 确保新表存在（create_tables 已处理，此处兜底）
        Base.metadata.create_all(bind=self.engine)

        with self.engine.connect() as conn:
            # 数据迁移：将旧的 custom_domain 记录统一为 moe_mail
            try:
                conn.execute(text("UPDATE email_services SET service_type='moe_mail' WHERE service_type='custom_domain'"))
                conn.execute(text("UPDATE accounts SET email_service='moe_mail' WHERE email_service='custom_domain'"))
                conn.commit()
            except Exception as e:
                logger.warning(f"迁移 custom_domain -> moe_mail 时出错: {e}")

            for table_name, column_name, column_type in migrations:
                try:
                    # 检查列是否存在
                    result = conn.execute(text(
                        f"SELECT * FROM pragma_table_info('{table_name}') WHERE name='{column_name}'"
                    ))
                    if result.fetchone() is None:
                        # 列不存在，添加它
                        logger.info(f"添加列 {table_name}.{column_name}")
                        conn.execute(text(
                            f"ALTER TABLE {table_name} ADD COLUMN {column_name} {column_type}"
                        ))
                        conn.commit()
                        logger.info(f"成功添加列 {table_name}.{column_name}")
                except Exception as e: