我正在加载列，这是一个varchar存储JSON字符串从mysql表到Spark dataframe。我希望能够在上面使用Spark Sql

val jdbcUrl = "jdbc:mysql://localhost:3306/database_name"
val connectionProperties = new java.util.Properties()
connectionProperties.put("user", "username")
connectionProperties.put("password", "password")

val df = spark.read.jdbc(jdbcUrl, "table_name", connectionProperties)

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

val jsonSchema = spark.read.json(df.select("json_column").as[String]).schema

val resultDf = df.select(from_json(col("json_column"), jsonSchema).as("json_data"))

resultDf.createOrReplaceTempView("temp_table")
val queryResult = spark.sql("SELECT * FROM temp_table WHERE json_data.field = 'value'")