Calcite ORDER BY 处理 NULL 值时的空指针异常解决方案

本文详解 Calcite 中执行 ORDER BY ... NULLS LAST 时因列类型未正确声明可空性导致 NullPointerException 的根本原因及修复方法，重点在于 RelDataType 必须显式设置 nullable = true。

先亮明结论：如果你在用 Apache Calcite 构建自定义 JDBC 数据源或内存表（比如实现 org.apache.calcite.schema.Table），然后某天跑了一个 ORDER BY col ASC NULLS LAST，结果列里明明有 NULL 值，却抛出了 ja va.lang.NullPointerException——堆栈指向 Utilities.compare——那大概率不是 SQL 写错了，而是元数据定义出了岔子。

核心问题在哪？Calcite 在做排序时，会调用比较器来对比值。如果某列实际包含 NULL，但对应的 RelDataType 被错误地标记为 NOT NULL（即 nullable = false），Calcite 内部就会认为“这列不可能有 NULL”，从而跳过空值安全检查。结果 Utilities.compare() 拿到一个 null 后直接调用 o1.compareTo(o2)，o1 本身就是 null，自然崩溃。

要修复，根本方法是在 Table.getRowType(RelDataTypeFactory) 中，为所有可能含 NULL 的列显式创建可空类型。下面是一个典型的正确实现：

@Override
public RelDataType getRowType(RelDataTypeFactory typeFactory) {
    final List fields = new ArrayList<>();
    // 示例：col1 对应 VARCHAR，但业务上允许 NULL
    RelDataType col1Type = typeFactory.createSqlType(SqlTypeName.VARCHAR);
    // 关键修复：必须 wrap 为 nullable 类型
    col1Type = typeFactory.createTypeWithNullability(col1Type, true);
    // 同理处理 col2
    RelDataType col2Type = typeFactory.createSqlType(SqlTypeName.INTEGER);
    col2Type = typeFactory.createTypeWithNullability(col2Type, true);
    fields.add(new RelDataTypeFieldImpl("col1", 0, col1Type));
    fields.add(new RelDataTypeFieldImpl("col2", 1, col2Type));
    return new RelRecordType(fields);
}

这里有几个需要警惕的地方：

• 即便数据库底层字段是 NOT NULL，只要查询结果中可能出现 NULL（比如外连接、聚合函数 MAX() 在空组里返回 NULL，或者 CASE WHEN 分支没覆盖全），对应的 RelDataType 就必须设为 nullable = true。
• NULLS LAST / NULLS FIRST 语义依赖 Calcite 对 NULL 的识别能力，而这种识别完全仰仗 RelDataType.isNullable() 的返回值。如果元数据说“非空”，Calcite 就真的认为不会有 NULL 进来。
• 试图绕路解决——比如去掉 NULLS LAST 或者用 COALESCE 硬转——只是治标不治本，掩盖不了元数据与实际数据之间的矛盾。

总结一下：Calcite 的类型系统是强契约式的。RelDataType 不只描述结构，它本身就是运行时的行为契约。把可能为空的列声明成非空，等于给 Calcite 发送了一个错误信号，后续的 NPE 或逻辑错乱几乎是必然。正确的做法就是在 getRowType() 里逐列校验，显式启用 nullability——这是构建健壮自定义表的基本功。