From 45286613d31831c6b1360900fc96e7c1025bac9d Mon Sep 17 00:00:00 2001 From: qevolg <2227465945@qq.com> Date: Tue, 11 Feb 2025 15:04:35 +0800 Subject: [PATCH] fix(keeper): fix sql for log.logs stable --- tools/keeper/process/handle.go | 4 +++- tools/keeper/process/handle_test.go | 6 ++++++ 2 files changed, 9 insertions(+), 1 deletion(-) diff --git a/tools/keeper/process/handle.go b/tools/keeper/process/handle.go index 980902daca..ea02dd91f3 100644 --- a/tools/keeper/process/handle.go +++ b/tools/keeper/process/handle.go @@ -411,9 +411,11 @@ func (p *Processor) Prepare() { func (p *Processor) withDBName(tableName string) string { b := pool.BytesPoolGet() + b.WriteByte('`') b.WriteString(p.db) - b.WriteByte('.') + b.WriteString("`.`") b.WriteString(tableName) + b.WriteByte('`') return b.String() } diff --git a/tools/keeper/process/handle_test.go b/tools/keeper/process/handle_test.go index bfd5c369b4..55f469eabb 100644 --- a/tools/keeper/process/handle_test.go +++ b/tools/keeper/process/handle_test.go @@ -119,3 +119,9 @@ func Test_getStatusStr(t *testing.T) { assert.Equal(t, tt.expected, res) } } + +func Test_withDBName(t *testing.T) { + processor := &Processor{db: "db"} + res := processor.withDBName("test") + assert.Equal(t, res, "`db`.`test`") +}