構文リファレンス

プログラムは、Pipe構文を使ったGoogleSQLです。このページは、そのテキストに書けるすべての形を1か所に集めたものです。プログラムの構成、Pipe演算子（GoogleSQLのものと、ActQLが足したもの）、ベクトル・グラフ・イベントの名前付き呼び出し、INFER、NEAREST、SERIALIZE、そしてEffectを載せます。普通のSQL（SELECT、JOIN、スカラー関数）はSQL互換性と型と関数にあります。各環境で現時点にどの形が動くかは実装状況にあります。

各項目には、形（[ ] は省略可、… は繰り返し、キーワードは大文字）、各部、意味、既定値、check を通る最小の例、check が報告するエラー、それを定義する仕様の節を載せます。例はクイックスタートのプロジェクトの接続を前提にし、パラメーターは明示します。それぞれの例はビルド時にフィクスチャに対して検査されます。

1. プログラムの構成Copy Anchor Link

プログラムのテキストCopy Anchor Link

形

[WITH name AS (…), …] SELECT … [|> step …] [|> EFFECT …]
[WITH name AS (…), …] FROM source [JOIN …] |> step … [|> EFFECT …]
CREATE [OR REPLACE] TABLE conn.table AS (query)

各部

意味 1つのテキストは1つのクエリで、任意でデータを変えるEffect1つで終わり、その後ろに名前付きResultに対するCommandの後置を任意の数だけ続けられます（Effectを参照）。末尾の ; は許されます。; はクエリと後置を区切るもので、文をつないだりテキストをスクリプトにしたりはしません。順序のあるステップが必要なワークフローは、テキストが変換されるProgramモデルにJSONやYAMLで複数のStageとして書きます。FROM で始まるクエリには、裸の WHERE、ORDER BY、LIMIT はありません。最初の |> より後ろでは、すべての演算がステップです。Pipeは論理的な合成にすぎず、Stage、Checkpoint、実行の境界を作りません。

例

FROM support.cases AS c
|> WHERE c.status = 'open'
|> AGGREGATE COUNT(*) AS open_cases GROUP BY c.account_id
|> ORDER BY open_cases DESC
|> LIMIT 10;

エラー query_syntax_invalid（2つ目の文、最後でないEffect、FROM の後ろの裸の句）。

仕様 SQL and explicit Pipe boundaries

WITHCopy Anchor Link

形

WITH name AS ( query | GRAPH (…) | time_series(…) | calendar_series(…) | mean_graphs(…) ), …

各部

意味 束縛は、値（テーブル、Graph、Vectors、Events）に名前を付け、後ろのステップから参照できるようにします。名前を付けても、読み取りも公開もしません。宣言そのものは読み取りを行わず、その名前がResultに現れることはありません。実行時には、意味を保ったまま、Hostが参照の間で1つの観測を共有したり計算を最適化したりできます。本体は副作用を持ちません。INFER、RESULT、EFFECT は本体の中では受け付けません。

例

WITH open_cases AS (FROM support.cases |> WHERE status = 'open')
SELECT account_id, COUNT(*) AS n FROM open_cases GROUP BY account_id;

エラー query_syntax_invalid（本体の中の INFER、RESULT、EFFECT）、query_invalid（名前の二重定義、解決できない名前）。

仕様 WITH producers and pure Graph construction

WITH と AS と RESULTCopy Anchor Link

読み取りだけのプログラムは、RESULT を宣言しなければ最終的なレコードをResult main として公開します。Effectで終わるプログラムは、RESULT を宣言しない限りResultを公開しません。RESULT は文の直下でだけ受け付けられ、WITH、派生テーブル、集合演算のオペランドの中には書けません。Resultは宣言した時点で確定し、後ろの SELECT や LIMIT で変わることはありません。

仕様 Named intermediate Results

パラメーターCopy Anchor Link

形 @name

意味 パラメーターは、プログラムが型付きで宣言し、実行時に渡します（--params、parameters）。パラメーターは値です。テキストに補間されることはなく、演算を選ぶことも、リソースを指定することもありません。式が書ける場所ならどこでも、また LIMIT/OFFSET と作者のガードに使えます。

例

SELECT id, name FROM crm.accounts WHERE owner = @owner;

