🔧fix(mongodb): 修复MongoDB查询仅返回一条数据的问题

- queryWithContext 中 find/count 命令改用原生 Collection.Find()和 CountDocuments() API，替代RunCommand 的 firstBatch 模式
- 新增 convertBsonValue 将 ObjectID/bson.M/bson.D/bson.A 转为JSON 友好类型，_id 列自动置首
- DBQuery 增加 MongoDB JSON 命令识别，避免 find 命令误走 Exec 分支

⚡️perf(macos): 动态控制 NSVisualEffectView 降低 MacOS GPU 持续消耗，Windows不受影响

- NSVisualEffectView 启动默认 alpha 由 0.72 改为 0，窗口默认 opaque
- 新增 gonaviSetEffectViewAlpha ObjC 函数支持运行时动态切换
- 新增 SetWindowTranslucency Wails 绑定方法供前端调用
- 启动重试次数由 24 次缩减至 8 次
- opacity=1.0 且 blur=0 时窗口标记 opaque，GPU 不再持续计算模糊合成
- App.tsx 仅保留最外层 Layout 的 backdropFilter，移除 TitleBar/MenuBar/Content/DataGrid/LogPanel 冗余嵌套
- App.css 移除暗色模式全局 text-shadow 减少 compositing 开销

internal/app/app.go

@@ -49,6 +49,13 @@ func (a *App) Startup(ctx context.Context) {
 	logger.Infof("应用启动完成")
 }
 
