feat(workbench): support PostgreSQL + fix AuditMiddleware fail-open (issue #850)

[LordofAvernus]

User description

Summary

• 工作台支持 PostgreSQL：在 SqlWorkbenchService.SupportDBType 白名单加入 postgresql（compat-RISK-2），打开工作台对 PG 数据源的入口。
• 部署侧把 sqle-pg-plugin 二进制随 RPM 打包并落到 SQLE plugin_path（compat-RISK-4 决策 B 的必补覆盖）。
• 修复 AuditMiddleware 在辅助路径（用户解析失败 / 缓存缺失 / DBService 元数据失败 / 未启用审核 / SQLE 调用失败）上把请求 400 掉的 bug，统一改为 fail-open 透传，让 ODC SQL Console 能正常执行 SQL；read-body 与「审核结果要求拦截」两个强约束仍保留 fail-closed。

关联 issue: actiontech/dms-ee#850
关联文档: docs/dev/compat_risks.md §compat-RISK-2 / §compat-RISK-4 / docs/dev/fix-task-004-odc-streamExecute-400.md

Test plan

• make EDITION=ce docker_install 构建通过
• go vet ./internal/sql_workbench/service/... 通过（本地已通过）
• ODC SQL Console 上对 MySQL / PG 实例执行 SELECT 不再 400（fix-task-004 复测证据）
• PG 数据源建表 / 工作台目录树展示不回归（compat-RISK-2 覆盖用例）
• RPM 打包后 /usr/local/dms/plugins 含 sqle-pg-plugin 可执行文件（compat-RISK-4 覆盖用例）

---

Description

• 增加 PostgreSQL 白名单支持

• 优化 AuditMiddleware 容错策略

• 更新单元测试验证逻辑

• 同步 Makefile 与 RPM 部署文件

---

Diagram Walkthrough

flowchart LR
  A["添加 PostgreSQL 支持"] --> B["调整 AuditMiddleware 错误处理"]
  B --> C["更新单元测试用例"]
  C --> D["同步 Makefile 与 RPM spec"]

Loading

File Walkthrough

	Relevant files
Enhancement	sql_workbench_service.go 调整数据库类型支持与审核中间件                                                                                    internal/sql_workbench/service/sql_workbench_service.go 增加 PostgreSQL 白名单判断 添加审计中间件详细注释 调整错误处理由阻塞改为跳过审计 使用 warn 记录非关键错误 +39/-14  Makefile 添加 PG 插件构建与复制步骤                                                                                    Makefile 新增 builddir/plugins 目录创建 增加拷贝 sqle-pg-plugin 逻辑 同步构建流程文件复制 +4/-0      dms_sqle_provision.spec 同步 RPM 文件复制逻辑                                                                                        build/dms_sqle_provision.spec 添加复制 sqle-pg-plugin 至 RPM 确保部署插件覆盖要求 +2/-0
Tests	sql_workbench_service_test.go 更新数据库支持测试用例                                                                                            internal/sql_workbench/service/sql_workbench_service_test.go 调整测试用例支持 PostgreSQL 扩充测试验证白名单逻辑 +14/-10

---

[github-actions]

PR Reviewer Guide 🔍

⏱️ Estimated effort to review: 3 🔵🔵🔵⚪⚪

🧪 PR contains tests

🔒 No security concerns identified

⚡ Recommended focus areas for review 日志不一致 在 AuditMiddleware 中，对于错误处理的日志记录级别不够统一。例如，读取请求体失败时使用了 error 级别日志，而获取用户 ID、缓存数据或 DBService 信息失败时则使用 warn 级别。建议统一日志级别，以便于后续问题排查和监控。 // body 读不出来无法叠加审核，但也无法继续构造反代请求；保留 fail-closed。 sqlWorkbenchService.log.Errorf("failed to read streamExecute request body: %v", err) return errors.New(locale.Bundle.LocalizeMsgByCtx(c.Request().Context(), locale.SqlWorkbenchAuditReadReqBodyErr)) } // 恢复请求体，供后续处理使用 c.Request().Body = io.NopCloser(bytes.NewBuffer(bodyBytes)) // 解析请求体获取 SQL 和 datasource ID // 注意：解析仅服务于审核辅助路径，解析失败不应直接阻塞用户的 SQL 执行； // 否则一旦中间件辅助能力出错（如 sid 解码失败），用户连查询都跑不了。 sql, sidInfo, err := sqlWorkbenchService.parseStreamExecuteRequest(bodyBytes) if err != nil { sqlWorkbenchService.log.Warnf("failed to parse streamExecute request, skipping audit: %v", err) return next(c) } if sql == "" || sidInfo == nil || sidInfo.datasourceID == "" { sqlWorkbenchService.log.Warnf("SQL or datasource ID is empty, skipping audit") return next(c) } datasourceID := sidInfo.datasourceID // 获取当前用户 ID dmsUserId, err := sqlWorkbenchService.getDMSUserIdFromRequest(c) if err != nil { // 审计需要用户上下文，缺失时跳过审计而非阻塞执行（鉴权由前置 Login() 已经把关）。 sqlWorkbenchService.log.Warnf("failed to get DMS user ID, skipping audit: %v", err) return next(c) }

[github-actions]

PR Code Suggestions ✨

Explore these optional code suggestions:

Category	Suggestion	Impact
Possible issue	改为fail-open处理 建议对读取请求体失败的情况采用fail-open策略，而不是阻断SQL执行。这样可以确保在不可预知的读取错误时，仍能继续执行SQL，避免整体服务中断。 internal/sql_workbench/service/sql_workbench_service.go [1073-1077] bodyBytes, err := io.ReadAll(c.Request().Body) if err != nil { - sqlWorkbenchService.log.Errorf("failed to read streamExecute request body: %v", err) - return errors.New(locale.Bundle.LocalizeMsgByCtx(c.Request().Context(), locale.SqlWorkbenchAuditReadReqBodyErr)) + sqlWorkbenchService.log.Warnf("failed to read streamExecute request body, skipping audit: %v", err) + return next(c) } Suggestion importance[1-10]: 8 __ Why: The suggestion correctly recommends switching from a fail-closed to a fail-open strategy by logging a warning and calling next(c), which increases service resilience. This error-handling improvement is contextually relevant and aligns with similar adjustments elsewhere in the code.	Medium