Function compareProcedures

backend/plugin/schema/differ.go:1804–1845

compareProcedures compares procedures between two schemas.

(diff *MetadataDiff, schemaName string, oldSchema, newSchema *model.SchemaMetadata)

// compareProcedures compares procedures between two schemas.
func compareProcedures(diff *MetadataDiff, schemaName string, oldSchema, newSchema *model.SchemaMetadata) {
	// Check for dropped procedures
	for _, procName := range oldSchema.ListProcedureNames() {
		if newSchema.GetProcedure(procName) == nil {
			oldProc := oldSchema.GetProcedure(procName)
			if oldProc != nil && !oldProc.SkipDump {
				diff.ProcedureChanges = append(diff.ProcedureChanges, &ProcedureDiff{
					Action:        MetadataDiffActionDrop,
					SchemaName:    schemaName,
					ProcedureName: procName,
					OldProcedure:  oldProc,
				})
			}
		}
	}

	// Check for new and modified procedures
	for _, procName := range newSchema.ListProcedureNames() {
		newProc := newSchema.GetProcedure(procName)
		if newProc == nil || newProc.SkipDump {
			continue
		}

		oldProc := oldSchema.GetProcedure(procName)
		if oldProc == nil {
			diff.ProcedureChanges = append(diff.ProcedureChanges, &ProcedureDiff{
				Action:        MetadataDiffActionCreate,
				SchemaName:    schemaName,
				ProcedureName: procName,
				NewProcedure:  newProc,
			})
		} else if !oldProc.SkipDump && !procedureDefinitionsEqual(oldProc.Definition, newProc.Definition, procName) {
			diff.ProcedureChanges = append(diff.ProcedureChanges, &ProcedureDiff{
				Action:        MetadataDiffActionAlter,
				SchemaName:    schemaName,
				ProcedureName: procName,
				OldProcedure:  oldProc,
				NewProcedure:  newProc,
			})
		}
	}
}

// compareSequences compares sequences between two schemas.
func compareSequences(diff *MetadataDiff, schemaName string, oldSchema, newSchema *model.SchemaMetadata) {