シーケンスの使用¶

シーケンスのセマンティクス¶

Snowflakeのシーケンスは現在、次のセマンティクスを利用しています。

• シーケンスによって生成されるすべての値は、シーケンス間隔の符号が変わらない限り（例: ステップサイズの変更）、グローバルで一意です。同時クエリで同じ値が観察されることはなく、1つのクエリ内の値は常に区別されます。

• シーケンス間隔を正から負に（例: 1 から -1 に）、またはその逆に変更すると、重複の発生する可能性があります。たとえば、最初のクエリがシーケンス値 1、 2、および 3 を返し、間隔が 1 から -1 に変更された場合、生成される次のいくつかの値には、 2 と以前に生成された 1 が含まれます。

• Snowflakeは、次のシーケンス番号がリクエストされるまで待つのではなく、現在のシーケンス番号が使用されるとすぐにシーケンスの次の値を計算する場合があります。

  その結果として、 ALTER SEQUENCE ... SET INCREMENT ... コマンドはシーケンスを使用する次の操作に影響を与えない可能性があります。例については、 シーケンスを逆方向にすることの影響を理解 をご参照ください。

• 生成された各シーケンス値は、「ステップ」とも呼ばれるシーケンス間隔に応じて、値を追加で予約します。予約された値は、次のシーケンス値の範囲です。

  <値>  +  (sign(<ステップ>) * abs(<ステップ>))  -  (sign(<ステップ>) * 1)

  （すべてを含む）。

  したがって、値 100 が生成される場合は、次のようになります。

  • ステップが 2 の場合は、値 100 および 101 が予約されています。

  • ステップが 10 の場合は、値 100 〜 109 が予約されています。

  • ステップが -5 の場合は、値 96 〜 100 が予約されています。

  ステップ/間隔が修正 されない限り、シーケンスによって予約値が生成されることはありません。

• 次の条件が当てはまる 場合に、シーケンスによって生成される値は、以前のステートメントによって生成された最大値より大きく（ステップサイズが負の場合は最小値より小さく）なります。

  • シーケンスが NOORDER プロパティを持たない。

    NOORDER は、値が昇順であることが保証されないことを指定します。

    たとえば、シーケンスに START 1 INCREMENT 2がある場合、生成される値は 1、 3、 101、 5、 103 などです。

    NOORDER は、複数の挿入操作を同時に実行する必要がある場合（例: 複数のクライアントが複数の INSERT ステートメントを実行する場合）に、パフォーマンスを向上させることができます。

  • 現在のステートメントを送信する前に、以前のステートメントが完了し、承認を受けていること。

  この動作は、間隔の符号が変更された場合（正から負、または負から正）には あてはまりません。

シーケンスからの値が連続している（ギャップがない）、またはシーケンス値が特定の順序で割り当てられているという保証はありません。単一行のステートメントを使用する以外に、指定された順序でシーケンスの値を行に割り当てる方法はありません（ギャップについての保証はありません）。

シーケンス値は、64ビットの2の補数整数（-2^63 から 2^63 - 1）を表すことがあります。シーケンスにおける次の値の内部表現がこの範囲を超える場合（どちらの方向でも）エラーが発生し、クエリに失敗します。このため、これらのシーケンス値が 失われる 場合があることに注意してください。

この状況では、より小さい（大きさの）増分値を使用するか、より小さい開始値で新しいシーケンスを作成する必要があります。ギャップが発生する可能性があるため、返されるシーケンス値がすべて許容範囲内であっても、次の値の内部表現が許容範囲を超える場合があります。Snowflakeは、このエラーを回避する方法に関する明示的な保証を提供していませんが、一意の値を正しく提供するシーケンスオブジェクトのサポートに努めています。開始値 1 および増分値 1 で作成されたシーケンスオブジェクトが、シーケンス値の許容範囲を使い果たす可能性はほとんどありません。

シーケンスの参照¶

シーケンスを使用したデフォルト列値の作成¶

シーケンスをテーブルで使用して、テーブル列の主キーを生成できます。次のツールは、これを行う簡単な方法を提供します。

