Merge pull request #110 from Syngnat/release/0.4.5

Release/0.4.5
2026-05-12 07:59:41 +08:00 · 2026-02-14 11:47:59 +08:00
parent 5df95730d8 663717d738
commit e90a3e2db6
10 changed files with 1971 additions and 141 deletions
--- a/.github/workflows/release.yml
+++ b/.github/workflows/release.yml
@@ -104,6 +104,8 @@ jobs:
          GOOS="${TARGET_PLATFORM%%/*}"
          GOARCH="${TARGET_PLATFORM##*/}"
          DRIVERS=(mariadb diros sphinx sqlserver sqlite duckdb dameng kingbase highgo vastbase mongodb tdengine)
+          OUTDIR="drivers/${{ matrix.os_name }}"
+          mkdir -p "$OUTDIR"

          for DRIVER in "${DRIVERS[@]}"; do
            TAG="gonavi_${DRIVER}_driver"
@@ -111,20 +113,21 @@ jobs:
            if [ "$GOOS" = "windows" ]; then
              OUTPUT="${OUTPUT}.exe"
            fi
-            echo "🔧 构建 ${OUTPUT} (tag=${TAG})"
+            OUTPUT_PATH="${OUTDIR}/${OUTPUT}"
+            echo "🔧 构建 ${OUTPUT_PATH} (tag=${TAG})"
            if [ "$DRIVER" = "duckdb" ]; then
              set +e
              CGO_ENABLED=1 GOOS="$GOOS" GOARCH="$GOARCH" go build \
                -tags "${TAG}" \
                -trimpath \
                -ldflags "-s -w" \
-                -o "${OUTPUT}" \
+                -o "${OUTPUT_PATH}" \
                ./cmd/optional-driver-agent
              DUCKDB_RC=$?
              set -e
              if [ "${DUCKDB_RC}" -ne 0 ]; then
                echo "⚠️ DuckDB 代理构建失败（平台 ${GOOS}/${GOARCH}），跳过该资产，不阻断发布"
-                rm -f "${OUTPUT}"
+                rm -f "${OUTPUT_PATH}"
                continue
              fi
            else
@@ -132,7 +135,7 @@ jobs:
                -tags "${TAG}" \
                -trimpath \
                -ldflags "-s -w" \
-                -o "${OUTPUT}" \
+                -o "${OUTPUT_PATH}" \
                ./cmd/optional-driver-agent
            fi
          done
@@ -295,7 +298,7 @@ jobs:
            GoNavi-*.zip
            GoNavi-*.tar.gz
            GoNavi-*.AppImage
