Function dropProcedure

server/node/drop_procedure.go:104–137

(ctx *sql.Context, procColl *procedures.Collection, fn *RoutineWithParams, ifExists bool)

}

func dropProcedure(ctx *sql.Context, procColl *procedures.Collection, fn *RoutineWithParams, ifExists bool) error {
	// TODO: provide db
	schema, err := core.GetSchemaName(ctx, nil, fn.SchemaName)
	if err != nil {
		return err
	}

	var procId = id.NewProcedure(schema, fn.RoutineName)
	if len(fn.Args) == 0 {
		procs, err := procColl.GetProcedureOverloads(ctx, procId)
		if err != nil {
			return err
		}
		if len(procs) == 1 {
			procId = procs[0].ID
		} else if len(procs) > 1 {
			procExists := procColl.HasProcedure(ctx, procId)
			if !procExists {
				return errors.Errorf(`procedure name "%s" is not unique`, fn.RoutineName)
			}
		}
	} else {
		var argTypes = make([]id.Type, len(fn.Args))
		for i, arg := range fn.Args {
			argTypes[i] = arg.Type.ID
		}
		procId = id.NewProcedure(schema, fn.RoutineName, argTypes...)
	}
	procExists := procColl.HasProcedure(ctx, procId)
	if !procExists && ifExists {
		return nil
	}
	return procColl.DropProcedure(ctx, procId)
}