如何检查Databricks中两张Delta表的列名是否完全一致？

方法1：通过Spark SQL查询系统元数据 #

利用Databricks兼容的information_schema系统表，直接对比两张表的列信息：

-- 找出仅在table_a中存在的列
SELECT column_name
FROM information_schema.columns
WHERE table_schema = 'your_database' AND table_name = 'table_a'
EXCEPT
SELECT column_name
FROM information_schema.columns
WHERE table_schema = 'your_database' AND table_name = 'table_b';

-- 找出仅在table_b中存在的列
SELECT column_name
FROM information_schema.columns
WHERE table_schema = 'your_database' AND table_name = 'table_b'
EXCEPT
SELECT column_name
FROM information_schema.columns
WHERE table_schema = 'your_database' AND table_name = 'table_a';

替换your_database、table_a、table_b为实际的数据库和表名；若使用默认数据库，可移除table_schema过滤条件。

方法2：PySpark DataFrame集合操作 #

通过Python脚本快速获取列名并计算差异，适合自动化验证场景：

# 读取目标表
df_a = spark.table("your_database.table_a")
df_b = spark.table("your_database.table_b")

# 转换为列名集合
cols_a = set(df_a.columns)
cols_b = set(df_b.columns)

# 计算仅在单表存在的列
only_in_a = cols_a - cols_b
only_in_b = cols_b - cols_a

print(f"仅在table_a存在的列：{only_in_a}")
print(f"仅在table_b存在的列：{only_in_b}")

方法3：Scala集合操作（针对Scala开发场景） #

逻辑与PySpark一致，用Scala实现：

// 读取目标表
val dfA = spark.table("your_database.table_a")
val dfB = spark.table("your_database.table_b")

// 转换为列名集合
val colsA = dfA.columns.toSet
val colsB = dfB.columns.toSet

// 计算差异列
val onlyInA = colsA.diff(colsB)
val onlyInB = colsB.diff(colsA)

println(s"仅在table_a存在的列：$onlyInA")
println(s"仅在table_b存在的列：$onlyInB")

内容的提问来源于stack exchange，提问作者SJJ9166