エラー parameter_undeclared、parameter_unused、supplied_value_type_mismatch。

仕様 Parameters

UNNESTCopy Anchor Link

形

FROM UNNEST(array_expr) [AS] element [WITH OFFSET [AS] position]
… JOIN UNNEST(array_expr) [AS] element [ON cond]
… CROSS JOIN UNNEST(array_expr) [AS] element

意味 配列を、要素ごとに1レコードへ展開します。element は要素の値全体の名前です。要素がオブジェクトなら、そのフィールドも element.field として見えます。配列には、パラメーター（UNNEST(@items)）、ARRAY[…] 構築子、現在のレコードの列（相関展開）を使えます。NULL と空の配列はレコードを作りません。

例

SELECT element.id, position
FROM UNNEST(@items) AS element WITH OFFSET AS position;

エラー query_expression_invalid（配列でない）、query_invalid（別名の重複）。

仕様 Declared UNNEST value tables

FROM のない SELECTCopy Anchor Link

形 SELECT expr [AS name], …（FROM なし）

意味 式とパラメーターだけから作る、論理的な1レコードです。WHERE が偽ならレコードはありません。ほかのクエリと同じように、集合演算、WITH の本体、JOIN に使えます。

例

SELECT @account_id AS id, 'high' AS level;

仕様 Source-free SELECT

ARRAY 構築子Copy Anchor Link

形

[expr, …]              -- 裸の形。型は要素から推定
ARRAY[expr, …]         -- 同じものを明示した形
ARRAY<T>[]             -- 空の配列には要素の型が要る

T は BOOL、BOOLEAN、STRING、FLOAT64、DOUBLE、TIMESTAMP、JSON のいずれかです。

意味 有限の配列です。要素は1つの型を共有する必要があり、空の配列には明示的な ARRAY<T> の注釈が要ります（ARRAY<STRING>[]）。配列は、IN UNNEST、UNNEST の読み取り元、そして値として使えます。

例

SELECT id FROM crm.accounts WHERE tier IN UNNEST(['gold', 'platinum']);

エラー expression_type_mismatch（要素の型が混在、[] に注釈がない）。

仕様 ARRAY constructors

LIST_FILESCopy Anchor Link

形 FROM LIST_FILES(connection.listing | connection [, paths => [string, …] | glob => string]) [AS alias]

各部

意味 一覧が公開するファイルを、resource、version、path、media_type、size と、Connectorが持つそのほかのメタデータの列を持つレコードとして読み取る読み取り元です。paths と glob は排他です。選択子を書かないことが一覧全体を意味するわけではありません。Connectorが無条件の一覧を許可し、プログラムの件数の上限の中に収められる必要があります。上限で途中までになった一覧は不完全として報告され、全体として扱われることはありません。一覧に対する LIMIT は少ないファイルを求める指定であって、それを全部とみなす許可ではありません。一覧は内容を読みません。ファイルの内容は別の読み取り元 connection.contents（resource、version、取り込んだバイト列のメディアタイプを持つ content_ref の content）にあり、resource と version でJOINします。プログラムは読むバージョンを正確に指定することになります。

例

FROM LIST_FILES(gcs.objects, glob => r'reports/*.csv') AS f
|> JOIN gcs.contents AS c ON f.resource = c.resource AND f.version = c.version
|> SELECT f.path, f.media_type, c.content;

エラー query_syntax_invalid（両方の選択子）、source_selector_unregistered（その一覧がない。一覧の読み取り元が複数ある接続を裸で指定した）。

仕様 File listing Sources

2. Pipe演算子Copy Anchor Link

Pipe構文はGoogleSQLのものです。最初の FROM の後ろ（または完全な SELECT の後ろ）のステップは、すべて |> で始め、直前のステップのレコードを入力にします。最初の表は、GoogleSQLのPipe演算子のうちActQLが受け付けるものを、GoogleSQLと同じ意味で載せます。2つ目の表は、ActQLが足した演算子です。

GoogleSQLの演算子

この表にないGoogleSQLの演算子（CALL、独立したステップとしての WINDOW、TABLESAMPLE）は0.1では受け付けず、check が名前付きの理由で拒否します。SELECT や EXTEND の中の WINDOW 句は受け付けます。

ActQLが足した演算子

