COPY INTO 雪花命令的语法错误

Question

我正在尝试从 s3 存储桶中的文件填充已在 Snowflake 中创建的表。我已验证存储集成正在运行，因此根据文档，我不需要外部阶段。

似乎为了使用 Parquet 文件格式填充表格，我需要在复制命令中指定列，每个帖子 in Snowflake community forum.

无论我进行什么更改，我的命令都会出现语法错误。如果我在 s3 存储桶 url 之后删除 '('，我会收到错误

    "unexpected SELECT"

但如果我把它留在里面，我会收到错误

    "unexpected '(' "

我的代码：

    COPY INTO MYTABLE
        FROM s3://bucket/folder2/File.snappy.parquet (
       SELECT 
       O_ID: NUMBER(19,0),        

       O_TYPE:VARCHAR(48),        

       C_ID:NUMBER(19,0),

       ON_ID:FLOAT,

       SE_ID:NUMBER(19,0),

       C_MATCH:BOOLEAN 

    )

        STORAGE_INTEGRATION = MY_INTEGRATION
        FILE_FORMAT=(
           TYPE = 'PARQUET' 
          SNAPPY_COMPRESSION = TRUE
       )
      ;

谁能告诉我如何修正这里的语法？

Answer 1

我相信你的命令应该是这样的

COPY INTO MYTABLE ( 
   O_ID: NUMBER(19,0),        
   O_TYPE:VARCHAR(48),        
   C_ID:NUMBER(19,0),
   ON_ID:FLOAT,
   SE_ID:NUMBER(19,0),
   C_MATCH:BOOLEAN 
   )
   FROM ( 
    SELECT $1,$2,$3,$4,$5,$6 FROM s3://bucket/folder2/File.snappy.parquet 
   ) STORAGE_INTEGRATION = MY_INTEGRATION
    FILE_FORMAT=(
       TYPE = 'PARQUET' 
      SNAPPY_COMPRESSION = TRUE
   );

请尝试让我知道它是否有效。

Answer 2

需要在 COPY INTO 之前创建表：

CREATE OR REPLACE TABLE MYTABLE (
    O_ID NUMBER(19,0),        
    O_TYPE VARCHAR(48),        
    C_ID NUMBER(19,0),
    ON_ID FLOAT,
    SE_ID NUMBER(19,0),
    C_MATCH BOOLEAN 
);


COPY INTO MYTABLE (
    O_ID,        
    O_TYPE,     
    C_ID,
    ON_ID,
    SE_ID
)
FROM s3://bucket/folder2/File.snappy.parquet

STORAGE_INTEGRATION = MY_INTEGRATION
FILE_FORMAT = (
    TYPE = 'PARQUET' 
    SNAPPY_COMPRESSION = TRUE
)
;