mirror of
https://github.com/Syngnat/GoNavi.git
synced 2026-05-11 19:19:52 +08:00
- 金仓外置驱动链路增加表名与变更字段归一化,修复 ApplyChanges 场景下双引号转义异常导致的 SQL 语法错误 - 新增金仓公共标识符工具并复用到 kingbase_impl 与 optional_driver_agent_impl,统一处理多重转义、schema.table 拆分与引用规范 - 金仓代理连接后自动探测并设置 search_path,降低查询时必须手写 schema 前缀的概率 - MongoDB 连接参数改为显式 host/hosts 优先,避免被 URI 中 localhost 覆盖;代理链路保留目标地址不再改写为本地地址 - 连接测试增加前后端超时收敛与日志增强,避免长时间转圈;连接错误文案在未启用 TLS 时移除误导性的“SSL”前缀 - 统一日志级别为 INFO/WARN/ERROR,默认日志目录收敛到 ~/.GoNavi/Logs,并补充驱动构建脚本 build-driver-agents.sh
118 lines
4.2 KiB
Go
118 lines
4.2 KiB
Go
//go:build gonavi_full_drivers || gonavi_kingbase_driver
|
|
|
|
package db
|
|
|
|
import "testing"
|
|
|
|
func TestNormalizeKingbaseIdentifier(t *testing.T) {
|
|
tests := []struct {
|
|
name string
|
|
in string
|
|
want string
|
|
}{
|
|
{name: "plain", in: "ldf_server", want: "ldf_server"},
|
|
{name: "quoted", in: `"ldf_server"`, want: "ldf_server"},
|
|
{name: "double quoted", in: `""ldf_server""`, want: "ldf_server"},
|
|
{name: "quad quoted", in: `""""ldf_server""""`, want: "ldf_server"},
|
|
{name: "escaped quoted", in: `\"ldf_server\"`, want: "ldf_server"},
|
|
{name: "double escaped quoted", in: `\\\"ldf_server\\\"`, want: "ldf_server"},
|
|
{name: "backtick quoted", in: "`ldf_server`", want: "ldf_server"},
|
|
{name: "bracket quoted", in: "[ldf_server]", want: "ldf_server"},
|
|
{name: "embedded double quotes", in: `ldf""server`, want: "ldfserver"},
|
|
}
|
|
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
if got := normalizeKingbaseIdentifier(tt.in); got != tt.want {
|
|
t.Fatalf("normalizeKingbaseIdentifier(%q) = %q, want %q", tt.in, got, tt.want)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestQuoteKingbaseIdent(t *testing.T) {
|
|
tests := []struct {
|
|
name string
|
|
in string
|
|
want string
|
|
}{
|
|
// 纯小写+下划线:不加引号
|
|
{name: "plain lowercase", in: "ldf_server", want: "ldf_server"},
|
|
{name: "plain lowercase 2", in: "bcs_barcode", want: "bcs_barcode"},
|
|
{name: "double quoted input", in: `""ldf_server""`, want: "ldf_server"},
|
|
{name: "escaped quoted input", in: `\"ldf_server\"`, want: "ldf_server"},
|
|
// 含大写字母:加引号
|
|
{name: "uppercase", in: "LDF_Server", want: `"LDF_Server"`},
|
|
{name: "mixed case", in: "myTable", want: `"myTable"`},
|
|
// SQL 保留字:加引号
|
|
{name: "reserved word order", in: "order", want: `"order"`},
|
|
{name: "reserved word user", in: "user", want: `"user"`},
|
|
{name: "reserved word table", in: "table", want: `"table"`},
|
|
{name: "reserved word select", in: "select", want: `"select"`},
|
|
// 含特殊字符:加引号
|
|
{name: "with hyphen", in: "my-table", want: `"my-table"`},
|
|
{name: "with space", in: "my table", want: `"my table"`},
|
|
{name: "with embedded quote", in: `ab"cd`, want: `"ab""cd"`},
|
|
// 空值
|
|
{name: "empty", in: "", want: `""`},
|
|
}
|
|
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
if got := quoteKingbaseIdent(tt.in); got != tt.want {
|
|
t.Fatalf("quoteKingbaseIdent(%q) = %q, want %q", tt.in, got, tt.want)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestKingbaseIdentNeedsQuote(t *testing.T) {
|
|
tests := []struct {
|
|
name string
|
|
in string
|
|
want bool
|
|
}{
|
|
{name: "plain lowercase", in: "ldf_server", want: false},
|
|
{name: "starts with underscore", in: "_col", want: false},
|
|
{name: "with digits", in: "col123", want: false},
|
|
{name: "uppercase", in: "MyTable", want: true},
|
|
{name: "reserved word", in: "order", want: true},
|
|
{name: "with hyphen", in: "my-col", want: true},
|
|
{name: "starts with digit", in: "123col", want: true},
|
|
{name: "empty", in: "", want: false},
|
|
}
|
|
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
if got := kingbaseIdentNeedsQuote(tt.in); got != tt.want {
|
|
t.Fatalf("kingbaseIdentNeedsQuote(%q) = %v, want %v", tt.in, got, tt.want)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestSplitKingbaseQualifiedTable(t *testing.T) {
|
|
tests := []struct {
|
|
name string
|
|
in string
|
|
wantSchema string
|
|
wantTable string
|
|
}{
|
|
{name: "plain qualified", in: "ldf_server.t_user", wantSchema: "ldf_server", wantTable: "t_user"},
|
|
{name: "double quoted qualified", in: `""ldf_server"".""t_user""`, wantSchema: "ldf_server", wantTable: "t_user"},
|
|
{name: "escaped qualified", in: `\"ldf_server\".\"t_user\"`, wantSchema: "ldf_server", wantTable: "t_user"},
|
|
{name: "double escaped qualified", in: `\\\"ldf_server\\\".\\\"t_user\\\"`, wantSchema: "ldf_server", wantTable: "t_user"},
|
|
{name: "bracket qualified", in: "[ldf_server].[t_user]", wantSchema: "ldf_server", wantTable: "t_user"},
|
|
{name: "table only", in: `""t_user""`, wantSchema: "", wantTable: "t_user"},
|
|
}
|
|
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
gotSchema, gotTable := splitKingbaseQualifiedTable(tt.in)
|
|
if gotSchema != tt.wantSchema || gotTable != tt.wantTable {
|
|
t.Fatalf("splitKingbaseQualifiedTable(%q) = (%q, %q), want (%q, %q)", tt.in, gotSchema, gotTable, tt.wantSchema, tt.wantTable)
|
|
}
|
|
})
|
|
}
|
|
}
|