句の引数は、その演算子の中に収まります。AGGREGATE の GROUP BY、JOIN の ON、INFER の INPUT、LIMIT の OFFSET、SERIALIZE の OPTIONS が、独立した |> を取ることはありません。

仕様 SQL and explicit Pipe boundaries、 Scope and lowering

SET、EXTEND、ASCopy Anchor Link

SET は、置き換えた値を新しい値のスロットに束縛します。古い値から確定した INFER のキーが付け替えられることはありません。SELECT は、列を選ぶことと範囲スコープを終えることの両方を行うステップです。

仕様 Scope and lowering

3. 名前付き呼び出しの引数Copy Anchor Link

名前付き呼び出しは |> name(key: value, …) と書きます。キーは演算ごとに閉じていて、大文字小文字を区別しません。予約語のキーはバッククォートで囲みます。各値の役割は、値の書き方ではなく、演算のシグネチャで決まります。

つまり interval_join(with: spans, …) は WITH のproducer spans と結合しますが、with: 'spans' は文字列なので拒否されます。数値リテラルには先頭に + か - を1つ付けられます。パラメーターや計算式に符号は付けられません。未知のキー、重複するキー、役割の違う値は、何かが動く前に拒否されます。

仕様 Named logical SGA calls

4. ガードとアサーションCopy Anchor Link

どちらもActQL独自の形です。GoogleSQLにはJOINに対するガードがありません。ASSERT UNIQUE BY はActQLの assert_rows 演算のための書き方で、GoogleSQLの一部の実装にある |> ASSERT condition 演算子とは別のものです。その演算子は受け付ける形には含まれません。

MAX_OUTPUT_ROWSCopy Anchor Link

形 … JOIN source ON cond MAX_OUTPUT_ROWS n

意味 1つのJOINに対する作者のガードです。JOINの出力が n レコードを超えるなら、上限の名前とともにRunが失敗します。切り詰めることはありません。n は正の整数リテラルかパラメーターです。WITH の中のJOINを含め、各 JOIN が自分のガードを持ちます。

例

FROM salesforce.accounts AS a
JOIN snowflake.usage_30d AS u ON a.id = u.account_id MAX_OUTPUT_ROWS 100000
|> SELECT a.id, u.active_users;

エラー operation_parameter_invalid（ゼロ、負、許容される上限を超える）。

仕様 Composition assertions

ASSERT UNIQUE BYCopy Anchor Link

形 |> ASSERT UNIQUE BY (col, …)

意味 列挙した列が、現在のレコード全体で存在し、NULLでなく、一意であることを証明し、すべてのレコードをそのままの順序で通します。重複があればRunが失敗します。重複を取り除くことはありません。読み取り元でキーが証明されていないとき、後ろの INFER や EFFECT … ID が頼れるのがこの証明です。

例

FROM sheets.leads
|> ASSERT UNIQUE BY (email)
|> SELECT email, company;

エラー query_invalid（空のキーの一覧、解決できない列）。実行時には、最初の重複キーを示すアサーションの失敗。

仕様 Composition assertions、 assert_rows

5. LLMとベクトルCopy Anchor Link

INFER は各レコードをmodel taskに送ります。ベクトルの形は、すでにあるベクトルに対して働きます。score_vectors はVectorsの集合に1つのクエリベクトルに対するスコアを付け、NEAREST はレコードごとのクエリに対して候補の上位K件を返します。テキストから埋め込みを作るのは別のmodel taskで、どちらの形も暗黙には行いません。

INFERCopy Anchor Link

形

|> INFER `model-task:<name>.v<n>`
     [ITEM KEY (col, …)]
     INPUT (col | expr AS field | field = expr, …)
     [KEEP (col [AS name] | * | alias.*, …)]
     AS name
     [MAX ITEMS n]
     [ON FAILURE FAIL]

各部

意味 各レコードの INPUT をtaskのLLMに送り、オブジェクトの列 name を1つ足します。name.outcome（ok または failed:<reason>）、name.value（ok のときはtaskの型付きの出力、それ以外は NULL）、name.input_key を持ちます。LLMが答えられなかったレコードもほかと一緒に返ってくるので、name.value を読む前に name.outcome で絞り込んでください。入力の列はレコードに残り、そのままJOINや絞り込みに使えます。

既定値

例

