paramètres de session insert_*

Ces paramètres sont disponibles dans system.settings et sont générés automatiquement à partir du source.

insert_allow_materialized_columns

Si ce paramètre est activé, les colonnes matérialisées sont autorisées dans INSERT.

insert_deduplicate

Active ou désactive la déduplication des blocs pour INSERT (pour les tables Replicated*). Ce paramètre ne prend effet que lorsque deduplicate_insert est défini sur backward_compatible_choice. Valeurs possibles :

0 — Désactivé.
1 — Activé.

Par défaut, les blocs insérés dans les tables répliquées par l’instruction INSERT sont dédupliqués (voir Réplication des données). Pour les tables répliquées, seuls les 100 blocs les plus récents de chaque partition sont dédupliqués par défaut (voir replicated_deduplication_window, replicated_deduplication_window_seconds). Pour les tables non répliquées, voir non_replicated_deduplication_window.

insert_deduplication_token

Ce paramètre permet à l’utilisateur de définir sa propre logique de déduplication dans MergeTree/ReplicatedMergeTree. Par exemple, en fournissant une valeur unique pour ce paramètre dans chaque instruction INSERT, l’utilisateur peut éviter que les mêmes données insérées soient dédupliquées. Valeurs possibles :

Toute chaîne

insert_deduplication_token est utilisé pour la déduplication uniquement lorsqu’il n’est pas vide. Pour les tables répliquées, par défaut, seules les 100 insertions les plus récentes de chaque partition sont dédupliquées (voir replicated_deduplication_window, replicated_deduplication_window_seconds). Pour les tables non répliquées, voir non_replicated_deduplication_window.

insert_deduplication_token est géré par partition. Ainsi, plusieurs partitions écrites par une même insertion peuvent porter le même jeton. Sans jeton, la somme de contrôle du contenu par défaut est calculée sur l’ensemble du bloc inséré ; une insertion n’est donc dédupliquée que si l’intégralité de ses données correspond à une insertion précédente (une nouvelle tentative), et non si seules les lignes d’une partition donnée coïncident avec celles d’une autre insertion.

Exemple :

CREATE TABLE test_table
( A Int64 )
ENGINE = MergeTree
ORDER BY A
SETTINGS non_replicated_deduplication_window = 100;

INSERT INTO test_table SETTINGS insert_deduplication_token = 'test' VALUES (1);

-- the next insert won't be deduplicated because insert_deduplication_token is different
INSERT INTO test_table SETTINGS insert_deduplication_token = 'test1' VALUES (1);

-- the next insert will be deduplicated because insert_deduplication_token
-- is the same as one of the previous
INSERT INTO test_table SETTINGS insert_deduplication_token = 'test' VALUES (2);

SELECT * FROM test_table

┌─A─┐
│ 1 │
└───┘
┌─A─┐
│ 1 │
└───┘

insert_null_as_default

Active ou désactive l’insertion de valeurs par défaut à la place de NULL dans les colonnes de type non Nullable. Si le type de la colonne n’est pas Nullable et que ce paramètre est désactivé, l’insertion de NULL provoque une exception. Si le type de la colonne est Nullable, les valeurs NULL sont insérées telles quelles, indépendamment de ce paramètre. Ce paramètre s’applique aux requêtes INSERT … SELECT. Notez que les sous-requêtes SELECT peuvent être concaténées avec la clause UNION ALL. Valeurs possibles :

0 — L’insertion de NULL dans une colonne non Nullable provoque une exception.
1 — La valeur par défaut de la colonne est insérée à la place de NULL.

insert_shard_id

S’il est différent de 0, indique le shard de la table Distributed dans lequel les données seront insérées de manière synchrone. Si la valeur de insert_shard_id est incorrecte, le serveur lèvera une exception. Pour obtenir le nombre de shards dans requested_cluster, vous pouvez vérifier la config du serveur ou utiliser cette requête :

SELECT uniq(shard_num) FROM system.clusters WHERE cluster = 'requested_cluster';

Valeurs possibles :

0 — Désactivé.
N’importe quel nombre de 1 à shards_num de la table Distributed correspondante.

Exemple Requête :

CREATE TABLE x AS system.numbers ENGINE = MergeTree ORDER BY number;
CREATE TABLE x_dist AS x ENGINE = Distributed('test_cluster_two_shards_localhost', currentDatabase(), x);
INSERT INTO x_dist SELECT * FROM numbers(5) SETTINGS insert_shard_id = 1;
SELECT * FROM x_dist ORDER BY number ASC;

Résultat :

┌─number─┐
│      0 │
│      0 │
│      1 │
│      1 │
│      2 │
│      2 │
│      3 │
│      3 │
│      4 │
│      4 │
└────────┘

Référence SQL

Types de données

Moteurs

Fonctions

Formats

Paramètres

Tables système

Lacs de données

insert_allow_materialized_columns

insert_deduplicate

insert_deduplication_token

insert_null_as_default

insert_shard_id

​insert_allow_materialized_columns

​insert_deduplicate

​insert_deduplication_token

​insert_null_as_default

​insert_shard_id

insert_allow_materialized_columns

insert_deduplicate

insert_deduplication_token

insert_null_as_default

insert_shard_id