如何使用SQL语句中使用的参数提交Spark SQL应用程序？

import org.apache.spark.sql.{SparkSession, PreparedStatement}

object SparkSQLParameterExample {
  def main(args: Array[String]): Unit = {
    // 创建SparkSession
    val spark = SparkSession.builder()
      .appName("Spark SQL Parameter Example")
      .master("local")
      .getOrCreate()

    // 创建参数列表
    val params = List("param1", "param2")

    // 定义SQL语句
    val sql = "SELECT * FROM table WHERE column1 = ? AND column2 = ?"

    // 创建PreparedStatement
    val statement: PreparedStatement = spark.sql(sql).bind(params: _*)

    // 执行查询
    val resultSet = statement.executeQuery()

    // 处理结果集
    while (resultSet.next()) {
      // 处理每一行数据
      val column1Value = resultSet.getString("column1")
      val column2Value = resultSet.getString("column2")
      // ...
    }

    // 关闭连接
    resultSet.close()
    statement.close()
    spark.stop()
  }
}