FROM salesforce.accounts AS a
JOIN snowflake.usage_30d AS u ON a.id = u.account_id
|> INFER `model-task:churn-risk.v1`
     INPUT (notes = a.description, active_users = u.active_users, trend = u.trend) AS risk
|> WHERE risk.outcome = 'ok' AND risk.value.level = 'high';

エラー query_invalid（未知のtask、入力フィールドの不足や余分、証明できるキーがない、KEEP の名前の重複、AS の名前との衝突）、expression_type_mismatch（入力の型）、operation_parameter_invalid（MAX ITEMS）。

仕様 INFER KEEP source projection、 infer

NEARESTCopy Anchor Link

形

|> NEAREST candidates [AS c]
     [USING expr | QUERY KEY (col, …) VECTOR expr]
     [CANDIDATE KEY (col, …) VECTOR expr]
     [METRIC cosine | dot | l2]
     K n
     [KEEP (col [AS name] | * | alias.*, …)]
     AS hit

各部

意味 現在の各レコードについて、指標のもとでスコアが最も良い K 件の候補を見つけ、一致ごとに1レコードを出します。検索は指標のもとで厳密です。ActQLが近似インデックスに置き換えることはありません。hit には hit.score、hit.rank、hit.query_key、hit.candidate_key と、候補に body 列があれば hit.body が入ります。候補のほかの列は KEEP (c.col) で取り出します。一致のないレコードはレコードを出しません。l2 のスコアは距離の符号を反転したものなので、「最も良い」は常にスコアが最大のものです。

既定値

例

SELECT c.id, c.description AS question, c.embedding AS query_vec
FROM salesforce.cases AS c
WHERE c.priority = 'urgent'
|> NEAREST kb.articles USING query_vec K 3 AS hit
|> AGGREGATE ARRAY_AGG(hit.body ORDER BY hit.rank) AS refs GROUP BY id, question;

エラー query_syntax_invalid（VECTOR のない KEY、USING と QUERY の併用）、query_invalid（ベクトル列やキーがない、またはあいまい、KEEP の名前の重複）、operation_parameter_invalid（K）。

仕様 NEAREST KEEP source projection、 nearest

ベクトルの呼び出しCopy Anchor Link

例

WITH v AS (FROM kb.articles |> to_vectors(id: id, vector: embedding) |> normalize_vectors())
FROM v
|> score_vectors(query: @query_vec, metric: 'cosine')
|> vectors()
|> ORDER BY score DESC |> LIMIT 5;

エラー query_invalid（Carrierの不一致。vectors() なしでVectorsに ORDER BY などRelationのステップを適用）、operation_parameter_invalid（query の次元が違う、またはNULLを含む）。

仕様 Vector-set-preserving operations and bridges、 pool_vectors

ベクトル関数Copy Anchor Link

vector_score とその別名は、同じ次元の2つのベクトルを要求します。NULL はどの関数でも伝播します。

仕様 Row-local vector expressions、 Decoding and expression rules

6. グラフCopy Anchor Link

GRAPH 構築子Copy Anchor Link

形

WITH g AS (GRAPH (
  NODE TABLES (rows [AS N] KEY (col, …) [LABEL Name | DEFAULT LABEL] [PROPERTIES (col [AS name], …) | PROPERTIES ARE ALL COLUMNS [EXCEPT (…)] | NO PROPERTIES], …)
  [EDGE TABLES (rows [AS E] KEY (col, …)
                SOURCE KEY (col, …) REFERENCES N [(col, …)]
                DESTINATION KEY (col, …) REFERENCES N [(col, …)]
                [LABEL Name] [PROPERTIES (…)], …)]
))

意味 RelationからGraphの値を作ります。各ノードテーブルは KEY をキーとするノードを、各エッジテーブルは両端が REFERENCES でノード定義を参照するエッジを提供します。ラベルとプロパティは定義に属します。Graphはプログラムの中にだけ存在し、カタログのオブジェクトは作られません。これはGoogleSQL/SQL-PGQのテーブル対応であって、ISO GQLの CREATE GRAPH ではありません。

例

