spark中的Jdbc更新语句

import java.sql.{Connection, DriverManager, PreparedStatement}

// JDBC连接信息
val url = "jdbc:mysql://localhost:3306/mydatabase"
val username = "myusername"
val password = "mypassword"

// 创建JDBC连接
val connection = DriverManager.getConnection(url, username, password)

try {
  // 创建PreparedStatement对象
  val statement = connection.prepareStatement("UPDATE mytable SET column1 = ?, column2 = ? WHERE id = ?")

  // 设置更新参数
  statement.setString(1, "new value for column1")
  statement.setString(2, "new value for column2")
  statement.setInt(3, 1) // 假设id为1

  // 执行更新操作
  val rowsUpdated = statement.executeUpdate()

  // 输出更新的行数
  println(s"Updated $rowsUpdated rows")

  // 关闭PreparedStatement对象
  statement.close()
} finally {
  // 关闭JDBC连接
  connection.close()
}