+// SetWindowTranslucency 动态调整 macOS 窗口透明度。
+// 前端在加载用户外观设置后、以及用户修改外观时调用此方法。
+// opacity=1.0 且 blur=0 时窗口标记为 opaque，GPU 不再持续计算窗口背后的模糊合成。
+func (a *App) SetWindowTranslucency(opacity float64, blur float64) {
+	setMacWindowTranslucency(opacity, blur)
+}
+
 // Shutdown is called when the app terminates
 func (a *App) Shutdown(ctx context.Context) {
 	logger.Infof("应用开始关闭，准备释放资源")

internal/app/methods_db.go

@@ -367,7 +367,12 @@ func (a *App) DBQuery(config connection.ConnectionConfig, dbName string, query s
 	defer cancel()
 
 	lowerQuery := strings.TrimSpace(strings.ToLower(query))
-	if strings.HasPrefix(lowerQuery, "select") || strings.HasPrefix(lowerQuery, "show") || strings.HasPrefix(lowerQuery, "describe") || strings.HasPrefix(lowerQuery, "explain") {
+	isReadQuery := strings.HasPrefix(lowerQuery, "select") || strings.HasPrefix(lowerQuery, "show") || strings.HasPrefix(lowerQuery, "describe") || strings.HasPrefix(lowerQuery, "explain")
+	// MongoDB JSON 命令中的 find/count/aggregate 也属于读查询
+	if !isReadQuery && strings.ToLower(strings.TrimSpace(runConfig.Type)) == "mongodb" && strings.HasPrefix(strings.TrimSpace(query), "{") {
+		isReadQuery = true
+	}
+	if isReadQuery {
 		var data []map[string]interface{}
 		var columns []string
 		if q, ok := dbInst.(interface {
@@ -539,6 +544,125 @@ func (a *App) DBGetTriggers(config connection.ConnectionConfig, dbName string, t
 	return connection.QueryResult{Success: true, Data: triggers}
 }
 
+func (a *App) DropView(config connection.ConnectionConfig, dbName string, viewName string) connection.QueryResult {
+	viewName = strings.TrimSpace(viewName)
+	if viewName == "" {
+		return connection.QueryResult{Success: false, Message: "视图名称不能为空"}
+	}
+
+	dbType := resolveDDLDBType(config)
+	switch dbType {
+	case "mysql", "mariadb", "postgres", "kingbase", "sqlite", "oracle", "dameng", "highgo", "vastbase", "sqlserver":
+	default:
+		return connection.QueryResult{Success: false, Message: fmt.Sprintf("当前数据源(%s)暂不支持删除视图", dbType)}
+	}
+
+	schemaName, pureViewName := normalizeSchemaAndTableByType(dbType, dbName, viewName)
+	if pureViewName == "" {
+		return connection.QueryResult{Success: false, Message: "视图名称不能为空"}
+	}
+	qualifiedView := quoteTableIdentByType(dbType, schemaName, pureViewName)
+	sql := fmt.Sprintf("DROP VIEW %s", qualifiedView)
+
+	runConfig := buildRunConfigForDDL(config, dbType, dbName)
+	dbInst, err := a.getDatabase(runConfig)
+	if err != nil {
+		return connection.QueryResult{Success: false, Message: err.Error()}
+	}
+	if _, err := dbInst.Exec(sql); err != nil {
+		return connection.QueryResult{Success: false, Message: err.Error()}
+	}
+	return connection.QueryResult{Success: true, Message: "视图删除成功"}
+}
+
+func (a *App) DropFunction(config connection.ConnectionConfig, dbName string, routineName string, routineType string) connection.QueryResult {
+	routineName = strings.TrimSpace(routineName)
+	routineType = strings.TrimSpace(strings.ToUpper(routineType))
+	if routineName == "" {
+		return connection.QueryResult{Success: false, Message: "函数/存储过程名称不能为空"}
+	}
+	if routineType != "FUNCTION" && routineType != "PROCEDURE" {
+		routineType = "FUNCTION"
+	}
+
+	dbType := resolveDDLDBType(config)
+	switch dbType {
+	case "mysql", "mariadb", "postgres", "kingbase", "oracle", "dameng", "highgo", "vastbase", "sqlserver":
+	default:
+		return connection.QueryResult{Success: false, Message: fmt.Sprintf("当前数据源(%s)暂不支持删除函数/存储过程", dbType)}
+	}
+
+	schemaName, pureName := normalizeSchemaAndTableByType(dbType, dbName, routineName)
+	if pureName == "" {
+		return connection.QueryResult{Success: false, Message: "函数/存储过程名称不能为空"}
+	}
+	qualifiedName := quoteTableIdentByType(dbType, schemaName, pureName)
+	sql := fmt.Sprintf("DROP %s %s", routineType, qualifiedName)
+
+	runConfig := buildRunConfigForDDL(config, dbType, dbName)
+	dbInst, err := a.getDatabase(runConfig)
+	if err != nil {
+		return connection.QueryResult{Success: false, Message: err.Error()}
+	}
+	if _, err := dbInst.Exec(sql); err != nil {
+		return connection.QueryResult{Success: false, Message: err.Error()}
+	}
+
+	label := "函数"
+	if routineType == "PROCEDURE" {
+		label = "存储过程"
+	}
+	return connection.QueryResult{Success: true, Message: fmt.Sprintf("%s删除成功", label)}
+}
+
+func (a *App) RenameView(config connection.ConnectionConfig, dbName string, oldName string, newName string) connection.QueryResult {
+	oldName = strings.TrimSpace(oldName)
+	newName = strings.TrimSpace(newName)
+	if oldName == "" || newName == "" {
+		return connection.QueryResult{Success: false, Message: "视图名称不能为空"}
+	}
+	if strings.EqualFold(oldName, newName) {
+		return connection.QueryResult{Success: false, Message: "新旧视图名称不能相同"}
+	}
+	if strings.Contains(newName, ".") {
+		return connection.QueryResult{Success: false, Message: "新视图名不能包含 schema 或数据库前缀"}
+	}
+
+	dbType := resolveDDLDBType(config)
+	schemaName, pureOldName := normalizeSchemaAndTableByType(dbType, dbName, oldName)
+	if pureOldName == "" {
+		return connection.QueryResult{Success: false, Message: "旧视图名不能为空"}
+	}
+	oldQualified := quoteTableIdentByType(dbType, schemaName, pureOldName)
+	newQuoted := quoteIdentByType(dbType, newName)
+
+	var sql string
+	switch dbType {
+	case "mysql", "mariadb":
+		newQualified := quoteTableIdentByType(dbType, schemaName, newName)
+		sql = fmt.Sprintf("RENAME TABLE %s TO %s", oldQualified, newQualified)
+	case "postgres", "kingbase", "highgo", "vastbase":
+		sql = fmt.Sprintf("ALTER VIEW %s RENAME TO %s", oldQualified, newQuoted)
+	case "sqlserver":
+		oldFullName := schemaName + "." + pureOldName
+		escapedOld := strings.ReplaceAll(oldFullName, "'", "''")
+		escapedNew := strings.ReplaceAll(newName, "'", "''")
+		sql = fmt.Sprintf("EXEC sp_rename '%s', '%s'", escapedOld, escapedNew)
+	default:
+		return connection.QueryResult{Success: false, Message: fmt.Sprintf("当前数据源(%s)暂不支持重命名视图", dbType)}
+	}
+
+	runConfig := buildRunConfigForDDL(config, dbType, dbName)
+	dbInst, err := a.getDatabase(runConfig)
+	if err != nil {
+		return connection.QueryResult{Success: false, Message: err.Error()}
+	}
+	if _, err := dbInst.Exec(sql); err != nil {
+		return connection.QueryResult{Success: false, Message: err.Error()}
+	}
+	return connection.QueryResult{Success: true, Message: "视图重命名成功"}
+}
+
 func (a *App) DBGetAllColumns(config connection.ConnectionConfig, dbName string) connection.QueryResult {
 	runConfig := normalizeRunConfig(config, dbName)
 

internal/app/methods_update.go

@@ -224,7 +224,19 @@ func (a *App) downloadAndStageUpdate(info UpdateInfo) connection.QueryResult {
 	// 使用版本号命名的工作目录，便于识别和调试
 	stagedDir := filepath.Join(workspaceDir, fmt.Sprintf(".gonavi-update-%s-%s", stdRuntime.GOOS, info.LatestVersion))
 	// 清理可能残留的旧目录（上次下载失败后未清理）
-	_ = os.RemoveAll(stagedDir)
+	// Windows 上文件可能被杀毒软件/索引服务占用，需要重试
+	for retry := 0; retry < 5; retry++ {
+		err := os.RemoveAll(stagedDir)
+		if err == nil {
+			break
+		}
+		if retry < 4 {
+			time.Sleep(time.Duration(retry+1) * 500 * time.Millisecond)
+		} else {
+			// 最后一次仍然失败，换一个带时间戳的目录名避免冲突
+			stagedDir = filepath.Join(workspaceDir, fmt.Sprintf(".gonavi-update-%s-%s-%d", stdRuntime.GOOS, info.LatestVersion, time.Now().UnixNano()))
+		}
+	}
 	if err := os.MkdirAll(stagedDir, 0o755); err != nil {
 		errMsg := fmt.Sprintf("无法在应用目录创建更新工作目录：%s", stagedDir)
 		a.emitUpdateDownloadProgress("error", 0, info.AssetSize, errMsg)
@@ -490,11 +502,21 @@ func downloadFileWithHash(url, filePath string, onProgress func(downloaded, tota
 		return "", fmt.Errorf("下载更新包失败：HTTP %d", resp.StatusCode)
 	}
 
-	out, err := os.Create(filePath)
-	if err != nil {
-		return "", err
+	// Windows 上旧文件可能被杀毒软件/索引服务占用，先尝试删除并重试
+	_ = os.Remove(filePath)
+	var out *os.File
+	for retry := 0; retry < 5; retry++ {
+		out, err = os.Create(filePath)
+		if err == nil {
+			break
+		}
+		if retry < 4 {
+			time.Sleep(time.Duration(retry+1) * 500 * time.Millisecond)
+		}
+	}
+	if err != nil {
+		return "", fmt.Errorf("更新下载失败，文件被占用：%w", err)
 	}
-	defer out.Close()
 
 	hasher := sha256.New()
 	total := resp.ContentLength
@@ -508,12 +530,22 @@ func downloadFileWithHash(url, filePath string, onProgress func(downloaded, tota
 		onProgress(0, total)
 	}
 	if _, err := io.Copy(io.MultiWriter(writers...), resp.Body); err != nil {
+		out.Close()
 		return "", err
 	}
 	if onProgress != nil {
 		onProgress(progressWriter.written, total)
 	}
 
+	// 显式 Sync + Close，确保数据落盘且文件句柄释放
+	if err := out.Sync(); err != nil {
+		out.Close()
+		return "", err
+	}
+	if err := out.Close(); err != nil {
+		return "", err
+	}
+
 	return hex.EncodeToString(hasher.Sum(nil)), nil
 }
 
@@ -544,18 +576,13 @@ func buildUpdateInstallLogPath(baseDir string) string {
 }
 
 func resolveUpdateWorkspaceDir() string {
-	exePath, err := os.Executable()
-	if err != nil {
-		return ""
-	}
-	exePath, _ = filepath.EvalSymlinks(exePath)
-	if stdRuntime.GOOS == "darwin" {
-		appPath := detectMacAppPath(exePath)
-		if appPath != "" {
-			return filepath.Dir(appPath)
-		}
-	}
-	return filepath.Dir(exePath)
+	// 使用系统临时目录作为更新工作区，避免以下问题：
+	// 1. Windows: exe 所在目录可能被杀毒软件/索引服务锁定，或缺少写权限（如 Program Files）
+	// 2. macOS: /Applications 需要管理员权限才能写入
+	// 3. 运行中的 exe 文件锁与 staging 文件冲突
+	dir := filepath.Join(os.TempDir(), "gonavi-updates")
+	_ = os.MkdirAll(dir, 0o755)
+	return dir
 }
 
 func resolveUpdateInstallTarget() string {

internal/app/window_translucency_darwin.go

@@ -47,14 +47,16 @@ static void gonaviTuneWindowTranslucency(NSWindow *window) {
 	[effectView setMaterial:NSVisualEffectMaterialHUDWindow];
 	[effectView setBlendingMode:NSVisualEffectBlendingModeBehindWindow];
 	[effectView setState:NSVisualEffectStateActive];
-	[effectView setAlphaValue:0.72];
+	// 默认 alpha=0（不可见），由前端根据用户外观设置动态启用
+	[effectView setAlphaValue:0.0];
 	[effectView setWantsLayer:YES];
 	[[effectView layer] setCornerRadius:cornerRadius];
 	[[effectView layer] setMasksToBounds:YES];
 }
 
 static void gonaviApplyWindowTranslucencyFix() {
-	for (int i = 0; i < 24; i++) {
+	// 启动时应用窗口透明度修复，减少重试次数以降低启动期 GPU 负载
+	for (int i = 0; i < 8; i++) {
 		dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(i * 250 * NSEC_PER_MSEC)), dispatch_get_main_queue(), ^{
 			for (NSWindow *window in [NSApp windows]) {
 				gonaviTuneWindowTranslucency(window);
@@ -62,9 +64,56 @@ static void gonaviApplyWindowTranslucencyFix() {
 		});
 	}
 }
+
+// 动态设置 NSVisualEffectView 的透明度和窗口不透明标志。
+// alpha <= 0 时窗口标记为 opaque，GPU 不再持续计算窗口背后的模糊效果。
+static void gonaviSetEffectViewAlpha(double alpha) {
+	dispatch_async(dispatch_get_main_queue(), ^{
+		for (NSWindow *window in [NSApp windows]) {
+			NSView *contentView = [window contentView];
+			if (contentView == nil) {
+				continue;
+			}
+
+			for (NSView *subview in [contentView subviews]) {
+				if ([subview isKindOfClass:[NSVisualEffectView class]]) {
+					NSVisualEffectView *effectView = (NSVisualEffectView *)subview;
+					[effectView setAlphaValue:alpha];
+					break;
+				}
+			}
+
+			if (alpha <= 0.01) {
+				[window setOpaque:YES];
+			} else {
+				[window setOpaque:NO];
+				[window setBackgroundColor:[NSColor clearColor]];
+			}
+		}
+	});
+}
 */
 import "C"
 
 func applyMacWindowTranslucencyFix() {
 	C.gonaviApplyWindowTranslucencyFix()
 }
+
+// setMacWindowTranslucency 根据用户外观设置动态调整 macOS 窗口透明度。
+// opacity=1.0 且 blur=0 时关闭 NSVisualEffectView（alpha=0），窗口标记为 opaque，
+// GPU 不再持续计算窗口背后的模糊合成，显著降低 CPU/GPU 温度。
+func setMacWindowTranslucency(opacity float64, blur float64) {
+	if opacity >= 0.999 && blur <= 0 {
+		C.gonaviSetEffectViewAlpha(C.double(0.0))
+	} else {
+		// 半透明模式：NSVisualEffectView alpha 根据透明度动态映射
+		alpha := (1.0 - opacity) * 1.2
+		if alpha < 0.3 {
+			alpha = 0.3
+		}
+		if alpha > 0.85 {
+			alpha = 0.85
+		}
+		C.gonaviSetEffectViewAlpha(C.double(alpha))
+	}
+}

internal/app/window_translucency_stub.go

@@ -3,3 +3,5 @@
 package app
 
 func applyMacWindowTranslucencyFix() {}
+
+func setMacWindowTranslucency(opacity float64, blur float64) {}

internal/db/mongodb_impl.go

@@ -200,13 +200,13 @@ func (m *MongoDB) getURI(config connection.ConnectionConfig) string {
 	uri := fmt.Sprintf("%s://%s", scheme, hostText)
 
 	if config.User != "" {
-		encodedUser := url.PathEscape(config.User)
+		var userinfo *url.Userinfo
 		if config.Password != "" {
-			encodedPass := url.PathEscape(config.Password)
-			uri = fmt.Sprintf("%s://%s:%s@%s", scheme, encodedUser, encodedPass, hostText)
+			userinfo = url.UserPassword(config.User, config.Password)
 		} else {
-			uri = fmt.Sprintf("%s://%s@%s", scheme, encodedUser, hostText)
+			userinfo = url.User(config.User)
 		}
+		uri = fmt.Sprintf("%s://%s@%s", scheme, userinfo.String(), hostText)
 	}
 
 	path := "/"
@@ -441,6 +441,23 @@ func asMongoBool(raw interface{}) bool {
 	}
 }
 
+func asMongoInt64(raw interface{}) int64 {
+	switch value := raw.(type) {
+	case int:
+		return int64(value)
+	case int32:
+		return int64(value)
+	case int64:
+		return value
+	case float32:
+		return int64(value)
+	case float64:
+		return int64(value)
+	default:
+		return 0
+	}
+}
+
 func mongoStateByCode(code int) string {
 	switch code {
 	case 1:
@@ -613,6 +630,98 @@ func (m *MongoDB) QueryContext(ctx context.Context, query string) ([]map[string]
 	return m.queryWithContext(ctx, query)
 }
 
+// sqlToMongoFind 将前端生成的简单 SQL 转换为 MongoDB find 命令 JSON。
+// 支持：SELECT * FROM "coll" LIMIT n OFFSET m / SELECT COUNT(*) as total FROM "coll"
+func sqlToMongoFind(sql string) (string, bool) {
+	lower := strings.ToLower(strings.TrimSpace(sql))
+
+	// SELECT COUNT(*) as total FROM "coll" ...
+	if strings.HasPrefix(lower, "select count(") {
+		coll := extractCollectionFromSQL(sql)
+		if coll == "" {
+			return "", false
+		}
+		return fmt.Sprintf(`{"count":"%s","query":{}}`, coll), true
+	}
+
+	// SELECT * FROM "coll" ... LIMIT n OFFSET m
+	if !strings.HasPrefix(lower, "select") {
+		return "", false
+	}
+	coll := extractCollectionFromSQL(sql)
+	if coll == "" {
+		return "", false
+	}
+
+	limit := int64(0)
+	skip := int64(0)
+
+	// 提取 LIMIT
+	if idx := strings.Index(lower, "limit "); idx >= 0 {
+		after := strings.TrimSpace(lower[idx+6:])
+		parts := strings.Fields(after)
+		if len(parts) > 0 {
+			if n, err := strconv.ParseInt(parts[0], 10, 64); err == nil {
+				limit = n
+			}
+		}
+	}
+
+	// 提取 OFFSET
+	if idx := strings.Index(lower, "offset "); idx >= 0 {
+		after := strings.TrimSpace(lower[idx+7:])
+		parts := strings.Fields(after)
+		if len(parts) > 0 {
+			if n, err := strconv.ParseInt(parts[0], 10, 64); err == nil {
+				skip = n
+			}
+		}
+	}
+
+	cmd := fmt.Sprintf(`{"find":"%s","filter":{}`, coll)
+	if limit > 0 {
+		cmd += fmt.Sprintf(`,"limit":%d`, limit)
+	}
+	if skip > 0 {
+		cmd += fmt.Sprintf(`,"skip":%d`, skip)
+	}
+	cmd += "}"
+	return cmd, true
+}
+
+// extractCollectionFromSQL 从 SQL 中提取 FROM 后的 collection 名称。
+func extractCollectionFromSQL(sql string) string {
+	lower := strings.ToLower(sql)
+	idx := strings.Index(lower, "from ")
+	if idx < 0 {
+		return ""
+	}
+	after := strings.TrimSpace(sql[idx+5:])
+
+	// 去掉引号包裹
+	var coll string
+	if len(after) > 0 && after[0] == '"' {
+		end := strings.Index(after[1:], "\"")
+		if end < 0 {
+			return ""
+		}
+		coll = after[1 : end+1]
+	} else if len(after) > 0 && after[0] == '`' {
+		end := strings.Index(after[1:], "`")
+		if end < 0 {
+			return ""
+		}
+		coll = after[1 : end+1]
+	} else {
+		parts := strings.Fields(after)
+		if len(parts) == 0 {
+			return ""
+		}
+		coll = parts[0]
+	}
+	return strings.TrimSpace(coll)
+}
+
 func (m *MongoDB) queryWithContext(ctx context.Context, query string) ([]map[string]interface{}, []string, error) {
 	if m.client == nil {
 		return nil, nil, fmt.Errorf("connection not open")
@@ -623,18 +732,44 @@ func (m *MongoDB) queryWithContext(ctx context.Context, query string) ([]map[str
 		return nil, nil, fmt.Errorf("empty query")
 	}
 
+	// 如果输入是 SQL 语句（前端 DataViewer 统一生成），自动转换为 MongoDB JSON 命令
+	lowerQuery := strings.ToLower(query)
+	if strings.HasPrefix(lowerQuery, "select") || strings.HasPrefix(lowerQuery, "show") {
+		if converted, ok := sqlToMongoFind(query); ok {
+			query = converted
+		}
+	}
+
 	// Parse JSON command
 	var cmd bson.D
 	if err := bson.UnmarshalExtJSON([]byte(query), true, &cmd); err != nil {
 		return nil, nil, fmt.Errorf("invalid JSON command: %w", err)
 	}
 
+	// 对 find 和 count 命令使用原生 driver API，避免 RunCommand 的 firstBatch 限制
+	if len(cmd) > 0 {
+		switch cmd[0].Key {
+		case "find":
+			return m.execFind(ctx, cmd)
+		case "count":
+			return m.execCount(ctx, cmd)
+		}
+	}
+
+	// 其他命令走 RunCommand
 	db := m.client.Database(m.database)
 	var result bson.M
 	if err := db.RunCommand(ctx, cmd).Decode(&result); err != nil {
 		return nil, nil, err
 	}
 
+	// Handle COUNT result (e.g. delete/update returns "n")
+	if n, ok := result["n"]; ok {
+		if _, hasCursor := result["cursor"]; !hasCursor {
+			return []map[string]interface{}{{"total": n}}, []string{"total"}, nil
+		}
+	}
+
 	// Convert result to standard format
 	data := []map[string]interface{}{{"result": result}}
 	columns := []string{"result"}
@@ -664,6 +799,156 @@ func (m *MongoDB) queryWithContext(ctx context.Context, query string) ([]map[str
 	return data, columns, nil
 }
 
+// execFind 使用原生 Collection.Find() 执行查询，正确处理游标迭代
+func (m *MongoDB) execFind(ctx context.Context, cmd bson.D) ([]map[string]interface{}, []string, error) {
+	var collName string
+	var filter interface{}
+	var limit int64
+	var skip int64
+	var sortDoc interface{}
+	var projection interface{}
+
+	for _, elem := range cmd {
+		switch elem.Key {
+		case "find":
+			collName = fmt.Sprintf("%v", elem.Value)
+		case "filter":
+			filter = elem.Value
+		case "limit":
+			limit = asMongoInt64(elem.Value)
+		case "skip":
+			skip = asMongoInt64(elem.Value)
+		case "sort":
+			sortDoc = elem.Value
+		case "projection":
+			projection = elem.Value
+		}
+	}
+
+	if collName == "" {
+		return nil, nil, fmt.Errorf("find command missing collection name")
+	}
+	if filter == nil {
+		filter = bson.D{}
+	}
+
+	collection := m.client.Database(m.database).Collection(collName)
+	opts := options.Find()
+	if limit > 0 {
+		opts.SetLimit(limit)
+	}
+	if skip > 0 {
+		opts.SetSkip(skip)
+	}
+	if sortDoc != nil {
+		opts.SetSort(sortDoc)
+	}
+	if projection != nil {
+		opts.SetProjection(projection)
+	}
+
+	cursor, err := collection.Find(ctx, filter, opts)
+	if err != nil {
+		return nil, nil, err
+	}
+	defer cursor.Close(ctx)
+
+	var data []map[string]interface{}
+	columnSet := make(map[string]bool)
+
+	for cursor.Next(ctx) {
+		var doc bson.M
+		if err := cursor.Decode(&doc); err != nil {
+			continue
+		}
+		row := make(map[string]interface{})
+		for k, v := range doc {
+			row[k] = convertBsonValue(v)
+			columnSet[k] = true
+		}
+		data = append(data, row)
+	}
+
+	if err := cursor.Err(); err != nil {
+		return nil, nil, err
+	}
+
+	columns := make([]string, 0, len(columnSet))
+	for k := range columnSet {
+		columns = append(columns, k)
+	}
+	sort.Strings(columns)
+
+	// 将 _id 列置首
+	for i, col := range columns {
+		if col == "_id" && i > 0 {
+			columns = append(columns[:i], columns[i+1:]...)
+			columns = append([]string{"_id"}, columns...)
+			break
+		}
+	}
+
+	return data, columns, nil
+}
+
+// execCount 使用原生 Collection.CountDocuments() 执行计数
+func (m *MongoDB) execCount(ctx context.Context, cmd bson.D) ([]map[string]interface{}, []string, error) {
+	var collName string
+	var filter interface{}
+
+	for _, elem := range cmd {
+		switch elem.Key {
+		case "count":
+			collName = fmt.Sprintf("%v", elem.Value)
+		case "query":
+			filter = elem.Value
+		}
+	}
+
+	if collName == "" {
+		return nil, nil, fmt.Errorf("count command missing collection name")
+	}
+	if filter == nil {
+		filter = bson.D{}
+	}
+
+	collection := m.client.Database(m.database).Collection(collName)
+	n, err := collection.CountDocuments(ctx, filter)
+	if err != nil {
+		return nil, nil, err
+	}
+
+	return []map[string]interface{}{{"total": n}}, []string{"total"}, nil
+}
+
+// convertBsonValue 将 BSON 特殊类型转换为前端可读的 JSON 友好值
+func convertBsonValue(v interface{}) interface{} {
+	switch val := v.(type) {
+	case bson.ObjectID:
+		return val.Hex()
+	case bson.M:
+		result := make(map[string]interface{}, len(val))
+		for k, v2 := range val {
+			result[k] = convertBsonValue(v2)
+		}
+		return result
+	case bson.D:
+		result := make(map[string]interface{}, len(val))
+		for _, elem := range val {
+			result[elem.Key] = convertBsonValue(elem.Value)
+		}
+		return result
+	case bson.A:
+		result := make([]interface{}, len(val))
+		for i, v2 := range val {
+			result[i] = convertBsonValue(v2)
+		}
+		return result
+	default:
+		return v
+	}
+}
+
 func (m *MongoDB) Exec(query string) (int64, error) {
 	_, _, err := m.Query(query)
 	if err != nil {