非正規化データのインジェスチョンと正規化¶

people と contact の2つのテーブルがあるスキーマを考えてみましょう。

• people テーブルには次が含まれます。

  • 主キーの一意の識別子: id

  • 2つの文字列の列: firstName および lastName

• contact テーブルには次が含まれます。

  • 主キーの一意の識別子: id

  • この連絡先エントリを個人にリンクする外部キー: p_id

  • 2つの文字列の列:

    • c_type: 連絡先の種類（例: 「メール」または「電話」）。

    • data: 実際の連絡先情報。

この形式のデータは、取り込みまたは半構造化データの処理中に非正規化されることがよくあります。

この例では、JSON データを取り込み、非正規化して目的のデータを抽出し、テーブルに挿入されるデータを正規化します。同時に、テーブルの行間で意図した関係を維持しながら、行に一意の識別子を作成することが重要です。これをシーケンスで実現します。

1. 最初に、例で使用するテーブルとシーケンスを設定します。

   -- primary data tables
   
   CREATE OR REPLACE TABLE people (id number, firstName string, lastName string);
   CREATE OR REPLACE TABLE contact (id number, p_id number, c_type string, data string);
   
   -- sequences to produce primary keys on our data tables
   
   CREATE OR REPLACE SEQUENCE people_seq;
   CREATE OR REPLACE SEQUENCE contact_seq;
   
   -- staging table for json
   
   CREATE OR REPLACE TABLE input (json variant);
   

   Copy

2. 次に、テーブル json からデータを挿入します。

   INSERT INTO input SELECT parse_json(
   '[
    {
      firstName : \'John\',
      lastName : \'Doe\',
      contacts : [
        {
          contactType : \'phone\',
          contactData : \'1234567890\',
        }
        ,
        {
          contactType : \'email\',
          contactData : \'jdoe@acme.com\',
        }
       ]
      }
   ,
     {
      firstName : \'Mister\',
      lastName : \'Smith\',
      contacts : [
        {
          contactType : \'phone\',
          contactData : \'0987654321\',
        }
        ,
        {
          contactType : \'email\',
          contactData : \'msmith@acme.com\',
        }
        ]
      }
    ,
      {
      firstName : \'George\',
      lastName : \'Washington\',
      contacts : [
        {
          contactType : \'phone\',
          contactData : \'1231231234\',
        }
        ,
        {
          contactType : \'email\',
          contactData : \'gwashington@acme.com\',
        }
      ]
    }
   ]'
   );
   

   Copy

3. 次に、 JSON を解析してフラット化し、各個人と連絡先エントリの一意の識別子を生成し、個人と連絡先エントリ間の関係を保持しながらデータを挿入します。

   INSERT ALL
     WHEN 1=1 THEN
       INTO contact VALUES (c_next, p_next, contact_value:contactType, contact_value:contactData)
     WHEN contact_index = 0 THEN
       INTO people VALUES (p_next, person_value:firstName, person_value:lastName)
   
   SELECT * FROM
   (
     SELECT f1.value person_value, f2.value contact_value, f2.index contact_index, p_seq.NEXTVAL p_next, c_seq.NEXTVAL c_next
     FROM input, LATERAL FLATTEN(input.json) f1, TABLE(GETNEXTVAL(people_seq)) p_seq,
       LATERAL FLATTEN(f1.value:contacts) f2, table(GETNEXTVAL(contact_seq)) c_seq
   );
   

   Copy

4. これにより、次のデータが生成されます（一意の IDs は変更される場合があります）。

   SELECT * FROM people;
   
   +----+-----------+------------+
   | ID | FIRSTNAME | LASTNAME   |
   |----+-----------+------------|
   |  1 | John      | Doe        |
   |  2 | Mister    | Smith      |
   |  3 | George    | Washington |
   +----+-----------+------------+
   
   SELECT * FROM contact;
   
   +----+------+--------+----------------------+
   | ID | P_ID | C_TYPE | DATA                 |
   |----+------+--------+----------------------|
   |  1 |    1 | phone  | 1234567890           |
   |  2 |    1 | email  | jdoe@acme.com        |
   |  3 |    2 | phone  | 0987654321           |
   |  4 |    2 | email  | msmith@acme.com      |
   |  5 |    3 | phone  | 1231231234           |
   |  6 |    3 | email  | gwashington@acme.com |
   +----+------+--------+----------------------+
   

   Copy