WITH accounts AS (FROM crm.accounts |> SELECT id, name),
     refs AS (FROM crm.referrals |> SELECT id, from_id, to_id),
     g AS (GRAPH (
       NODE TABLES (accounts AS Account KEY (id) LABEL Account PROPERTIES (name))
       EDGE TABLES (refs AS Referred KEY (id)
                    SOURCE KEY (from_id) REFERENCES Account
                    DESTINATION KEY (to_id) REFERENCES Account
                    LABEL Referred NO PROPERTIES)
     ))
FROM g |> MATCH (a:Account)-[:Referred]->(b:Account) |> SELECT a.name, b.name AS referred;

エラー graph_operation_invalid（REFERENCES の定義が未知、ラベルの重複、キーの型の不一致）。

仕様 WITH producers and pure Graph construction、 graph

MATCHCopy Anchor Link

形

FROM [GRAPH] g
|> MATCH [p =] [WALK | TRAIL | ACYCLIC] node (edge node)…

node  ::= ( [var] [:Label] [{prop: expr, …} | WHERE cond] )
edge  ::= -[ [var] [:Label] [{…} | WHERE cond] ]->  |  <-[ … ]-  |  -[ … ]-  |  ->  |  <-  |  -
          [ {n} | {m,n} ]

各部

意味 一致ごとに1レコードを出し、パターンの変数を束縛します。Graphの読み取り元1つにつき MATCH は1つです。2つ目のパターンには、別の読み取り元と普通のJOINが要ります。MATCH の後ろの SELECT はパターンのスコープを終え、その列だけを出します。これはGoogleSQLの要素パターンのプロファイルであって、GQL全体ではありません。

既定値 パスのモードは WALK。

例

FROM g
|> MATCH ACYCLIC (a:Account WHERE a.tier = 'gold')-[:Referred]->{1,3}(b:Account)
|> SELECT a.name AS source, b.name AS reached;

エラー query_syntax_invalid（上限のない量指定子、2つ目の MATCH）、graph_operation_invalid（未知のラベル、すべての候補にないプロパティ）、query_invalid（Graphに対するレコードの別名）。

仕様 Graph pattern source、 Graph operations

グラフの呼び出しCopy Anchor Link

断りがなければ、どれも現在の入力としてGraphを取ります。列挙値の引数は文字列で、direction は 'out'、'in'、'both' のいずれかです。

例

WITH seeds AS (FROM crm.accounts |> WHERE tier = 'gold' |> SELECT id)
FROM g
|> reach(start: {from: seeds, id: id}, direction: 'out', max_depth: 2)
|> SELECT start_id, node_id, depth;

FROM g
|> shortest_path(source: 'acc_1', target: 'acc_9', direction: 'out', max_hops: 5)
|> SELECT total_cost, hop_count, node_ids;

WITH stats AS (FROM g |> degree(direction: 'out'))
FROM stats |> WHERE degree > 10 |> SELECT node_id, degree |> RESULT hubs;

エラー graph_operation_invalid（必須のキーがない、Carrierの不一致、producerや列を期待する位置に文字列）、operation_parameter_invalid。

仕様 Named logical SGA calls、 Graph operations

7. イベントと時間Copy Anchor Link

イベントの呼び出しCopy Anchor Link

to_events はレコードをEvents Carrierにし、events() はそれを戻します。その間の呼び出しは、与えられたCarrierを保ちます。時刻の引数（time、left_time、right_time、start、end）は timestamp の列か、エポックからのミリ秒の整数列です。列そのものはそのまま保たれます。occurred_ms を自分で作らず、occurred_at をそのまま渡してください。

生成子Copy Anchor Link

生成子は入力を読まないので、WITH の本体（またはPipeの先頭）であって、|> のステップにはなりません。

calendar_bucketCopy Anchor Link

形 |> calendar_bucket(time: col, into: name, unit: '…', timezone: '…' [, week_start: '…'])

意味 指定したタイムゾーンで time を含む暦のバケットを、列 name として足します。

例

WITH records AS (FROM app.events |> SELECT id, account_id, occurred_at, kind)
FROM records AS e
|> sequence(by: [e.account_id], id: e.id, time: e.occurred_at,
     pattern: [{as: first, where: e.kind = 1}, {as: second, where: e.kind = 2}],
     within: 20, max_output_rows: 100)
|> SELECT first_id, second_id;

WITH ticks AS (FROM market.ticks |> SELECT id, at),
     spans AS (FROM market.spans |> SELECT id, begin, finish)
