Function writeCreateTables

backend/plugin/schema/pg/metadata_migration.go:679–704

(out *strings.Builder, diff *schema.MetadataDiff)

}

func writeCreateTables(out *strings.Builder, diff *schema.MetadataDiff) error {
	maps := buildCreateObjectMaps(diff)
	graph := base.NewGraph()
	for _, id := range sortedMapKeys(maps.tables) {
		graph.AddNode(id)
	}
	for tableID, tableDiff := range maps.tables {
		for _, fk := range tableDiff.NewTable.GetForeignKeys() {
			depID := getMigrationObjectID(fk.GetReferencedSchema(), fk.GetReferencedTable())
			if _, ok := maps.tables[depID]; ok {
				graph.AddEdge(depID, tableID)
			}
		}
	}

	orderedIDs, err := graph.TopologicalSort()
	if err != nil {
		orderedIDs = sortedMapKeys(maps.tables)
	}
	for _, id := range orderedIDs {
		if err := writeTableDiff(out, maps.tables[id]); err != nil {
			return err
		}
	}
	return nil
}

func writeAlterTables(out *strings.Builder, diff *schema.MetadataDiff) error {
	for _, tableDiff := range diff.TableChanges {