用于匹配并返回所有出现的搜索字符串的 SQL 查询答案

【问题标题】：SQL query to match and return all occurrences of search string用于匹配并返回所有出现的搜索字符串的 SQL 查询
【发布时间】：2023-03-08 02:18:02
【问题描述】：

我在列（记录）中有一个 json 文档，其中有一个表（表），如下所示。需要编写一个 SQL 查询来将所有出现的字段“a”、“b”、“k”的值带入 aaagroup。

结果应该是：

NAME1   age1    comment1
NAME2   age2    
NAME3            comment3

JSON 数据：

{
    "reportfile": {
        "aaa": {
            "aaagroup": [{
                "a": "NAME1",
                "b": "age1",
                "k": "comment1"
            },
        {
                "a": "NAME2",
                "b": "age2"
            },
        {
                "a": "NAME3",
                "k": "comment3"
            }]
        },
        "dsa": {
            "dsagroup": [{
                "j": "Name"
            },
            {
                "j": "Title"
            }]
        }
    }
}

我使用下面的查询单次出现：

数据：

{"reportfile":{"aaa":{"aaagroup":[{"a":"NAME1","k":"age1}]},"dsa":{"dsagroup":[{"j":"USERNAME"}],"l":"1","m":"1"}}}

查询：

select 
    substr(cc.BUS_NME, 1, strpos(cc.BUS_NME,'"')-1) as BUS_NME,
    substr(cc.AGE, 1, strpos(cc.AGE,'"')-1) as AGE
from 
    (substr(bb.aaa,strpos(bb.aaa,'"a":"')+5) as BUS_NME,
     substr(bb.aaa,strpos(bb.aaa,'"k":"')+5) as AGE 
from 
    (substr(aa.G, strpos(aa.G,'"aaagroup'),strpos(aa.G,'},')) as aaa                 
from 
    (select substr(record, strpos(record,'"aaagroup')) as G 
     from TABLE) aa) bb) cc

【问题讨论】：

请用您正在使用的 RDBMS（及其版本）标记您的问题。 JSON 函数是非常特定于供应商的。
这是一个 parquet 文件，加载到 AWS Athena 并创建了一个表。

标签： sql amazon-athena

【解决方案1】：

ush rani - 如果我的问题得到了正确的回答，您将拥有一个像这样的外部表，您可以尝试下面的查询以从外部表中获取所需的结果

示例外部表：

CREATE EXTERNAL TABLE Ext_JSON_data(
reportfile string
  )
ROW FORMAT SERDE 
  'org.openx.data.jsonserde.JsonSerDe' 
WITH SERDEPROPERTIES (  
'serialization.format' = '1'
  )
LOCATION
  's3://bucket/folder/'

获取期望结果的查询：

WITH the_table AS (
SELECT CAST(social AS MAP(VARCHAR, JSON)) AS social_data
  FROM (
    VALUES
    (JSON '{"aaa": {"aaagroup": [{"a": "NAME1","b": "age1","k": "comment1"},{"a": "NAME2","b": "age2"},{"a": "NAME3","k": "comment3"}]},"dsa": {"dsagroup": [{"j": "Name"},{"j": "Title"}]}}')
) AS t (social)    
),
cte_first_level as
(  
SELECT 
    first_level_key
  ,CAST(first_level_value AS MAP(VARCHAR, JSON))As first_level_value
  FROM the_table
  CROSS JOIN UNNEST (social_data) AS t (first_level_key, first_level_value)
),
cte_second_level as
(
Select 
first_level_key
,SECOND_level_key
,SECOND_level_value
from 
cte_first_level  
CROSS JOIN UNNEST (first_level_value) AS t (SECOND_level_key, SECOND_level_value)
)
SELECT
first_level_key
,SECOND_level_key
,SECOND_level_value
,items
,items['a'] value_of_a
,items['b'] value_of_b
,items['k'] value_of_k
from 
cte_second_level
cross join unnest(cast(json_extract(SECOND_level_value, '$') AS ARRAY<MAP<VARCHAR, VARCHAR>>)) t (items)

查询输出：

【讨论】：