(out *strings.Builder, procedureDiff *schema.ProcedureDiff)
| 1743 | } |
| 1744 | |
| 1745 | func writeProcedureDiff(out *strings.Builder, procedureDiff *schema.ProcedureDiff) error { |
| 1746 | switch procedureDiff.Action { |
| 1747 | case schema.MetadataDiffActionCreate: |
| 1748 | return writeProcedure(out, procedureDiff.SchemaName, procedureDiff.NewProcedure) |
| 1749 | case schema.MetadataDiffActionDrop: |
| 1750 | signature := procedureDiff.ProcedureName |
| 1751 | if procedureDiff.OldProcedure.GetSignature() != "" { |
| 1752 | signature = procedureDiff.OldProcedure.GetSignature() |
| 1753 | } |
| 1754 | return writeDropRoutine(out, "PROCEDURE", procedureDiff.SchemaName, signature) |
| 1755 | case schema.MetadataDiffActionAlter: |
| 1756 | signature := procedureDiff.ProcedureName |
| 1757 | if procedureDiff.OldProcedure.GetSignature() != "" { |
| 1758 | signature = procedureDiff.OldProcedure.GetSignature() |
| 1759 | } |
| 1760 | if err := writeDropRoutine(out, "PROCEDURE", procedureDiff.SchemaName, signature); err != nil { |
| 1761 | return err |
| 1762 | } |
| 1763 | return writeProcedure(out, procedureDiff.SchemaName, procedureDiff.NewProcedure) |
| 1764 | default: |
| 1765 | return nil |
| 1766 | } |
| 1767 | } |
| 1768 | |
| 1769 | func writeProcedure(out *strings.Builder, schemaName string, procedure *storepb.ProcedureMetadata) error { |
| 1770 | if err := writeDefinitionStatement(out, procedure.Definition); err != nil { |
no test coverage detected