index.go 2.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100
  1. package schema
  2. import (
  3. "strconv"
  4. "strings"
  5. )
  6. type Index struct {
  7. Name string
  8. Class string // UNIQUE | FULLTEXT | SPATIAL
  9. Type string // btree, hash, gist, spgist, gin, and brin
  10. Where string
  11. Comment string
  12. Fields []IndexOption
  13. }
  14. type IndexOption struct {
  15. *Field
  16. Expression string
  17. Sort string // DESC, ASC
  18. Collate string
  19. Length int
  20. }
  21. // ParseIndexes parse schema indexes
  22. func (schema *Schema) ParseIndexes() map[string]Index {
  23. var indexes = map[string]Index{}
  24. for _, field := range schema.FieldsByDBName {
  25. if field.TagSettings["INDEX"] != "" || field.TagSettings["UNIQUE_INDEX"] != "" {
  26. for _, index := range parseFieldIndexes(field) {
  27. idx := indexes[index.Name]
  28. idx.Name = index.Name
  29. if idx.Class == "" {
  30. idx.Class = index.Class
  31. }
  32. if idx.Type == "" {
  33. idx.Type = index.Type
  34. }
  35. if idx.Where == "" {
  36. idx.Where = index.Where
  37. }
  38. if idx.Comment == "" {
  39. idx.Comment = index.Comment
  40. }
  41. idx.Fields = append(idx.Fields, index.Fields...)
  42. indexes[index.Name] = idx
  43. }
  44. }
  45. }
  46. return indexes
  47. }
  48. func parseFieldIndexes(field *Field) (indexes []Index) {
  49. for _, value := range strings.Split(field.Tag.Get("gorm"), ";") {
  50. if value != "" {
  51. v := strings.Split(value, ":")
  52. k := strings.TrimSpace(strings.ToUpper(v[0]))
  53. if k == "INDEX" || k == "UNIQUE_INDEX" {
  54. var (
  55. name string
  56. tag = strings.Join(v[1:], ":")
  57. idx = strings.Index(tag, ",")
  58. settings = ParseTagSetting(tag, ",")
  59. length, _ = strconv.Atoi(settings["LENGTH"])
  60. )
  61. if idx != -1 {
  62. name = tag[0:idx]
  63. }
  64. if name == "" {
  65. name = field.Schema.namer.IndexName(field.Schema.Table, field.Name)
  66. }
  67. if (k == "UNIQUE_INDEX") || settings["UNIQUE"] != "" {
  68. settings["CLASS"] = "UNIQUE"
  69. }
  70. indexes = append(indexes, Index{
  71. Name: name,
  72. Class: settings["CLASS"],
  73. Type: settings["TYPE"],
  74. Where: settings["WHERE"],
  75. Comment: settings["COMMENT"],
  76. Fields: []IndexOption{{
  77. Field: field,
  78. Expression: settings["EXPRESSION"],
  79. Sort: settings["SORT"],
  80. Collate: settings["COLLATE"],
  81. Length: length,
  82. }},
  83. })
  84. }
  85. }
  86. }
  87. return
  88. }