fix(updates): chunk bulk queries to avoid SQLite variable limit (#914)

_split _get_records_bulk into 500-id batches so the WHERE IN clause
never exceeds SQLite's 999-parameter ceiling.

Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>

locales/de.json

@@ -276,6 +276,7 @@
             "help": "Optionaler Pfad zur ausführbaren aria2c-Datei. Leer lassen, um aria2c aus dem System-PATH zu verwenden.",
             "placeholder": "Leer lassen, um aria2c aus dem PATH zu verwenden"
         },
+        "aria2HelpLink": "Erfahren Sie, wie Sie das aria2-Download-Backend einrichten",
         "civitaiHostBanner": {
             "title": "Civitai-Host-Einstellung verfügbar",
             "content": "Civitai verwendet jetzt civitai.com für SFW-Inhalte und civitai.red für uneingeschränkte Inhalte. In den Einstellungen können Sie ändern, welche Seite standardmäßig geöffnet wird.",

locales/en.json

@@ -276,6 +276,7 @@
             "help": "Optional path to the aria2c executable. Leave empty to use aria2c from your system PATH.",
             "placeholder": "Leave empty to use aria2c from PATH"
         },
+        "aria2HelpLink": "Learn how to set up the aria2 download backend",
         "civitaiHostBanner": {
             "title": "Civitai host preference available",
             "content": "Civitai now uses civitai.com for SFW content and civitai.red for unrestricted content. You can change which site opens by default in Settings.",

locales/es.json

@@ -276,6 +276,7 @@
             "help": "Ruta opcional al ejecutable aria2c. Déjalo vacío para usar aria2c desde el PATH del sistema.",
             "placeholder": "Déjalo vacío para usar aria2c desde el PATH"
         },
+        "aria2HelpLink": "Aprende a configurar el backend de descarga aria2",
         "civitaiHostBanner": {
             "title": "Preferencia de host de Civitai disponible",
             "content": "Civitai ahora usa civitai.com para contenido SFW y civitai.red para contenido sin restricciones. Puedes cambiar en Ajustes qué sitio se abre por defecto.",

locales/fr.json

@@ -276,6 +276,7 @@
             "help": "Chemin facultatif vers l’exécutable aria2c. Laissez vide pour utiliser aria2c depuis le PATH système.",
             "placeholder": "Laisser vide pour utiliser aria2c depuis le PATH"
         },
+        "aria2HelpLink": "Apprenez à configurer le backend de téléchargement aria2",
         "civitaiHostBanner": {
             "title": "Préférence d’hôte Civitai disponible",
             "content": "Civitai utilise désormais civitai.com pour le contenu SFW et civitai.red pour le contenu sans restriction. Vous pouvez modifier dans les paramètres le site ouvert par défaut.",

locales/he.json

@@ -276,6 +276,7 @@
             "help": "נתיב אופציונלי לקובץ ההפעלה aria2c. השאר ריק כדי להשתמש ב-aria2c מתוך ה-PATH של המערכת.",
             "placeholder": "השאר ריק כדי להשתמש ב-aria2c מתוך ה-PATH"
         },
+        "aria2HelpLink": "למד כיצד להגדיר את מנוע ההורדה aria2",
         "civitaiHostBanner": {
             "title": "העדפת מארח Civitai זמינה",
             "content": "Civitai משתמש כעת ב-civitai.com עבור תוכן SFW וב-civitai.red עבור תוכן ללא הגבלות. ניתן לשנות בהגדרות איזה אתר ייפתח כברירת מחדל.",

locales/ja.json

@@ -276,6 +276,7 @@
             "help": "aria2c 実行ファイルへの任意のパスです。空欄のままにすると、システム PATH 上の aria2c を使用します。",
             "placeholder": "空欄のままにすると PATH 上の aria2c を使用します"
         },
+        "aria2HelpLink": "aria2 ダウンロードバックエンドの設定方法",
         "civitaiHostBanner": {
             "title": "Civitai ホスト設定を利用できます",
             "content": "Civitai は現在、SFW コンテンツには civitai.com、制限なしコンテンツには civitai.red を使用しています。設定で既定で開くサイトを変更できます。",

locales/ko.json

@@ -276,6 +276,7 @@
             "help": "aria2c 실행 파일의 선택적 경로입니다. 비워 두면 시스템 PATH의 aria2c를 사용합니다.",
             "placeholder": "비워 두면 PATH의 aria2c를 사용합니다"
         },
