RESULTSETs の操作¶

カーソルの使用による RESULTSET からのデータへのアクセス¶

カーソルを使用して RESULTSET からデータにアクセスするには、オブジェクト上で カーソルを宣言 します。例:

DECLARE
  ...
  res RESULTSET DEFAULT (SELECT col1 FROM mytable ORDER BY col1);
  c1 CURSOR FOR res;

RESULTSET でカーソルを宣言すると、カーソルはすでに RESULTSET にあるデータにアクセスできることに注意してください。カーソルで OPEN コマンドを実行しても、 RESULTSET のクエリは再度実行されません。

次に、 カーソルを開き、カーソルを使用して データをフェッチ します。

RESULTSET をテーブルとして返す¶

RESULTSET がポイントする結果を返す場合は、 RESULTSET を TABLE() に渡します。例:

CREATE PROCEDURE f()
  RETURNS TABLE(column_1 INTEGER, column_2 VARCHAR)
  ...
    RETURN TABLE(my_resultset_1);
  ...

Copy

これは、 TABLE() が テーブル関数 （RESULT_SCAN など）で使用される方法と似ています。

例に示すように、テーブルを返すストアドプロシージャを作成する場合は、テーブルを返すものとしてストアドプロシージャを宣言する必要があります。

カーソルを使用して RESULTSET から行をフェッチ した場合でも、 TABLE(resultset_name) によって返されるテーブルには、（カーソルの内部行ポインターから始まる行だけでなく）すべての行が含まれていることに注意してください。

例に対するデータの設定¶

以下の例の多くでは、以下に示すテーブルとデータを使用しています。

CREATE TABLE t001 (a INTEGER, b VARCHAR);
INSERT INTO t001 (a, b) VALUES
    (1, 'row1'),
    (2, 'row2');

Copy

例: ストアドプロシージャからテーブルを返す¶

次のコードは、 RESULTSET を宣言し、 RESULTSET がポイントする結果を返す方法を示しています。 CREATE PROCEDURE コマンドの RETURNS 句は、ストアドプロシージャが INTEGER型の1つの列を含むテーブルを返すことを宣言しています。

ブロック内の RETURN ステートメントは、 TABLE() 構文を使用して結果をテーブルとして返します。

ストアドプロシージャを作成します。

CREATE OR REPLACE PROCEDURE test_sp()
RETURNS TABLE(a INTEGER)
LANGUAGE SQL
AS
  DECLARE
    res RESULTSET default (select a from t001 order by a);
  BEGIN
    RETURN TABLE(res);
  END;

Copy

注: SnowSQL または Classic Console を使用している場合は、代わりに次の例を使用します（SnowSQL および Classic Console でのSnowflakeスクリプトの使用 を参照）。

CREATE OR REPLACE PROCEDURE test_sp()
RETURNS TABLE(a INTEGER)
LANGUAGE SQL
AS
$$
    DECLARE
        res RESULTSET default (select a from t001 order by a);
    BEGIN
        RETURN TABLE(res);
    END;
$$;

Copy

ストアドプロシージャを呼び出します。

CALL test_sp();
+---+
| A |
|---|
| 1 |
| 2 |
+---+

Copy

RESULT_SCAN 関数を使用して、ストアドプロシージャ呼び出しの結果を処理できることに注意してください。

SELECT *
    FROM TABLE(RESULT_SCAN(LAST_QUERY_ID()))
    ORDER BY 1;
+---+
| A |
|---|
| 1 |
| 2 |
+---+

Copy

例: SQL ステートメントを動的に作成する¶

SQL を動的に構築できます。以下は、上記のストアドプロシージャと同じクエリを実行するが、動的に構築される SQL ステートメントを使用する例です。

CREATE OR REPLACE PROCEDURE test_sp_dynamic(table_name VARCHAR)
RETURNS TABLE(a INTEGER)
LANGUAGE SQL
AS
  DECLARE
    res RESULTSET;
    query VARCHAR DEFAULT 'SELECT a FROM ' || :table_name || ' ORDER BY a';
  BEGIN
    res := (EXECUTE IMMEDIATE :query);
    RETURN TABLE (res);
  END;

Copy

注: SnowSQL または Classic Console を使用している場合は、代わりに次の例を使用します（SnowSQL および Classic Console でのSnowflakeスクリプトの使用 を参照）。

CREATE OR REPLACE PROCEDURE test_sp_dynamic(table_name VARCHAR)
RETURNS TABLE(a INTEGER)
LANGUAGE SQL
AS
$$
  DECLARE
    res RESULTSET;
    query VARCHAR DEFAULT 'SELECT a FROM ' || :table_name || ' ORDER BY a';
  BEGIN
    res := (EXECUTE IMMEDIATE :query);
    RETURN TABLE (res);
  END;
$$
;

Copy

例を実行するには、ストアドプロシージャを呼び出し、テーブル名を渡します。

call test_sp_dynamic('t001');

+---+
| A |
|---|
| 1 |
| 2 |
+---+

Copy

例: DEFAULT 句なしで RESULTSET 変数を宣言する¶

次のコードは、 DEFAULT 句なしで（つまり、クエリを RESULTSET に関連付けずに） RESULTSET を宣言し、後で RESULTSET をクエリに関連付ける方法を示しています。

CREATE OR REPLACE PROCEDURE test_sp_02()
RETURNS TABLE(a INTEGER)
LANGUAGE SQL
AS
  DECLARE
    res RESULTSET;
  BEGIN
    res := (select a from t001 order by a);
    RETURN TABLE(res);
  END;

Copy

注: SnowSQL または Classic Console を使用している場合は、代わりに次の例を使用します（SnowSQL および Classic Console でのSnowflakeスクリプトの使用 を参照）。

CREATE OR REPLACE PROCEDURE test_sp_02()
RETURNS TABLE(a INTEGER)
LANGUAGE SQL
AS
$$
    DECLARE
        res RESULTSET;
    BEGIN
        res := (select a from t001 order by a);
        RETURN TABLE(res);
    END;
$$;

Copy

例: CURSOR を RESULTSET で使用する¶

次のコードは、 カーソル を使用して RESULTSET の行を反復処理する方法を示しています。

ストアドプロシージャを作成します。

CREATE OR REPLACE PROCEDURE test_sp_03()
RETURNS VARCHAR
LANGUAGE SQL
AS

  DECLARE
    accumulator INTEGER DEFAULT 0;
    res1 RESULTSET DEFAULT (select a from t001 order by a);
    cur1 CURSOR FOR res1;
  BEGIN
    FOR row_variable IN cur1 DO
      accumulator := accumulator + row_variable.a;
    END FOR;
    RETURN accumulator::VARCHAR;
  END;

Copy

注: SnowSQL または Classic Console を使用している場合は、代わりに次の例を使用します（SnowSQL および Classic Console でのSnowflakeスクリプトの使用 を参照）。

CREATE OR REPLACE PROCEDURE test_sp_03()
RETURNS INTEGER
LANGUAGE SQL
AS
$$
    DECLARE
        accumulator INTEGER DEFAULT 0;
        res1 RESULTSET DEFAULT (select a from t001 order by a);
        cur1 CURSOR FOR res1;
    BEGIN
        FOR row_variable IN cur1 DO
                accumulator := accumulator + row_variable.a;
        END FOR;
        RETURN accumulator;
    END;
$$;

Copy

ストアドプロシージャを呼び出します。

CALL test_sp_03();
+------------+
| TEST_SP_03 |
|------------|
| 3          |
+------------+

Copy