GithubBackup/MyGoNavi
1
0
Fork 0
mirror of https://github.com/Syngnat/GoNavi.git synced 2026-08-18 12:54:08 +08:00
Code Issues Packages Projects Releases Wiki Activity
Files
545ff37f6c1f1a9f44acce3d81d7d54550141404
MyGoNavi/internal/db
History
Syngnat 545ff37f6c 🐛 fix(rabbitmq): 避免字段元数据读取队列消息 (#889) 
## 背景与问题

RabbitMQ 的 GetColumns 为推断 Payload 动态字段，会调用队列 /get 接口并使用
ck_requeue_true。该操作会实际读取并重新投递消息，使本应只读的字段元数据读取产生 Broker 副作用。

Closes #881

## 变更点

- GetColumns 仅返回 RabbitMQ 静态消息字段，不再读取队列样本消息。
- 保留 SELECT 查询的消息预览逻辑。
- 增加回归断言，确保普通字段元数据读取不会请求 /api/queues/{vhost}/{queue}/get。

## 影响范围

- 字段元数据和全库字段搜索不再触碰真实队列消息。
- payload.*、headers.*、properties.* 等样本推断字段不再自动出现在元数据中；项目当前没有显式样本读取入口。

## 验证方式

`	ext
go test ./internal/db -run RabbitMQ -count=1
` 

## 风险与回滚

不涉及数据迁移或构建链路。若需要恢复隐式动态字段推断，可回滚本 PR。
2026-08-09 15:56:54 +08:00
..
agent_process_stub.go
…
agent_process_test.go
…
agent_process_windows.go
…
agent_process.go
…
batch_insert_test.go
🐛 fix(sync/mysql): 修复批量导入占位符超限
2026-07-30 17:41:01 +08:00
batch_insert.go
🐛 fix(sync/mysql): 修复批量导入占位符超限
2026-07-30 17:41:01 +08:00
batch_write_interface_gaussdb_test.go
…
batch_write_interface_highgo_test.go
…
batch_write_interface_kingbase_test.go
…
batch_write_interface_sqlserver_test.go
…
batch_write_interface_test.go
…
batch_write_interface_vastbase_test.go
…
change_preview_test.go
…
change_preview.go
…
chroma_impl_test.go
…
chroma_impl.go
🐛 fix(query): 放开所有数据源默认查询超时
2026-08-06 16:50:28 +08:00
clickhouse_impl_test.go
🔥 remove(go-test): 删除后端读取源码文本断言的测试函数
2026-07-26 21:37:22 +08:00
clickhouse_impl.go
🐛 fix(query): 放开所有数据源默认查询超时
2026-08-06 16:50:28 +08:00
clickhouse_legacy_http_test.go
…
clickhouse_legacy_http.go
…
connection_param_allowlists.go
…
connection_params_test.go
…
connection_params.go
…
custom_impl_test.go
🔥 remove(go-test): 删除后端读取源码文本断言的测试函数
2026-07-26 21:37:22 +08:00
custom_impl.go
…
dameng_columns_runtime_test.go
🐛 fix(dameng): 修复表设计字段注释加载失败
2026-07-30 20:44:12 +08:00
dameng_columns_test.go
…
dameng_i18n_test.go
🔥 remove(go-test): 删除后端读取源码文本断言的测试函数
2026-07-26 21:37:22 +08:00
dameng_impl.go
✨ feat(data-import): 重构大文件导入与安全任务运行时
2026-08-08 20:51:23 +08:00
dameng_metadata_test.go
🐛 fix(dameng): 修复表设计字段注释加载失败
2026-07-30 20:44:12 +08:00
dameng_metadata.go
🐛 fix(dameng): 修复表设计字段注释加载失败
2026-07-30 20:44:12 +08:00
dameng_transaction_test.go
✨ feat(data-import): 重构大文件导入与安全任务运行时
2026-08-08 20:51:23 +08:00
database_i18n_test.go
🔥 remove(go-test): 删除后端读取源码文本断言的测试函数
2026-07-26 21:37:22 +08:00
database_optional_factories_full.go
…
database_optional_factories_lite.go
…
database_session_test.go
…
database.go
✨ feat(data-import): 重构大文件导入与安全任务运行时
2026-08-08 20:51:23 +08:00
diros_impl.go
…
driver_agent_binary_check_test.go
…
driver_agent_binary_check.go
…
driver_agent_revisions_gen.go
🐛 fix(query-editor): 修复 Cmd 点击失效表链接异常
2026-08-03 14:57:06 +08:00
driver_agent_stderr_tail.go
…
driver_agent_stderr_test.go
…
driver_i18n.go
…
driver_support_test.go
🔥 remove(go-test): 删除后端读取源码文本断言的测试函数
2026-07-26 21:37:22 +08:00
driver_support.go
…
dsn_test.go
🐛 fix(query): 放开所有数据源默认查询超时
2026-08-06 16:50:28 +08:00
duckdb_applychanges_test.go
…
duckdb_driver_import.go
…
duckdb_i18n_test.go
…
duckdb_impl.go
…
duckdb_metadata_integration_test.go
…
duckdb_metadata_test.go
…
duckdb_metadata.go
…
duckdb_platform_supported.go
…
duckdb_platform_unsupported.go
…
elasticsearch_console_test.go
✨ feat(elasticsearch): 新增 REST 控制台并完善安全执行链
2026-08-01 14:58:12 +08:00
elasticsearch_helpers.go
🐛 fix(query): 放开所有数据源默认查询超时
2026-08-06 16:50:28 +08:00
elasticsearch_i18n_test.go
🔥 remove(go-test): 删除后端读取源码文本断言的测试函数
2026-07-26 21:37:22 +08:00
elasticsearch_impl_test.go
🐛 fix(query): 放开所有数据源默认查询超时
2026-08-06 16:50:28 +08:00
elasticsearch_impl.go
🐛 fix(query-editor): 修复 Cmd 点击失效表链接异常
2026-08-03 14:57:06 +08:00
gaussdb_impl.go
🐛 fix(ssh): 为共享端口转发增加引用计数与失败回滚
2026-07-27 00:07:42 +08:00
highgo_i18n_test.go
🔥 remove(go-test): 删除后端读取源码文本断言的测试函数
2026-07-26 21:37:22 +08:00
highgo_impl.go
🐛 fix(ssh): 为共享端口转发增加引用计数与失败回滚
2026-07-27 00:07:42 +08:00
iotdb_impl_test.go
🐛 fix(query): 放开所有数据源默认查询超时
2026-08-06 16:50:28 +08:00
iotdb_impl.go
🐛 fix(query): 放开所有数据源默认查询超时
2026-08-06 16:50:28 +08:00
iris_i18n_test.go
🔥 remove(go-test): 删除后端读取源码文本断言的测试函数
2026-07-26 21:37:22 +08:00
iris_impl_test.go
…
iris_impl.go
🐛 fix(ssh): 为共享端口转发增加引用计数与失败回滚
2026-07-27 00:07:42 +08:00
json_decode_test.go
…
json_decode.go
…
kafka_impl_test.go
🐛 fix(query): 放开所有数据源默认查询超时
2026-08-06 16:50:28 +08:00
kafka_impl.go
🐛 fix(query): 放开所有数据源默认查询超时
2026-08-06 16:50:28 +08:00
kingbase_i18n_test.go
🔥 remove(go-test): 删除后端读取源码文本断言的测试函数
2026-07-26 21:37:22 +08:00
kingbase_identifier_utils_test.go
…
kingbase_identifier_utils.go
…
kingbase_impl_test.go
🐛 fix(kingbase): 修复开表与 ER 图加载缓慢问题
2026-07-27 20:39:08 +08:00
kingbase_impl.go
🐛 fix(kingbase): 修复开表与 ER 图加载缓慢问题
2026-07-27 20:39:08 +08:00
mariadb_batch_capability_test.go
✨ feat(data-import): 重构大文件导入与安全任务运行时
2026-08-08 20:51:23 +08:00
mariadb_i18n_test.go
🔥 remove(go-test): 删除后端读取源码文本断言的测试函数
2026-07-26 21:37:22 +08:00
mariadb_impl.go
✨ feat(data-import): 重构大文件导入与安全任务运行时
2026-08-08 20:51:23 +08:00
mariadb_write_outcome_test.go
✨ feat(data-import): 重构大文件导入与安全任务运行时
2026-08-08 20:51:23 +08:00
memory_limit_autoscale_test.go
…
memory_limit_autoscale.go
…
metadata_value.go
…
milvus_impl_test.go
…
milvus_impl.go
🐛 fix(query): 放开所有数据源默认查询超时
2026-08-06 16:50:28 +08:00
mongodb_impl_uri_test.go
🐛 fix(mongodb): 支持 SRV 连接使用 SSH 隧道 (#887)
2026-08-09 13:23:27 +08:00
mongodb_impl_v1_uri_test.go
🐛 fix(mongodb): 支持 SRV 连接使用 SSH 隧道 (#887)
2026-08-09 13:23:27 +08:00
mongodb_impl_v1.go
🐛 fix(mongodb): 支持 SRV 连接使用 SSH 隧道 (#887)
2026-08-09 13:23:27 +08:00
mongodb_impl.go
🐛 fix(mongodb): 支持 SRV 连接使用 SSH 隧道 (#887)
2026-08-09 13:23:27 +08:00
mqtt_close_race_test.go
🐛 fix(mqtt): 修复关闭连接与在途消息拉取竞争导致的进程崩溃
2026-07-26 20:08:07 +08:00
mqtt_i18n_test.go
🔥 remove(go-test): 删除后端读取源码文本断言的测试函数
2026-07-26 21:37:22 +08:00
mqtt_impl_test.go
🐛 fix(mqtt): 修复 Broker 地址端口重复追加
2026-08-06 18:20:23 +08:00
mqtt_impl.go
🐛 fix(mqtt): 修复 Broker 地址端口重复追加
2026-08-06 18:20:23 +08:00
mysql_agent_impl.go
…
mysql_agent_path.go
…
mysql_connection_params_test.go
✨ feat(data-import): 重构大文件导入与安全任务运行时
2026-08-08 20:51:23 +08:00
mysql_i18n_test.go
🔥 remove(go-test): 删除后端读取源码文本断言的测试函数
2026-07-26 21:37:22 +08:00
mysql_impl.go
✨ feat(data-import): 重构大文件导入与安全任务运行时
2026-08-08 20:51:23 +08:00
mysql_metadata_test.go
…
mysql_ssh_test.go
…
mysql_value_test.go
…
notice_query.go
…
oceanbase_impl_test.go
✨ feat(data-import): 重构大文件导入与安全任务运行时
2026-08-08 20:51:23 +08:00
oceanbase_impl.go
✨ feat(data-import): 重构大文件导入与安全任务运行时
2026-08-08 20:51:23 +08:00
oceanbase_oracle_live_test.go
…
opengauss_impl.go
…
optional_driver_agent_impl_test.go
🐛 fix(query-editor): 修复 Cmd 点击失效表链接异常
2026-08-03 14:57:06 +08:00
optional_driver_agent_impl.go
✨ feat(data-import): 重构大文件导入与安全任务运行时
2026-08-08 20:51:23 +08:00
optional_driver_build_full.go
…
optional_driver_build_lite.go
…
oracle_applychanges_test.go
✨ feat(data-import): 重构大文件导入与安全任务运行时
2026-08-08 20:51:23 +08:00
oracle_dsn_test.go
✨ feat(oracle): 支持 SID 连接模式
2026-07-31 22:02:11 +08:00
oracle_get_tables_test.go
🐛 fix(oracle): 修复视图 DDL 截断与 ROWID 注入问题
2026-07-30 23:20:03 +08:00
oracle_i18n_test.go
🔥 remove(go-test): 删除后端读取源码文本断言的测试函数
2026-07-26 21:37:22 +08:00
oracle_impl.go
✨ feat(data-import): 重构大文件导入与安全任务运行时
2026-08-08 20:51:23 +08:00
oracle_triggers_test.go
🐛 fix(oracle): 修复触发器编辑误启用问题
2026-08-04 11:04:10 +08:00
pg_metadata_test.go
…
pg_metadata.go
…
postgres_applychanges_context_test.go
✨ feat(data-import): 重构大文件导入与安全任务运行时
2026-08-08 20:51:23 +08:00
postgres_connect_test.go
🐛 fix(query-editor): 支持 PostgreSQL 查询选择 Schema
2026-08-07 23:25:25 +08:00
postgres_i18n_test.go
🔥 remove(go-test): 删除后端读取源码文本断言的测试函数
2026-07-26 21:37:22 +08:00
postgres_impl.go
✨ feat(data-import): 重构大文件导入与安全任务运行时
2026-08-08 20:51:23 +08:00
qdrant_impl_test.go
…
qdrant_impl.go
🐛 fix(query): 放开所有数据源默认查询超时
2026-08-06 16:50:28 +08:00
query_value_stringer_test.go
🐛 fix(db): 修复大整数与 IP 列显示丢值、会话路径方言退化、MariaDB 漏影响行数校验
2026-07-26 20:52:58 +08:00
query_value_test.go
…
query_value.go
🐛 fix(db): 修复大整数与 IP 列显示丢值、会话路径方言退化、MariaDB 漏影响行数校验
2026-07-26 20:52:58 +08:00
rabbitmq_impl_test.go
🐛 fix(rabbitmq): 避免字段元数据读取队列消息
2026-08-09 12:54:51 +08:00
rabbitmq_impl.go
🐛 fix(rabbitmq): 避免字段元数据读取队列消息
2026-08-09 12:54:51 +08:00
rocketmq_impl_test.go
🐛 fix(rocketmq): 支持经隧道访问隔离网络 (#886)
2026-08-09 14:22:41 +08:00
rocketmq_impl.go
🐛 fix(rocketmq): 支持经隧道访问隔离网络 (#886)
2026-08-09 14:22:41 +08:00
rocketmq_tunnel_test.go
🐛 fix(rocketmq): 支持经隧道访问隔离网络 (#886)
2026-08-09 14:22:41 +08:00
rocketmq_tunnel.go
🐛 fix(rocketmq): 支持经隧道访问隔离网络 (#886)
2026-08-09 14:22:41 +08:00
scan_rows_test.go
🐛 fix(oracle): 修复大对象查询导致客户端崩溃
2026-07-28 15:28:23 +08:00
scan_rows.go
🐛 fix(oracle): 修复视图 DDL 截断与 ROWID 注入问题
2026-07-30 23:20:03 +08:00
shardingsphere_tables_test.go
🐛 fix(vastbase): 修复含点表名误识别为模式 (#757)
2026-07-30 15:59:28 +08:00
shardingsphere_tables.go
…
sphinx_impl.go
…
sql_pool_test.go
⚡️ perf(kingbase): 优化数据表首屏加载性能
2026-07-30 11:26:50 +08:00
sql_pool.go
⚡️ perf(kingbase): 优化数据表首屏加载性能
2026-07-30 11:26:50 +08:00
sqlite_i18n_test.go
🔥 remove(go-test): 删除后端读取源码文本断言的测试函数
2026-07-26 21:37:22 +08:00
sqlite_impl_test.go
…
sqlite_impl.go
✨ feat(data-import): 重构大文件导入与安全任务运行时
2026-08-08 20:51:23 +08:00
sqlserver_impl_test.go
✨ feat(data-import): 重构大文件导入与安全任务运行时
2026-08-08 20:51:23 +08:00
sqlserver_impl.go
✨ feat(data-import): 重构大文件导入与安全任务运行时
2026-08-08 20:51:23 +08:00
ssl_mode.go
…
starrocks_impl.go
…
starrocks_metadata_test.go
…
tdengine_applychanges_test.go
🔥 remove(go-test): 删除后端读取源码文本断言的测试函数
2026-07-26 21:37:22 +08:00
tdengine_dsn_test.go
🐛 fix(tdengine): 编码 DSN 用户名与密码
2026-07-26 23:33:48 +08:00
tdengine_i18n_test.go
🔥 remove(go-test): 删除后端读取源码文本断言的测试函数
2026-07-26 21:37:22 +08:00
tdengine_impl.go
🐛 fix(ssh): 为共享端口转发增加引用计数与失败回滚
2026-07-27 00:07:42 +08:00
timeout_policy_test.go
🐛 fix(query): 放开所有数据源默认查询超时
2026-08-06 16:50:28 +08:00
timeout.go
…
timezone_data.go
…
trino_impl_test.go
🐛 fix(query): 放开所有数据源默认查询超时
2026-08-06 16:50:28 +08:00
trino_impl.go
🐛 fix(query): 放开所有数据源默认查询超时
2026-08-06 16:50:28 +08:00
vastbase_i18n_test.go
🔥 remove(go-test): 删除后端读取源码文本断言的测试函数
2026-07-26 21:37:22 +08:00
vastbase_impl.go
🐛 fix(vastbase): 修复含点表名误识别为模式 (#757)
2026-07-30 15:59:28 +08:00
write_outcome_transaction_test.go
✨ feat(data-import): 重构大文件导入与安全任务运行时
2026-08-08 20:51:23 +08:00
write_outcome.go
✨ feat(data-import): 重构大文件导入与安全任务运行时
2026-08-08 20:51:23 +08:00