update.go 3.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108
  1. package gen
  2. import (
  3. "sort"
  4. "strings"
  5. "github.com/zeromicro/go-zero/core/collection"
  6. "github.com/zeromicro/go-zero/tools/goctl/model/sql/template"
  7. "github.com/zeromicro/go-zero/tools/goctl/util"
  8. "github.com/zeromicro/go-zero/tools/goctl/util/pathx"
  9. "github.com/zeromicro/go-zero/tools/goctl/util/stringx"
  10. )
  11. func genUpdate(table Table, withCache, postgreSql bool) (
  12. string, string, error,
  13. ) {
  14. expressionValues := make([]string, 0)
  15. pkg := "data."
  16. if table.ContainsUniqueCacheKey {
  17. pkg = "newData."
  18. }
  19. for _, field := range table.Fields {
  20. camel := util.SafeString(field.Name.ToCamel())
  21. if camel == "CreateTime" || camel == "UpdateTime" || camel == "CreateAt" || camel == "UpdateAt" {
  22. continue
  23. }
  24. if field.Name.Source() == table.PrimaryKey.Name.Source() {
  25. continue
  26. }
  27. expressionValues = append(expressionValues, pkg+camel)
  28. }
  29. keySet := collection.NewSet()
  30. keyVariableSet := collection.NewSet()
  31. keySet.AddStr(table.PrimaryCacheKey.DataKeyExpression)
  32. keyVariableSet.AddStr(table.PrimaryCacheKey.KeyLeft)
  33. for _, key := range table.UniqueCacheKey {
  34. keySet.AddStr(key.DataKeyExpression)
  35. keyVariableSet.AddStr(key.KeyLeft)
  36. }
  37. keys := keySet.KeysStr()
  38. sort.Strings(keys)
  39. keyVars := keyVariableSet.KeysStr()
  40. sort.Strings(keyVars)
  41. if postgreSql {
  42. expressionValues = append(
  43. []string{pkg + table.PrimaryKey.Name.ToCamel()},
  44. expressionValues...,
  45. )
  46. } else {
  47. expressionValues = append(
  48. expressionValues, pkg+table.PrimaryKey.Name.ToCamel(),
  49. )
  50. }
  51. camelTableName := table.Name.ToCamel()
  52. text, err := pathx.LoadTemplate(category, updateTemplateFile, template.Update)
  53. if err != nil {
  54. return "", "", err
  55. }
  56. output, err := util.With("update").Parse(text).Execute(
  57. map[string]interface{}{
  58. "withCache": withCache,
  59. "containsIndexCache": table.ContainsUniqueCacheKey,
  60. "upperStartCamelObject": camelTableName,
  61. "keys": strings.Join(keys, "\n"),
  62. "keyValues": strings.Join(keyVars, ", "),
  63. "primaryCacheKey": table.PrimaryCacheKey.DataKeyExpression,
  64. "primaryKeyVariable": table.PrimaryCacheKey.KeyLeft,
  65. "lowerStartCamelObject": stringx.From(camelTableName).Untitle(),
  66. "upperStartCamelPrimaryKey": util.EscapeGolangKeyword(
  67. stringx.From(table.PrimaryKey.Name.ToCamel()).Title(),
  68. ),
  69. "originalPrimaryKey": wrapWithRawString(
  70. table.PrimaryKey.Name.Source(), postgreSql,
  71. ),
  72. "expressionValues": strings.Join(
  73. expressionValues, ", ",
  74. ),
  75. "postgreSql": postgreSql,
  76. "data": table,
  77. },
  78. )
  79. if err != nil {
  80. return "", "", nil
  81. }
  82. // update interface method
  83. text, err = pathx.LoadTemplate(category, updateMethodTemplateFile, template.UpdateMethod)
  84. if err != nil {
  85. return "", "", err
  86. }
  87. updateMethodOutput, err := util.With("updateMethod").Parse(text).Execute(
  88. map[string]interface{}{
  89. "upperStartCamelObject": camelTableName,
  90. "data": table,
  91. },
  92. )
  93. if err != nil {
  94. return "", "", nil
  95. }
  96. return output.String(), updateMethodOutput.String(), nil
  97. }