Function evaluteNoticeMessage

server/plpgsql/interpreter_logic.go:448–486

evaluteNoticeMessage evaluates the message for a RAISE NOTICE statement, including evaluating any specified parameters and plugging them into the message in place of the % placeholders.

(ctx *sql.Context, iFunc InterpretedFunction,
	operation InterpreterOperation, stack InterpreterStack)

// evaluating any specified parameters and plugging them into the message in place of
// the % placeholders.
func evaluteNoticeMessage(ctx *sql.Context, iFunc InterpretedFunction,
	operation InterpreterOperation, stack InterpreterStack) (string, error) {
	message := operation.SecondaryData[0]
	if len(operation.SecondaryData) > 1 {
		params := operation.SecondaryData[1:]
		currentParamIdx := 0

		parts := strings.Split(message, "%%")
		for i, part := range parts {
			for strings.Contains(part, "%") {
				if currentParamIdx >= len(params) {
					return "", errors.New("too few parameters specified for RAISE")
				}
				currentParam := params[currentParamIdx]
				currentParamIdx += 1
				formattedVar, varFound, err := iFunc.ApplyBindings(ctx, stack, "$1", []string{currentParam}, false)
				if varFound {
					if err != nil {
						return "", err
					}
					part = strings.Replace(part, "%", formattedVar, 1)
				} else {
					retVal, err := iFunc.QuerySingleReturn(ctx, stack, fmt.Sprintf("SELECT (%s)::text", currentParam), nil, nil)
					if err != nil {
						return "", err
					}
					stringVal := fmt.Sprintf("%v", retVal) // We should always return a string, but this is just a safety net
					part = strings.Replace(part, "%", stringVal, 1)
				}
			}
			parts[i] = part
		}
		if currentParamIdx < len(params) {
			return "", errors.New("too many parameters specified for RAISE")
		}
		message = strings.Join(parts, "%")
	}
	return message, nil
}

// triggerSpecialVariables are the list of special variables for triggers.
// https://www.postgresql.org/docs/15/plpgsql-trigger.html