FROM ticks AS t
|> interval_join(with: spans, kind: 'left', mode: 'point_in_interval',
     on: [], left: {time: t.at}, right: {start: spans.begin, end: spans.finish},
     select: {id: left.id, value: right.id}, max_output_rows: 1000)
|> SELECT id, value;

WITH days AS (calendar_series(start: '2026-01-01T00:00:00.000Z',
                              end: '2026-03-01T00:00:00.000Z',
                              unit: 'day', timezone: 'Asia/Tokyo'))
FROM days AS d
|> calendar_bucket(time: d.start, into: month, unit: 'month', timezone: 'Asia/Tokyo')
|> AGGREGATE COUNT(*) AS days GROUP BY month;

エラー query_invalid（Carrierの不一致、必須のキーがない）、operation_parameter_invalid（負の大きさ、week 以外の単位での week_start、リテラルが必要な位置のパラメーター）。

仕様 Event operations、 Relational temporal operations、 sequence、as-of join、 interval join、merge_rankings、 Calendar profile、 Named finite event sequences

8. シリアライズとその他のActQL関数Copy Anchor Link

SERIALIZECopy Anchor Link

形

|> SERIALIZE FORMAT CSV | JSONL
     ORDER BY col [ASC | DESC], … | PRESERVE ORDER
     OPTIONS (name = '…', header = TRUE | FALSE, null_marker = '' | r'\N',
              field_delimiter = '…', encoding = '…', line_ending = 'LF' | 'CRLF',
              max_rows = n, max_bytes = n)

各部

意味 現在のレコードを1つのコンテンツにエンコードします。出力はちょうど name、content（content_ref）、media_type、size_bytes、row_count を持つ1レコードで、入力の列は残りません。これはコンテンツを作る明示的な境界です。何もアップロードはしません。コンテンツをどこかへ書くのは、後ろの EFFECT STORE です。

例

FROM support.cases
|> WHERE status = 'open'
|> SELECT id, subject, opened_at
|> SERIALIZE FORMAT CSV ORDER BY opened_at
     OPTIONS (name = 'open-cases.csv', header = TRUE, null_marker = '')
|> EFFECT STORE s3.objects SET (key = 'exports/' || name, content = content);

エラー query_syntax_invalid（順序の句や OPTIONS がない）、operation_parameter_invalid（未知または重複するオプション、リテラルでない値、CSVでの header/null_marker の欠落）。

仕様 Content serialization、 serialize

GoogleSQLと意味が違う関数、ActQL独自の関数Copy Anchor Link

型と NULL の規則を含む関数の完全な一覧は、型と関数にあります。

仕様 Decoding and expression rules、 Common expression contract

9. EffectCopy Anchor Link

プログラムが外部システムを変える手段は、Effectだけです。テキストの中でEffectを置ける場所は2つあります。Pipeの終端にはデータを変えるEffect（UPDATE、INSERT、UPSERT、DELETE、STORE、CREATE TABLE）を多くても1つ。そして、終端の ; の後ろには、クエリの名前付きResultをそれぞれ読むCommandの後置をいくつでも（この節の最後にある長い形式）。Pipeの中の2つ目のデータを変えるEffectや、WITH の中のEffectは拒否されます。1つのテキストで宣言したEffectは1つのStageに属し、1つのEffect Setになります。まとめて検査され、1つのCheckpointで承認されます。順序を守る必要のある処理（書き込んでから、その内容を通知する）は、文をつなぐのではなく、ProgramモデルのStageとして表現します。Effectの値は、現在のレコードに対する純粋な式です。列、リテラル、それらに対する関数が書けます。値は何かを送る前に評価され、評価された値がPreviewに固定され、承認の対象になります。すべてのEffectは、何かを送る前にポリシーを通り、ポリシーが求めるときはCheckpointを通ります。承認はEffect Set全体に対して行われ、Effectが1つならそのEffectが対象です（Effectと承認）。

対象とMapping。 conn.resource は、接続と、そのConnectorが公開するリソースの1つを指定します（actql catalog show conn）。書き込みのMapping、つまり設定できるフィールド、その型、キーは、Connectorがそのリソースについて公開している書き込みスキーマからHostが解決します。作者がMappingを指定することはありません。複数のMappingやCommand契約を公開しているリソースは、この節の最後にある長い形式で指定します。

