应用集成新手求助：如何将BigQuery读取的JSON插入SingleStore表

1. 确认表结构匹配 #

先确保你的SingleStore表字段与BigQuery返回的JSON数据字段名称、类型完全匹配。比如BigQuery返回的JSON包含user_id(INT)、username(VARCHAR)、signup_date(DATETIME)，SingleStore表也要对应创建这些字段。

2. 添加SingleStore执行SQL任务 #

在Application Integration画布的bigqueryss任务之后，添加SingleStore连接器的「执行SQL」操作，用来执行插入逻辑。

3. 编写动态INSERT语句 #

根据connectorOutputPayload的JSON结构（单条记录/多条记录数组）选择对应写法：

场景1：JSON是多条记录的数组

用SingleStore的JSON_TABLE函数解析数组，批量插入：

INSERT INTO your_single_store_table (user_id, username, signup_date)
SELECT j.user_id, j.username, j.signup_date
FROM JSON_TABLE(
    {{connectorOutputPayload}},
    '$[*]' COLUMNS (
        user_id INT PATH '$.user_id',
        username VARCHAR(100) PATH '$.username',
        signup_date DATETIME PATH '$.signup_date'
    )
) AS j;

场景2：JSON是单条记录

直接用JSON_EXTRACT_SCALAR提取字段值插入：

INSERT INTO your_single_store_table (user_id, username, signup_date)
VALUES (
    JSON_EXTRACT_SCALAR({{connectorOutputPayload}}, '$.user_id'),
    JSON_EXTRACT_SCALAR({{connectorOutputPayload}}, '$.username'),
    JSON_EXTRACT_SCALAR({{connectorOutputPayload}}, '$.signup_date')
);

注意：替换your_single_store_table为你的实际表名，调整字段名、类型和JSON路径以匹配你的数据。

4. 配置变量引用 #

在Application Integration的SQL编辑器中，用平台指定的变量语法引用connectorOutputPayload（多数平台用{{变量名}}，如果你的平台语法不同，替换为对应格式）。

5. 测试与验证 #

• 先用单条测试数据验证SQL解析和插入是否成功
• 查看任务执行日志，排查字段类型不匹配、JSON路径错误等问题

内容的提问来源于stack exchange，提问作者Rubén Lara