diff --git a/dbpool.go b/dbpool.go index 92f12cf..e792a7a 100644 --- a/dbpool.go +++ b/dbpool.go @@ -252,6 +252,25 @@ func (this *dbPool) joinUpdateFields(fieldsKv [][]string, params *[]string) stri } func (this *dbPool) joinInsertFields(fieldsKv [][]string, params *[]string) string { + sql := " (" + for index, items := range fieldsKv { + suffix := "" + if index + 1 < len(fieldsKv) { + suffix = "," + } + sql += "`" + items[0] + "`" + suffix + } + sql += ")" + sql += " VALUES(" + for index, items := range fieldsKv { + suffix := "" + if index + 1 < len(fieldsKv) { + suffix = "," + } + sql += "?" + suffix + *params = append(*params, items[1]) + } + sql += ")" return "" }