EFFECT UPDATECopy Anchor Link

形 |> EFFECT UPDATE conn.resource ID key SET (field = value, …)

各部

意味 レコードごとに1件を、キーで更新します。Previewにはすべての対象とフィールドの変更が並びます。書き込みのあと、各項目は applied、failed、unknown のいずれか（あとで書き込みを確認するConnectorでは accepted）になり、キーで突き合わせられます。

例

FROM salesforce.accounts AS a
|> WHERE a.id = @account_id
|> EFFECT UPDATE salesforce.Account ID id SET (Churn_Risk__c = 'high');

エラー query_invalid（未知のリソース、書き込みスキーマにないフィールド、フィールドの重複、キーの列がない）、expression_type_mismatch。

EFFECT INSERTCopy Anchor Link

形 |> EFFECT INSERT conn.resource (col, …) [VALUES (value, …)]

意味 レコードごとに1件を作成します。VALUES がなければ、各レコードの列挙した列が同じ名前のフィールドに書かれます。VALUES があれば、列挙した各列が対応する式の値を受け取ります。

例

FROM webshop.signups
|> WHERE created_at > @since
|> EFFECT INSERT hubspot.contacts (email, company) VALUES (email, company_name);

EFFECT UPSERTCopy Anchor Link

形 |> EFFECT UPSERT conn.resource ID key SET (field = value, …)

意味 そのキーのレコードを更新し、なければ作成します。Previewと結果は UPDATE と同じです。applied の項目には、どちらだったかの内訳（action: created または action: updated）が付きます。

EFFECT DELETECopy Anchor Link

形 |> EFFECT DELETE conn.resource ID key

意味 レコードごとに1件を、キーで削除します。Previewには対象が並びます。

EFFECT STORECopy Anchor Link

形 |> EFFECT STORE conn.resource [SET (field = value, …)]

意味 コンテンツまたはレコードを保存します。オブジェクトやファイルのリソース（s3.objects、gcs.objects、drive.files）に向けると、各レコードの content（SERIALIZE が作った、または contents の読み取り元から読んだ content_ref）を1つのオブジェクトとして書きます。SET のフィールドは保存先が受け取る入力で、それぞれレコードに対する式です。オブジェクトの置き場所（key、name、folder など）、content そのもの、既存のオブジェクトを置き換えてよいか（overwrite）を渡します。これらはEffectの設定ではなく、Effectのデータです。content のないレコードは拒否されます。Relationがコンテンツになるのは SERIALIZE を通したときだけです。Connectorが宣言するテーブルのリソース（local.<table>、tableau.datasources）に向けると、レコードそのものを、そのリソースが宣言する形で保存します。Previewには、保存先、コンテンツそのもの（コンテンツの識別子）または件数、そして上書きの条件が固定されます。リソースごとに受け取るフィールドは各Connectorのページにあります。

例

FROM support.cases
|> WHERE status = 'open'
|> SELECT id, subject, opened_at
|> SERIALIZE FORMAT CSV ORDER BY opened_at
     OPTIONS (name = 'open-cases.csv', header = TRUE, null_marker = '')
|> EFFECT STORE s3.objects SET (key = 'exports/' || name, content = content);

エラー query_invalid（オブジェクトのリソースに対して content の列がない、不明なフィールド）、expression_type_mismatch（content が content_ref でない）。

EFFECT COMMANDCopy Anchor Link

形 |> EFFECT COMMAND conn.operation [TARGET expr] ID key [INPUT (field = value, …)]

各部

意味 名前付きの操作をレコードごとに1回実行します。メッセージの送信、抽出の更新、ジョブの開始などです。契約が、入力の型、対象の種類、必要な権限、Previewに出る内容、結果の確認方法を決めます。check はそのすべてを検査します。項目ごとの結果は accepted（システムが要求を受け付けた）、applied（結果を確認した）、failed、unknown のいずれかです。不明な結果はConnector自身の証拠で確認し、再送はしません。複数のCommand契約を公開しているリソースは、この節の最後にある長い形式で指定します。

例

FROM support.replies AS r
|> WHERE r.status = 'ready'
|> EFFECT COMMAND gmail.send
     ID r.id
     INPUT (to = r.recipient, subject = r.subject, body = r.body);

