| 84 | } |
| 85 | |
| 86 | func (s *ChangedSchema) build() *storepb.ChangedResourceSchema { |
| 87 | changedResourceSchema := &storepb.ChangedResourceSchema{} |
| 88 | for _, table := range s.tables { |
| 89 | changedResourceSchema.Tables = append(changedResourceSchema.Tables, table.table) |
| 90 | } |
| 91 | slices.SortFunc(changedResourceSchema.Tables, func(a, b *storepb.ChangedResourceTable) int { |
| 92 | if a.GetName() < b.GetName() { |
| 93 | return -1 |
| 94 | } else if a.GetName() > b.GetName() { |
| 95 | return 1 |
| 96 | } |
| 97 | return 0 |
| 98 | }) |
| 99 | |
| 100 | return changedResourceSchema |
| 101 | } |
| 102 | |
| 103 | func (r *ChangedResources) AddTable(database string, schema string, change *storepb.ChangedResourceTable, affectedTable bool) { |
| 104 | if _, ok := r.databases[database]; !ok { |