Function compareSchemaObjects

backend/plugin/schema/differ.go:467–531

compareSchemaObjects compares objects between two schemas.

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

// compareSchemaObjects compares objects between two schemas.
func compareSchemaObjects(engine storepb.Engine, diff *MetadataDiff, schemaName string, oldSchema, newSchema *model.SchemaMetadata) {
	// Compare tables

	// Check for dropped tables
	for _, tableName := range oldSchema.ListTableNames() {
		if newSchema.GetTable(tableName) == nil {
			oldTable := oldSchema.GetTable(tableName)
			if oldTable != nil && !oldTable.GetProto().GetSkipDump() {
				diff.TableChanges = append(diff.TableChanges, &TableDiff{
					Action:     MetadataDiffActionDrop,
					SchemaName: schemaName,
					TableName:  tableName,
					OldTable:   oldTable.GetProto(),
				})
			}
		}
	}

	// Check for new and modified tables
	for _, tableName := range newSchema.ListTableNames() {
		newTable := newSchema.GetTable(tableName)
		if newTable == nil || newTable.GetProto().GetSkipDump() {
			continue
		}

		if oldSchema.GetTable(tableName) == nil {
			diff.TableChanges = append(diff.TableChanges, &TableDiff{
				Action:     MetadataDiffActionCreate,
				SchemaName: schemaName,
				TableName:  tableName,
				NewTable:   newTable.GetProto(),
			})
		} else {
			// Compare table details
			oldTable := oldSchema.GetTable(tableName)
			if oldTable != nil && !oldTable.GetProto().GetSkipDump() {
				tableDiff := compareTableDetails(engine, schemaName, tableName, oldTable, newTable)
				if tableDiff != nil {
					diff.TableChanges = append(diff.TableChanges, tableDiff)
				}
			}
		}
	}

	// Compare views
	compareViews(engine, diff, schemaName, oldSchema, newSchema)

	// Compare materialized views
	compareMaterializedViews(engine, diff, schemaName, oldSchema, newSchema)

	// Compare functions
	compareFunctions(engine, diff, schemaName, oldSchema, newSchema)

	// Compare procedures
	compareProcedures(diff, schemaName, oldSchema, newSchema)

	// Compare sequences
	compareSequences(diff, schemaName, oldSchema, newSchema)