エラー query_invalid（不明な操作、入力フィールドの不足や余り、TARGET が必須なのに無い、または受け付けないのに有る）、expression_type_mismatch（入力や対象の型）。

CREATE TABLECopy Anchor Link

形

CREATE [OR REPLACE] TABLE conn.table AS (query)
… |> [EFFECT [name]] CREATE [OR REPLACE] TABLE conn.table

意味 レコードをテーブル全体として書き込みます。CREATE はテーブルが存在しないことを要求し、CREATE OR REPLACE は同じスキーマでテーブル全体を置き換えます。作成時の競合は、OR REPLACE でも競合のままです。これはstoreのEffectで、storeと同じようにPreviewと承認を通ります。

例

FROM snowflake.usage_30d
|> WHERE active_users > 0
|> CREATE OR REPLACE TABLE duckdb.active_usage;

仕様 Table create and whole-table replace

SQL文の形Copy Anchor Link

形

UPDATE conn.resource SET field = value, … WHERE cond;
INSERT INTO conn.resource (col, …) VALUES (value, …) | SELECT …;
DELETE FROM conn.resource WHERE cond;

意味 EFFECT UPDATE、EFFECT INSERT、EFFECT DELETE と同じEffectです。WHERE がキーの列との等価なら、キーで書き込みます。それ以外の WHERE では、Previewの時点で対象を選びます。Hostが一致するレコードを読んで、その識別子とバージョンを固定し、Previewにはちょうどそれらが並び、承認はそれらだけに及びます。適用時に WHERE を評価し直すことはないので、そのときに一致するようになったレコードが加わることはありません。適用時には各対象の条件（バージョンか現在の値）を確認し、変わっていたレコードは failed（conflict）で終わります。対象の集合とその条件をこの形で固定できないConnectorは、この形式を check で拒否します。キーによる書き込みが突き合わせはいちばん簡単ですが、WHERE で選んだ書き込みも、Connectorに操作ID、冪等性キー、監査記録があれば突き合わせられます。

例

UPDATE salesforce.Account
SET Churn_Risk__c = 'high'
WHERE Id = @account_id;

長い形式Copy Anchor Link

リソースが複数のMappingやCommand契約を公開しているときは、どれを使うかを指定します。

|> EFFECT mark UPDATE
     TARGET 'connector://salesforce/Account'
     MAPPING `mapping:salesforce.account-risk.v1`
     ID id SET (Churn_Risk__c = risk.value.level);

FROM support.escalations |> SELECT channel, message |> RESULT escalations;
EFFECT notify COMMAND
  FROM RESULT escalations AS e
  TARGET e.channel
  CONTRACT `command:slack.post.v1`
  INPUT (text = e.message);

TARGET はリソースのURI、MAPPING または CONTRACT は公開された契約、省略可能なEffectの名前（mark、notify）はRunの状態や台帳がそのEffectを指すときの名前です。COMMAND の長い形式は ; で終わるクエリの後ろに置き、そのクエリの RESULT の1つを参照します。短い形式は、Effectの名前、Mapping、ResultをHostに任せた長い形式です。

エラー query_invalid（未知のMappingや契約、保持されていないResult、Pipeの中の2つ目のデータを変えるEffect）。

仕様 Terminal updates、 COMMAND postludes、 Effect declarations

10. 予定している構文Copy Anchor Link

RESULT(name) — 同じプログラムの中で先に公開したResultへの参照で、読み取り元として使えます（FROM RESULT(updates)）。1つのプログラムがレコードを公開し、公開したちょうどその内容から続けられるようにするものです。0.1より後の予定です。

BRANCH — それぞれが自分のResultを公開するステップのまとまりを、1つのプログラムの下で動かす本体です。共通の前段を繰り返さずに、1つのテキストから複数のResultへ分岐できるようにするものです。0.1より後の予定です。

11. クエリ構文のないプログラム演算Copy Anchor Link

JSON/YAMLのプログラム文書には、SQLやPipeでは直接書けない演算があります。存在しないキーワードを探すことのないよう、ここに挙げます。|> name(…) とは書きません。

仕様 top_k、nest、 Reshaping and nested data、 search_candidates、 text_rank、 Effect declarations