Объединить данные в таблицу из именованного этапа - PullRequest
Новая
       4

Объединить данные в таблицу из именованного этапа

0 голосов
/ 13 февраля 2020

У меня проблемы с объединением данных в таблицу Snowflake из внутренней именованной стадии. Я имел в виду базу знаний статья . 

My code is pasted below and the error is also pasted below.

Код: 

MERGE INTO ORDERS TGT 
USING 
    (
        SELECT $1::NUMBER                             o_orderkey,
               $2::NUMBER                             o_custkey,
               $3::STRING                             o_orderstatus,
               $4::FLOAT                              o_totalprice,
               TO_DATE($5::VARCHAR, 'YYYY-MM-DD')     O_ORDERDATE,
               $6::STRING                             o_orderpriority,
               $7::STRING                             o_clerk,
               $8::STRING                             o_shippriority,
               $9::STRING                             o_comment
        from '@STG_IVP_REF_BULK_DATA_MIGRATION/ORDERS/Snowflake_DB_Data_12-Feb-2020_02-59-50-PM.csv.gz'
        (file_format = (field_delimiter = '|'))
    )SRC
ON SRC.O_ORDERKEY = TGT.O_ORDERKEY
WHEN MATCHED 
THEN
    UPDATE SET TGT.LAST_MODIFIED_DATE = CURRENT_TIMESTAMP()::TIMESTAMP_NTZ
WHEN NOT MATCHED
THEN
    INSERT (o_orderkey, o_custkey, o_orderstatus, o_totalprice, O_ORDERDATE, o_orderpriority, o_clerk, o_shippriority, o_comment)
    VALUES (o_orderkey, o_custkey, o_orderstatus, o_totalprice, O_ORDERDATE, o_orderpriority, o_clerk, o_shippriority, o_comment);

Ошибка вывода: 

SQL Error [2018] [22023]: SQL compilation error:
Invalid argument [2=>[unresolved function: "="](FILE_FORMAT, [unresolved function: "="](FIELD_DELIMITER, '|'))] for table function. Table function argument is required to be a constant.

1 Ответ

1 голос
/ 13 февраля 2020

Можете ли вы создать объект file_format для определения разделителя как '|' и использовать его в своем запросе? Например: 

CREATE FILE FORMAT myformat TYPE = 'CSV' FIELD_DELIMITER = '|';


MERGE INTO ORDERS TGT 
USING 
    (
        SELECT $1::NUMBER                             o_orderkey,
               $2::NUMBER                             o_custkey,
               $3::STRING                             o_orderstatus,
               $4::FLOAT                              o_totalprice,
               TO_DATE($5::VARCHAR, 'YYYY-MM-DD')     O_ORDERDATE,
               $6::STRING                             o_orderpriority,
               $7::STRING                             o_clerk,
               $8::STRING                             o_shippriority,
               $9::STRING                             o_comment
        from '@STG_IVP_REF_BULK_DATA_MIGRATION/ORDERS/Snowflake_DB_Data_12-Feb-2020_02-59-50-PM.csv.gz'
        (file_format => myformat)
    )SRC
ON SRC.O_ORDERKEY = TGT.O_ORDERKEY
WHEN MATCHED 
THEN
    UPDATE SET TGT.LAST_MODIFIED_DATE = CURRENT_TIMESTAMP()::TIMESTAMP_NTZ
WHEN NOT MATCHED
THEN
    INSERT (o_orderkey, o_custkey, o_orderstatus, o_totalprice, O_ORDERDATE, o_orderpriority, o_clerk, o_shippriority, o_comment)
    VALUES (o_orderkey, o_custkey, o_orderstatus, o_totalprice, O_ORDERDATE, o_orderpriority, o_clerk, o_shippriority, o_comment);

При запросе данных из промежуточной стадии необходимо использовать объекты FILE_FORMAT:

https://docs.snowflake.net/manuals/user-guide/querying-stage.html#query -синтаксис-параметры

...