+        "aria2HelpLink": "aria2 다운로드 백엔드 설정 방법 알아보기",
         "civitaiHostBanner": {
             "title": "Civitai 호스트 기본 설정 사용 가능",
             "content": "이제 Civitai는 SFW 콘텐츠에 civitai.com을, 무제한 콘텐츠에 civitai.red를 사용합니다. 설정에서 기본으로 열 사이트를 변경할 수 있습니다.",

locales/ru.json

@@ -276,6 +276,7 @@
             "help": "Необязательный путь к исполняемому файлу aria2c. Оставьте пустым, чтобы использовать aria2c из системного PATH.",
             "placeholder": "Оставьте пустым, чтобы использовать aria2c из PATH"
         },
+        "aria2HelpLink": "Узнайте, как настроить сервер загрузки aria2",
         "civitaiHostBanner": {
             "title": "Доступна настройка хоста Civitai",
             "content": "Теперь Civitai использует civitai.com для контента SFW и civitai.red для контента без ограничений. В настройках можно изменить, какой сайт открывать по умолчанию.",

locales/zh-CN.json

@@ -276,6 +276,7 @@
             "help": "可选的 aria2c 可执行文件路径。留空则使用系统 PATH 中的 aria2c。",
             "placeholder": "留空则使用 PATH 中的 aria2c"
         },
+        "aria2HelpLink": "了解如何配置 aria2 下载后端",
         "civitaiHostBanner": {
             "title": "已提供 Civitai 站点偏好设置",
             "content": "Civitai 现在使用 civitai.com 提供 SFW 内容，使用 civitai.red 提供无限制内容。你可以在设置中更改默认打开的站点。",

locales/zh-TW.json

@@ -276,6 +276,7 @@
             "help": "可選的 aria2c 可執行檔路徑。留空則使用系統 PATH 中的 aria2c。",
             "placeholder": "留空則使用 PATH 中的 aria2c"
         },