-            *-driver-agent-*
+            drivers/**
          retention-days: 1

  # Phase 2: Collect all artifacts and Publish Release (Single Job)
@@ -314,6 +317,59 @@ jobs:
      - name: List Assets
        run: ls -R release-assets

+      - name: Package Driver Agents Bundle
+        shell: bash
+        run: |
+          set -euo pipefail
+          cd release-assets
+          if [ ! -d drivers ]; then
+            echo "⚠️ 未找到 drivers 目录，跳过驱动总包打包"
+            exit 0
+          fi
+          if [ -z "$(find drivers -type f 2>/dev/null | head -n 1)" ]; then
+            echo "⚠️ drivers 目录为空，跳过驱动总包打包"
+            rm -rf drivers
+            exit 0
+          fi
+
+          echo "📦 打包驱动总包：GoNavi-DriverAgents.zip"
+          python3 - <<'PY'
+          import json
+          import os
+          import zipfile
+          from pathlib import Path
+
+          out_name = "GoNavi-DriverAgents.zip"
+          index_name = "GoNavi-DriverAgents-Index.json"
+          base = Path("drivers")
+          out_path = Path(out_name)
+          index_path = Path(index_name)
+          if out_path.exists():
+              out_path.unlink()
+          if index_path.exists():
+              index_path.unlink()
+
+          size_index = {}
+          with zipfile.ZipFile(out_path, "w", compression=zipfile.ZIP_DEFLATED) as zf:
+              for p in base.rglob("*"):
+                  if not p.is_file():
+                      continue
+                  arcname = p.relative_to(base).as_posix()
+                  zf.write(p, arcname)
+                  size_index[p.name] = p.stat().st_size
+
+          index_path.write_text(
+              json.dumps({"assets": size_index}, ensure_ascii=False, indent=2),
+              encoding="utf-8",
+          )
+
+          print(f"created {out_name} size={out_path.stat().st_size} bytes")
+          print(f"created {index_name} entries={len(size_index)}")
+          PY
+
+          # Release 只发布一个驱动总包，避免大量平铺资产污染 Release 页面
+          rm -rf drivers
+
      - name: Generate SHA256SUMS
        shell: bash
        run: |
--- a/frontend/src/components/ConnectionModal.tsx
+++ b/frontend/src/components/ConnectionModal.tsx
@@ -27,6 +27,7 @@ const getDefaultPortByType = (type: string) => {
    case 'highgo': return 5866;
    case 'mariadb': return 3306;
    case 'vastbase': return 5432;
+    case 'sqlite': return 0;
    case 'duckdb': return 0;
    default: return 3306;
  }
@@ -236,6 +237,23 @@ const ConnectionModal: React.FC<{
      }
  };

+  const normalizeFileDbPath = (rawPath: string): string => {
+      let pathText = String(rawPath || '').trim();
+      if (!pathText) {
+          return '';
+      }
+      // 兼容 sqlite:///C:/... 或 sqlite:///C:\... 解析后多出的前导斜杠。
+      if (/^\/[a-zA-Z]:[\\/]/.test(pathText)) {
+          pathText = pathText.slice(1);
+      }
+      // 兼容历史版本把 Windows 文件路径误拼成 :3306:3306。
+      const legacyMatch = pathText.match(/^([a-zA-Z]:[\\/].*?)(?::\d+)+$/);
+      if (legacyMatch?.[1]) {
+          return legacyMatch[1];
+      }
+      return pathText;
+  };
+
  const parseMultiHostUri = (uriText: string, expectedScheme: string) => {
      const prefix = `${expectedScheme}://`;
      if (!uriText.toLowerCase().startsWith(prefix)) {
@@ -335,30 +353,6 @@ const ConnectionModal: React.FC<{
      }

      if (isFileDatabaseType(type)) {
-          const tryExtractPath = (uri: string, scheme: string): string | null => {
-              const parsed = parseMultiHostUri(uri, scheme);
-              if (!parsed) {
-                  return null;
-              }
-              const host = String(parsed.hosts?.[0] || '').trim();
-              const dbPath = String(parsed.database || '').trim();
-              if (host && dbPath) {
-                  return `/${host}/${dbPath}`.replace(/\/+/g, '/');
-              }
-              if (host) {
-                  return `/${host}`.replace(/\/+/g, '/');
-              }
-              if (dbPath) {
-                  return dbPath.startsWith('/') ? dbPath : `/${dbPath}`;
-              }
-              return null;
-          };
-
-          const pathFromScheme = tryExtractPath(trimmedUri, type);
-          if (pathFromScheme) {
-              return { host: decodeURIComponent(pathFromScheme) };
-          }
-
          const rawPath = trimmedUri
              .replace(/^sqlite:\/\//i, '')
              .replace(/^duckdb:\/\//i, '')
@@ -366,7 +360,7 @@ const ConnectionModal: React.FC<{
          if (!rawPath) {
              return null;
          }
-          return { host: decodeURIComponent(rawPath) };
+          return { host: normalizeFileDbPath(safeDecode(rawPath)) };
      }

      if (type === 'mongodb') {
@@ -481,12 +475,11 @@ const ConnectionModal: React.FC<{
      }

      if (isFileDatabaseType(type)) {
-          const pathText = String(values.host || '').trim();
+          const pathText = normalizeFileDbPath(String(values.host || '').trim());
          if (!pathText) {
              return `${type}://`;
          }
-          const normalizedPath = pathText.startsWith('/') ? pathText : `/${pathText}`;
-          return `${type}://${encodeURI(normalizedPath)}`;
+          return `${type}://${encodeURI(pathText)}`;
      }

      if (type === 'mongodb') {
@@ -602,13 +595,20 @@ const ConnectionModal: React.FC<{
              const config: any = initialValues.config || {};
              const configType = String(config.type || 'mysql');
              const defaultPort = getDefaultPortByType(configType);
-              const normalizedHosts = normalizeAddressList(config.hosts, defaultPort);
-              const primaryAddress = parseHostPort(
-                  normalizedHosts[0] || toAddress(config.host || 'localhost', Number(config.port || defaultPort), defaultPort),
-                  defaultPort
-              );
-              const primaryHost = primaryAddress?.host || String(config.host || 'localhost');
-              const primaryPort = primaryAddress?.port || Number(config.port || defaultPort);
+              const isFileDbConfigType = isFileDatabaseType(configType);
+              const normalizedHosts = isFileDbConfigType ? [] : normalizeAddressList(config.hosts, defaultPort);
+              const primaryAddress = isFileDbConfigType
+                  ? null
+                  : parseHostPort(
+                      normalizedHosts[0] || toAddress(config.host || 'localhost', Number(config.port || defaultPort), defaultPort),
+                      defaultPort
+                  );
+              const primaryHost = isFileDbConfigType
+                  ? normalizeFileDbPath(String(config.host || ''))
+                  : (primaryAddress?.host || String(config.host || 'localhost'));
+              const primaryPort = isFileDbConfigType
+                  ? 0
+                  : (primaryAddress?.port || Number(config.port || defaultPort));
              const mysqlReplicaHosts = (configType === 'mysql' || configType === 'mariadb' || configType === 'diros' || configType === 'sphinx') ? normalizedHosts.slice(1) : [];
              const mongoHosts = configType === 'mongodb' ? normalizedHosts.slice(1) : [];
              const mysqlIsReplica = String(config.topology || '').toLowerCase() === 'replica' || mysqlReplicaHosts.length > 0;
@@ -847,12 +847,22 @@ const ConnectionModal: React.FC<{

      const type = String(mergedValues.type || '').toLowerCase();
      const defaultPort = getDefaultPortByType(type);
-      const parsedPrimary = parseHostPort(
-          toAddress(mergedValues.host || 'localhost', Number(mergedValues.port || defaultPort), defaultPort),
-          defaultPort
-      );
-      const primaryHost = parsedPrimary?.host || 'localhost';
-      const primaryPort = parsedPrimary?.port || defaultPort;
+      const isFileDbType = isFileDatabaseType(type);
+
+      let primaryHost = 'localhost';
+      let primaryPort = defaultPort;
+      if (isFileDbType) {
+          // 文件型数据库（sqlite/duckdb）这里的 host 即数据库文件路径，不应参与 host:port 拼接与解析。
+          primaryHost = normalizeFileDbPath(String(mergedValues.host || '').trim());
+          primaryPort = 0;
+      } else {
+          const parsedPrimary = parseHostPort(
+              toAddress(mergedValues.host || 'localhost', Number(mergedValues.port || defaultPort), defaultPort),
+              defaultPort
+          );
+          primaryHost = parsedPrimary?.host || 'localhost';
+          primaryPort = parsedPrimary?.port || defaultPort;
+      }

      let hosts: string[] = [];
      let topology: 'single' | 'replica' | undefined;
@@ -960,7 +970,36 @@ const ConnectionModal: React.FC<{
      form.setFieldsValue({ type: type });

      const defaultPort = getDefaultPortByType(type);
-      if (!isFileDatabaseType(type) && type !== 'custom') {
+      if (isFileDatabaseType(type)) {
+          setUseSSH(false);
+          form.setFieldsValue({
+              host: '',
+              port: 0,
+              user: '',
+              password: '',
+              database: '',
+              useSSH: false,
+              sshHost: '',
+              sshPort: 22,
+              sshUser: '',
+              sshPassword: '',
+              sshKeyPath: '',
+              mysqlTopology: 'single',
+              mongoTopology: 'single',
+              mongoSrv: false,
+              mongoReadPreference: 'primary',
+              mongoReplicaSet: '',
+              mongoAuthSource: '',
+              mongoAuthMechanism: '',
+              savePassword: true,
+              mysqlReplicaHosts: [],
+              mongoHosts: [],
+              mysqlReplicaUser: '',
+              mysqlReplicaPassword: '',
+              mongoReplicaUser: '',
+              mongoReplicaPassword: '',
+          });
+      } else if (type !== 'custom') {
          form.setFieldsValue({
              port: defaultPort,
              mysqlTopology: 'single',
--- a/frontend/src/components/DataGrid.tsx
+++ b/frontend/src/components/DataGrid.tsx
@@ -1,12 +1,13 @@
 import React, { useState, useEffect, useRef, useContext, useMemo, useCallback } from 'react';
 import { createPortal } from 'react-dom';
-import { Table, message, Input, Button, Dropdown, MenuProps, Form, Pagination, Select, Modal, Checkbox, Segmented } from 'antd';
+import { Table, message, Input, Button, Dropdown, MenuProps, Form, Pagination, Select, Modal, Checkbox, Segmented, Tooltip, Popover } from 'antd';
 import type { SortOrder } from 'antd/es/table/interface';
 import { ReloadOutlined, ImportOutlined, ExportOutlined, DownOutlined, PlusOutlined, DeleteOutlined, SaveOutlined, UndoOutlined, FilterOutlined, CloseOutlined, ConsoleSqlOutlined, FileTextOutlined, CopyOutlined, ClearOutlined, EditOutlined, VerticalAlignBottomOutlined } from '@ant-design/icons';
 import Editor from '@monaco-editor/react';
-import { ImportData, ExportTable, ExportData, ExportQuery, ApplyChanges } from '../../wailsjs/go/app/App';
+import { ImportData, ExportTable, ExportData, ExportQuery, ApplyChanges, DBGetColumns } from '../../wailsjs/go/app/App';
 import ImportPreviewModal from './ImportPreviewModal';
 import { useStore } from '../store';
+import type { ColumnDefinition } from '../types';
 import { v4 as uuidv4 } from 'uuid';
 import 'react-resizable/css/styles.css';
 import { buildOrderBySQL, buildWhereSQL, escapeLiteral, quoteIdentPart, quoteQualifiedIdent, withSortBufferTuningSQL, type FilterCondition } from '../utils/sql';
@@ -292,6 +293,7 @@ const DataContext = React.createContext<{
    handleExportSelected: (format: string, r: any) => void;
    copyToClipboard: (t: string) => void;
    tableName?: string;
+    enableRowContextMenu: boolean;
 } | null>(null);

 interface Item {
@@ -434,7 +436,11 @@ const ContextMenuRow = React.memo(({ children, record, ...props }: any) => {
    
    if (!record || !context) return <tr {...props}>{children}</tr>;

-    const { selectedRowKeysRef, displayDataRef, handleCopyInsert, handleCopyJson, handleCopyCsv, handleExportSelected, copyToClipboard } = context;
+    const { selectedRowKeysRef, displayDataRef, handleCopyInsert, handleCopyJson, handleCopyCsv, handleExportSelected, copyToClipboard, enableRowContextMenu } = context;
+
+    if (!enableRowContextMenu) {
+        return <tr {...props}>{children}</tr>;
+    }

    const getTargets = () => {
        const keys = selectedRowKeysRef.current;
@@ -513,6 +519,11 @@ type GridFilterCondition = FilterCondition & {

 type GridViewMode = 'table' | 'json' | 'text';

+type ColumnMeta = {
+    type: string;
+    comment: string;
+};
+
 const DataGrid: React.FC<DataGridProps> = ({ 
    data, columnNames, loading, tableName, dbName, connectionId, pkColumns = [], readOnly = false,
    onReload, onSort, onPageChange, pagination, sortInfoExternal, showFilter, onToggleFilter, onApplyFilter
@@ -521,10 +532,14 @@ const DataGrid: React.FC<DataGridProps> = ({
  const addSqlLog = useStore(state => state.addSqlLog);
  const theme = useStore(state => state.theme);
  const appearance = useStore(state => state.appearance);
+  const queryOptions = useStore(state => state.queryOptions);
+  const setQueryOptions = useStore(state => state.setQueryOptions);
  const isMacLike = useMemo(() => isMacLikePlatform(), []);
  const darkMode = theme === 'dark';
  const opacity = normalizeOpacityForPlatform(appearance.opacity);
  const canModifyData = !readOnly && !!tableName;
+  const showColumnComment = queryOptions?.showColumnComment !== false;
+  const showColumnType = queryOptions?.showColumnType !== false;
  const selectionColumnWidth = 46;

  // Background Helper
@@ -538,7 +553,7 @@ const DataGrid: React.FC<DataGridProps> = ({
  };
  const bgContent = getBg('#1d1d1d');
  const bgFilter = getBg('#262626');
-  const bgContextMenu = getBg('#1f1f1f');
+  const bgContextMenu = darkMode ? '#1f1f1f' : '#ffffff';
  
  // Row Colors with Opacity
  const getRowBg = (r: number, g: number, b: number) => `rgba(${r}, ${g}, ${b}, ${opacity})`;
@@ -661,6 +676,9 @@ const DataGrid: React.FC<DataGridProps> = ({
  
  const [sortInfo, setSortInfo] = useState<{ columnKey: string, order: string } | null>(null);
  const [columnWidths, setColumnWidths] = useState<Record<string, number>>({});
+  const [columnMetaMap, setColumnMetaMap] = useState<Record<string, ColumnMeta>>({});
+  const columnMetaCacheRef = useRef<Record<string, Record<string, ColumnMeta>>>({});
+  const columnMetaSeqRef = useRef(0);

  useEffect(() => {
      const nextOrder = sortInfoExternal?.order === 'ascend' || sortInfoExternal?.order === 'descend'
@@ -677,6 +695,129 @@ const DataGrid: React.FC<DataGridProps> = ({
      }
  }, [sortInfoExternal, sortInfo]);

+  useEffect(() => {
+      const normalizedTableName = String(tableName || '').trim();
+      const normalizedDbName = String(dbName || '').trim();
+      if (!connectionId || !normalizedTableName) {
+          setColumnMetaMap({});
+          return;
+      }
+      const cacheKey = `${connectionId}|${normalizedDbName}|${normalizedTableName}`;
+      setColumnMetaMap(columnMetaCacheRef.current[cacheKey] || {});
+  }, [connectionId, dbName, tableName]);
+
+  useEffect(() => {
+      const normalizedTableName = String(tableName || '').trim();
+      const normalizedDbName = String(dbName || '').trim();
+      if (!connectionId || !normalizedTableName) return;
+
+      const cacheKey = `${connectionId}|${normalizedDbName}|${normalizedTableName}`;
+      if (columnMetaCacheRef.current[cacheKey]) return;
+
+      const conn = connections.find(c => c.id === connectionId);
+      if (!conn) {
+          setColumnMetaMap({});
+          return;
+      }
+
+      const config = {
+          ...conn.config,
+          port: Number(conn.config.port),
+          password: conn.config.password || "",
+          database: conn.config.database || "",
+          useSSH: conn.config.useSSH || false,
+          ssh: conn.config.ssh || { host: "", port: 22, user: "", password: "", keyPath: "" }
+      };
+
+      const seq = ++columnMetaSeqRef.current;
+      DBGetColumns(config as any, normalizedDbName, normalizedTableName)
+          .then((res) => {
+              if (seq !== columnMetaSeqRef.current) return;
+              if (!res.success || !Array.isArray(res.data)) {
+                  setColumnMetaMap({});
+                  return;
+              }
+              const nextMap: Record<string, ColumnMeta> = {};
+              (res.data as ColumnDefinition[]).forEach((column: any) => {
+                  const name = String(column?.name ?? column?.Name ?? '').trim();
+                  if (!name) return;
+                  const type = String(column?.type ?? column?.Type ?? '').trim();
+                  const comment = String(column?.comment ?? column?.Comment ?? '').trim();
+                  nextMap[name] = { type, comment };
+              });
+              columnMetaCacheRef.current[cacheKey] = nextMap;
+              setColumnMetaMap(nextMap);
+          })
+          .catch(() => {
+              if (seq !== columnMetaSeqRef.current) return;
+              setColumnMetaMap({});
+          });
+  }, [connections, connectionId, dbName, tableName]);
+
+  const columnMetaMapByLowerName = useMemo(() => {
+      const next: Record<string, ColumnMeta> = {};
+      Object.entries(columnMetaMap).forEach(([name, meta]) => {
+          const lowerName = String(name || '').toLowerCase();
+          if (!lowerName || next[lowerName]) return;
+          next[lowerName] = meta;
+      });
+      return next;
+  }, [columnMetaMap]);
+
+  const renderColumnTitle = useCallback((name: string): React.ReactNode => {
+      const normalizedName = String(name || '');
+      const meta = columnMetaMap[normalizedName] || columnMetaMapByLowerName[normalizedName.toLowerCase()];
+      const hoverLines: string[] = [];
+      if (meta?.type) hoverLines.push(`类型：${meta.type}`);
+      if (meta?.comment) hoverLines.push(`备注：${meta.comment}`);
+
+      const titleNode = (
+          <div style={{ display: 'flex', flexDirection: 'column', minWidth: 0, lineHeight: 1.2 }}>
+              <span style={{ whiteSpace: 'nowrap' }}>{normalizedName}</span>
+              {showColumnType && meta?.type && (
+                  <span
+                      style={{
+                          marginTop: 2,
+                          fontSize: 11,
+                          color: '#8c8c8c',
+                          overflow: 'hidden',
+                          textOverflow: 'ellipsis',
+                          whiteSpace: 'nowrap',
+                          maxWidth: '100%',
+                      }}
+                  >
+                      {meta.type}
+                  </span>
+              )}
+              {showColumnComment && meta?.comment && (
+                  <span
+                      style={{
+                          marginTop: 2,
+                          fontSize: 11,
+                          color: '#8c8c8c',
+                          overflow: 'hidden',
+                          textOverflow: 'ellipsis',
+                          whiteSpace: 'nowrap',
+                          maxWidth: '100%',
+                      }}
+                  >
+                      {meta.comment}
+                  </span>
+              )}
+          </div>
+      );
+
+      if (hoverLines.length === 0) return titleNode;
+      return (
+          <Tooltip
+              title={<pre style={{ maxHeight: 260, overflow: 'auto', margin: 0, fontSize: 12, whiteSpace: 'pre-wrap' }}>{hoverLines.join('\n')}</pre>}
+              styles={{ root: { maxWidth: 640 } }}
+          >
+              <span style={{ display: 'inline-flex', maxWidth: '100%' }}>{titleNode}</span>
+          </Tooltip>
+      );
+  }, [columnMetaMap, columnMetaMapByLowerName, showColumnComment, showColumnType]);
+
  const closeCellEditor = useCallback(() => {
      setCellEditorOpen(false);
      setCellEditorMeta(null);
@@ -1592,7 +1733,7 @@ const DataGrid: React.FC<DataGridProps> = ({

  const columns = useMemo(() => {
      return columnNames.map(key => ({
-          title: key,
+          title: renderColumnTitle(key),
          dataIndex: key,
          key: key,
          // 不使用 ellipsis，避免 Ant Design 的 Tooltip 展开行为
@@ -1608,9 +1749,29 @@ const DataGrid: React.FC<DataGridProps> = ({
          onHeaderCell: (column: any) => ({
              width: column.width,
              onResizeStart: handleResizeStart(key), // Only need start
+              onClickCapture: (event: React.MouseEvent<HTMLElement>) => {
+                  if (!onSort) return;
+                  const headerCell = event.currentTarget as HTMLElement;
+                  const upArrow = headerCell.querySelector('.ant-table-column-sorter-up') as HTMLElement | null;
+                  const downArrow = headerCell.querySelector('.ant-table-column-sorter-down') as HTMLElement | null;
+                  const isInArrow = [upArrow, downArrow].some((el) => {
+                      if (!el) return false;
+                      const rect = el.getBoundingClientRect();
+                      return (
+                          event.clientX >= rect.left &&
+                          event.clientX <= rect.right &&
+                          event.clientY >= rect.top &&
+                          event.clientY <= rect.bottom
+                      );
+                  });
+                  if (isInArrow) return;
+                  // 仅允许点击上下箭头触发排序，点击字段名或表头其它区域不触发排序。
+                  event.preventDefault();
+                  event.stopPropagation();
+              },
          }),
      }));
-  }, [columnNames, columnWidths, sortInfo, handleResizeStart, canModifyData, onSort]);
+  }, [columnNames, columnWidths, sortInfo, handleResizeStart, canModifyData, onSort, renderColumnTitle]);

  const mergedColumns = useMemo(() => columns.map(col => {
      if (!col.editable) return col;
@@ -1620,7 +1781,7 @@ const DataGrid: React.FC<DataGridProps> = ({
              record,
              editable: col.editable,
              dataIndex: col.dataIndex,
-              title: col.title,
+              title: String(col.dataIndex),
              handleSave: handleCellSave,
              focusCell: openCellEditor,
          }),
@@ -2037,6 +2198,23 @@ const DataGrid: React.FC<DataGridProps> = ({
      { key: 'md', label: 'Markdown', onClick: () => handleExport('md') },
  ];

+  const columnInfoSettingContent = (
+      <div style={{ display: 'flex', flexDirection: 'column', gap: 8, minWidth: 168 }}>
+          <Checkbox
+              checked={showColumnComment}
+              onChange={(e) => setQueryOptions({ showColumnComment: e.target.checked })}
+          >
+              下方显示备注
+          </Checkbox>
+          <Checkbox
+              checked={showColumnType}
+              onChange={(e) => setQueryOptions({ showColumnType: e.target.checked })}
+          >
+              下方显示类型
+          </Checkbox>
+      </div>
+  );
+
  const tableComponents = useMemo(() => ({
      body: { cell: EditableCell, row: ContextMenuRow },
      header: { cell: ResizableTitle }
@@ -2149,6 +2327,15 @@ const DataGrid: React.FC<DataGridProps> = ({
           )}

           <div style={{ marginLeft: 'auto' }} />
+	           <div style={{ flexShrink: 0 }}>
+	               <Popover
+	                   trigger="click"
+	                   placement="bottomRight"
+	                   content={columnInfoSettingContent}
+	               >
+	                   <Button icon={<FileTextOutlined />}>字段信息</Button>
+	               </Popover>
+	           </div>
 	           <div style={{ flexShrink: 0 }}>
 	               <Segmented
 	                   size="small"
@@ -2413,13 +2600,14 @@ const DataGrid: React.FC<DataGridProps> = ({

        {viewMode === 'table' ? (
            <Form component={false} form={form}>
-                <DataContext.Provider value={{ selectedRowKeysRef, displayDataRef, handleCopyInsert, handleCopyJson, handleCopyCsv, handleExportSelected, copyToClipboard, tableName }}>
+                <DataContext.Provider value={{ selectedRowKeysRef, displayDataRef, handleCopyInsert, handleCopyJson, handleCopyCsv, handleExportSelected, copyToClipboard, tableName, enableRowContextMenu: !canModifyData }}>
                    <CellContextMenuContext.Provider value={{ showMenu: showCellContextMenu, handleBatchFillToSelected }}>
                            <EditableContext.Provider value={form}>
                                <Table
                                    components={tableComponents}
                                    dataSource={mergedDisplayData}
                                    columns={mergedColumns}
+                                    showSorterTooltip={{ target: 'sorter-icon' }}
                                    size="small"
                                    tableLayout="fixed"
                                    scroll={{ x: tableScrollX, y: tableHeight }}
@@ -2721,6 +2909,9 @@ const DataGrid: React.FC<DataGridProps> = ({
                .${gridId} .ant-table-tbody > tr > td { background: transparent !important; border-bottom: 1px solid ${darkMode ? 'rgba(255,255,255,0.05)' : 'rgba(0,0,0,0.05)'} !important; border-inline-end: 1px solid transparent !important; }
                .${gridId} .ant-table-thead > tr > th { background: transparent !important; border-bottom: 1px solid ${darkMode ? 'rgba(255,255,255,0.05)' : 'rgba(0,0,0,0.05)'} !important; border-inline-end: 1px solid transparent !important; }
                .${gridId} .ant-table-thead > tr > th::before { display: none !important; }
+                .${gridId} .ant-table-thead > tr > th .ant-table-column-sorters { cursor: default !important; }
+                .${gridId} .ant-table-thead > tr > th .ant-table-column-sorter,
+                .${gridId} .ant-table-thead > tr > th .ant-table-column-sorter * { cursor: pointer !important; }
                .${gridId} .ant-table-tbody > tr:hover > td { background-color: ${darkMode ? 'rgba(255, 255, 255, 0.08)' : 'rgba(0, 0, 0, 0.02)'} !important; }
                .${gridId} .ant-table-tbody > tr.ant-table-row-selected > td { background-color: ${darkMode ? 'rgba(24, 144, 255, 0.15)' : 'rgba(24, 144, 255, 0.08)'} !important; }
                .${gridId} .ant-table-tbody > tr.ant-table-row-selected:hover > td { background-color: ${darkMode ? 'rgba(24, 144, 255, 0.25)' : 'rgba(24, 144, 255, 0.12)'} !important; }
--- a/frontend/src/components/Sidebar.tsx
+++ b/frontend/src/components/Sidebar.tsx
@@ -573,16 +573,33 @@ const Sidebar: React.FC<{ onEditConnection?: (conn: SavedConnection) => void }>

      results.forEach((queryResult) => {
          queryResult.rows.forEach((row) => {
-              const triggerName = getCaseInsensitiveValue(row, ['trigger_name', 'triggername', 'trigger', 'name']) || getFirstRowValue(row);
-              if (!triggerName) return;
-              const schemaName = getCaseInsensitiveValue(row, ['schema_name', 'schemaname', 'owner', 'event_object_schema', 'trigger_schema', 'db']);
-              const tableName = getCaseInsensitiveValue(row, ['table_name', 'event_object_table', 'tbl_name', 'table']);
-              const fullTableName = buildQualifiedName(schemaName, tableName);
-              const uniqueKey = `${triggerName}@@${fullTableName}`;
+              const rawTriggerName = getCaseInsensitiveValue(row, ['trigger_name', 'triggername', 'trigger', 'name']) || getFirstRowValue(row);
+              if (!rawTriggerName) return;
+
+              const rawSchemaName = getCaseInsensitiveValue(row, ['schema_name', 'schemaname', 'owner', 'event_object_schema', 'trigger_schema', 'db']);
+              const rawTableName = getCaseInsensitiveValue(row, ['table_name', 'event_object_table', 'tbl_name', 'table']);
+
+              const triggerParts = splitQualifiedName(rawTriggerName);
+              const tableParts = splitQualifiedName(rawTableName);
+
+              const resolvedSchema = (
+                  rawSchemaName
+                  || tableParts.schemaName
+                  || triggerParts.schemaName
+                  || dbName
+              ).trim();
+              const resolvedTriggerName = (triggerParts.objectName || rawTriggerName).trim();
+              const resolvedTableName = (tableParts.objectName || rawTableName).trim();
+              const fullTableName = buildQualifiedName(resolvedSchema, resolvedTableName);
+
+              // MySQL 下 trigger 名在同 schema 内唯一，直接按 schema+trigger 去重可彻底规避多元数据查询导致的重复
+              const uniqueKey = dialect === 'mysql'
+                  ? `${resolvedSchema.toLowerCase()}@@${resolvedTriggerName.toLowerCase()}`
+                  : `${resolvedSchema.toLowerCase()}@@${resolvedTriggerName.toLowerCase()}@@${resolvedTableName.toLowerCase()}`;
              if (seen.has(uniqueKey)) return;
              seen.add(uniqueKey);
-              const displayName = fullTableName ? `${triggerName} (${fullTableName})` : triggerName;
-              triggers.push({ displayName, triggerName, tableName: fullTableName });
+              const displayName = fullTableName ? `${resolvedTriggerName} (${fullTableName})` : resolvedTriggerName;
+              triggers.push({ displayName, triggerName: resolvedTriggerName, tableName: fullTableName || resolvedTableName });
          });
      });
      return { triggers, supported: hasSuccessfulQuery };
@@ -755,19 +772,35 @@ const Sidebar: React.FC<{ onEditConnection?: (conn: SavedConnection) => void }>
 	                };
 	            });

-            const triggerEntries = triggersResult.triggers.map((trigger) => {
-                const triggerParsed = splitQualifiedName(trigger.triggerName);
-                const tableParsed = splitQualifiedName(trigger.tableName);
-                const schemaName = tableParsed.schemaName || triggerParsed.schemaName;
-	                const triggerObjectName = triggerParsed.objectName || trigger.triggerName;
-	                const tableObjectName = tableParsed.objectName || trigger.tableName;
-	                const displayName = tableObjectName ? `${triggerObjectName} (${tableObjectName})` : triggerObjectName;
-	                return {
-	                    ...trigger,
-	                    schemaName,
-	                    displayName,
-	                };
-	            });
+            const triggerEntries = (() => {
+                const deduped: Array<{ displayName: string; triggerName: string; tableName: string; schemaName: string }> = [];
+                const triggerSeen = new Set<string>();
+                const metadataDialect = getMetadataDialect(conn as SavedConnection);
+
+                triggersResult.triggers.forEach((trigger) => {
+                    const triggerParsed = splitQualifiedName(trigger.triggerName);
+                    const tableParsed = splitQualifiedName(trigger.tableName);
+                    const schemaName = tableParsed.schemaName || triggerParsed.schemaName || String(conn.dbName || '').trim();
+                    const triggerObjectName = (triggerParsed.objectName || trigger.triggerName).trim();
+                    const tableObjectName = (tableParsed.objectName || trigger.tableName).trim();
+                    const displayName = tableObjectName ? `${triggerObjectName} (${tableObjectName})` : triggerObjectName;
+                    const dedupeKey = metadataDialect === 'mysql'
+                        ? `${schemaName.toLowerCase()}@@${triggerObjectName.toLowerCase()}`
+                        : `${schemaName.toLowerCase()}@@${triggerObjectName.toLowerCase()}@@${tableObjectName.toLowerCase()}`;
+
+                    if (triggerSeen.has(dedupeKey)) return;
+                    triggerSeen.add(dedupeKey);
+                    deduped.push({
+                        ...trigger,
+                        schemaName,
+                        triggerName: triggerObjectName,
+                        tableName: buildQualifiedName(schemaName, tableObjectName) || tableObjectName,
+                        displayName,
+                    });
+                });
+
+                return deduped;
+            })();

            const routineEntries = routinesResult.routines.map((routine) => {
                const parsed = splitQualifiedName(routine.routineName);
@@ -1061,9 +1094,9 @@ const Sidebar: React.FC<{ onEditConnection?: (conn: SavedConnection) => void }>
          setActiveContext({ connectionId: dataRef.id, dbName: `db${dataRef.redisDB}` });
      }

-      if (type === 'folder-columns') openDesign(info.node, 'columns', true);
-      else if (type === 'folder-indexes') openDesign(info.node, 'indexes', true);
-      else if (type === 'folder-fks') openDesign(info.node, 'foreignKeys', true);
+      if (type === 'folder-columns') openDesign(info.node, 'columns', false);
+      else if (type === 'folder-indexes') openDesign(info.node, 'indexes', false);
+      else if (type === 'folder-fks') openDesign(info.node, 'foreignKeys', false);
      else if (type === 'folder-triggers') openDesign(info.node, 'triggers', true);
  };

--- a/frontend/src/components/TableDesigner.tsx
+++ b/frontend/src/components/TableDesigner.tsx
--- a/frontend/src/store.ts
+++ b/frontend/src/store.ts
@@ -252,6 +252,12 @@ export interface SqlLog {
  affectedRows?: number;
 }

+export interface QueryOptions {
+  maxRows: number;
+  showColumnComment: boolean;
+  showColumnType: boolean;
+}
+
 interface AppState {
  connections: SavedConnection[];
  tabs: TabData[];
@@ -261,7 +267,7 @@ interface AppState {
  theme: 'light' | 'dark';
  appearance: { opacity: number; blur: number };
  sqlFormatOptions: { keywordCase: 'upper' | 'lower' };
-  queryOptions: { maxRows: number };
+  queryOptions: QueryOptions;
  sqlLogs: SqlLog[];
  tableAccessCount: Record<string, number>;
  tableSortPreference: Record<string, 'name' | 'frequency'>;
@@ -287,7 +293,7 @@ interface AppState {
  setTheme: (theme: 'light' | 'dark') => void;
  setAppearance: (appearance: Partial<{ opacity: number; blur: number }>) => void;
  setSqlFormatOptions: (options: { keywordCase: 'upper' | 'lower' }) => void;
-  setQueryOptions: (options: Partial<{ maxRows: number }>) => void;
+  setQueryOptions: (options: Partial<QueryOptions>) => void;

  addSqlLog: (log: SqlLog) => void;
  clearSqlLogs: () => void;
@@ -326,13 +332,15 @@ const sanitizeSqlFormatOptions = (value: unknown): { keywordCase: 'upper' | 'low
  return { keywordCase: raw.keywordCase === 'lower' ? 'lower' : 'upper' };
 };

-const sanitizeQueryOptions = (value: unknown): { maxRows: number } => {
+const sanitizeQueryOptions = (value: unknown): QueryOptions => {
  const raw = (value && typeof value === 'object') ? value as Record<string, unknown> : {};
  const maxRows = Number(raw.maxRows);
+  const showColumnComment = typeof raw.showColumnComment === 'boolean' ? raw.showColumnComment : true;
+  const showColumnType = typeof raw.showColumnType === 'boolean' ? raw.showColumnType : true;
  if (!Number.isFinite(maxRows) || maxRows <= 0) {
-    return { maxRows: 5000 };
+    return { maxRows: 5000, showColumnComment, showColumnType };
  }
-  return { maxRows: Math.min(50000, Math.trunc(maxRows)) };
+  return { maxRows: Math.min(50000, Math.trunc(maxRows)), showColumnComment, showColumnType };
 };

 const sanitizeTableAccessCount = (value: unknown): Record<string, number> => {
@@ -383,7 +391,7 @@ export const useStore = create<AppState>()(
      theme: 'light',
      appearance: { ...DEFAULT_APPEARANCE },
      sqlFormatOptions: { keywordCase: 'upper' },
-      queryOptions: { maxRows: 5000 },
+      queryOptions: { maxRows: 5000, showColumnComment: true, showColumnType: true },
      sqlLogs: [],
      tableAccessCount: {},
      tableSortPreference: {},
--- a/internal/app/app.go
+++ b/internal/app/app.go
@@ -133,8 +133,17 @@ func formatConnSummary(config connection.ConnectionConfig) string {
 	}

 	var b strings.Builder
-	b.WriteString(fmt.Sprintf("类型=%s 地址=%s:%d 数据库=%s 用户=%s 超时=%ds",
-		config.Type, config.Host, config.Port, dbName, config.User, timeoutSeconds))
+	normalizedType := strings.ToLower(strings.TrimSpace(config.Type))
+	if normalizedType == "sqlite" || normalizedType == "duckdb" {
+		path := strings.TrimSpace(config.Host)
+		if path == "" {
+			path = "(未配置)"
+		}
+		b.WriteString(fmt.Sprintf("类型=%s 路径=%s 超时=%ds", config.Type, path, timeoutSeconds))
+	} else {
+		b.WriteString(fmt.Sprintf("类型=%s 地址=%s:%d 数据库=%s 用户=%s 超时=%ds",
+			config.Type, config.Host, config.Port, dbName, config.User, timeoutSeconds))
+	}

 	if len(config.Hosts) > 0 {
 		b.WriteString(fmt.Sprintf(" 节点数=%d", len(config.Hosts)))
--- a/internal/app/methods_driver.go
+++ b/internal/app/methods_driver.go
@@ -1,6 +1,7 @@
 package app

 import (
+	"archive/zip"
 	"crypto/sha256"
 	"encoding/hex"
 	"encoding/json"
@@ -111,13 +112,20 @@ type driverReleaseAssetSizeCacheEntry struct {
 	Err       string
 }

+type driverBundleAssetIndex struct {
+	Assets map[string]int64 `json:"assets"`
+}
+
 const (
 	// 默认使用内置 manifest，避免依赖网络与外部仓库 404。
 	defaultDriverManifestURLValue       = "builtin://manifest"
+	optionalDriverBundleAssetName       = "GoNavi-DriverAgents.zip"
+	optionalDriverBundleIndexAssetName  = "GoNavi-DriverAgents-Index.json"
 	driverManifestCacheTTL              = 5 * time.Minute
 	driverReleaseAssetSizeCacheTTL      = 30 * time.Minute
 	driverReleaseAssetSizeErrorCacheTTL = 30 * time.Second
 	driverReleaseAssetSizeProbeTimeout  = 4 * time.Second
+	driverBundleIndexMaxSize            = 1 << 20
 	driverManifestMaxSize               = 2 << 20
 	driverChecksumPolicyStrict          = "strict"
 	driverChecksumPolicyWarn            = "warn"
@@ -1123,6 +1131,19 @@ func ensureOptionalDriverAgentBinary(a *App, definition driverDefinition, execut
 			downloadErrs = append(downloadErrs, fmt.Sprintf("%s: %s", candidateURL, strings.TrimSpace(dlErr.Error())))
 		}
 	}
+	bundleURLs := resolveOptionalDriverBundleDownloadURLs()
+	if len(bundleURLs) > 0 {
+		for _, bundleURL := range bundleURLs {
+			if a != nil {
+				a.emitDriverDownloadProgress(driverType, "downloading", 20, 100, fmt.Sprintf("从驱动总包提取 %s 代理", displayName))
+			}
+			source, hash, bundleErr := downloadOptionalDriverAgentFromBundle(a, definition, bundleURL, executablePath)
+			if bundleErr == nil {
+				return source, hash, nil
+			}
+			downloadErrs = append(downloadErrs, fmt.Sprintf("%s: %s", bundleURL, strings.TrimSpace(bundleErr.Error())))
+		}
+	}
 	if a != nil {
 		a.emitDriverDownloadProgress(driverType, "downloading", 92, 100, "未命中预编译包，尝试开发态本地构建")
 	}
@@ -1176,6 +1197,112 @@ func downloadOptionalDriverAgentBinary(a *App, definition driverDefinition, urlT
 	return hash, nil
 }

+func downloadOptionalDriverAgentFromBundle(a *App, definition driverDefinition, bundleURL, executablePath string) (string, string, error) {
+	driverType := normalizeDriverType(definition.Type)
+	displayName := resolveDriverDisplayName(definition)
+	trimmedURL := strings.TrimSpace(bundleURL)
+	if trimmedURL == "" {
+		return "", "", fmt.Errorf("驱动总包下载地址为空")
+	}
+
+	bundleTempPath := executablePath + ".bundle.zip.tmp"
+	_ = os.Remove(bundleTempPath)
+	_, err := downloadFileWithHash(trimmedURL, bundleTempPath, func(downloaded, total int64) {
+		if a == nil {
+			return
+		}
+		scaledDownloaded, scaledTotal := scaleProgress(downloaded, total, 20, 78)
+		a.emitDriverDownloadProgress(driverType, "downloading", scaledDownloaded, scaledTotal, fmt.Sprintf("下载 %s 驱动总包", displayName))
+	})
+	if err != nil {
+		_ = os.Remove(bundleTempPath)
+		return "", "", fmt.Errorf("下载驱动总包失败：%w", err)
+	}
+	defer func() { _ = os.Remove(bundleTempPath) }()
+
+	reader, err := zip.OpenReader(bundleTempPath)
+	if err != nil {
+		return "", "", fmt.Errorf("打开驱动总包失败：%w", err)
+	}
+	defer reader.Close()
+
+	entryPath := optionalDriverBundleEntryPath(driverType)
+	expectedBaseName := optionalDriverReleaseAssetName(driverType)
+	findEntry := func() *zip.File {
+		for _, file := range reader.File {
+			name := filepath.ToSlash(strings.TrimPrefix(strings.TrimSpace(file.Name), "./"))
+			if name == entryPath {
+				return file
+			}
+		}
+		for _, file := range reader.File {
+			name := filepath.ToSlash(strings.TrimPrefix(strings.TrimSpace(file.Name), "./"))
+			if strings.EqualFold(name, entryPath) {
+				return file
+			}
+		}
+		for _, file := range reader.File {
+			name := filepath.ToSlash(strings.TrimPrefix(strings.TrimSpace(file.Name), "./"))
+			if strings.EqualFold(filepath.Base(name), expectedBaseName) {
+				return file
+			}
+		}
+		return nil
+	}
+
+	entry := findEntry()
+	if entry == nil {
+		return "", "", fmt.Errorf("驱动总包内未找到 %s（期望路径 %s）", displayName, entryPath)
+	}
+	if a != nil {
+		a.emitDriverDownloadProgress(driverType, "downloading", 84, 100, fmt.Sprintf("解压 %s 驱动代理", displayName))
+	}
+
+	src, err := entry.Open()
+	if err != nil {
+		return "", "", fmt.Errorf("读取驱动总包条目失败：%w", err)
+	}
+	defer src.Close()
+
+	tempPath := executablePath + ".tmp"
+	_ = os.Remove(tempPath)
+	dst, err := os.Create(tempPath)
+	if err != nil {
+		return "", "", fmt.Errorf("创建驱动代理临时文件失败：%w", err)
+	}
+	if _, err := io.Copy(dst, src); err != nil {
+		dst.Close()
+		_ = os.Remove(tempPath)
+		return "", "", fmt.Errorf("写入驱动代理失败：%w", err)
+	}
+	if err := dst.Sync(); err != nil {
+		dst.Close()
+		_ = os.Remove(tempPath)
+		return "", "", fmt.Errorf("落盘驱动代理失败：%w", err)
+	}
+	if err := dst.Close(); err != nil {
+		_ = os.Remove(tempPath)
+		return "", "", fmt.Errorf("关闭驱动代理文件失败：%w", err)
+	}
+	if chmodErr := os.Chmod(tempPath, 0o755); chmodErr != nil && stdRuntime.GOOS != "windows" {
+		_ = os.Remove(tempPath)
+		return "", "", fmt.Errorf("设置驱动代理权限失败：%w", chmodErr)
+	}
+	if err := os.Rename(tempPath, executablePath); err != nil {
+		_ = os.Remove(tempPath)
+		return "", "", fmt.Errorf("替换驱动代理失败：%w", err)
+	}
+	if chmodErr := os.Chmod(executablePath, 0o755); chmodErr != nil && stdRuntime.GOOS != "windows" {
+		return "", "", fmt.Errorf("设置驱动代理权限失败：%w", chmodErr)
+	}
+	hash, err := hashFileSHA256(executablePath)
+	if err != nil {
+		return "", "", fmt.Errorf("计算驱动代理摘要失败：%w", err)
+	}
+	source := fmt.Sprintf("%s#%s", trimmedURL, filepath.ToSlash(strings.TrimPrefix(strings.TrimSpace(entry.Name), "./")))
+	return source, hash, nil
+}
+
 func buildOptionalDriverAgentFromSource(definition driverDefinition, executablePath string) (string, error) {
 	driverType := normalizeDriverType(definition.Type)
 	displayName := resolveDriverDisplayName(definition)
@@ -1282,6 +1409,46 @@ func optionalDriverReleaseAssetName(driverType string) string {
 	return name
 }

+func optionalDriverBundlePlatformDir(goos string) string {
+	switch strings.ToLower(strings.TrimSpace(goos)) {
+	case "windows":
+		return "Windows"
+	case "darwin":
+		return "MacOS"
+	case "linux":
+		return "Linux"
+	default:
+		return "Unknown"
+	}
+}
+
+func optionalDriverBundleEntryPath(driverType string) string {
+	return filepath.ToSlash(filepath.Join(optionalDriverBundlePlatformDir(stdRuntime.GOOS), optionalDriverReleaseAssetName(driverType)))
+}
+
+func resolveOptionalDriverBundleDownloadURLs() []string {
+	candidates := make([]string, 0, 2)
+	seen := make(map[string]struct{}, 2)
+	appendURL := func(value string) {
+		trimmed := strings.TrimSpace(value)
+		if trimmed == "" {
+			return
+		}
+		if _, ok := seen[trimmed]; ok {
+			return
+		}
+		seen[trimmed] = struct{}{}
+		candidates = append(candidates, trimmed)
+	}
+
+	currentVersion := normalizeVersion(getCurrentVersion())
+	if currentVersion != "" && currentVersion != "0.0.0" {
+		appendURL(fmt.Sprintf("https://github.com/Syngnat/GoNavi/releases/download/v%s/%s", currentVersion, optionalDriverBundleAssetName))
+	}
+	appendURL(fmt.Sprintf("https://github.com/Syngnat/GoNavi/releases/latest/download/%s", optionalDriverBundleAssetName))
+	return candidates
+}
+
 func resolveOptionalDriverAgentDownloadURLs(definition driverDefinition, rawURL string) []string {
 	driverType := normalizeDriverType(definition.Type)
 	candidates := make([]string, 0, 3)
@@ -1541,6 +1708,15 @@ func loadReleaseAssetSizesCached(cacheKey string, fetch func() (*githubRelease,
 		entry.Err = err.Error()
 	} else {
 		entry.SizeByKey = buildReleaseAssetSizeMap(release)
+		if indexSizes, indexErr := fetchDriverBundleAssetSizeIndex(release); indexErr == nil {
+			for name, size := range indexSizes {
+				trimmedName := strings.TrimSpace(name)
+				if trimmedName == "" || size <= 0 {
+					continue
+				}
+				entry.SizeByKey[trimmedName] = size
+			}
+		}
 	}

 	driverReleaseSizeMu.Lock()
@@ -1568,6 +1744,50 @@ func buildReleaseAssetSizeMap(release *githubRelease) map[string]int64 {
 	return sizes
 }

+func fetchDriverBundleAssetSizeIndex(release *githubRelease) (map[string]int64, error) {
+	if release == nil {
+		return nil, fmt.Errorf("release 为空")
+	}
+	indexURL := ""
+	for _, asset := range release.Assets {
+		if strings.EqualFold(strings.TrimSpace(asset.Name), optionalDriverBundleIndexAssetName) {
+			indexURL = strings.TrimSpace(asset.BrowserDownloadURL)
+			break
+		}
+	}
+	if indexURL == "" {
+		return nil, fmt.Errorf("未找到驱动总包索引资产")
+	}
+
+	client := &http.Client{Timeout: driverReleaseAssetSizeProbeTimeout}
+	req, err := http.NewRequest(http.MethodGet, indexURL, nil)
+	if err != nil {
+		return nil, err
+	}
+	req.Header.Set("User-Agent", "GoNavi-DriverManager")
+	req.Header.Set("Accept", "application/json")
+
+	resp, err := client.Do(req)
+	if err != nil {
+		return nil, err
+	}
+	defer resp.Body.Close()
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("拉取驱动总包索引失败：HTTP %d", resp.StatusCode)
+	}
+
+	limited := io.LimitReader(resp.Body, driverBundleIndexMaxSize)
+	decoder := json.NewDecoder(limited)
+	var index driverBundleAssetIndex
+	if err := decoder.Decode(&index); err != nil {
+		return nil, fmt.Errorf("解析驱动总包索引失败：%w", err)
+	}
+	if len(index.Assets) == 0 {
+		return nil, fmt.Errorf("驱动总包索引为空")
+	}
+	return index.Assets, nil
+}
+
 func fetchLatestReleaseForDriverAssets() (*githubRelease, error) {
 	return fetchDriverReleaseByURL(updateAPIURL)
 }
--- a/internal/db/sqlite_impl.go
+++ b/internal/db/sqlite_impl.go
@@ -6,6 +6,9 @@ import (
 	"context"
 	"database/sql"
 	"fmt"
+	"os"
+	"path/filepath"
+	"strconv"
 	"strings"
 	"time"

@@ -21,7 +24,14 @@ type SQLiteDB struct {
 }

 func (s *SQLiteDB) Connect(config connection.ConnectionConfig) error {
-	dsn := config.Host
+	dsn, err := resolveSQLiteDSN(config)
+	if err != nil {
+		return err
+	}
+	if err := ensureSQLiteParentDir(dsn); err != nil {
+		return err
+	}
+
 	db, err := sql.Open("sqlite", dsn)
 	if err != nil {
 		return fmt.Errorf("打开数据库连接失败：%w", err)
@@ -31,11 +41,140 @@ func (s *SQLiteDB) Connect(config connection.ConnectionConfig) error {

 	// Force verification
 	if err := s.Ping(); err != nil {
+		_ = db.Close()
+		s.conn = nil
 		return fmt.Errorf("连接建立后验证失败：%w", err)
 	}
 	return nil
 }

+func resolveSQLiteDSN(config connection.ConnectionConfig) (string, error) {
+	dsn := strings.TrimSpace(config.Host)
+	if dsn == "" {
+		dsn = strings.TrimSpace(config.Database)
+	}
+	dsn = normalizeSQLitePath(dsn)
+	if dsn == "" {
+		return "", fmt.Errorf("SQLite 需要本地数据库文件路径（例如 /path/to/demo.sqlite）")
+	}
+	if strings.EqualFold(dsn, ":memory:") {
+		return dsn, nil
+	}
+	if looksLikeHostPort(dsn) {
+		return "", fmt.Errorf("SQLite 需要本地数据库文件路径，当前输入看起来是主机地址：%s", dsn)
+	}
+	return dsn, nil
+}
+
+func normalizeSQLitePath(raw string) string {
+	text := strings.TrimSpace(raw)
+	if strings.HasPrefix(text, "/") && len(text) > 3 && isWindowsDrivePath(text[1:]) {
+		text = text[1:]
+	}
+	if isWindowsDrivePath(text) {
+		text = trimLegacyPortSuffix(text)
+	}
+	return text
+}
+
+func isWindowsDrivePath(path string) bool {
+	if len(path) < 3 {
+		return false
+	}
+	drive := path[0]
+	if !((drive >= 'a' && drive <= 'z') || (drive >= 'A' && drive <= 'Z')) {
+		return false
+	}
+	if path[1] != ':' {
+		return false
+	}
+	sep := path[2]
+	return sep == '\\' || sep == '/'
+}
+
+func trimLegacyPortSuffix(path string) string {
+	normalized := path
+	for {
+		idx := strings.LastIndex(normalized, ":")
+		if idx <= 1 || idx+1 >= len(normalized) {
+			return normalized
+		}
+		suffix := normalized[idx+1:]
+		validDigits := true
+		for _, ch := range suffix {
+			if ch < '0' || ch > '9' {
+				validDigits = false
+				break
+			}
+		}
+		if !validDigits {
+			return normalized
+		}
+		normalized = normalized[:idx]
+	}
+}
+
+func looksLikeHostPort(raw string) bool {
+	text := strings.TrimSpace(raw)
+	if text == "" {
+		return false
+	}
+	if strings.ContainsAny(text, `/\`) {
+		return false
+	}
+	if strings.HasPrefix(strings.ToLower(text), "file:") {
+		return false
+	}
+	if strings.HasPrefix(text, "[") {
+		closing := strings.LastIndex(text, "]")
+		if closing <= 0 || closing+1 >= len(text) {
+			return false
+		}
+		portText := strings.TrimSpace(strings.TrimPrefix(text[closing+1:], ":"))
+		return isValidPortText(portText)
+	}
+	if strings.Count(text, ":") != 1 {
+		return false
+	}
+	split := strings.LastIndex(text, ":")
+	if split <= 0 || split+1 >= len(text) {
+		return false
+	}
+	return isValidPortText(strings.TrimSpace(text[split+1:]))
+}
+
+func isValidPortText(text string) bool {
+	port, err := strconv.Atoi(text)
+	return err == nil && port > 0 && port <= 65535
+}
+
+func ensureSQLiteParentDir(dsn string) error {
+	text := strings.TrimSpace(dsn)
+	if text == "" || strings.EqualFold(text, ":memory:") {
+		return nil
+	}
+	// file: URI 由驱动处理，避免在这里误判路径格式。
+	if strings.HasPrefix(strings.ToLower(text), "file:") {
+		return nil
+	}
+	path := text
+	if idx := strings.Index(path, "?"); idx >= 0 {
+		path = path[:idx]
+	}
+	path = strings.TrimSpace(path)
+	if path == "" {
+		return nil
+	}
+	dir := filepath.Dir(path)
+	if dir == "." || dir == "" {
+		return nil
+	}
+	if err := os.MkdirAll(dir, 0o755); err != nil {
+		return fmt.Errorf("创建 SQLite 数据文件目录失败：%w", err)
+	}
+	return nil
+}
+
 func (s *SQLiteDB) Close() error {
 	if s.conn != nil {
 		return s.conn.Close()
--- a/internal/db/sqlite_impl_test.go
+++ b/internal/db/sqlite_impl_test.go
@@ -0,0 +1,79 @@
+//go:build gonavi_full_drivers || gonavi_sqlite_driver
+
+package db
+
+import (
+	"os"
+	"path/filepath"
+	"strings"
+	"testing"
+
+	"GoNavi-Wails/internal/connection"
+)
+
+func TestResolveSQLiteDSNRejectsHostPort(t *testing.T) {
+	_, err := resolveSQLiteDSN(connection.ConnectionConfig{Type: "sqlite", Host: "localhost:3306"})
+	if err == nil {
+		t.Fatalf("期望拦截 host:port 输入")
+	}
+	if !strings.Contains(err.Error(), "本地数据库文件路径") {
+		t.Fatalf("错误提示不符合预期: %v", err)
+	}
+}
+
+func TestResolveSQLiteDSNFallbackDatabase(t *testing.T) {
+	dsn, err := resolveSQLiteDSN(connection.ConnectionConfig{Type: "sqlite", Database: "/tmp/demo.sqlite"})
+	if err != nil {
+		t.Fatalf("解析 DSN 失败: %v", err)
+	}
+	if dsn != "/tmp/demo.sqlite" {
+		t.Fatalf("期望使用 database 作为 DSN，实际=%s", dsn)
+	}
+}
+
+func TestResolveSQLiteDSNNormalizesWindowsLegacyPath(t *testing.T) {
+	dsn, err := resolveSQLiteDSN(connection.ConnectionConfig{Type: "sqlite", Host: `F:\py\py\history.db:3306:3306`})
+	if err != nil {
+		t.Fatalf("解析 DSN 失败: %v", err)
+	}
+	if dsn != `F:\py\py\history.db` {
+		t.Fatalf("期望清理历史端口污染，实际=%s", dsn)
+	}
+}
+
+func TestResolveSQLiteDSNNormalizesWindowsPathWithLeadingSlash(t *testing.T) {
+	dsn, err := resolveSQLiteDSN(connection.ConnectionConfig{Type: "sqlite", Host: `/F:\py\py\history.db:3306`})
+	if err != nil {
+		t.Fatalf("解析 DSN 失败: %v", err)
+	}
+	if dsn != `F:\py\py\history.db` {
+		t.Fatalf("期望清理前导斜杠与端口污染，实际=%s", dsn)
+	}
+}
+
+func TestEnsureSQLiteParentDirCreatesNestedDir(t *testing.T) {
+	base := t.TempDir()
+	target := filepath.Join(base, "nested", "child", "demo.sqlite")
+	if err := ensureSQLiteParentDir(target); err != nil {
+		t.Fatalf("创建目录失败: %v", err)
+	}
+	info, err := os.Stat(filepath.Dir(target))
+	if err != nil {
+		t.Fatalf("目录不存在: %v", err)
+	}
+	if !info.IsDir() {
+		t.Fatalf("目标不是目录: %s", filepath.Dir(target))
+	}
+}
+
+func TestLooksLikeHostPort(t *testing.T) {
+	if !looksLikeHostPort("localhost:3306") {
+		t.Fatalf("localhost:3306 应识别为 host:port")
+	}
+	if looksLikeHostPort("/tmp/demo.sqlite") {
+		t.Fatalf("/tmp/demo.sqlite 不应识别为 host:port")
+	}
+	if looksLikeHostPort(`C:\sqlite\demo.db`) {
+		t.Fatalf("Windows 路径不应识别为 host:port")
+	}
+}