ここで見るように、行は people.id と contact.p_id の間でリンクされ、結合できます。

データが追加されると、新しい行は引き続き一意の IDs を受け取ります。例:

 TRUNCATE TABLE input;

 INSERT INTO input SELECT PARSE_JSON(
 '[
  {
    firstName : \'Genghis\',
    lastName : \'Khan\',
    contacts : [
      {
        contactType : \'phone\',
        contactData : \'1111111111\',
      }
      ,
      {
        contactType : \'email\',
        contactData : \'gkahn@acme.com\',
      }
   ]
 }
,
 {
    firstName : \'Julius\',
    lastName : \'Caesar\',
    contacts : [
      {
        contactType : \'phone\',
        contactData : \'2222222222\',
      }
      ,
      {
        contactType : \'email\',
        contactData : \'gcaesar@acme.com\',
      }
    ]
  }
 ]'
 );

 INSERT ALL
   WHEN 1=1 THEN
     INTO contact VALUES (c_next, p_next, contact_value:contactType, contact_value:contactData)
   WHEN contact_index = 0 THEN
     INTO people VALUES (p_next, person_value:firstName, person_value:lastName)
 SELECT * FROM
 (
   SELECT f1.value person_value, f2.value contact_value, f2.index contact_index, p_seq.NEXTVAL p_next, c_seq.NEXTVAL c_next
   FROM input, LATERAL FLATTEN(input.json) f1, table(GETNEXTVAL(people_seq)) p_seq,
     LATERAL FLATTEN(f1.value:contacts) f2, table(GETNEXTVAL(contact_seq)) c_seq
 );

 SELECT * FROM people;

 +----+-----------+------------+
 | ID | FIRSTNAME | LASTNAME   |
 |----+-----------+------------|
 |  4 | Genghis   | Khan       |
 |  5 | Julius    | Caesar     |
 |  1 | John      | Doe        |
 |  2 | Mister    | Smith      |
 |  3 | George    | Washington |
 +----+-----------+------------+

 SELECT * FROM contact;

 +----+------+--------+----------------------+
 | ID | P_ID | C_TYPE | DATA                 |
 |----+------+--------+----------------------|
 |  1 |    1 | phone  | 1234567890           |
 |  2 |    1 | email  | jdoe@acme.com        |
 |  3 |    2 | phone  | 0987654321           |
 |  4 |    2 | email  | msmith@acme.com      |
 |  5 |    3 | phone  | 1231231234           |
 |  6 |    3 | email  | gwashington@acme.com |
 |  7 |    4 | phone  | 1111111111           |
 |  8 |    4 | email  | gkahn@acme.com       |
 |  9 |    5 | phone  | 2222222222           |
 | 10 |    5 | email  | gcaesar@acme.com     |
 +----+------+--------+----------------------+

Copy

シーケンスの変更¶

CREATE OR REPLACE SEQUENCE test_sequence_wraparound_low
   START = 1
   INCREMENT = 1
   ;

CREATE or replace TABLE test_seq_wrap_low (
    i int,
    j int default test_sequence_wraparound_low.nextval
    );

INSERT INTO test_seq_wrap_low (i) VALUES
     (1),
     (2),
     (3);

SELECT * FROM test_seq_wrap_low ORDER BY i;
+---+---+
| I | J |
|---+---|
| 1 | 1 |
| 2 | 2 |
| 3 | 3 |
+---+---+

ALTER SEQUENCE test_sequence_wraparound_low SET INCREMENT = -4;

INSERT INTO test_seq_wrap_low (i) VALUES
    (4),
    (5);

SELECT * FROM test_seq_wrap_low ORDER BY i;
+---+---+
| I | J |
|---+---|
| 1 | 1 |
| 2 | 2 |
| 3 | 3 |
| 4 | 4 |
| 5 | 0 |
+---+---+