如何在新的databricks连接中正确使用sql/hive变量

-- 设置变量
SET my_var = 'example_value';

-- 使用变量
SELECT * FROM my_table WHERE column_name = '${my_var}';

from pyspark.sql.functions import lit

# 设置变量
my_var = 'example_value'

# 使用变量
df = spark.sql(f"SELECT * FROM my_table WHERE column_name = '{my_var}'")

spark.conf.set("my_var", "example_value")

# 使用变量
df = spark.sql("SELECT * FROM my_table WHERE column_name = '${my_var}'")

# 设置变量
spark.conf.set("my_var", "example_value")

# 使用变量
query = f"SELECT * FROM my_table WHERE column_name = '{spark.conf.get('my_var')}'"
df = spark.sql(query)