1

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 ""
 }