Function writeSchemaDiff

backend/plugin/schema/pg/metadata_migration.go:1463–1482

(out *strings.Builder, schemaDiff *schema.SchemaDiff)

}

func writeSchemaDiff(out *strings.Builder, schemaDiff *schema.SchemaDiff) error {
	switch schemaDiff.Action {
	case schema.MetadataDiffActionCreate:
		if skipPostgresSchemaDDL(schemaDiff.SchemaName) {
			return nil
		}
		return writeSchema(out, schemaDiff.NewSchema)
	case schema.MetadataDiffActionDrop:
		if skipPostgresSchemaDDL(schemaDiff.SchemaName) {
			return nil
		}
		if err := writeDropSchemaObjects(out, schemaDiff.SchemaName, schemaDiff.OldSchema); err != nil {
			return err
		}
		_, err := fmt.Fprintf(out, "DROP SCHEMA IF EXISTS \"%s\";\n\n", schemaDiff.SchemaName)
		return err
	default:
		return nil
	}
}

func skipPostgresSchemaDDL(schemaName string) bool {
	return schemaName == "pg_catalog" || schemaName == "public"