diff --git a/frontend/src/components/ImportPreviewModal.test.tsx b/frontend/src/components/ImportPreviewModal.test.tsx
index 7d6e45ca..16564ec4 100644
--- a/frontend/src/components/ImportPreviewModal.test.tsx
+++ b/frontend/src/components/ImportPreviewModal.test.tsx
@@ -10,6 +10,7 @@ const mocks = vi.hoisted(() => ({
   previewImportFile: vi.fn(),
   dbGetColumns: vi.fn(),
   importDataWithProgressOptions: vi.fn(),
+  cancelQuery: vi.fn(),
   progressHandler: null as ((data: any) => void) | null,
   eventsOn: vi.fn((_event: string, handler: (data: any) => void) => {
     mocks.progressHandler = handler;
@@ -47,6 +48,7 @@ vi.mock("../../wailsjs/go/app/App", () => ({
   PreviewImportFile: mocks.previewImportFile,
   DBGetColumns: mocks.dbGetColumns,
   ImportDataWithProgressOptions: mocks.importDataWithProgressOptions,
+  CancelQuery: mocks.cancelQuery,
 }));
 
 vi.mock("../../wailsjs/runtime/runtime", () => ({
@@ -144,6 +146,7 @@ vi.mock("@ant-design/icons", async () => {
   return {
     CheckCircleOutlined: Icon,
     CloseCircleOutlined: Icon,
+    StopOutlined: Icon,
   };
 });
 
@@ -220,6 +223,8 @@ describe("ImportPreviewModal i18n", () => {
       ],
     });
     mocks.importDataWithProgressOptions.mockReset();
+    mocks.cancelQuery.mockReset();
+    mocks.cancelQuery.mockResolvedValue({ success: true });
     mocks.progressHandler = null;
     mocks.eventsOn.mockClear();
     mocks.eventsOff.mockClear();
@@ -496,6 +501,160 @@ describe("ImportPreviewModal i18n", () => {
     expect(textContent(renderer.toJSON())).toContain("Row 12: duplicate key");
   });
 
+  it("stops an active import by its job id and preserves the partial result", async () => {
+    let resolveImport!: (value: any) => void;
+    mocks.importDataWithProgressOptions.mockImplementation(
+      () => new Promise((resolve) => {
+        resolveImport = resolve;
+      }),
+    );
+    const renderer = await renderImportPreview();
+    const startButton = renderer.root
+      .findAllByType("button")
+      .find((node) => textContent(node.props.children) === "Start import");
+
+    await act(async () => {
+      startButton?.props.onClick();
+      await Promise.resolve();
+    });
+
+    const importJobId = mocks.importDataWithProgressOptions.mock.calls[0][4].jobId;
+    const stopButton = renderer.root
+      .findAllByType("button")
+      .find((node) => textContent(node.props.children) === "Stop import");
+    expect(stopButton).toBeDefined();
+
+    await act(async () => {
+      stopButton?.props.onClick();
+      stopButton?.props.onClick();
+      await Promise.resolve();
+    });
+    expect(mocks.cancelQuery).toHaveBeenCalledTimes(1);
+    expect(mocks.cancelQuery).toHaveBeenCalledWith(importJobId);
+
+    await act(async () => {
+      resolveImport({
+        success: false,
+        message: "Import stopped",
+        data: {
+          success: 10,
+          failed: 2,
+          total: 12,
+          errorLogs: ["Row 11: duplicate key", "Row 12: duplicate key"],
+          cancelled: true,
+        },
+      });
+      await Promise.resolve();
+      await Promise.resolve();
+    });
+
+    const renderedText = textContent(renderer.toJSON());
+    expect(renderedText).toContain("Import stopped");
+    expect(renderedText).toContain("Successfully imported 10 rows");
+    expect(renderedText).toContain("Failed 2 rows");
+  });
+
+  it("ignores a late stop failure after the import already completed", async () => {
+    let resolveImport!: (value: any) => void;
+    let resolveCancel!: (value: any) => void;
+    mocks.importDataWithProgressOptions.mockImplementation(
+      () => new Promise((resolve) => {
+        resolveImport = resolve;
+      }),
+    );
+    mocks.cancelQuery.mockImplementation(
+      () => new Promise((resolve) => {
+        resolveCancel = resolve;
+      }),
+    );
+    const renderer = await renderImportPreview();
+    const startButton = renderer.root
+      .findAllByType("button")
+      .find((node) => textContent(node.props.children) === "Start import");
+
+    await act(async () => {
+      startButton?.props.onClick();
+      await Promise.resolve();
+    });
+    const stopButton = renderer.root
+      .findAllByType("button")
+      .find((node) => textContent(node.props.children) === "Stop import");
+    await act(async () => {
+      stopButton?.props.onClick();
+      await Promise.resolve();
+    });
+
+    await act(async () => {
+      resolveImport({
+        success: true,
+        data: { success: 12, failed: 0, total: 12, errorLogs: [] },
+      });
+      await Promise.resolve();
+      await Promise.resolve();
+    });
+    await act(async () => {
+      resolveCancel({ success: false, message: "No running query" });
+      await Promise.resolve();
+    });
+
+    const renderedText = textContent(renderer.toJSON());
+    expect(renderedText).toContain("Import completed");
+    expect(renderedText).not.toContain("No running query");
+  });
+
+  it("clears an earlier stop failure when stop is retried", async () => {
+    let resolveImport!: (value: any) => void;
+    mocks.importDataWithProgressOptions.mockImplementation(
+      () => new Promise((resolve) => {
+        resolveImport = resolve;
+      }),
+    );
+    mocks.cancelQuery.mockResolvedValue({ success: false, message: "No running query" });
+    const renderer = await renderImportPreview();
+    const startButton = renderer.root
+      .findAllByType("button")
+      .find((node) => textContent(node.props.children) === "Start import");
+
+    await act(async () => {
+      startButton?.props.onClick();
+      await Promise.resolve();
+    });
+    const stopButton = renderer.root
+      .findAllByType("button")
+      .find((node) => textContent(node.props.children) === "Stop import");
+    await act(async () => {
+      stopButton?.props.onClick();
+      await Promise.resolve();
+      await Promise.resolve();
+    });
+    expect(textContent(renderer.toJSON())).toContain("No running query");
+
+    mocks.cancelQuery.mockResolvedValue({ success: true });
+    const retryStopButton = renderer.root
+      .findAllByType("button")
+      .find((node) => textContent(node.props.children) === "Stop import");
+    await act(async () => {
+      retryStopButton?.props.onClick();
+      await Promise.resolve();
+    });
+    expect(mocks.cancelQuery).toHaveBeenCalledTimes(2);
+    expect(textContent(renderer.toJSON())).not.toContain("No running query");
+
+    await act(async () => {
+      resolveImport({
+        success: false,
+        message: "Import stopped",
+        data: { success: 10, failed: 2, total: 12, errorLogs: [], cancelled: true },
+      });
+      await Promise.resolve();
+      await Promise.resolve();
+    });
+
+    const renderedText = textContent(renderer.toJSON());
+    expect(renderedText).toContain("Import stopped");
+    expect(renderedText).not.toContain("No running query");
+  });
+
   it("preserves an RPC failure when connection state changes during import", async () => {
     let resolveImport!: (value: any) => void;
     mocks.importDataWithProgressOptions.mockImplementation(
diff --git a/frontend/src/components/ImportPreviewModal.tsx b/frontend/src/components/ImportPreviewModal.tsx
index f75f7215..2baa4795 100644
--- a/frontend/src/components/ImportPreviewModal.tsx
+++ b/frontend/src/components/ImportPreviewModal.tsx
@@ -1,8 +1,9 @@
 import Modal from './common/ResizableDraggableModal';
 import React, { useState, useEffect, useRef } from "react";
 import { Table, Alert, Progress, Button, Space, Select } from 'antd';
-import { CheckCircleOutlined, CloseCircleOutlined } from "@ant-design/icons";
+import { CheckCircleOutlined, CloseCircleOutlined, StopOutlined } from "@ant-design/icons";
 import {
+  CancelQuery,
   DBGetColumns,
   PreviewImportFile,
   ImportDataWithProgressOptions,
@@ -69,11 +70,13 @@ const ImportPreviewModal: React.FC<ImportPreviewModalProps> = ({
   const [columnMappings, setColumnMappings] = useState<Record<string, string>>({});
   const [error, setError] = useState<string | null>(null);
   const [importing, setImporting] = useState(false);
+  const [stopping, setStopping] = useState(false);
   const [progress, setProgress] = useState<ImportProgress | null>(null);
   const [importResult, setImportResult] = useState<any>(null);
   const previewRequestRef = useRef(0);
   const importRequestRef = useRef(0);
   const importingRef = useRef(false);
+  const stoppingRef = useRef(false);
   const activeImportJobIdRef = useRef("");
   const previewConnectionConfigRef = useRef<any>(null);
   const secondaryTextColor = darkMode ? "rgba(255,255,255,0.65)" : "rgba(0,0,0,0.45)";
@@ -131,9 +134,11 @@ const ImportPreviewModal: React.FC<ImportPreviewModalProps> = ({
   const loadPreview = async (requestId: number) => {
     importRequestRef.current += 1;
     importingRef.current = false;
+    stoppingRef.current = false;
     activeImportJobIdRef.current = "";
     previewConnectionConfigRef.current = null;
     setImporting(false);
+    setStopping(false);
     setLoading(true);
     setError(null);
     setPreviewData(null);
@@ -240,8 +245,11 @@ const ImportPreviewModal: React.FC<ImportPreviewModalProps> = ({
     const importJobId = createImportJobId();
     importRequestRef.current = importRequestId;
     importingRef.current = true;
+    stoppingRef.current = false;
     activeImportJobIdRef.current = importJobId;
     setImporting(true);
+    setStopping(false);
+    setError(null);
     setProgress({
       current: 0,
       total: previewData.totalRows,
@@ -269,7 +277,10 @@ const ImportPreviewModal: React.FC<ImportPreviewModalProps> = ({
       );
       if (importRequestRef.current !== importRequestId) return;
 
-      if (res.success && res.data) {
+      setError(null);
+      if (res.data?.cancelled) {
+        setImportResult(res.data);
+      } else if (res.success && res.data) {
         setImportResult(res.data);
         if (res.data.failed === 0) {
           onSuccess();
@@ -287,12 +298,43 @@ const ImportPreviewModal: React.FC<ImportPreviewModalProps> = ({
     } finally {
       if (importRequestRef.current === importRequestId) {
         importingRef.current = false;
+        stoppingRef.current = false;
         activeImportJobIdRef.current = "";
         setImporting(false);
+        setStopping(false);
       }
     }
   };
 
+  const handleStopImport = async () => {
+    const importJobId = activeImportJobIdRef.current;
+    if (!importJobId || stoppingRef.current) return;
+
+    stoppingRef.current = true;
+    setStopping(true);
+    setError(null);
+    try {
+      const res = await CancelQuery(importJobId);
+      if (!importingRef.current || activeImportJobIdRef.current !== importJobId) {
+        return;
+      }
+      if (!res.success) {
+        stoppingRef.current = false;
+        setStopping(false);
+        setError(res.message || t("import_preview.error.stop_failed"));
+      }
+    } catch (e: any) {
+      if (!importingRef.current || activeImportJobIdRef.current !== importJobId) {
+        return;
+      }
+      stoppingRef.current = false;
+      setStopping(false);
+      setError(t("import_preview.error.stop_failed_detail", {
+        detail: String(e?.message || e),
+      }));
+    }
+  };
+
   const columns =
     previewData?.columns.map((col) => ({
       title: col,
@@ -311,7 +353,19 @@ const ImportPreviewModal: React.FC<ImportPreviewModalProps> = ({
     <Space>
       <Button onClick={onClose}>{t("common.close")}</Button>
     </Space>
-  ) : importing ? null : (
+  ) : importing ? (
+    <Space>
+      <Button
+        danger
+        icon={<StopOutlined />}
+        loading={stopping}
+        disabled={stopping}
+        onClick={() => void handleStopImport()}
+      >
+        {t("import_preview.action.stop")}
+      </Button>
+    </Space>
+  ) : (
     <Space>
       <Button onClick={onClose}>{t("common.cancel")}</Button>
       <Button
@@ -453,7 +507,9 @@ const ImportPreviewModal: React.FC<ImportPreviewModalProps> = ({
               textAlign: "center",
             }}
           >
-            {t("import_preview.status.importing")}
+            {stopping
+              ? t("import_preview.status.stopping")
+              : t("import_preview.status.importing")}
           </div>
           <Progress percent={progressPercent} status="active" />
           <div style={{ marginTop: 16, textAlign: "center", color: "#666" }}>
@@ -482,8 +538,10 @@ const ImportPreviewModal: React.FC<ImportPreviewModalProps> = ({
       {importResult && (
         <div style={{ padding: 20 }}>
           <Alert
-            type={importResult.failed === 0 ? "success" : "warning"}
-            message={t("import_preview.result.completed")}
+            type={!importResult.cancelled && importResult.failed === 0 ? "success" : "warning"}
+            message={importResult.cancelled
+              ? t("import_preview.result.stopped")
+              : t("import_preview.result.completed")}
             description={
               <div>
                 <div>
diff --git a/frontend/src/components/SQLFileExecutionWorkbench.tsx b/frontend/src/components/SQLFileExecutionWorkbench.tsx
index 61e62851..efbd0d2a 100644
--- a/frontend/src/components/SQLFileExecutionWorkbench.tsx
+++ b/frontend/src/components/SQLFileExecutionWorkbench.tsx
@@ -120,7 +120,6 @@ const SQLFileExecutionWorkbench: React.FC<{ tab: TabData }> = ({ tab }) => {
   const theme = useStore((state) => state.theme);
   const [nowTick, setNowTick] = useState(() => Date.now());
   const [historyEntries, setHistoryEntries] = useState<SQLFileExecutionHistoryEntry[]>(EMPTY_HISTORY);
-  const lastArchivedJobIdRef = useRef('');
   const lastRequestKeyRef = useRef('');
   const darkMode = theme === 'dark';
   const shellBg = darkMode ? '#101319' : '#f5f7fb';
@@ -165,10 +164,6 @@ const SQLFileExecutionWorkbench: React.FC<{ tab: TabData }> = ({ tab }) => {
     if (state.status !== 'done' && state.status !== 'cancelled' && state.status !== 'error') {
       return;
     }
-    if (lastArchivedJobIdRef.current === state.jobId) {
-      return;
-    }
-    lastArchivedJobIdRef.current = state.jobId;
     setHistoryEntries((prev) => [
       {
         ...state,
diff --git a/frontend/src/components/useSQLFileExecutionRunner.test.tsx b/frontend/src/components/useSQLFileExecutionRunner.test.tsx
index 65fd3cd0..f604dade 100644
--- a/frontend/src/components/useSQLFileExecutionRunner.test.tsx
+++ b/frontend/src/components/useSQLFileExecutionRunner.test.tsx
@@ -168,7 +168,30 @@ describe('useSQLFileExecutionRunner', () => {
     expect(cancelSpy).toHaveBeenCalledWith(jobId);
     expect(runner?.state.status).toBe('cancelled');
 
+    act(() => {
+      runtimeApi.emitProgress({
+        jobId,
+        status: 'running',
+        executed: 10,
+        percent: 100,
+      });
+      vi.advanceTimersByTime(20);
+    });
+    expect(runner?.state.status).toBe('cancelled');
+
     now = 6_000;
+    act(() => {
+      runtimeApi.emitProgress({
+        jobId,
+        status: 'cancelled',
+        executed: 11,
+        percent: 100,
+      });
+      vi.advanceTimersByTime(20);
+    });
+    expect(runner?.state.status).toBe('cancelled');
+    expect(runner?.state.executed).toBe(11);
+
     await act(async () => {
       resolveRun({ success: false, message: '已取消' });
       await runPromise;
@@ -177,4 +200,125 @@ describe('useSQLFileExecutionRunner', () => {
     expect(runner?.state.status).toBe('cancelled');
     expect(runner?.state.finishedAt).toBe(6_000);
   });
+
+  it('keeps a running task below 100 percent until completion', async () => {
+    renderRunner();
+
+    let resolveRun!: (value: { success: boolean; message: string }) => void;
+    const pendingRun = new Promise<{ success: boolean; message: string }>((resolve) => {
+      resolveRun = resolve;
+    });
+
+    let runPromise: Promise<{ success: boolean; message: string } | null> | null = null;
+    await act(async () => {
+      runPromise = runner?.runSQLFileExecutionWithProgress({
+        title: 'small-prefetched.sql',
+        filePath: 'D:/sql/small-prefetched.sql',
+        run: async () => pendingRun,
+      }) || null;
+      await Promise.resolve();
+    });
+
+    const jobId = runner?.state.jobId || '';
+    act(() => {
+      runtimeApi.emitProgress({
+        jobId,
+        status: 'running',
+        executed: 28,
+        failed: 0,
+        percent: 100,
+      });
+      vi.advanceTimersByTime(20);
+    });
+
+    expect(runner?.state.status).toBe('running');
+    expect(runner?.state.percent).toBe(99);
+
+    await act(async () => {
+      resolveRun({ success: true, message: '执行完成' });
+      await runPromise;
+    });
+
+    expect(runner?.state.status).toBe('done');
+    expect(runner?.state.percent).toBe(100);
+  });
+
+  it('keeps 100 percent when the whole file completed with failed statements', async () => {
+    renderRunner();
+
+    let resolveRun!: (value: { success: boolean; message: string }) => void;
+    const pendingRun = new Promise<{ success: boolean; message: string }>((resolve) => {
+      resolveRun = resolve;
+    });
+
+    let runPromise: Promise<{ success: boolean; message: string } | null> | null = null;
+    await act(async () => {
+      runPromise = runner?.runSQLFileExecutionWithProgress({
+        title: 'completed-with-errors.sql',
+        filePath: 'D:/sql/completed-with-errors.sql',
+        run: async () => pendingRun,
+      }) || null;
+      await Promise.resolve();
+    });
+
+    act(() => {
+      runtimeApi.emitProgress({
+        jobId: runner?.state.jobId,
+        status: 'done',
+        executed: 27,
+        failed: 1,
+        percent: 100,
+      });
+      vi.advanceTimersByTime(20);
+    });
+
+    await act(async () => {
+      resolveRun({ success: false, message: '1 statement failed' });
+      await runPromise;
+    });
+
+    expect(runner?.state.status).toBe('error');
+    expect(runner?.state.failed).toBe(1);
+    expect(runner?.state.percent).toBe(100);
+  });
+
+  it('keeps the RPC error status when a queued done event flushes later', async () => {
+    renderRunner();
+
+    let resolveRun!: (value: { success: boolean; message: string }) => void;
+    const pendingRun = new Promise<{ success: boolean; message: string }>((resolve) => {
+      resolveRun = resolve;
+    });
+
+    let runPromise: Promise<{ success: boolean; message: string } | null> | null = null;
+    await act(async () => {
+      runPromise = runner?.runSQLFileExecutionWithProgress({
+        title: 'queued-done.sql',
+        filePath: 'D:/sql/queued-done.sql',
+        run: async () => pendingRun,
+      }) || null;
+      await Promise.resolve();
+    });
+
+    act(() => {
+      runtimeApi.emitProgress({
+        jobId: runner?.state.jobId,
+        status: 'done',
+        executed: 27,
+        failed: 1,
+        percent: 100,
+      });
+    });
+    await act(async () => {
+      resolveRun({ success: false, message: '1 statement failed' });
+      await runPromise;
+    });
+    act(() => {
+      vi.advanceTimersByTime(20);
+    });
+
+    expect(runner?.state.status).toBe('error');
+    expect(runner?.state.failed).toBe(1);
+    expect(runner?.state.percent).toBe(100);
+  });
 });
diff --git a/frontend/src/components/useSQLFileExecutionRunner.ts b/frontend/src/components/useSQLFileExecutionRunner.ts
index 1474eef8..3742a9be 100644
--- a/frontend/src/components/useSQLFileExecutionRunner.ts
+++ b/frontend/src/components/useSQLFileExecutionRunner.ts
@@ -109,9 +109,22 @@ export function useSQLFileExecutionRunner(options?: UseSQLFileExecutionRunnerOpt
         if (prev.jobId !== activeJobIdRef.current) {
           return prev;
         }
-        const nextStatus = (event.status || prev.status || 'running') as SQLFileExecutionRunnerStatus;
+        const reportedStatus = (event.status || prev.status || 'running') as SQLFileExecutionRunnerStatus;
+        const wasTerminal = prev.status === 'done' || prev.status === 'cancelled' || prev.status === 'error';
+        const reportedIsTerminal = reportedStatus === 'done' || reportedStatus === 'cancelled' || reportedStatus === 'error';
+        if (wasTerminal && !reportedIsTerminal) {
+          return prev;
+        }
+        // The RPC result is authoritative once it has settled. A terminal
+        // progress event delayed by the animation-frame throttle may still
+        // contribute final counters/percent, but must not rewrite that result.
+        const nextStatus = wasTerminal && reportedIsTerminal ? prev.status : reportedStatus;
         const nextStartedAt = prev.startedAt || Date.now();
         const isTerminal = nextStatus === 'done' || nextStatus === 'cancelled' || nextStatus === 'error';
+        const reportedPercent = Math.max(0, Math.min(100, Number(event.percent ?? prev.percent) || 0));
+        const nextPercent = reportedStatus === 'done' || nextStatus === 'done'
+          ? 100
+          : Math.min(99, reportedPercent);
         return {
           ...prev,
           startedAt: nextStartedAt,
@@ -121,11 +134,13 @@ export function useSQLFileExecutionRunner(options?: UseSQLFileExecutionRunnerOpt
             ? t('sidebar.sql_file_exec.status.cancelled')
             : nextStatus === 'error'
               ? t('sidebar.sql_file_exec.status.error')
-              : t('sidebar.sql_file_exec.status.running'),
+              : nextStatus === 'done'
+                ? t('sidebar.sql_file_exec.status.done')
+                : t('sidebar.sql_file_exec.status.running'),
           executed: normalizeCount(event.executed ?? prev.executed),
           failed: normalizeCount(event.failed ?? prev.failed),
           total: normalizeCount(event.total ?? prev.total),
-          percent: Math.max(0, Math.min(100, Number(event.percent ?? prev.percent) || 0)),
+          percent: nextPercent,
           currentSQL: typeof event.currentSQL === 'string' ? event.currentSQL : prev.currentSQL,
           message: typeof event.error === 'string' && event.error.trim() ? event.error : prev.message,
         };
@@ -246,7 +261,9 @@ export function useSQLFileExecutionRunner(options?: UseSQLFileExecutionRunnerOpt
             : nextStatus === 'done'
               ? t('sidebar.sql_file_exec.status.done')
               : t('sidebar.sql_file_exec.status.error'),
-          percent: nextStatus === 'cancelled' ? prev.percent : 100,
+          percent: nextStatus === 'done' || prev.status === 'done'
+            ? 100
+            : Math.min(99, prev.percent),
           message: typeof result.message === 'string' ? result.message : prev.message,
         };
       });
diff --git a/internal/app/app.go b/internal/app/app.go
index 13a458ab..fc5e6b33 100644
--- a/internal/app/app.go
+++ b/internal/app/app.go
@@ -133,8 +133,9 @@ type databaseConnectResult struct {
 }
 
 type queryContext struct {
-	cancel  context.CancelFunc
-	started time.Time
+	cancel          context.CancelFunc
+	started         time.Time
+	retainUntilDone bool
 }
 
 type managedSQLTransaction struct {
@@ -1665,7 +1666,9 @@ func (a *App) CancelQuery(queryID string) connection.QueryResult {
 
 	if ctx, exists := a.runningQueries[queryID]; exists {
 		ctx.cancel()
-		delete(a.runningQueries, queryID)
+		if !ctx.retainUntilDone {
+			delete(a.runningQueries, queryID)
+		}
 		logger.Infof("查询已取消：queryID=%s", queryID)
 		return connection.QueryResult{Success: true, Message: a.appText("query_editor.message.cancel_success", nil)}
 	}
diff --git a/internal/app/import_pipeline.go b/internal/app/import_pipeline.go
index 44ab3cd0..b744b72e 100644
--- a/internal/app/import_pipeline.go
+++ b/internal/app/import_pipeline.go
@@ -2,8 +2,10 @@ package app
 
 import (
 	"bufio"
+	"context"
 	"encoding/csv"
 	"encoding/json"
+	"errors"
 	"fmt"
 	"io"
 	"os"
@@ -327,6 +329,7 @@ func (w *importDatabaseRowWriter) ApplyOne(row map[string]interface{}) error {
 
 type importBatchConsumer struct {
 	writer         importRowWriter
+	ctx            context.Context
 	jobID          string
 	batchSize      int
 	totalRows      int
@@ -345,6 +348,7 @@ func newImportBatchConsumer(writer importRowWriter, batchSize int, totalRows int
 	}
 	return &importBatchConsumer{
 		writer:         writer,
+		ctx:            context.Background(),
 		batchSize:      batchSize,
 		totalRows:      totalRows,
 		totalRowsKnown: totalRowsKnown,
@@ -352,7 +356,24 @@ func newImportBatchConsumer(writer importRowWriter, batchSize int, totalRows int
 	}
 }
 
+func (c *importBatchConsumer) SetContext(ctx context.Context) {
+	if ctx == nil {
+		ctx = context.Background()
+	}
+	c.ctx = ctx
+}
+
+func (c *importBatchConsumer) contextError() error {
+	if c == nil || c.ctx == nil {
+		return nil
+	}
+	return c.ctx.Err()
+}
+
 func (c *importBatchConsumer) SetColumns(columns []string) error {
+	if err := c.contextError(); err != nil {
+		return err
+	}
 	if c.writer != nil {
 		c.writer.SetColumns(columns)
 	}
@@ -360,6 +381,9 @@ func (c *importBatchConsumer) SetColumns(columns []string) error {
 }
 
 func (c *importBatchConsumer) ConsumeRow(row map[string]interface{}) error {
+	if err := c.contextError(); err != nil {
+		return err
+	}
 	c.currentRow++
 	if len(c.batch) == 0 {
 		c.batchStartRow = c.currentRow
@@ -385,6 +409,9 @@ func (c *importBatchConsumer) Result() importExecutionResult {
 }
 
 func (c *importBatchConsumer) flush() error {
+	if err := c.contextError(); err != nil {
+		return err
+	}
 	if len(c.batch) == 0 {
 		return nil
 	}
@@ -394,22 +421,41 @@ func (c *importBatchConsumer) flush() error {
 	c.batchStartRow = 0
 
 	if c.writer != nil && c.writer.BatchEnabled() {
-		if err := c.writer.ApplyBatch(rows); err == nil {
+		batchErr := c.writer.ApplyBatch(rows)
+		if batchErr == nil {
 			c.successCount += len(rows)
 			c.emitProgress(startRow + len(rows) - 1)
-			return nil
+			return c.contextError()
+		}
+		if errors.Is(batchErr, context.Canceled) {
+			return batchErr
+		}
+		if err := c.contextError(); err != nil {
+			return err
 		}
 	}
 
 	for idx, row := range rows {
+		if err := c.contextError(); err != nil {
+			return err
+		}
 		if c.writer != nil {
 			if err := c.writer.ApplyOne(row); err != nil {
+				if errors.Is(err, context.Canceled) {
+					return err
+				}
+				if contextErr := c.contextError(); contextErr != nil {
+					return contextErr
+				}
 				c.errorLogs = append(c.errorLogs, fmt.Sprintf("Row %d: %s", startRow+idx, err.Error()))
 			} else {
 				c.successCount++
 			}
 		}
 		c.emitProgress(startRow + idx)
+		if err := c.contextError(); err != nil {
+			return err
+		}
 	}
 	return nil
 }
diff --git a/internal/app/methods_file.go b/internal/app/methods_file.go
index 375ba5dd..e896c460 100644
--- a/internal/app/methods_file.go
+++ b/internal/app/methods_file.go
@@ -1695,6 +1695,26 @@ func buildGoNaviMySQLDatabaseBackupBootstrapSQL(backup goNaviMySQLDatabaseBackup
 	return fmt.Sprintf("CREATE DATABASE IF NOT EXISTS %s", quoteIdentByType("mysql", backup.databaseName))
 }
 
+func resolveSQLFileExecutionProgressPercent(status string, bytesRead, totalSize int64) float64 {
+	if totalSize <= 0 {
+		return 0
+	}
+	percent := float64(bytesRead) / float64(totalSize) * 100
+	if percent < 0 {
+		return 0
+	}
+	if percent > 100 {
+		percent = 100
+	}
+	// The SQL splitter reads ahead before executing the statements found in that
+	// chunk. Reaching EOF therefore means parsing is complete, not execution.
+	// Reserve 100% for the successful terminal event.
+	if !strings.EqualFold(strings.TrimSpace(status), "done") && percent >= 100 {
+		return 99
+	}
+	return percent
+}
+
 func resolveSQLFileExecutionRunConfig(config connection.ConnectionConfig, dbName string, preamble []byte) connection.ConnectionConfig {
 	runConfig := normalizeRunConfig(config, dbName)
 	if strings.EqualFold(strings.TrimSpace(runConfig.Type), "mysql") {
@@ -1782,13 +1802,7 @@ func (a *App) ExecuteSQLFile(config connection.ConnectionConfig, dbName string,
 
 	// 发送进度事件的辅助函数
 	emitProgress := func(status string, executed, failed, total int, bytesRead int64, currentSQL string, errMsg string) {
-		percent := 0.0
-		if totalSize > 0 {
-			percent = float64(bytesRead) / float64(totalSize) * 100
-			if percent > 100 {
-				percent = 100
-			}
-		}
+		percent := resolveSQLFileExecutionProgressPercent(status, bytesRead, totalSize)
 		uievents.Emit(a.ctx, "sqlfile:progress", map[string]interface{}{
 			"jobId":      jobID,
 			"status":     status,
@@ -2562,6 +2576,35 @@ func (a *App) ImportDataWithProgress(config connection.ConnectionConfig, dbName,
 	return a.ImportDataWithProgressOptions(config, dbName, tableName, filePath, ImportFileOptions{})
 }
 
+func buildImportExecutionPayload(resultData importExecutionResult, summary string, cancelled bool) map[string]interface{} {
+	total := resultData.Total
+	if cancelled {
+		// Rows that were parsed into an uncommitted buffer are not processed rows.
+		total = resultData.Success + resultData.Failed
+	}
+	return map[string]interface{}{
+		"success":      resultData.Success,
+		"failed":       resultData.Failed,
+		"total":        total,
+		"affectedRows": int64(resultData.Success),
+		"errorLogs":    resultData.ErrorLogs,
+		"errorSummary": summary,
+		"cancelled":    cancelled,
+	}
+}
+
+func (a *App) cancelledImportResult(resultData importExecutionResult) connection.QueryResult {
+	summary := a.appText("file.backend.message.import_cancelled", map[string]any{
+		"imported": resultData.Success,
+		"failed":   resultData.Failed,
+	})
+	return connection.QueryResult{
+		Success: false,
+		Data:    buildImportExecutionPayload(resultData, summary, true),
+		Message: summary,
+	}
+}
+
 // ImportDataWithProgressOptions executes a streamed import with optional source-header
 // to database-column mappings. ImportDataWithProgress remains the compatibility entrypoint.
 func (a *App) ImportDataWithProgressOptions(config connection.ConnectionConfig, dbName, tableName, filePath string, options ImportFileOptions) (result connection.QueryResult) {
@@ -2586,13 +2629,56 @@ func (a *App) ImportDataWithProgressOptions(config connection.ConnectionConfig,
 	if err := ensureConnectionAllowsDataImport(config, "connection.backend.action.import_data"); err != nil {
 		return connection.QueryResult{Success: false, Message: err.Error()}
 	}
+
+	importCtx := context.Background()
+	jobID := strings.TrimSpace(options.JobID)
+	if jobID != "" {
+		registeredAt := time.Now()
+		ctx, cancel := context.WithCancel(context.Background())
+		importCtx = ctx
+		a.queryMu.Lock()
+		if a.runningQueries == nil {
+			a.runningQueries = make(map[string]queryContext)
+		}
+		if _, exists := a.runningQueries[jobID]; exists {
+			a.queryMu.Unlock()
+			cancel()
+			return connection.QueryResult{Success: false, Message: a.appText("file.backend.error.import_job_already_running", nil)}
+		}
+		a.runningQueries[jobID] = queryContext{
+			cancel:          cancel,
+			started:         registeredAt,
+			retainUntilDone: true,
+		}
+		a.queryMu.Unlock()
+		defer cancel()
+		defer func() {
+			a.queryMu.Lock()
+			if running, exists := a.runningQueries[jobID]; exists && running.started.Equal(registeredAt) {
+				delete(a.runningQueries, jobID)
+			}
+			a.queryMu.Unlock()
+		}()
+	}
+	if err := importCtx.Err(); err != nil {
+		return a.cancelledImportResult(importExecutionResult{})
+	}
 	runConfig := normalizeRunConfig(config, dbName)
 	dbInst, err := a.getDatabase(runConfig)
 	if err != nil {
+		if errors.Is(importCtx.Err(), context.Canceled) {
+			return a.cancelledImportResult(importExecutionResult{})
+		}
 		return connection.QueryResult{Success: false, Message: err.Error()}
 	}
+	if err := importCtx.Err(); err != nil {
+		return a.cancelledImportResult(importExecutionResult{})
+	}
 
 	targetColumns, colErr := getColumnsWithMetadataFallback(dbInst, config, metadataSchemaName, metadataTableName, a.appText)
+	if errors.Is(importCtx.Err(), context.Canceled) {
+		return a.cancelledImportResult(importExecutionResult{})
+	}
 	if colErr != nil && options.ColumnMappings != nil {
 		return connection.QueryResult{Success: false, Message: colErr.Error()}
 	}
@@ -2601,18 +2687,27 @@ func (a *App) ImportDataWithProgressOptions(config connection.ConnectionConfig,
 	batchConsumer := newImportBatchConsumer(writer, defaultImportApplyBatchSize, 0, false, func(state importProgressState) {
 		uievents.Emit(a.ctx, "import:progress", state)
 	})
-	batchConsumer.jobID = strings.TrimSpace(options.JobID)
+	batchConsumer.SetContext(importCtx)
+	batchConsumer.jobID = jobID
 	consumer, err := newImportColumnMappingConsumer(batchConsumer, options.ColumnMappings, targetColumns)
 	if err != nil {
 		return connection.QueryResult{Success: false, Message: err.Error()}
 	}
 	if err := streamImportFile(filePath, consumer); err != nil {
 		resultData := batchConsumer.Result()
+		if errors.Is(err, context.Canceled) {
+			maybeReleaseFileTransferMemory("import-cancelled", int64(resultData.Success+resultData.Failed), filePath)
+			return a.cancelledImportResult(resultData)
+		}
 		maybeReleaseFileTransferMemory("import-stream-error", int64(resultData.Total), filePath)
 		return connection.QueryResult{Success: false, Message: err.Error()}
 	}
 	if err := batchConsumer.Flush(); err != nil {
 		resultData := batchConsumer.Result()
+		if errors.Is(err, context.Canceled) {
+			maybeReleaseFileTransferMemory("import-cancelled", int64(resultData.Success+resultData.Failed), filePath)
+			return a.cancelledImportResult(resultData)
+		}
 		maybeReleaseFileTransferMemory("import-flush-error", int64(resultData.Total), filePath)
 		return connection.QueryResult{Success: false, Message: err.Error()}
 	}
@@ -2627,14 +2722,7 @@ func (a *App) ImportDataWithProgressOptions(config connection.ConnectionConfig,
 		"imported": resultData.Success,
 		"failed":   resultData.Failed,
 	})
-	resultPayload := map[string]interface{}{
-		"success":      resultData.Success,
-		"failed":       resultData.Failed,
-		"total":        resultData.Total,
-		"affectedRows": int64(resultData.Success),
-		"errorLogs":    resultData.ErrorLogs,
-		"errorSummary": summary,
-	}
+	resultPayload := buildImportExecutionPayload(resultData, summary, false)
 
 	maybeReleaseFileTransferMemory("import-finished", int64(resultData.Total), filePath)
 	return connection.QueryResult{Success: true, Data: resultPayload, Message: summary}
diff --git a/internal/app/methods_file_i18n_test.go b/internal/app/methods_file_i18n_test.go
index 50067b96..893464b9 100644
--- a/internal/app/methods_file_i18n_test.go
+++ b/internal/app/methods_file_i18n_test.go
@@ -344,9 +344,11 @@ func TestImportDataBackendCatalogKeysExist(t *testing.T) {
 		"file.backend.error.import_excel_parse_failed",
 		"file.backend.error.import_excel_read_failed",
 		"file.backend.error.import_file_empty",
+		"file.backend.error.import_job_already_running",
 		"file.backend.error.import_json_parse_failed",
 		"file.backend.error.import_unsupported_format",
 		"file.backend.filter.data_files",
+		"file.backend.message.import_cancelled",
 		"file.backend.message.import_no_data",
 		"file.backend.message.import_row_failed",
 		"file.backend.message.import_summary",
diff --git a/internal/app/methods_file_import_test.go b/internal/app/methods_file_import_test.go
index 21f49d51..c9b872bc 100644
--- a/internal/app/methods_file_import_test.go
+++ b/internal/app/methods_file_import_test.go
@@ -186,12 +186,27 @@ type fakeImportRowWriter struct {
 	batchRows        []map[string]interface{}
 	batchErr         error
 	singleErrByRowID map[interface{}]error
+	afterSingleCall  func()
 }
 
 type noopImportEventEmitter struct{}
 
 func (noopImportEventEmitter) Emit(string, ...any) {}
 
+type cancellableImportTestDB struct {
+	fakeMetadataRetryDB
+	execCalls      int
+	afterFirstExec func()
+}
+
+func (d *cancellableImportTestDB) Exec(string) (int64, error) {
+	d.execCalls++
+	if d.execCalls == 1 && d.afterFirstExec != nil {
+		d.afterFirstExec()
+	}
+	return 1, nil
+}
+
 func (w *fakeImportRowWriter) SetColumns(columns []string) {
 	w.columns = append([]string(nil), columns...)
 }
@@ -205,6 +220,9 @@ func (w *fakeImportRowWriter) ApplyBatch(rows []map[string]interface{}) error {
 
 func (w *fakeImportRowWriter) ApplyOne(row map[string]interface{}) error {
 	w.singleCalls++
+	if w.afterSingleCall != nil {
+		w.afterSingleCall()
+	}
 	if err, ok := w.singleErrByRowID[row["id"]]; ok {
 		return err
 	}
@@ -404,6 +422,71 @@ func TestImportDataWithProgressOptionsRejectsEmptyFilePathBeforeDatabaseAccess(t
 	}
 }
 
+func TestImportDataWithProgressOptionsStopsByJobIDAndReturnsCommittedPartialResult(t *testing.T) {
+	originalNewDatabaseFunc := newDatabaseFunc
+	originalResolveDialConfigWithProxyFunc := resolveDialConfigWithProxyFunc
+	t.Cleanup(func() {
+		newDatabaseFunc = originalNewDatabaseFunc
+		resolveDialConfigWithProxyFunc = originalResolveDialConfigWithProxyFunc
+	})
+
+	database := &cancellableImportTestDB{fakeMetadataRetryDB: fakeMetadataRetryDB{
+		columns: []connection.ColumnDefinition{{Name: "id", Type: "bigint"}},
+	}}
+	newDatabaseFunc = func(string) (db.Database, error) { return database, nil }
+	resolveDialConfigWithProxyFunc = func(config connection.ConnectionConfig) (connection.ConnectionConfig, error) {
+		return config, nil
+	}
+
+	path := filepath.Join(t.TempDir(), "users.csv")
+	if err := os.WriteFile(path, []byte("id\n1\n2\n3\n"), 0o600); err != nil {
+		t.Fatalf("write csv: %v", err)
+	}
+
+	app := NewAppWithSecretStore(secretstore.NewUnavailableStore("test"))
+	app.ctx = uievents.WithEmitter(context.Background(), noopImportEventEmitter{})
+	const jobID = "import-cancel-test"
+	database.afterFirstExec = func() {
+		cancelResult := app.CancelQuery(jobID)
+		if !cancelResult.Success {
+			t.Errorf("CancelQuery returned failure: %s", cancelResult.Message)
+		}
+		app.queryMu.Lock()
+		_, retainedWhileStopping := app.runningQueries[jobID]
+		app.queryMu.Unlock()
+		if !retainedWhileStopping {
+			t.Error("cancelled import job was unregistered before its owner stopped")
+		}
+	}
+
+	result := app.ImportDataWithProgressOptions(
+		connection.ConnectionConfig{Type: "mysql", Host: "127.0.0.1", Port: 3306, Database: "app"},
+		"app",
+		"users",
+		path,
+		ImportFileOptions{ColumnMappings: map[string]string{"id": "id"}, JobID: jobID},
+	)
+	if result.Success {
+		t.Fatal("cancelled import should not be reported as a completed success")
+	}
+	payload, ok := result.Data.(map[string]interface{})
+	if !ok {
+		t.Fatalf("result data type = %T, want map[string]interface{}", result.Data)
+	}
+	if payload["cancelled"] != true || payload["success"] != 1 || payload["failed"] != 0 || payload["total"] != 1 {
+		t.Fatalf("unexpected cancelled payload: %#v", payload)
+	}
+	if database.execCalls != 1 {
+		t.Fatalf("Exec calls = %d, want 1", database.execCalls)
+	}
+	app.queryMu.Lock()
+	_, stillRegistered := app.runningQueries[jobID]
+	app.queryMu.Unlock()
+	if stillRegistered {
+		t.Fatal("cancelled import job remained registered")
+	}
+}
+
 func TestImportDataWithProgressOptionsUsesOracleColumnMetadataFallback(t *testing.T) {
 	originalNewDatabaseFunc := newDatabaseFunc
 	originalResolveDialConfigWithProxyFunc := resolveDialConfigWithProxyFunc
@@ -526,6 +609,51 @@ func TestImportBatchConsumerFallsBackToSingleRowsWhenBatchFails(t *testing.T) {
 	}
 }
 
+func TestImportBatchConsumerStopsSingleRowFallbackAfterCancellation(t *testing.T) {
+	ctx, cancel := context.WithCancel(context.Background())
+	writer := &fakeImportRowWriter{
+		batchErr:        fmt.Errorf("batch failed"),
+		afterSingleCall: cancel,
+	}
+	consumer := newImportBatchConsumer(writer, 1000, 3, true, nil)
+	consumer.SetContext(ctx)
+
+	for i := 1; i <= 3; i++ {
+		if err := consumer.ConsumeRow(map[string]interface{}{"id": i}); err != nil {
+			t.Fatalf("ConsumeRow(%d) returned error: %v", i, err)
+		}
+	}
+
+	err := consumer.Flush()
+	if !errors.Is(err, context.Canceled) {
+		t.Fatalf("Flush error = %v, want context.Canceled", err)
+	}
+	if writer.singleCalls != 1 {
+		t.Fatalf("single-row fallback calls = %d, want 1", writer.singleCalls)
+	}
+	result := consumer.Result()
+	if result.Success != 1 || result.Failed != 0 {
+		t.Fatalf("unexpected partial result: %#v", result)
+	}
+}
+
+func TestImportBatchConsumerDoesNotCountCancellationAsRowFailure(t *testing.T) {
+	writer := &fakeImportRowWriter{
+		batchErr:         fmt.Errorf("batch failed"),
+		singleErrByRowID: map[interface{}]error{1: context.Canceled},
+	}
+	consumer := newImportBatchConsumer(writer, 1, 1, true, nil)
+
+	err := consumer.ConsumeRow(map[string]interface{}{"id": 1})
+	if !errors.Is(err, context.Canceled) {
+		t.Fatalf("ConsumeRow error = %v, want context.Canceled", err)
+	}
+	result := consumer.Result()
+	if result.Success != 0 || result.Failed != 0 {
+		t.Fatalf("unexpected cancelled result: %#v", result)
+	}
+}
+
 func TestImportBatchConsumerProgressIncludesJobID(t *testing.T) {
 	writer := &fakeImportRowWriter{}
 	var progress []importProgressState
diff --git a/internal/app/methods_file_sql_execution_test.go b/internal/app/methods_file_sql_execution_test.go
index 275d21b0..df71b031 100644
--- a/internal/app/methods_file_sql_execution_test.go
+++ b/internal/app/methods_file_sql_execution_test.go
@@ -12,6 +12,29 @@ import (
 	"GoNavi-Wails/internal/db"
 )
 
+func TestResolveSQLFileExecutionProgressPercentReservesCompletionForTerminalState(t *testing.T) {
+	tests := []struct {
+		name      string
+		status    string
+		bytesRead int64
+		totalSize int64
+		want      float64
+	}{
+		{name: "running reader reached eof", status: "running", bytesRead: 128, totalSize: 128, want: 99},
+		{name: "running partial read", status: "running", bytesRead: 64, totalSize: 128, want: 50},
+		{name: "done", status: "done", bytesRead: 128, totalSize: 128, want: 100},
+		{name: "unknown size", status: "running", bytesRead: 64, totalSize: 0, want: 0},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			if got := resolveSQLFileExecutionProgressPercent(tt.status, tt.bytesRead, tt.totalSize); got != tt.want {
+				t.Fatalf("percent = %v, want %v", got, tt.want)
+			}
+		})
+	}
+}
+
 type fakeSQLFileBatchDB struct {
 	batchCalls   int
 	execCalls    int
diff --git a/internal/app/methods_sql_audit.go b/internal/app/methods_sql_audit.go
index c1774d70..b01345d2 100644
--- a/internal/app/methods_sql_audit.go
+++ b/internal/app/methods_sql_audit.go
@@ -710,6 +710,11 @@ func sqlAuditStatusFromResult(result connection.QueryResult) string {
 	if result.Success {
 		return "success"
 	}
+	if data, ok := result.Data.(map[string]interface{}); ok {
+		if cancelled, ok := data["cancelled"].(bool); ok && cancelled {
+			return "cancelled"
+		}
+	}
 	message := strings.ToLower(strings.TrimSpace(result.Message))
 	if strings.Contains(message, "context canceled") ||
 		strings.Contains(message, "context cancelled") ||
diff --git a/internal/app/methods_sql_audit_test.go b/internal/app/methods_sql_audit_test.go
index d637b439..870b67c7 100644
--- a/internal/app/methods_sql_audit_test.go
+++ b/internal/app/methods_sql_audit_test.go
@@ -84,6 +84,17 @@ func loadSQLAuditEvents(t *testing.T, app *App, filter sqlaudit.Filter) []sqlaud
 	return page.Items
 }
 
+func TestSQLAuditStatusFromResultUsesStructuredCancellationMarker(t *testing.T) {
+	result := connection.QueryResult{
+		Success: false,
+		Message: "导入已停止",
+		Data:    map[string]interface{}{"cancelled": true},
+	}
+	if got := sqlAuditStatusFromResult(result); got != "cancelled" {
+		t.Fatalf("status = %q, want cancelled", got)
+	}
+}
+
 func TestSQLAuditConnectionFingerprintExcludesSecrets(t *testing.T) {
 	base := connection.ConnectionConfig{
 		Type:          "postgres",
diff --git a/shared/i18n/de-DE.json b/shared/i18n/de-DE.json
index e81d91c1..5a8ba3e5 100644
--- a/shared/i18n/de-DE.json
+++ b/shared/i18n/de-DE.json
@@ -5466,6 +5466,7 @@
   "file.backend.error.mysql_workbench_parse_failed": "MySQL Workbench-XML konnte nicht geparst werden: {{detail}}",
   "file.backend.error.navicat_connection_password_parse_failed": "Passwort für Verbindung {{name}} konnte nicht verarbeitet werden",
   "file.backend.error.navicat_connection_proxy_password_parse_failed": "Proxy-Passwort für Verbindung {{name}} konnte nicht verarbeitet werden",
+  "file.backend.error.import_job_already_running": "Dieser Importauftrag wird bereits ausgeführt",
   "file.backend.error.navicat_connection_ssh_password_parse_failed": "SSH-Passwort für Verbindung {{name}} konnte nicht verarbeitet werden",
   "file.backend.error.navicat_ncx_no_connections": "In Navicat NCX wurde keine von GoNavi unterstützte gültige Verbindungskonfiguration gefunden",
   "file.backend.error.navicat_ncx_parse_failed": "Navicat NCX konnte nicht geparst werden",
@@ -5534,6 +5535,7 @@
   "file.backend.message.table_data_truncate_succeeded": "TRUNCATE erfolgreich",
   "file.backend.message.transaction_committed": "Transaktion erfolgreich committet",
   "file.backend.message.user_cancelled": "Benutzer hat die Ausführung abgebrochen",
+  "file.backend.message.import_cancelled": "Import gestoppt. {{imported}} Zeilen erfolgreich, {{failed}} fehlgeschlagen; bereits übernommene Daten wurden nicht zurückgerollt.",
   "file.backend.sql_dump.database": "Datenbank: {{database}}",
   "file.backend.sql_dump.empty_rows": "(0 Zeilen)",
   "file.backend.sql_dump.generated_at": "Erstellt am: {{generatedAt}}",
@@ -5571,11 +5573,14 @@
   "import_preview.error.target_columns_failed": "Spalten der Zieltabelle konnten nicht geladen werden",
   "import_preview.mapping.description": "Ordnen Sie Dateikopfzeilen Datenbankfeldern zu. Nicht zugeordnete Spalten werden übersprungen.",
   "import_preview.mapping.ignore": "Diese Spalte überspringen",
+  "import_preview.action.stop": "Import stoppen",
   "import_preview.mapping.source_column": "Dateispalte",
   "import_preview.mapping.target_column": "Datenbankfeld",
   "import_preview.mapping.title": "Spaltenzuordnung",
   "import_preview.mapping.validation.duplicate_source": "Die Datei enthält doppelte Spaltenüberschriften und kann nicht sicher importiert werden",
   "import_preview.mapping.validation.duplicate_target": "Jedes Datenbankfeld darf nur einmal zugeordnet werden",
+  "import_preview.error.stop_failed": "Import konnte nicht gestoppt werden",
+  "import_preview.error.stop_failed_detail": "Import konnte nicht gestoppt werden: {{detail}}",
   "import_preview.mapping.validation.required": "Ordnen Sie mindestens eine Dateispalte zu",
   "import_preview.preview.description": "Die ersten 5 Zeilen werden unten angezeigt. Starten Sie den Import nach der Prüfung der Daten.",
   "import_preview.preview.field_list": "Feldliste:",
@@ -5595,9 +5600,11 @@
   "jvm.backend.connection_error.agent.base_url_invalid.help": "Gib eine vollständige http://- oder https://-URL ein, z. B. http://127.0.0.1:19090/gonavi/agent/jvm.",
   "jvm.backend.connection_error.agent.base_url_invalid.summary": "Agent-Verbindung fehlgeschlagen: Agent Base URL ist ungültig.",
   "jvm.backend.connection_error.agent.base_url_required": "Agent-Verbindung fehlgeschlagen: Agent Base URL fehlt.",
+  "import_preview.result.stopped": "Import gestoppt (übernommene Daten wurden nicht zurückgerollt)",
   "jvm.backend.connection_error.agent.connection_refused.help": "Prüfe, ob der Java-Dienst den GoNavi Agent mit `-javaagent` gestartet hat, und prüfe Base URL, Port-Mapping und Firewall.",
   "jvm.backend.connection_error.agent.connection_refused.summary": "Agent-Verbindung fehlgeschlagen: Der Ziel-Agent-Management-Port lauscht nicht oder die Adresse ist nicht erreichbar.",
   "jvm.backend.connection_error.agent.forbidden.help": "Prüfe, ob Client-Quelle, Authentifizierung und Agent-Zugriffsrichtlinie GoNavi den Zugriff erlauben.",
+  "import_preview.status.stopping": "Import wird nach dem aktuellen Datenbankvorgang gestoppt...",
   "jvm.backend.connection_error.agent.forbidden.summary": "Agent-Verbindung fehlgeschlagen: Agent hat diese Anfrage abgelehnt.",
   "jvm.backend.connection_error.agent.scheme_unsupported.help": "Ändere Agent Base URL auf eine Adresse, die mit http:// oder https:// beginnt.",
   "jvm.backend.connection_error.agent.scheme_unsupported.summary": "Agent-Verbindung fehlgeschlagen: nur HTTP oder HTTPS wird unterstützt.",
diff --git a/shared/i18n/en-US.json b/shared/i18n/en-US.json
index e6842037..825fa90e 100644
--- a/shared/i18n/en-US.json
+++ b/shared/i18n/en-US.json
@@ -5466,6 +5466,7 @@
   "file.backend.error.mysql_workbench_parse_failed": "Failed to parse MySQL Workbench XML: {{detail}}",
   "file.backend.error.navicat_connection_password_parse_failed": "Failed to parse password for connection {{name}}",
   "file.backend.error.navicat_connection_proxy_password_parse_failed": "Failed to parse proxy password for connection {{name}}",
+  "file.backend.error.import_job_already_running": "This import job is already running",
   "file.backend.error.navicat_connection_ssh_password_parse_failed": "Failed to parse SSH password for connection {{name}}",
   "file.backend.error.navicat_ncx_no_connections": "No valid GoNavi-supported connection configuration was found in Navicat NCX",
   "file.backend.error.navicat_ncx_parse_failed": "Failed to parse Navicat NCX",
@@ -5534,6 +5535,7 @@
   "file.backend.message.table_data_truncate_succeeded": "Truncation succeeded",
   "file.backend.message.transaction_committed": "Transaction committed successfully",
   "file.backend.message.user_cancelled": "User canceled execution",
+  "file.backend.message.import_cancelled": "Import stopped. {{imported}} rows succeeded and {{failed}} failed; committed data was not rolled back.",
   "file.backend.sql_dump.database": "Database: {{database}}",
   "file.backend.sql_dump.empty_rows": "(0 rows)",
   "file.backend.sql_dump.generated_at": "Time: {{generatedAt}}",
@@ -5571,11 +5573,14 @@
   "import_preview.error.target_columns_failed": "Could not load target table columns",
   "import_preview.mapping.description": "Map file headers to database fields. Unmapped columns will be skipped.",
   "import_preview.mapping.ignore": "Skip this column",
+  "import_preview.action.stop": "Stop import",
   "import_preview.mapping.source_column": "File column",
   "import_preview.mapping.target_column": "Database field",
   "import_preview.mapping.title": "Column mapping",
   "import_preview.mapping.validation.duplicate_source": "The file contains duplicate column headers and cannot be imported safely",
   "import_preview.mapping.validation.duplicate_target": "Each database field can be mapped only once",
+  "import_preview.error.stop_failed": "Could not stop the import",
+  "import_preview.error.stop_failed_detail": "Could not stop the import: {{detail}}",
   "import_preview.mapping.validation.required": "Map at least one file column",
   "import_preview.preview.description": "The first 5 rows are shown below. Start the import after confirming the data.",
   "import_preview.preview.field_list": "Field list:",
@@ -5595,9 +5600,11 @@
   "jvm.backend.connection_error.agent.base_url_invalid.help": "Enter a full http:// or https:// URL, for example http://127.0.0.1:19090/gonavi/agent/jvm.",
   "jvm.backend.connection_error.agent.base_url_invalid.summary": "Agent connection failed: Agent Base URL is invalid.",
   "jvm.backend.connection_error.agent.base_url_required": "Agent connection failed: Agent Base URL is missing.",
+  "import_preview.result.stopped": "Import stopped (committed data was not rolled back)",
   "jvm.backend.connection_error.agent.connection_refused.help": "Confirm the Java service started GoNavi Agent with `-javaagent`, and check Base URL, port mapping, and firewall rules.",
   "jvm.backend.connection_error.agent.connection_refused.summary": "Agent connection failed: the target Agent management port is not listening, or the address is unreachable.",
   "jvm.backend.connection_error.agent.forbidden.help": "Confirm that client source, authentication settings, and Agent access policy allow GoNavi to access it.",
+  "import_preview.status.stopping": "Stopping import after the current database operation...",
   "jvm.backend.connection_error.agent.forbidden.summary": "Agent connection failed: Agent rejected this request.",
   "jvm.backend.connection_error.agent.scheme_unsupported.help": "Change Agent Base URL to an address that starts with http:// or https://.",
   "jvm.backend.connection_error.agent.scheme_unsupported.summary": "Agent connection failed: only HTTP or HTTPS is supported.",
diff --git a/shared/i18n/ja-JP.json b/shared/i18n/ja-JP.json
index 03005675..7e09d002 100644
--- a/shared/i18n/ja-JP.json
+++ b/shared/i18n/ja-JP.json
@@ -5466,6 +5466,7 @@
   "file.backend.error.mysql_workbench_parse_failed": "MySQL Workbench XML の解析に失敗しました: {{detail}}",
   "file.backend.error.navicat_connection_password_parse_failed": "接続 {{name}} のパスワードを解析できません",
   "file.backend.error.navicat_connection_proxy_password_parse_failed": "接続 {{name}} のプロキシパスワードを解析できません",
+  "file.backend.error.import_job_already_running": "このインポートジョブはすでに実行中です",
   "file.backend.error.navicat_connection_ssh_password_parse_failed": "接続 {{name}} の SSH パスワードを解析できません",
   "file.backend.error.navicat_ncx_no_connections": "Navicat NCX に GoNavi がサポートする有効な接続設定が見つかりません",
   "file.backend.error.navicat_ncx_parse_failed": "Navicat NCX の解析に失敗しました",
@@ -5534,6 +5535,7 @@
   "file.backend.message.table_data_truncate_succeeded": "truncate が完了しました",
   "file.backend.message.transaction_committed": "トランザクションをコミットしました",
   "file.backend.message.user_cancelled": "ユーザーが実行をキャンセルしました",
+  "file.backend.message.import_cancelled": "インポートを停止しました。成功 {{imported}} 行、失敗 {{failed}} 行です。コミット済みデータはロールバックされません。",
   "file.backend.sql_dump.database": "データベース: {{database}}",
   "file.backend.sql_dump.empty_rows": "(0 行)",
   "file.backend.sql_dump.generated_at": "生成日時: {{generatedAt}}",
@@ -5571,11 +5573,14 @@
   "import_preview.error.target_columns_failed": "対象テーブルの列を読み込めませんでした",
   "import_preview.mapping.description": "ファイルのヘッダーをデータベース列に対応付けます。未対応の列はスキップされます。",
   "import_preview.mapping.ignore": "この列をスキップ",
+  "import_preview.action.stop": "インポートを停止",
   "import_preview.mapping.source_column": "ファイル列",
   "import_preview.mapping.target_column": "データベース列",
   "import_preview.mapping.title": "列マッピング",
   "import_preview.mapping.validation.duplicate_source": "ファイルに重複した列ヘッダーがあるため、安全にインポートできません",
   "import_preview.mapping.validation.duplicate_target": "各データベース列は 1 回だけマッピングできます",
+  "import_preview.error.stop_failed": "インポートを停止できませんでした",
+  "import_preview.error.stop_failed_detail": "インポートを停止できませんでした: {{detail}}",
   "import_preview.mapping.validation.required": "ファイル列を 1 つ以上マッピングしてください",
   "import_preview.preview.description": "最初の 5 行を表示しています。内容を確認してからインポートを開始してください。",
   "import_preview.preview.field_list": "フィールド一覧:",
@@ -5595,9 +5600,11 @@
   "jvm.backend.connection_error.agent.base_url_invalid.help": "完全な `http://` または `https://` の URL を入力してください。例: `http://127.0.0.1:19090/gonavi/agent/jvm`。",
   "jvm.backend.connection_error.agent.base_url_invalid.summary": "Agent 接続に失敗しました: Agent Base URL の形式が正しくありません。",
   "jvm.backend.connection_error.agent.base_url_required": "Agent 接続に失敗しました: Agent Base URL が未入力です。",
+  "import_preview.result.stopped": "インポートを停止しました（コミット済みデータはロールバックされません）",
   "jvm.backend.connection_error.agent.connection_refused.help": "Java サービスが `-javaagent` で GoNavi Agent を起動していることを確認し、Base URL、ポートマッピング、ファイアウォールを確認してください。",
   "jvm.backend.connection_error.agent.connection_refused.summary": "Agent 接続に失敗しました: ターゲット Agent 管理ポートが待ち受けていないか、現在のアドレスに到達できません。",
   "jvm.backend.connection_error.agent.forbidden.help": "現在のクライアント送信元、認証設定、Agent アクセスポリシーが GoNavi のアクセスを許可しているか確認してください。",
+  "import_preview.status.stopping": "現在のデータベース操作の完了後にインポートを停止します...",
   "jvm.backend.connection_error.agent.forbidden.summary": "Agent 接続に失敗しました: Agent がこのリクエストを拒否しました。",
   "jvm.backend.connection_error.agent.scheme_unsupported.help": "Agent Base URL を `http://` または `https://` で始まるアドレスに変更してください。",
   "jvm.backend.connection_error.agent.scheme_unsupported.summary": "Agent 接続に失敗しました: HTTP または HTTPS のみサポートされています。",
diff --git a/shared/i18n/ru-RU.json b/shared/i18n/ru-RU.json
index 3d873c57..701a0cb2 100644
--- a/shared/i18n/ru-RU.json
+++ b/shared/i18n/ru-RU.json
@@ -5466,6 +5466,7 @@
   "file.backend.error.mysql_workbench_parse_failed": "Не удалось разобрать XML MySQL Workbench: {{detail}}",
   "file.backend.error.navicat_connection_password_parse_failed": "Не удалось разобрать пароль для подключения {{name}}",
   "file.backend.error.navicat_connection_proxy_password_parse_failed": "Не удалось разобрать пароль прокси для подключения {{name}}",
+  "file.backend.error.import_job_already_running": "Эта задача импорта уже выполняется",
   "file.backend.error.navicat_connection_ssh_password_parse_failed": "Не удалось разобрать SSH-пароль для подключения {{name}}",
   "file.backend.error.navicat_ncx_no_connections": "В Navicat NCX не найдены допустимые конфигурации подключений, поддерживаемые GoNavi",
   "file.backend.error.navicat_ncx_parse_failed": "Не удалось разобрать Navicat NCX",
@@ -5534,6 +5535,7 @@
   "file.backend.message.table_data_truncate_succeeded": "TRUNCATE выполнен успешно",
   "file.backend.message.transaction_committed": "Транзакция успешно закоммичена",
   "file.backend.message.user_cancelled": "Пользователь отменил выполнение",
+  "file.backend.message.import_cancelled": "Импорт остановлен. Успешно: {{imported}}, ошибок: {{failed}}; зафиксированные данные не были отменены.",
   "file.backend.sql_dump.database": "База данных: {{database}}",
   "file.backend.sql_dump.empty_rows": "(0 строк)",
   "file.backend.sql_dump.generated_at": "Создано: {{generatedAt}}",
@@ -5571,11 +5573,14 @@
   "import_preview.error.target_columns_failed": "Не удалось загрузить столбцы целевой таблицы",
   "import_preview.mapping.description": "Сопоставьте заголовки файла с полями базы данных. Несопоставленные столбцы будут пропущены.",
   "import_preview.mapping.ignore": "Пропустить столбец",
+  "import_preview.action.stop": "Остановить импорт",
   "import_preview.mapping.source_column": "Столбец файла",
   "import_preview.mapping.target_column": "Поле базы данных",
   "import_preview.mapping.title": "Сопоставление столбцов",
   "import_preview.mapping.validation.duplicate_source": "Файл содержит повторяющиеся заголовки столбцов и не может быть безопасно импортирован",
   "import_preview.mapping.validation.duplicate_target": "Каждое поле базы данных можно сопоставить только один раз",
+  "import_preview.error.stop_failed": "Не удалось остановить импорт",
+  "import_preview.error.stop_failed_detail": "Не удалось остановить импорт: {{detail}}",
   "import_preview.mapping.validation.required": "Сопоставьте хотя бы один столбец файла",
   "import_preview.preview.description": "Ниже показаны первые 5 строк. Начните импорт после проверки данных.",
   "import_preview.preview.field_list": "Список полей:",
@@ -5595,9 +5600,11 @@
   "jvm.backend.connection_error.agent.base_url_invalid.help": "Укажите полный URL http:// или https://, например http://127.0.0.1:19090/gonavi/agent/jvm.",
   "jvm.backend.connection_error.agent.base_url_invalid.summary": "Подключение Agent не удалось: Agent Base URL недействителен.",
   "jvm.backend.connection_error.agent.base_url_required": "Подключение Agent не удалось: Agent Base URL отсутствует.",
+  "import_preview.result.stopped": "Импорт остановлен (зафиксированные данные не были отменены)",
   "jvm.backend.connection_error.agent.connection_refused.help": "Убедитесь, что Java service запущен с GoNavi Agent через `-javaagent`, и проверьте Base URL, port mapping и правила firewall.",
   "jvm.backend.connection_error.agent.connection_refused.summary": "Подключение Agent не удалось: целевой management port Agent не слушается или адрес недоступен.",
   "jvm.backend.connection_error.agent.forbidden.help": "Убедитесь, что источник клиента, настройки authentication и access policy Agent разрешают GoNavi доступ.",
+  "import_preview.status.stopping": "Импорт будет остановлен после текущей операции базы данных...",
   "jvm.backend.connection_error.agent.forbidden.summary": "Подключение Agent не удалось: Agent отклонил этот запрос.",
   "jvm.backend.connection_error.agent.scheme_unsupported.help": "Измените Agent Base URL на адрес, начинающийся с http:// или https://.",
   "jvm.backend.connection_error.agent.scheme_unsupported.summary": "Подключение Agent не удалось: поддерживаются только HTTP или HTTPS.",
diff --git a/shared/i18n/zh-CN.json b/shared/i18n/zh-CN.json
index 8304db1e..013557e2 100644
--- a/shared/i18n/zh-CN.json
+++ b/shared/i18n/zh-CN.json
@@ -5466,6 +5466,7 @@
   "file.backend.error.mysql_workbench_parse_failed": "解析 MySQL Workbench XML 失败: {{detail}}",
   "file.backend.error.navicat_connection_password_parse_failed": "连接 {{name}} 的密码解析失败",
   "file.backend.error.navicat_connection_proxy_password_parse_failed": "连接 {{name}} 的代理密码解析失败",
+  "file.backend.error.import_job_already_running": "该导入任务正在运行，请勿重复启动",
   "file.backend.error.navicat_connection_ssh_password_parse_failed": "连接 {{name}} 的 SSH 密码解析失败",
   "file.backend.error.navicat_ncx_no_connections": "未在 Navicat NCX 中找到 GoNavi 支持的有效连接配置",
   "file.backend.error.navicat_ncx_parse_failed": "解析 Navicat NCX 失败",
@@ -5534,6 +5535,7 @@
   "file.backend.message.table_data_truncate_succeeded": "截断成功",
   "file.backend.message.transaction_committed": "事务提交成功",
   "file.backend.message.user_cancelled": "用户取消执行",
+  "file.backend.message.import_cancelled": "导入已停止。成功 {{imported}} 行，失败 {{failed}} 行；已提交的数据不会回滚。",
   "file.backend.sql_dump.database": "数据库: {{database}}",
   "file.backend.sql_dump.empty_rows": "(0 行)",
   "file.backend.sql_dump.generated_at": "生成时间: {{generatedAt}}",
@@ -5571,11 +5573,14 @@
   "import_preview.error.target_columns_failed": "无法加载目标表字段",
   "import_preview.mapping.description": "将文件表头映射到数据库字段；未映射的列会被跳过。",
   "import_preview.mapping.ignore": "跳过此列",
+  "import_preview.action.stop": "停止导入",
   "import_preview.mapping.source_column": "源文件列",
   "import_preview.mapping.target_column": "数据库字段",
   "import_preview.mapping.title": "字段映射",
   "import_preview.mapping.validation.duplicate_source": "文件中存在重复列标题，无法安全导入",
   "import_preview.mapping.validation.duplicate_target": "同一个数据库字段只能映射一次",
+  "import_preview.error.stop_failed": "停止导入失败",
+  "import_preview.error.stop_failed_detail": "停止导入失败: {{detail}}",
   "import_preview.mapping.validation.required": "请至少映射一个文件列",
   "import_preview.preview.description": "以下是前 5 行预览数据，确认无误后点击“开始导入”",
   "import_preview.preview.field_list": "字段列表：",
@@ -5595,9 +5600,11 @@
   "jvm.backend.connection_error.agent.base_url_invalid.help": "请填写完整的 `http://` 或 `https://` 地址，例如 `http://127.0.0.1:19090/gonavi/agent/jvm`。",
   "jvm.backend.connection_error.agent.base_url_invalid.summary": "Agent 连接失败：Agent Base URL 格式不合法。",
   "jvm.backend.connection_error.agent.base_url_required": "Agent 连接失败：未填写 Agent Base URL。",
+  "import_preview.result.stopped": "导入已停止（已提交的数据不会回滚）",
   "jvm.backend.connection_error.agent.connection_refused.help": "请确认 Java 服务已通过 `-javaagent` 启动 GoNavi Agent，并检查 Base URL、端口映射和防火墙。",
   "jvm.backend.connection_error.agent.connection_refused.summary": "Agent 连接失败：目标 Agent 管理端口未监听，或当前地址不可达。",
   "jvm.backend.connection_error.agent.forbidden.help": "请确认当前客户端来源、鉴权配置和 Agent 访问策略允许 GoNavi 访问。",
+  "import_preview.status.stopping": "正在停止导入，请等待当前数据库操作完成...",
   "jvm.backend.connection_error.agent.forbidden.summary": "Agent 连接失败：当前请求被 Agent 拒绝。",
   "jvm.backend.connection_error.agent.scheme_unsupported.help": "请把 Agent Base URL 改成 `http://` 或 `https://` 开头的地址。",
   "jvm.backend.connection_error.agent.scheme_unsupported.summary": "Agent 连接失败：当前只支持 HTTP 或 HTTPS 协议。",
diff --git a/shared/i18n/zh-TW.json b/shared/i18n/zh-TW.json
index c8374d2d..2c82a693 100644
--- a/shared/i18n/zh-TW.json
+++ b/shared/i18n/zh-TW.json
@@ -5466,6 +5466,7 @@
   "file.backend.error.mysql_workbench_parse_failed": "解析 MySQL Workbench XML 失敗: {{detail}}",
   "file.backend.error.navicat_connection_password_parse_failed": "連線 {{name}} 的密碼解析失敗",
   "file.backend.error.navicat_connection_proxy_password_parse_failed": "連線 {{name}} 的代理密碼解析失敗",
+  "file.backend.error.import_job_already_running": "此匯入工作正在執行，請勿重複啟動",
   "file.backend.error.navicat_connection_ssh_password_parse_failed": "連線 {{name}} 的 SSH 密碼解析失敗",
   "file.backend.error.navicat_ncx_no_connections": "未在 Navicat NCX 中找到 GoNavi 支援的有效連線設定",
   "file.backend.error.navicat_ncx_parse_failed": "解析 Navicat NCX 失敗",
@@ -5534,6 +5535,7 @@
   "file.backend.message.table_data_truncate_succeeded": "截斷成功",
   "file.backend.message.transaction_committed": "交易提交成功",
   "file.backend.message.user_cancelled": "使用者取消執行",
+  "file.backend.message.import_cancelled": "匯入已停止。成功 {{imported}} 列，失敗 {{failed}} 列；已提交的資料不會回復。",
   "file.backend.sql_dump.database": "資料庫: {{database}}",
   "file.backend.sql_dump.empty_rows": "(0 筆)",
   "file.backend.sql_dump.generated_at": "產生時間: {{generatedAt}}",
@@ -5571,11 +5573,14 @@
   "import_preview.error.target_columns_failed": "無法載入目標資料表欄位",
   "import_preview.mapping.description": "將檔案標題映射到資料庫欄位；未映射的欄位會被略過。",
   "import_preview.mapping.ignore": "略過此欄",
+  "import_preview.action.stop": "停止匯入",
   "import_preview.mapping.source_column": "來源檔案欄位",
   "import_preview.mapping.target_column": "資料庫欄位",
   "import_preview.mapping.title": "欄位映射",
   "import_preview.mapping.validation.duplicate_source": "檔案中存在重複欄位標題，無法安全匯入",
   "import_preview.mapping.validation.duplicate_target": "同一個資料庫欄位只能映射一次",
+  "import_preview.error.stop_failed": "停止匯入失敗",
+  "import_preview.error.stop_failed_detail": "停止匯入失敗: {{detail}}",
   "import_preview.mapping.validation.required": "請至少映射一個檔案欄位",
   "import_preview.preview.description": "以下顯示前 5 列預覽資料，確認無誤後開始匯入。",
   "import_preview.preview.field_list": "欄位清單：",
@@ -5595,9 +5600,11 @@
   "jvm.backend.connection_error.agent.base_url_invalid.help": "請填寫完整的 `http://` 或 `https://` 位址，例如 `http://127.0.0.1:19090/gonavi/agent/jvm`。",
   "jvm.backend.connection_error.agent.base_url_invalid.summary": "Agent 連線失敗：Agent Base URL 格式不合法。",
   "jvm.backend.connection_error.agent.base_url_required": "Agent 連線失敗：未填寫 Agent Base URL。",
+  "import_preview.result.stopped": "匯入已停止（已提交的資料不會回復）",
   "jvm.backend.connection_error.agent.connection_refused.help": "請確認 Java 服務已透過 `-javaagent` 啟動 GoNavi Agent，並檢查 Base URL、連接埠對映與防火牆。",
   "jvm.backend.connection_error.agent.connection_refused.summary": "Agent 連線失敗：目標 Agent 管理連接埠未監聽，或目前位址無法連線。",
   "jvm.backend.connection_error.agent.forbidden.help": "請確認目前用戶端來源、鑑權設定和 Agent 存取策略允許 GoNavi 存取。",
+  "import_preview.status.stopping": "正在停止匯入，請等待目前的資料庫操作完成...",
   "jvm.backend.connection_error.agent.forbidden.summary": "Agent 連線失敗：目前請求被 Agent 拒絕。",
   "jvm.backend.connection_error.agent.scheme_unsupported.help": "請將 Agent Base URL 改成以 `http://` 或 `https://` 開頭的位址。",
   "jvm.backend.connection_error.agent.scheme_unsupported.summary": "Agent 連線失敗：目前只支援 HTTP 或 HTTPS 協定。",