insert.go 2.4 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586
  1. package gen
  2. import (
  3. "fmt"
  4. "strings"
  5. "github.com/tal-tech/go-zero/core/collection"
  6. "github.com/tal-tech/go-zero/tools/goctl/model/sql/template"
  7. "github.com/tal-tech/go-zero/tools/goctl/util"
  8. "github.com/tal-tech/go-zero/tools/goctl/util/pathx"
  9. "github.com/tal-tech/go-zero/tools/goctl/util/stringx"
  10. )
  11. func genInsert(table Table, withCache, postgreSql bool) (string, string, error) {
  12. keySet := collection.NewSet()
  13. keyVariableSet := collection.NewSet()
  14. keySet.AddStr(table.PrimaryCacheKey.DataKeyExpression)
  15. keyVariableSet.AddStr(table.PrimaryCacheKey.KeyLeft)
  16. for _, key := range table.UniqueCacheKey {
  17. keySet.AddStr(key.DataKeyExpression)
  18. keyVariableSet.AddStr(key.KeyLeft)
  19. }
  20. expressions := make([]string, 0)
  21. expressionValues := make([]string, 0)
  22. var count int
  23. for _, field := range table.Fields {
  24. camel := field.Name.ToCamel()
  25. if camel == "CreateTime" || camel == "UpdateTime" {
  26. continue
  27. }
  28. if field.Name.Source() == table.PrimaryKey.Name.Source() {
  29. if table.PrimaryKey.AutoIncrement {
  30. continue
  31. }
  32. }
  33. count += 1
  34. if postgreSql {
  35. expressions = append(expressions, fmt.Sprintf("$%d", count))
  36. } else {
  37. expressions = append(expressions, "?")
  38. }
  39. expressionValues = append(expressionValues, "data."+camel)
  40. }
  41. camel := table.Name.ToCamel()
  42. text, err := pathx.LoadTemplate(category, insertTemplateFile, template.Insert)
  43. if err != nil {
  44. return "", "", err
  45. }
  46. output, err := util.With("insert").
  47. Parse(text).
  48. Execute(map[string]interface{}{
  49. "withCache": withCache,
  50. "containsIndexCache": table.ContainsUniqueCacheKey,
  51. "upperStartCamelObject": camel,
  52. "lowerStartCamelObject": stringx.From(camel).Untitle(),
  53. "expression": strings.Join(expressions, ", "),
  54. "expressionValues": strings.Join(expressionValues, ", "),
  55. "keys": strings.Join(keySet.KeysStr(), "\n"),
  56. "keyValues": strings.Join(keyVariableSet.KeysStr(), ", "),
  57. "data": table,
  58. })
  59. if err != nil {
  60. return "", "", err
  61. }
  62. // interface method
  63. text, err = pathx.LoadTemplate(category, insertTemplateMethodFile, template.InsertMethod)
  64. if err != nil {
  65. return "", "", err
  66. }
  67. insertMethodOutput, err := util.With("insertMethod").Parse(text).Execute(map[string]interface{}{
  68. "upperStartCamelObject": camel,
  69. "data": table,
  70. })
  71. if err != nil {
  72. return "", "", err
  73. }
  74. return output.String(), insertMethodOutput.String(), nil
  75. }