SQL ステートメントは、Snowflake でパイプを作成するためのコマンドです。これは、Snowpipe が取り込みキューから tables1 にデータをロードするために使用する COPY INTO <table> ステートメントを定義するオブジェクトです。このステートメントは、FROM 句でサブクエリを使用して、ステージングされたファイルのデータを table2 にロードする前に変換します。
サブクエリでサポートされている変換は次のとおりです2:
データはオプションの WHERE 句によってフィルタリングできます。これは、サブクエリによって返された行が満たす必要がある条件を指定します。例えば：
SQLAI によって生成されたコード。慎重に確認して使用してください。詳細については FAQ をご覧ください。
パイプ mypipe を次のように作成します
mytableにコピーする
から （
@mystage から * を選択
ここで、col1 = 'A'、col2 > 10
);
列は並べ替えることができます。これは、サブクエリ内の列の順序を変更して、ターゲット テーブル内の列の順序と一致させることを意味します。例えば：
SQLAI によって生成されたコード。慎重に確認して使用してください。詳細については FAQ をご覧ください。
パイプ mypipe を次のように作成します
mytable にコピー (col1、col2、col3)
から （
@mystageからcol3、col1、col2を選択
);
列は省略できます。これは、ターゲットテーブルで必要のない一部の列をサブクエリから除外することを意味します。例えば：
SQLAI によって生成されたコード。慎重に確認して使用してください。詳細については FAQ をご覧ください。
パイプ mypipe を次のように作成します
mytable (col1、col2) にコピーします。
から （
@mystageからcol1、col2を選択
);
他のオプションはサブクエリではサポートされていません。理由 2:
型キャストはサポートされていません。これは、サブクエリ内の列のデータ型を変更することを意味します。たとえば、次のステートメントではエラーが発生します。
SQLAI によって生成されたコード。慎重に確認して使用してください。詳細については FAQ をご覧ください。
パイプ mypipe を次のように作成します
mytable (col1、col2) にコピーします。
から （
@mystageからcol1::date、col2を選択
);
受信データを他のテーブルと結合することはできません。これは、ステージングされたファイルのデータをサブクエリ内の別のテーブルのデータと結合することを意味します。たとえば、次のステートメントではエラーが発生します。
SQLAI によって生成されたコード。慎重に確認して使用してください。詳細については FAQ をご覧ください。
パイプ mypipe を次のように作成します
mytable にコピー (col1、col2、col3)
から （
@mystage から s.col1、s.col2、t.col3 を選択します
s.col1 = t.col1 で他のテーブル t を結合します
);
ON ERROR - ABORT ステートメント コマンドは使用できません。つまり、エラーが発生した場合はロード操作全体が中止されます。このコマンドは COPY INTO <table> ステートメントでのみ使用でき、サブクエリでは使用できません。たとえば、次のステートメントではエラーが発生します。
SQLAI によって生成されたコード。慎重に確認して使用してください。詳細については FAQ をご覧ください。
パイプ mypipe を次のように作成します
mytableにコピーする
から （
@mystage から * を選択
エラー中止時
);
参照：
1: パイプを作成する | スノーフレークのドキュメント
2: ロード中のデータの変換 | スノーフレークのドキュメント