Skip to content

[SPARK-52428] Add parameterized SQL support (named and positional args)#30

Open
rafafrdz wants to merge 1 commit intoapache:masterfrom
rafafrdz:add-sql-with-params
Open

[SPARK-52428] Add parameterized SQL support (named and positional args)#30
rafafrdz wants to merge 1 commit intoapache:masterfrom
rafafrdz:add-sql-with-params

Conversation

@rafafrdz
Copy link
Copy Markdown

Summary

  • Add sql_with_args() for named parameters (:name syntax) using HashMap<String, Literal>
  • Add sql_with_pos_args() for positional parameters (? syntax) using Vec<Literal>
  • Existing sql() method unchanged

Usage:

let mut args = HashMap::new();
args.insert("threshold".to_string(), Literal::from(100i32));
let df = spark.sql_with_args("SELECT * FROM t WHERE value > :threshold", args).await?;

Test plan

  • cargo build passes
  • cargo test unit tests pass
  • cargo fmt -- --check passes

@rafafrdz rafafrdz force-pushed the add-sql-with-params branch from 44c3113 to e74af9a Compare March 29, 2026 08:08
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant