Function writeCreateOrAlterPhase

backend/plugin/schema/pg/metadata_migration.go:271–330

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

}

func writeCreateOrAlterPhase(out *strings.Builder, diff *schema.MetadataDiff) error {
	for _, schemaDiff := range diff.SchemaChanges {
		if schemaDiff.Action == schema.MetadataDiffActionCreate {
			if err := writeSchemaDiff(out, schemaDiff); err != nil {
				return err
			}
		}
	}
	for _, extensionDiff := range diff.ExtensionChanges {
		if extensionDiff.Action == schema.MetadataDiffActionCreate {
			if err := writeExtensionDiff(out, extensionDiff); err != nil {
				return err
			}
		}
	}
	for _, enumDiff := range diff.EnumTypeChanges {
		if enumDiff.Action == schema.MetadataDiffActionCreate || enumDiff.Action == schema.MetadataDiffActionAlter {
			if err := writeEnumTypeDiff(out, enumDiff); err != nil {
				return err
			}
		}
	}
	for _, sequenceDiff := range diff.SequenceChanges {
		if sequenceDiff.Action == schema.MetadataDiffActionCreate || sequenceDiff.Action == schema.MetadataDiffActionAlter {
			if err := writeSequenceDiff(out, sequenceDiff); err != nil {
				return err
			}
		}
	}

	if err := writeCreateTables(out, diff); err != nil {
		return err
	}
	if err := writeAlterTables(out, diff); err != nil {
		return err
	}
	if err := writeSequenceOwnershipAfterTables(out, diff); err != nil {
		return err
	}
	if err := writeCreateRoutinesViewsAndMaterializedViews(out, diff); err != nil {
		return err
	}
	if err := writeCreateTableForeignKeys(out, diff); err != nil {
		return err
	}
	if err := writeCreateTableTriggers(out, diff); err != nil {
		return err
	}
	if err := writeCommentChanges(out, diff); err != nil {
		return err
	}
	for _, eventTriggerDiff := range diff.EventTriggerChanges {
		if eventTriggerDiff.Action == schema.MetadataDiffActionCreate || eventTriggerDiff.Action == schema.MetadataDiffActionAlter {
			if err := writeEventTriggerDiff(out, eventTriggerDiff); err != nil {
				return err
			}
		}
	}