Function FilterPostgresArchiveSchema

backend/plugin/schema/differ.go:2145–2226

FilterPostgresArchiveSchema filters out schema diff objects related to bbdataarchive schema.

(diff *MetadataDiff)

// FilterPostgresArchiveSchema filters out schema diff objects related to bbdataarchive schema.
func FilterPostgresArchiveSchema(diff *MetadataDiff) *MetadataDiff {
	if diff == nil {
		return nil
	}

	archiveSchemaName := common.BackupDatabaseNameOfEngine(storepb.Engine_POSTGRES)

	// Create a new diff object with filtered changes
	filtered := &MetadataDiff{
		DatabaseName: diff.DatabaseName,
	}

	// Filter schema changes
	for _, schemaChange := range diff.SchemaChanges {
		if schemaChange.SchemaName != archiveSchemaName {
			filtered.SchemaChanges = append(filtered.SchemaChanges, schemaChange)
		}
	}

	// Filter table changes
	for _, tableChange := range diff.TableChanges {
		if tableChange.SchemaName != archiveSchemaName {
			filtered.TableChanges = append(filtered.TableChanges, tableChange)
		}
	}

	// Filter view changes
	for _, viewChange := range diff.ViewChanges {
		if viewChange.SchemaName != archiveSchemaName {
			filtered.ViewChanges = append(filtered.ViewChanges, viewChange)
		}
	}

	// Filter materialized view changes
	for _, mvChange := range diff.MaterializedViewChanges {
		if mvChange.SchemaName != archiveSchemaName {
			filtered.MaterializedViewChanges = append(filtered.MaterializedViewChanges, mvChange)
		}
	}

	// Filter function changes
	for _, funcChange := range diff.FunctionChanges {
		if funcChange.SchemaName != archiveSchemaName {
			filtered.FunctionChanges = append(filtered.FunctionChanges, funcChange)
		}
	}

	// Filter procedure changes
	for _, procChange := range diff.ProcedureChanges {
		if procChange.SchemaName != archiveSchemaName {
			filtered.ProcedureChanges = append(filtered.ProcedureChanges, procChange)
		}
	}

	// Filter sequence changes
	for _, seqChange := range diff.SequenceChanges {
		if seqChange.SchemaName != archiveSchemaName {
			filtered.SequenceChanges = append(filtered.SequenceChanges, seqChange)