feat(db): align migration prototype with single-table RFC

.github/workflows/master.yml

@@ -154,6 +154,62 @@ jobs:
       - name: Test code indexing with embedded seekdb
         run: make code-seekdb-test
 
+      - name: Test unified migrations with embedded seekdb
+        timeout-minutes: 10
+        env:
+          POWERCONTEXT_TEST_MIGRATION_SEEKDB: "1"
+          POWERCONTEXT_TEST_MIGRATION_SQL_LOG: "1"
+          PYTHONUNBUFFERED: "1"
+          TMPDIR: ${{ runner.temp }}/seekdb-migration
+        run: |
+          set -o pipefail
+          mkdir -p "$TMPDIR"
+          collect_diagnostics() {
+            df -h . /tmp
+            # A timed-out pytest process cannot run fixture cleanup. Retain
+            # bounded native logs from its isolated data directories as well
+            # as the Python stack and SQL trace.
+            find "$TMPDIR" -type f \( -name '*.log' -o -name '*.log.wf' \) \
+              -print -exec tail -c 8388608 {} \; > seekdb-native.log
+          }
+          trap collect_diagnostics EXIT
+          df -h . /tmp
+          uv run --locked --extra seekdb pytest -vv \
+            -o faulthandler_timeout=120 --durations=20 \
+            tests/builtin/persistence/test_database_migration_backends.py \
+            tests/builtin/persistence/test_database_backup_providers.py \
+            tests/builtin/persistence/test_database_migration_connections.py \
+            tests/builtin/persistence/test_mysql_migration_schema.py -k seekdb \
+            2>&1 | tee seekdb-migrations.log
+          uv run --locked --extra seekdb pytest --collect-only -q --color=no \
+            tests/builtin/persistence/test_mysql_migration_runner.py -k seekdb \
+            2>&1 | tee seekdb-runner-collection.log | tee -a seekdb-migrations.log
+          mapfile -t seekdb_runner_nodes < <(
+            sed -n '/^tests\/builtin\/persistence\/test_mysql_migration_runner\.py::/p' \
+              seekdb-runner-collection.log
+          )
+          if [ "${#seekdb_runner_nodes[@]}" -eq 0 ]; then
+            echo "No seekdb migration runner tests were collected" >&2
+            exit 1
+          fi
+          for seekdb_runner_node in "${seekdb_runner_nodes[@]}"; do
+            timeout --signal=TERM --kill-after=10s 180s \
+              uv run --locked --extra seekdb pytest -vv \
+              -o faulthandler_timeout=120 --durations=20 --log-cli-level=INFO \
+              "$seekdb_runner_node" -k seekdb \
+              2>&1 | tee -a seekdb-migrations.log
+          done
+
+      - name: Upload seekdb migration diagnostics
+        if: always()
+        uses: actions/upload-artifact@043fb46d1a93c77aae656e7c1c64a875d1fc6a0a # v7
+        with:
+          name: seekdb-migrations-${{ matrix.python-version }}
+          path: |
+            seekdb-migrations.log
+            seekdb-native.log
+          if-no-files-found: ignore
+
   windows-unit-portability:
     timeout-minutes: 20
     runs-on: windows-latest

desktop/ui/tests/connections.test.tsx

@@ -15,7 +15,7 @@
  */
 
 import { afterEach, beforeEach, expect, test, vi } from "vitest";
-import { act, cleanup, render, screen } from "@testing-library/react";
+import { act, cleanup, render, screen, waitFor } from "@testing-library/react";
 import userEvent from "@testing-library/user-event";
 import { App } from "../src/app/App";
 import { Connections } from "../src/app/Connections";
@@ -148,23 +148,39 @@ test("a save from the previous connection editor cannot dismiss a new draft", as
   const user = userEvent.setup();
   vi.mocked(desktopApi.state).mockResolvedValue(state());
   let finish!: (next: DesktopState) => void;
-  vi.mocked(desktopApi.save).mockImplementationOnce(
-    () =>
-      new Promise((resolve) => {
-        finish = resolve;
-      }),
-  );
+  const pendingSave = new Promise<DesktopState>((resolve) => {
+    finish = resolve;
+  });
+  vi.mocked(desktopApi.save).mockReturnValueOnce(pendingSave);
   const confirm = vi.spyOn(window, "confirm").mockReturnValue(true);
   render(<App />);
   await user.click(screen.getByRole("button", { name: "连接" }));
+  // Let navigation finish moving focus before keyboard input begins.
+  await waitFor(() => {
+    expect(document.activeElement).toBe(
+      screen.getByRole("heading", { level: 1, name: "连接" }),
+    );
+    expect(screen.getByLabelText("连接名称").matches(":enabled")).toBe(true);
+  });
   await user.type(screen.getByLabelText("连接名称"), "First");
   await user.type(
     screen.getByLabelText("Server 地址"),
     "http://localhost:8000",
   );
   await user.click(screen.getByRole("button", { name: "保存配置" }));
+  expect(desktopApi.save).toHaveBeenCalledWith(
+    expect.objectContaining({
+      name: "First",
+      endpoint: "http://localhost:8000",
+    }),
+  );
   await user.click(screen.getByRole("button", { name: "总览" }));
   await user.click(screen.getByRole("button", { name: "连接" }));
+  await waitFor(() => {
+    expect(document.activeElement).toBe(
+      screen.getByRole("heading", { level: 1, name: "连接" }),
+    );
+  });
   await user.type(screen.getByLabelText("连接名称"), "New draft");
   await act(async () => {
     finish(state({ ...profile, name: "First" }));