如何在Databricks中更新字符串列内JSON的指定值？

你需要先将String类型的JSON列解析为结构化数据，修改目标字段后重新序列化为JSON字符串，再替换原列的值。直接用你尝试的语法无法生效，因为原列是String类型，而非结构体/Map类型，不能直接通过字段访问语法修改。

以下是几种可行的实现方式：

方式1：显式构造结构体（适合字段固定的场景） #

假设表名为your_table，JSON列是tags，要将Key1的值改为'test1'，过滤条件id='abc'：

UPDATE your_table
SET tags = to_json(
  struct(
    'test1' AS Key1,
    from_json(tags, 'STRUCT<Key1: STRING, `Key2`: STRING>').`Key2` AS `Key2`
  )
)
WHERE id='abc';

该方式通过解析原JSON得到结构体，显式指定修改后的Key1值，同时保留原Key2的值，最后转成JSON字符串替换原列。

方式2：遍历修改结构体字段（适合字段较多的场景） #

用transform_values遍历解析后的结构体键值对，仅替换目标字段：

UPDATE your_table
SET tags = to_json(
  transform_values(
    from_json(tags, 'STRUCT<Key1: STRING, `Key2`: STRING>'),
    (k, v) -> CASE WHEN k = 'Key1' THEN 'test1' ELSE v END
  )
)
WHERE id='abc';

这种方式无需逐个列出所有字段，自动保留未修改的字段值，更高效。

方式3：用Map类型解析（适合JSON结构不固定的场景） #

如果JSON的键值对不固定，可解析为Map类型，通过map_concat覆盖目标键的值：

UPDATE your_table
SET tags = to_json(
  map_concat(
    from_json(tags, 'MAP<STRING, STRING>'),
    map('Key1', 'test1')
  )
)
WHERE id='abc';

验证建议 #

执行UPDATE前，可先通过SELECT验证修改结果是否符合预期：

SELECT
  tags AS original_tags,
  to_json(transform_values(from_json(tags, 'STRUCT<Key1: STRING, `Key2`: STRING>'), (k, v) -> CASE WHEN k = 'Key1' THEN 'test1' ELSE v END)) AS updated_tags
FROM your_table
WHERE id='abc';

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