执行Snowflake存储过程时出现STATEMENT_ERROR错误求助

你的存储过程执行出现STATEMENT_ERROR，主要是以下几个问题导致的，逐一修复即可：

1. 表列名不匹配 #

products表定义的列是name，但存储过程插入时用了product_name，这会直接触发列不存在的错误。

2. 硬编码order_id，未正确获取刚插入的订单ID #

你直接给order_id赋值为458281，这既不符合业务逻辑，也会导致后续插入products时关联错误的订单ID，应该通过序列的CURRVAL获取刚生成的ID。

3. 数据类型长度不匹配（潜在问题） #

orders表的customer_id是VARCHAR(10)，但存储过程里将JSON字段转成VARCHAR(50)，虽然不会直接报错，但建议和表结构保持一致，避免潜在的截断问题。

4. FLATTEN用法冗余 #

原FLATTEN的写法嵌套了子查询，可以简化为更简洁的形式。

修复后的完整代码 #

1. 序列与表结构（确保序列配置生效）

CREATE SEQUENCE order_id_seq START = 0 INCREMENT = 1;

CREATE TABLE orders 
(
    order_id NUMBER default order_id_seq.nextval,
    customer_id VARCHAR(10),
    order_date DATE,
    total_amount FLOAT,
    PRIMARY KEY (order_id)
);

CREATE TABLE products 
(
    order_id NUMBER,
    name VARCHAR(100),
    quantity INT,
    unit_price FLOAT
);

2. 修复后的存储过程

CREATE OR REPLACE PROCEDURE insert_order_and_products(json_data VARIANT)
RETURNS STRING
LANGUAGE SQL
AS
$$
DECLARE
    order_id INTEGER;
BEGIN
    -- 插入orders表，匹配表结构的字段长度
    INSERT INTO orders (customer_id, order_date, total_amount)
    SELECT
        json_data:customer_id::VARCHAR(10) AS customer_id,
        TO_DATE(json_data:order_date::VARCHAR, 'YYYY-MM-DD') AS order_date,
        json_data:total_amount::FLOAT AS total_amount;

    -- 通过序列CURRVAL获取刚生成的订单ID
    SELECT order_id_seq.CURRVAL INTO order_id FROM dual;

    -- 插入products表，修正列名匹配，简化FLATTEN写法
    INSERT INTO products (order_id, name, quantity, unit_price)
    SELECT
        order_id AS order_id,
        value:name::VARCHAR(100) AS name,
        value:quantity::INTEGER AS quantity,
        value:unit_price::FLOAT AS unit_price
    FROM
        TABLE(FLATTEN(json_data:products));

    RETURN 'Data inserted successfully.';
END;
$$;

3. 调用语句（保持原逻辑）

CALL insert_order_and_products(parse_json('{
    "customer_id": "C001",
    "order_date": "2024-04-26",
    "total_amount": 100.50,
    "products": [
        {
            "name": "Product A",
            "quantity": 2,
            "unit_price": 25.25
        },
        {
            "name": "Product B",
            "quantity": 1,
            "unit_price": 50.00
        }
    ]
}'));

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