如何通过SparkSql读取配置单元事务表并对其执行删除操作

import org.apache.spark.sql.SparkSession

val spark = SparkSession.builder()
  .appName("SparkSQLExample")
  .config("spark.some.config.option", "some-value")
  .getOrCreate()

val jdbcDF = spark.read
  .format("jdbc")
  .option("url", "jdbc:mysql://localhost:3306/db_name")
  .option("dbtable", "transaction_table")
  .option("user", "username")
  .option("password", "password")
  .load()

import org.apache.spark.sql.functions._

val filteredDF = jdbcDF.filter(col("column_name") === "some_value")
filteredDF.show()

// 执行删除操作
filteredDF.write
  .format("jdbc")
  .option("url", "jdbc:mysql://localhost:3306/db_name")
  .option("dbtable", "transaction_table")
  .option("user", "username")
  .option("password", "password")
  .option("deleteFromTable", "true")
  .save()

spark.stop()