如何在Trino SQL中无需创建临时视图获取查询语句的Schema？

阿华AIGC实验室

2026-3-31

这个问题确实戳中了Trino schema校验场景里的常见痛点——临时视图的权限限制和清理麻烦，我之前也遇到过类似的需求，刚好有几个不用创建临时视图的方案可以分享给你：

方案1：利用`EXPLAIN`解析执行计划的JSON输出（推荐，全SQL嵌入）

Trino的EXPLAIN (TYPE JSON)语句会返回查询的完整执行计划，其中**outputColumns字段包含了查询输出列的所有schema信息**（名称、类型、位置等）。我们可以用Trino的JSON函数提取这些字段，直接和目标表的schema做对比，全程不需要创建任何临时对象。

完整校验模板

把下面的<your_query>替换为你要校验的实际查询，<catalog.schema.target_table>替换为目标表的全限定名即可：

WITH query_schema_raw AS (
  -- 生成查询的执行计划JSON，提取outputColumns
  SELECT
    json_array_elements(
      json_extract_scalar(
        explain_result,
        '$.outputColumns'
      )::JSON
    ) AS col_json
  FROM (
    SELECT EXPLAIN (TYPE JSON)
      -- 替换这里为你要校验的实际查询
      SELECT id, name, age::VARCHAR FROM some_source_table
    AS explain_result
  ) t
),
query_schema AS (
  -- 解析JSON得到结构化的schema信息，生成列的位置序号
  SELECT
    row_number() OVER () AS ordinal_position,
    json_extract_scalar(col_json, '$.name') AS column_name,
    json_extract_scalar(col_json, '$.type') AS type_name
  FROM query_schema_raw
),
target_table_schema AS (
  -- 从system.jdbc.columns获取目标表的schema
  SELECT
    ordinal_position,
    column_name,
    type_name
  FROM system.jdbc.columns
  WHERE table_cat = '<catalog>'
    AND table_schem = '<schema>'
    AND table_name = '<target_table>'
),
schema_comparison AS (
  -- 全外连接对比列名、类型和位置
  SELECT
    coalesce(a.ordinal_position, b.ordinal_position) AS ordinal_position,
    a.column_name AS original_column_name,
    b.column_name AS new_column_name,
    a.column_name = b.column_name AS has_same_name,
    a.type_name AS original_type,
    b.type_name AS new_type,
    a.type_name = b.type_name AS has_same_type
  FROM target_table_schema a
  FULL OUTER JOIN query_schema b
    ON a.ordinal_position = b.ordinal_position
),
validation_summary AS (
  -- 生成整体校验结果
  SELECT
    every(has_same_name) over () as test_same_name,
    every(has_same_type) over () as test_same_type,
    *
  FROM schema_comparison
)
SELECT * FROM validation_summary ORDER BY ordinal_position;

方案优势

无权限限制：只需要用户有查询目标表和执行EXPLAIN的权限（EXPLAIN权限和查询权限一致，不需要DDL权限）
无残留对象：全程不创建任何临时视图或表，不会积累垃圾对象
全SQL嵌入：可以直接作为单一SQL模板复用，不需要客户端额外逻辑

注意事项

确保使用Trino 350+版本：旧版本的EXPLAIN JSON输出格式可能略有不同，需要调整JSON解析逻辑
类型名称一致性：system.jdbc.columns的type_name和EXPLAIN输出的type可能有大小写或别名差异（比如VARCHAR vs varchar），可以用lower(a.type_name) = lower(b.type_name)来兼容
细粒度校验：如果需要校验nullable、精度等信息，可以从col_json中提取nullable、typeArguments等字段扩展对比逻辑