Function addNewSchemaObjects

backend/plugin/schema/differ.go:360–464

addNewSchemaObjects adds all objects from a new schema as created.

(diff *MetadataDiff, schemaName string, schema *model.SchemaMetadata)

// addNewSchemaObjects adds all objects from a new schema as created.
func addNewSchemaObjects(diff *MetadataDiff, schemaName string, schema *model.SchemaMetadata) {
	schemaProto := schema.GetProto()

	// Add all tables
	for _, tableName := range schema.ListTableNames() {
		table := schema.GetTable(tableName)
		if table != nil && !table.GetProto().GetSkipDump() {
			diff.TableChanges = append(diff.TableChanges, &TableDiff{
				Action:     MetadataDiffActionCreate,
				SchemaName: schemaName,
				TableName:  tableName,
				NewTable:   table.GetProto(),
			})
		}
	}

	// Add all views
	for _, viewName := range schema.ListViewNames() {
		view := schema.GetView(viewName)
		if view != nil && !view.SkipDump {
			diff.ViewChanges = append(diff.ViewChanges, &ViewDiff{
				Action:     MetadataDiffActionCreate,
				SchemaName: schemaName,
				ViewName:   viewName,
				NewView:    view,
			})
		}
	}

	// Add all materialized views
	for _, mvName := range schema.ListMaterializedViewNames() {
		mv := schema.GetMaterializedView(mvName)
		if mv != nil && !mv.SkipDump {
			diff.MaterializedViewChanges = append(diff.MaterializedViewChanges, &MaterializedViewDiff{
				Action:               MetadataDiffActionCreate,
				SchemaName:           schemaName,
				MaterializedViewName: mvName,
				NewMaterializedView:  mv,
			})
		}
	}

	// Add all functions
	for _, function := range schema.GetProto().GetFunctions() {
		if !function.GetSkipDump() {
			// Use signature if available, otherwise fall back to name
			functionName := function.Signature
			if functionName == "" {
				functionName = function.Name
			}
			diff.FunctionChanges = append(diff.FunctionChanges, &FunctionDiff{
				Action:       MetadataDiffActionCreate,
				SchemaName:   schemaName,
				FunctionName: functionName,
				NewFunction:  function,
			})
		}
	}