+        "aria2HelpLink": "了解如何設定 aria2 下載後端",
         "civitaiHostBanner": {
             "title": "已提供 Civitai 站點偏好設定",
             "content": "Civitai 現在使用 civitai.com 提供 SFW 內容，使用 civitai.red 提供無限制內容。你可以在設定中變更預設開啟的站點。",

py/services/model_update_service.py

@@ -209,6 +209,8 @@ class ModelUpdateRecord:
 class ModelUpdateService:
     """Persist and query remote model version metadata."""
 
+    _SQLITE_MAX_VARIABLES = 500
+
     _SCHEMA = """
         PRAGMA foreign_keys = ON;
         CREATE TABLE IF NOT EXISTS model_update_status (
@@ -1439,33 +1441,41 @@ class ModelUpdateService:
         if not model_ids:
             return {}
 
-        params = tuple(model_ids)
-        placeholders = ",".join("?" for _ in params)
+        ids = list(model_ids)
+        status_rows: list = []
+        version_rows: list = []
 
         with self._connect() as conn:
-            status_rows = conn.execute(
-                f"""
-                SELECT model_id, model_type, last_checked_at, should_ignore_model
-                FROM model_update_status
-                WHERE model_id IN ({placeholders})
-                """,
-                params,
-            ).fetchall()
+            for start in range(0, len(ids), self._SQLITE_MAX_VARIABLES):
+                chunk = tuple(ids[start : start + self._SQLITE_MAX_VARIABLES])
+                placeholders = ",".join("?" for _ in chunk)
+
+                chunk_status = conn.execute(
+                    f"""
+                    SELECT model_id, model_type, last_checked_at, should_ignore_model
+                    FROM model_update_status
+                    WHERE model_id IN ({placeholders})
+                    """,
+                    chunk,
+                ).fetchall()
+                status_rows.extend(chunk_status)
+
+                chunk_versions = conn.execute(
+                    f"""
+                    SELECT model_id, version_id, sort_index, name, base_model, released_at,
+                           size_bytes, preview_url, is_in_library, should_ignore, early_access_ends_at,
+                           is_early_access
+                    FROM model_update_versions
+                    WHERE model_id IN ({placeholders})
+                    ORDER BY model_id ASC, sort_index ASC, version_id ASC
+                    """,
+                    chunk,
+                ).fetchall()
+                version_rows.extend(chunk_versions)
+
             if not status_rows:
                 return {}
 
-            version_rows = conn.execute(
-                f"""
-                SELECT model_id, version_id, sort_index, name, base_model, released_at,
-                       size_bytes, preview_url, is_in_library, should_ignore, early_access_ends_at,
-                       is_early_access
-                FROM model_update_versions
-                WHERE model_id IN ({placeholders})
-                ORDER BY model_id ASC, sort_index ASC, version_id ASC
-                """,
-                params,
-            ).fetchall()
-
         versions_by_model: Dict[int, List[ModelVersionRecord]] = {}
         for row in version_rows:
             model_id = int(row["model_id"])

templates/components/modals/settings_modal.html

@@ -138,6 +138,9 @@
                                     <div class="setting-info">
                                         <label for="downloadBackend">{{ t('settings.downloadBackend.label') }}</label>
                                         <i class="fas fa-info-circle info-icon" data-tooltip="{{ t('settings.downloadBackend.help') }}"></i>
+                                        <a class="settings-action-link" href="https://github.com/willmiao/ComfyUI-Lora-Manager/wiki/Aria2-Download-Backend-(Experimental)" target="_blank" rel="noopener" aria-label="{{ t('settings.aria2HelpLink') }}" title="{{ t('settings.aria2HelpLink') }}">
+                                            <i class="fas fa-question-circle" aria-hidden="true"></i>
+                                        </a>
                                     </div>
                                     <div class="setting-control select-control">
                                         <select id="downloadBackend" onchange="settingsManager.saveSelectSetting('downloadBackend', 'download_backend')">

tests/services/test_model_update_service.py

@@ -442,6 +442,42 @@ async def test_has_updates_bulk_returns_mapping(tmp_path):
     assert await service.has_update("lora", 9) is True
 
 
+@pytest.mark.asyncio
+async def test_has_updates_bulk_handles_more_than_sqlite_max_variables(tmp_path):
+    """Bulk query with >999 model IDs must not raise 'too many SQL variables'."""
+    db_path = tmp_path / "updates.sqlite"
+    service = ModelUpdateService(str(db_path), ttl_seconds=3600)
+
+    model_ids = list(range(1, 1201))
+    with sqlite3.connect(str(db_path)) as conn:
+        conn.execute("INSERT INTO model_update_status (model_id, model_type) VALUES (?, ?)", (1, "lora"))
+        conn.execute("INSERT INTO model_update_versions (model_id, version_id, sort_index, name) VALUES (?, ?, ?, ?)", (1, 10, 0, "v1"))
+
+    mapping = await service.has_updates_bulk("lora", model_ids)
+
+    assert mapping[1] is True
+    assert len(mapping) == len(model_ids)
+    assert all(v is False for k, v in mapping.items() if k != 1)
+
+
+@pytest.mark.asyncio
+async def test_get_records_bulk_handles_more_than_sqlite_max_variables(tmp_path):
+    """Bulk record fetch with >999 model IDs must not raise 'too many SQL variables'."""
+    db_path = tmp_path / "updates.sqlite"
+    service = ModelUpdateService(str(db_path), ttl_seconds=3600)
+
+    model_ids = list(range(1, 1201))
+    with sqlite3.connect(str(db_path)) as conn:
+        conn.execute("INSERT INTO model_update_status (model_id, model_type) VALUES (?, ?)", (1, "lora"))
+        conn.execute("INSERT INTO model_update_versions (model_id, version_id, sort_index, name) VALUES (?, ?, ?, ?)", (1, 10, 0, "v1"))
+
+    records = await service.get_records_bulk("lora", model_ids)
+
+    assert 1 in records
+    assert records[1].model_id == 1
+    assert len(records) == 1
+
+
 @pytest.mark.asyncio
 async def test_refresh_allows_duplicate_version_ids_across_models(tmp_path):
     db_path = tmp_path / "updates.sqlite"