RESULTSET 작업하기¶

커서를 사용하여 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 타입의 열 하나를 포함하는 테이블을 반환한다고 선언합니다.

블록 내부의 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 Scripting 사용하기 참조).

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 Scripting 사용하기 참조).

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 Scripting 사용하기 참조).

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

예: RESULTSET와 함께 CURSOR 사용하기¶

다음 코드는 커서 를 사용하여 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 Scripting 사용하기 참조).

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