CREATE DYNAMIC TABLE¶

Syntaxe¶

CREATE [ OR REPLACE ] [ TRANSIENT ] DYNAMIC TABLE [ IF NOT EXISTS ] <name> (
    -- Column definition
    <col_name> <col_type>
      [ [ WITH ] MASKING POLICY <policy_name> [ USING ( <col_name> , <cond_col1> , ... ) ] ]
      [ [ WITH ] TAG ( <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' , ... ] ) ]
      [ COMMENT '<string_literal>' ]

    -- Additional column definitions
    [ , <col_name> <col_type> [ ... ] ]

  )
  TARGET_LAG = { '<num> { seconds | minutes | hours | days }' | DOWNSTREAM }
  WAREHOUSE = <warehouse_name>
  [ REFRESH_MODE = { AUTO | FULL | INCREMENTAL } ]
  [ INITIALIZE = { ON_CREATE | ON_SCHEDULE } ]
  [ CLUSTER BY ( <expr> [ , <expr> , ... ] ) ]
  [ DATA_RETENTION_TIME_IN_DAYS = <integer> ]
  [ MAX_DATA_EXTENSION_TIME_IN_DAYS = <integer> ]
  [ COMMENT = '<string_literal>' ]
  [ [ WITH ] ROW ACCESS POLICY <policy_name> ON ( <col_name> [ , <col_name> ... ] ) ]
  [ [ WITH ] TAG ( <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' , ... ] ) ]
  AS <query>

Syntaxe des variantes¶

CREATE [ OR REPLACE ] [ TRANSIENT ] DYNAMIC TABLE <name>
  CLONE <source_dynamic_table>
        [ { AT | BEFORE } ( { TIMESTAMP => <timestamp> | OFFSET => <time_difference> | STATEMENT => <id> } ) ]
  [
    COPY GRANTS
    TARGET_LAG = { '<num> { seconds | minutes | hours | days }' | DOWNSTREAM }
    WAREHOUSE = <warehouse_name>
  ]

CREATE [ OR REPLACE ] DYNAMIC ICEBERG TABLE <name> (
  -- Column definition
  <col_name> <col_type>
    [ [ WITH ] MASKING POLICY <policy_name> [ USING ( <col_name> , <cond_col1> , ... ) ] ]
    [ [ WITH ] TAG ( <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' , ... ] ) ]
    [ COMMENT '<string_literal>' ]

  -- Additional column definitions
  [ , <col_name> <col_type> [ ... ] ]

)
TARGET_LAG = { '<num> { seconds | minutes | hours | days }' | DOWNSTREAM }
WAREHOUSE = <warehouse_name>
[ EXTERNAL_VOLUME = '<external_volume_name>' ]
[ CATALOG = 'SNOWFLAKE' ]
BASE_LOCATION = '<directory_for_table_files>'
[ REFRESH_MODE = { AUTO | FULL | INCREMENTAL } ]
[ INITIALIZE = { ON_CREATE | ON_SCHEDULE } ]
[ CLUSTER BY ( <expr> [ , <expr> , ... ] ) ]
[ DATA_RETENTION_TIME_IN_DAYS = <integer> ]
[ MAX_DATA_EXTENSION_TIME_IN_DAYS = <integer> ]
[ COMMENT = '<string_literal>' ]
[ [ WITH ] ROW ACCESS POLICY <policy_name> ON ( <col_name> [ , <col_name> ... ] ) ]
[ [ WITH ] TAG ( <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' , ... ] ) ]
AS <query>

Paramètres requis¶

name

Indique l’identificateur (c’est-à-dire le nom) de la table dynamique ; doit être unique pour le schéma dans lequel la table dynamique est créée.

De plus, l’identificateur doit commencer par un caractère alphabétique et ne peut pas contenir d’espaces ou de caractères spéciaux à moins que toute la chaîne d’identificateur soit délimitée par des guillemets doubles (p. ex. "My object"). Les identificateurs entre guillemets doubles sont également sensibles à la casse.

Pour plus de détails, voir Exigences relatives à l’identificateur.

TARGET_LAG = { num { seconds | minutes | hours | days } | DOWNSTREAM }

Spécifie le décalage de la table dynamique :

'num seconds | minutes | hours | days'

Spécifie le délai maximum pendant lequel le contenu de la table dynamique doit être décalé par rapport aux mises à jour des tables de base.

Par exemple :

• Si les données de la table dynamique ne doivent pas être décalées de plus de 5 minutes, indiquez 5 minutes.

• Si les données de la table dynamique ne doivent pas être décalées de plus de 5 heures, indiquez 5 hours.

Si la table dynamique dépend d’une autre table dynamique, la latence cible minimum doit être supérieure ou égale à la latence cible de la table dynamique dont elle dépend.

DOWNSTREAM

Spécifie que la table dynamique ne doit être actualisée que lorsque les tables dynamiques qui en dépendent sont actualisées.

WAREHOUSE = warehouse_name

Spécifie le nom de l’entrepôt qui fournit les ressources de calcul pour l’actualisation de la table dynamique.

Vous devez utiliser un rôle doté du privilège USAGE sur cet entrepôt pour pouvoir créer la table dynamique. Pour connaître les limites et d’autres informations, voir Privilèges permettant de créer une table dynamique.

AS query

Spécifie la requête dont les résultats doivent être contenus dans la table dynamique.

Paramètres facultatifs¶

TRANSIENT

Indique que la table est transitoire.

Comme les tables dynamiques permanents, les tables dynamiques transitoires existent jusqu’à ce qu’elles soient explicitement supprimées et sont accessibles à tout utilisateur disposant des privilèges appropriés. Les tables dynamiques transitoires ne conservent pas les données dans un stockage Fail-safe, ce qui permet de réduire les coûts de stockage, en particulier pour les tables fréquemment actualisés. En raison de ce niveau de durabilité réduit, les tables dynamiques transitoires sont idéales pour les données transitoires qui n’ont pas besoin du même niveau de protection et de récupération des données que les tables permanentes.

Par défaut : aucune valeur. Si une table dynamique n’est pas déclarée comme TRANSIENT, elle est permanente.

REFRESH_MODE = { AUTO | FULL | INCREMENTAL }

Spécifie le mode d’actualisation de la table dynamique.

Cette propriété ne peut pas être modifiée après la création de la table dynamique. Pour modifier la propriété, créez à nouveau la table dynamique avec une commande CREATE OR REPLACE DYNAMIC TABLE.

AUTO

Lorsque le mode d’actualisation est AUTO, le système tente d’appliquer une actualisation incrémentielle par défaut. Cependant, lorsque l’actualisation incrémentielle n’est pas prise en charge ou risque de ne pas fonctionner correctement, la table dynamique sélectionne automatiquement l’actualisation complète à la place. Pour plus d’informations, voir Limitations de l’actualisation incrémentielle.

Pour déterminer le mode le mieux adapté à votre casse, expérimentez les modes d’actualisation et les recommandations automatiques. Pour un comportement cohérent entre les versions de Snowflake, définissez explicitement le mode d’actualisation de toutes les tables dynamiques.

Pour vérifier le mode d’actualisation de vos tables dynamiques, consultez Afficher le mode d’actualisation de tables dynamiques.

FULL

Impose une actualisation complète de la table dynamique, même si celle-ci peut être actualisée de manière incrémentielle.

INCREMENTAL

Permet une actualisation incrémentielle de la table dynamique. Si la requête qui sous-tend la table dynamique ne peut pas effectuer une actualisation incrémentielle, la création de la table dynamique échoue et affiche un message d’erreur.

Par défaut : AUTO

INITIALIZE

Spécifie le comportement de l’actualisation initiale de la table dynamique. Cette propriété ne peut pas être modifiée après la création de la table dynamique. Pour modifier la propriété, remplacez la table dynamique avec une commande CREATE OR REPLACE DYNAMIC TABLE.

ON_CREATE

Actualise la table dynamique de manière synchrone lors de sa création. Si cette actualisation échoue, la création de la table dynamique échoue et affiche un message d’erreur.

ON_SCHEDULE

Actualise la table dynamique lors de la prochaine actualisation planifiée.

La table dynamique est alimentée lors de l’exécution du processus de planification de l’actualisation. Aucune donnée n’est ajoutée lors de la création de la table dynamique. Si vous essayez d’interroger la table en utilisant SELECT * FROM DYNAMIC TABLE, vous risquez d’obtenir l’erreur suivante, car la première actualisation planifiée n’a pas encore eu lieu.

Dynamic Table is not initialized. Please run a manual refresh or wait for a scheduled refresh before querying.

Par défaut : ON_CREATE

COMMENT 'string_literal'

Spécifie un commentaire pour la colonne.

(Notez que les commentaires peuvent être spécifiés au niveau de la colonne ou de la table. La syntaxe de chacun est légèrement différente).

MASKING POLICY = policy_name

Spécifie la politique de masquage à définir sur une colonne.

column_list

Si vous voulez modifier le nom d’une colonne ou ajouter un commentaire à une colonne dans la table dynamique, incluez une liste de colonnes qui spécifie les noms des colonnes et, le cas échéant, les commentaires sur les colonnes. Vous n’avez pas besoin de spécifier les types de données des colonnes.

Si l’une des colonnes de la table dynamique est basée sur des expressions (pas seulement des noms de colonnes simples, par exemple), vous devez fournir un nom de colonne pour chaque colonne de la table dynamique. Par exemple, les noms de colonnes sont obligatoires dans le cas suivant :

CREATE DYNAMIC TABLE product (pre_tax_profit, taxes, after_tax_profit)
  TARGET_LAG = '20 minutes'
    WAREHOUSE = mywh
    AS
      SELECT revenue - cost, (revenue - cost) * tax_rate, (revenue - cost) * (1.0 - tax_rate)
      FROM staging_table;

Copy

Vous pouvez spécifier un commentaire facultatif pour chaque colonne. Par exemple :

CREATE DYNAMIC TABLE product (pre_tax_profit COMMENT 'revenue minus cost',
                taxes COMMENT 'assumes taxes are a fixed percentage of profit',
                after_tax_profit)
  TARGET_LAG = '20 minutes'
    WAREHOUSE = mywh
    AS
      SELECT revenue - cost, (revenue - cost) * tax_rate, (revenue - cost) * (1.0 - tax_rate)
      FROM staging_table;

Copy

CLUSTER BY ( expr [ , expr , ... ] )

Spécifie une ou plusieurs colonnes ou expressions de colonne de la table dynamique comme clés de clustering. Avant de spécifier une clé de clustering pour une table dynamique, vous devez comprendre ce que sont les micro-partitions. Pour plus d’informations, voir Fonctionnement des structures de table dans Snowflake.

Notez les points suivants lors de l’utilisation de clés de clustering avec des tables dynamiques :

• Les définitions des colonnes sont obligatoires et doivent être explicitement spécifiées dans l’instruction.

• Par défaut, le clustering automatique n’est pas suspendu pour la nouvelle table dynamique, même si le clustering automatique est suspendu pour la table source.

• Les clés de clustering ne sont pas prévues ni recommandées pour toutes les tables ; elles sont généralement intéressantes pour les tables de très grande taille (par exemple, de plusieurs téraoctets).

• La spécification de CLUSTER BY n’entraîne pas la mise en cluster des données au moment de la création ; en revanche, CLUSTER BY s’appuie sur le clustering automatique pour remettre en cluster les données au fil du temps.

Pour plus d’informations, voir Clés de clustering et tables en cluster.

Par défaut : aucune valeur (aucune clé de clustering n’est définie pour la table)

DATA_RETENTION_TIME_IN_DAYS = integer

Spécifie la période de conservation de la table dynamique pour que les actions Time Travel (SELECT, CLONE) puissent être effectuées sur les données historiques de la table dynamique. Time Travel se comporte de la même manière pour les tables dynamiques que pour les tables traditionnelles. Pour plus d’informations, voir Compréhension et utilisation de la fonction Time Travel.

Pour une description détaillée de ce paramètre de niveau objet, ainsi que plus d’informations sur les paramètres d’objet, voir Paramètres.

Valeurs :

• Édition Standard : 0 ou 1

• Édition Enterprise :

  • 0 à 90 pour les tables permanentes

  • 0 ou 1 pour les tables temporaires et transitoires

Par défaut :

• Édition Standard : 1

• Édition Enterprise (ou supérieure) : 1 (sauf si une valeur par défaut différente a été spécifiée au niveau du compte, du schéma ou de la base de données)

Note

Une valeur de 0 désactive effectivement Time Travel pour la table.

MAX_DATA_EXTENSION_TIME_IN_DAYS = integer

Un paramètre d’objet qui définit le nombre maximum de jours pendant lesquels Snowflake peut prolonger la période de conservation pour éviter que les flux de la table dynamique ne deviennent obsolètes.

Pour une description détaillée de ce paramètre, voir MAX_DATA_EXTENSION_TIME_IN_DAYS.

COMMENT = 'string_literal'

Spécifie un commentaire pour la table dynamique.

(Notez que les commentaires peuvent être spécifiés au niveau de la colonne ou de la table. La syntaxe de chacun est légèrement différente).

Par défaut : aucune valeur.

COPY GRANTS

Spécifie de conserver les privilèges d’accès de la table dynamique d’origine lorsqu’une nouvelle table dynamique est créée à l’aide de la variante CREATE DYNAMIC TABLE … CLONE.

Ce paramètre copie tous les privilèges, excepté OWNERSHIP, de la table dynamique existante vers la nouvelle table dynamique. La nouvelle table dynamique n’hérite pas des attributions futures définies pour le type d’objet dans le schéma. Par défaut, le rôle qui exécute l’instruction CREATE DYNAMICTABLE possède la nouvelle table dynamique.

Si ce paramètre n’est pas inclus dans l’instruction CREATE DYNAMIC TABLE, la nouvelle table n’hérite pas des privilèges d’accès explicites accordés sur la table dynamique d’origine, mais des attributions futures définies pour le type d’objet dans le schéma.

Remarque :

• Avec le partage des données :

  • Si la table dynamique existante a été partagée avec un autre compte, la table dynamique de remplacement est également partagée.

  • Si la table dynamique existante a été partagée avec votre compte en tant que consommateur de données et que l’accès a été accordé à d’autres rôles dans le compte (en utilisant GRANT IMPORTED PRIVILEGES sur la base de données mère), l’accès est également accordé à la table dynamique de remplacement.

• La sortie SHOW GRANTS pour la table dynamique de remplacement liste le concessionnaire des privilèges copiés comme le rôle qui a exécuté l’instruction CREATE TABLE avec l’horodatage courant lorsque l’instruction a été exécutée.

• La sortie SHOW GRANTS pour la table dynamique de remplacement liste le concessionnaire des privilèges copiés comme le rôle qui a exécuté l’instruction CREATE TABLE avec l’horodatage courant lorsque l’instruction a été exécutée.

• L’opération de copie des accords s’effectue atomiquement dans la commande CREATE DYNAMIC TABLE (c’est-à-dire dans la même transaction).

ROW ACCESS POLICY policy_name ON ( col_name [ , col_name ... ] )

Spécifie la politique d’accès aux lignes à définir sur une table dynamique.

TAG ( tag_name = 'tag_value' [ , tag_name = 'tag_value' , ... ] )

Spécifie le nom de la balise et la valeur de la chaîne de la balise.

La valeur de la balise est toujours une chaîne de caractères et le nombre maximum de caractères pour la valeur de la balise est 256.

Pour plus d’informations sur la spécification des balises dans une instruction, voir Quotas de balises pour les objets et les colonnes.

Exigences en matière de contrôle d’accès¶

Un rôle utilisé pour exécuter cette commande SQL doit avoir les privilèges suivants définis au minimum ainsi :

Notez que l’exploitation d’un objet dans un schéma requiert également le privilège USAGE sur la base de données et le schéma parents.

Pour obtenir des instructions sur la création d’un rôle personnalisé avec un ensemble spécifique de privilèges, voir Création de rôles personnalisés.

Pour des informations générales sur les rôles et les privilèges accordés pour effectuer des actions SQL sur des objets sécurisables, voir Aperçu du contrôle d’accès.

Notes sur l’utilisation¶

• Lorsque vous exécutez la commande CREATE DYNAMIC TABLE, le rôle en cours d’utilisation devient propriétaire de la table dynamique. Ce rôle est utilisé pour effectuer des actualisations de la table dynamique en arrière-plan.

• Vous ne pouvez pas modifier le schéma après avoir créé une table dynamique.

• Les tables dynamiques sont mises à jour lorsque les objets de la base de données sous-jacente changent. Le suivi des modifications doit être activé pour tous les objets sous-jacents utilisés par une table dynamique. Voir Activer le suivi des modifications.

• Si vous souhaitez remplacer une table dynamique existant et que vous avez besoin de voir sa définition actuelle, appelez la fonction GET_DDL.

• L’utilisation de ORDER BY dans la définition d’une table dynamique peut produire des résultats triés dans un ordre imprévu. Vous pouvez utiliser ORDER BY lorsque vous interrogez votre table dynamique afin de vous assurer que les lignes sélectionnées sont renvoyées dans un ordre spécifique.

• Snowflake ne prend pas en charge l’utilisation de ORDER BY pour créer une vue qui effectue une sélection à partir d’une table dynamique.

• Certaines expressions, clauses et fonctions ne sont actuellement pas prises en charge dans les tables dynamiques. Pour une liste complète, voir Limitations connues relatives aux tables dynamiques.

• Les clients doivent s’assurer qu’aucune donnée personnelle (autre que pour un objet utilisateur), donnée sensible, donnée à exportation contrôlée ou autre donnée réglementée n’est saisie comme métadonnée lors de l’utilisation du service Snowflake. Pour plus d’informations, voir Champs de métadonnées dans Snowflake.

Exemples¶

Créez une table dynamique nommée product :

CREATE OR REPLACE DYNAMIC TABLE product
 TARGET_LAG = '20 minutes'
  WAREHOUSE = mywh
  AS
    SELECT product_id, product_name FROM staging_table;

Copy

Dans l’exemple ci-dessus :

• La table dynamique matérialise les résultats d’une requête sur les colonnes product_id et product_name de la table staging_table.

• Le temps de latence cible est de 20 minutes, ce qui signifie que les données de la table dynamique ne devraient idéalement pas être antérieures de plus de 20 minutes à celles de la staging_table.

• Le processus d’actualisation automatisé utilise les ressources informatiques de l’entrepôt mywh pour actualiser les données de la table dynamique.

Créer une table Iceberg dynamique nommée product qui lit à partir de my_iceberg_table :

CREATE DYNAMIC ICEBERG TABLE product (date TIMESTAMP_NTZ, id NUMBER, content STRING)
  TARGET_LAG = '20 minutes'
  WAREHOUSE = mywh
  EXTERNAL_VOLUME = 'my_external_volume'
  CATALOG = 'SNOWFLAKE'
  BASE_LOCATION = 'my_iceberg_table'
  AS
    SELECT product_id, product_name FROM staging_table;

Copy

Créer une table avec une clé de clustering multi-colonnes :

CREATE DYNAMIC TABLE product (date TIMESTAMP_NTZ, id NUMBER, content VARIANT)
  TARGET_LAG = '20 minutes'
  WAREHOUSE = mywh
  CLUSTER BY (date, id)
  AS
    SELECT product_id, product_name FROM staging_table;

Copy

Cloner une table dynamique telle qu’elle existait exactement à la date et à l’heure de l’horodatage spécifié :

CREATE DYNAMIC TABLE product_clone CLONE product AT (TIMESTAMP => TO_TIMESTAMP_TZ('04/05/2013 01:02:03', 'mm/dd/yyyy hh24:mi:ss'));

Copy