Function AddJoinFromSQL

pkg/transform/joins.go:98–111

AddJoinFromSQL returns a Rule that parses a JOIN clause from SQL and adds it to a SELECT statement. The sql parameter should be a complete JOIN clause, e.g. "LEFT JOIN orders ON orders.user_id = users.id". WARNING: sql parameter must not contain untrusted user input. This function parses raw SQL -

(sql string)

// produce unintended query modifications. Use parameterized queries
// or construct AST nodes directly for untrusted input.
func AddJoinFromSQL(sql string) Rule {
	return RuleFunc(func(stmt ast.Statement) error {
		join, err := parseJoinClause(sql)
		if err != nil {
			return err
		}
		sel, err := getSelect(stmt, "AddJoinFromSQL")
		if err != nil {
			return err
		}
		sel.Joins = append(sel.Joins, *join)
		return nil
	})
}