From 851fea0221ff6ab53e3b9ce2d127c2126bd9a6f0 Mon Sep 17 00:00:00 2001 From: River Date: Wed, 29 Sep 2021 14:02:35 +0800 Subject: [PATCH] fix: QuoteTo not fully support raw mode (#4735) * fix: QuoteTo not fully support raw mode * fix: table alias without AS * test: clause.Column/Table quote test * fix: revert table alias quote --- clause/expression_test.go | 28 ++++++++++++++++++++++++++++ statement.go | 30 +++++++++++++++++------------- 2 files changed, 45 insertions(+), 13 deletions(-) diff --git a/clause/expression_test.go b/clause/expression_test.go index eadd96ea..4826db38 100644 --- a/clause/expression_test.go +++ b/clause/expression_test.go @@ -94,6 +94,34 @@ func TestNamedExpr(t *testing.T) { Vars: []interface{}{sql.Named("name", "jinzhu")}, Result: "name1 = ? AND name2 = ?;", ExpectedVars: []interface{}{"jinzhu", "jinzhu"}, + }, { + SQL: "?", + Vars: []interface{}{clause.Column{Table: "table", Name: "col"}}, + Result: "`table`.`col`", + }, { + SQL: "?", + Vars: []interface{}{clause.Column{Table: "table", Name: "col", Raw: true}}, + Result: "table.col", + }, { + SQL: "?", + Vars: []interface{}{clause.Column{Table: "table", Name: clause.PrimaryKey, Raw: true}}, + Result: "table.id", + }, { + SQL: "?", + Vars: []interface{}{clause.Column{Table: "table", Name: "col", Alias: "alias"}}, + Result: "`table`.`col` AS `alias`", + }, { + SQL: "?", + Vars: []interface{}{clause.Column{Table: "table", Name: "col", Alias: "alias", Raw: true}}, + Result: "table.col AS alias", + }, { + SQL: "?", + Vars: []interface{}{clause.Table{Name: "table", Alias: "alias"}}, + Result: "`table` `alias`", + }, { + SQL: "?", + Vars: []interface{}{clause.Table{Name: "table", Alias: "alias", Raw: true}}, + Result: "table alias", }} for idx, result := range results { diff --git a/statement.go b/statement.go index 38363443..347f88ff 100644 --- a/statement.go +++ b/statement.go @@ -75,30 +75,36 @@ func (stmt *Statement) WriteQuoted(value interface{}) { // QuoteTo write quoted value to writer func (stmt *Statement) QuoteTo(writer clause.Writer, field interface{}) { + write := func(raw bool, str string) { + if raw { + writer.WriteString(str) + } else { + stmt.DB.Dialector.QuoteTo(writer, str) + } + } + switch v := field.(type) { case clause.Table: if v.Name == clause.CurrentTable { if stmt.TableExpr != nil { stmt.TableExpr.Build(stmt) } else { - stmt.DB.Dialector.QuoteTo(writer, stmt.Table) + write(v.Raw, stmt.Table) } - } else if v.Raw { - writer.WriteString(v.Name) } else { - stmt.DB.Dialector.QuoteTo(writer, v.Name) + write(v.Raw, v.Name) } if v.Alias != "" { writer.WriteByte(' ') - stmt.DB.Dialector.QuoteTo(writer, v.Alias) + write(v.Raw, v.Alias) } case clause.Column: if v.Table != "" { if v.Table == clause.CurrentTable { - stmt.DB.Dialector.QuoteTo(writer, stmt.Table) + write(v.Raw, stmt.Table) } else { - stmt.DB.Dialector.QuoteTo(writer, v.Table) + write(v.Raw, v.Table) } writer.WriteByte('.') } @@ -107,19 +113,17 @@ func (stmt *Statement) QuoteTo(writer clause.Writer, field interface{}) { if stmt.Schema == nil { stmt.DB.AddError(ErrModelValueRequired) } else if stmt.Schema.PrioritizedPrimaryField != nil { - stmt.DB.Dialector.QuoteTo(writer, stmt.Schema.PrioritizedPrimaryField.DBName) + write(v.Raw, stmt.Schema.PrioritizedPrimaryField.DBName) } else if len(stmt.Schema.DBNames) > 0 { - stmt.DB.Dialector.QuoteTo(writer, stmt.Schema.DBNames[0]) + write(v.Raw, stmt.Schema.DBNames[0]) } - } else if v.Raw { - writer.WriteString(v.Name) } else { - stmt.DB.Dialector.QuoteTo(writer, v.Name) + write(v.Raw, v.Name) } if v.Alias != "" { writer.WriteString(" AS ") - stmt.DB.Dialector.QuoteTo(writer, v.Alias) + write(v.Raw, v.Alias) } case []clause.Column: writer.WriteByte('(')