update.go 2.9 KB

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