INSERT
S’applique à : Databricks SQL Databricks Runtime
Insère de nouvelles lignes dans une table et tronque ou partitionne éventuellement table. Vous spécifiez les lignes insérées par des expressions de valeur ou le résultat d’une requête.
Databricks ne prend pas en charge INSERT
pour Hive Avrotables si le type timestamp-millis
est présent dans le tableschema.
Syntaxe
INSERT { OVERWRITE | INTO } [ TABLE ] table_name
[ PARTITION clause ]
[ ( column_name [, ...] ) | BY NAME ]
query
INSERT INTO [ TABLE ] table_name
REPLACE WHERE predicate
query
Notes
Lorsque vous INSERT INTO
une tableDelta, schema l’application et l’évolution sont prises en charge.
Si le type de données d’une column ne peut pas être converti en toute sécurité vers le type de données d’une table Delta, une exception de runtime est levée.
Si schemal'évolution est activée, de nouvelles columns peuvent exister en tant que dernière columns de votre schema (ou columnsimbriqué) pour que le schema évolue.
Parameters
INTO
ouOVERWRITE
Si vous spécifiez
OVERWRITE
, ce qui suit s’applique :- Sans
partition_spec
, le table est tronqué avant l'insertion de la première ligne. - Sinon, toutes les partitions correspondant à
partition_spec
sont tronquées avant l’insertion de la première ligne.
Si vous spécifiez
INTO
, toutes les lignes insérées s’ajoutent aux lignes existantes.- Sans
-
Identifie la table à insérer à. Le nom ne doit pas inclure une spécification temporelle. Si le table est introuvable, Azure Databricks génère une erreur de TABLE_OR_VIEW_NOT_FOUND.
table_name
ne doit pas être une tableétrangère.S’applique à : Databricks Runtime 16.0 et versions ultérieures
table_name
peut inclure une spécification d’options. -
Paramètre facultatif qui spécifie une cible partition pour le insert. Vous ne pouvez également spécifier que partiellement le partition.
Lors de la spécification d'un partition statique(
column = value
), ce column ne doit pas être répété dans le insertcolumnlist.Lorsque vous spécifiez un partition dynamique pour
INSERT OVERWRITE
, letable_name
doit être un Delta Lake table. ( column_name [, …] )
Une list facultative de columns dans le table. La commande insert peut spécifier une column particulière du table au plus une fois.
S’applique à : Databricks SQL Databricks Runtime 12.2 LTS et versions ultérieures
- Si cette commande omet un column, Databricks SQL affecte à la place la valeur par défaut correspondante.
- Si le tableschema cible ne définit aucune valeur par défaut pour l'columninséré, Databricks SQL affecte
NULL
si le column est nullable. Sinon, Databricks SQL génère une erreur.
Si aucune columnlist n’est équivalente à la spécification de toutes les columns, sauf pour les colonnes auxquelles des values ont été attribuées dans la clause
PARTITION
, dans l’ordre défini dans la tabletable.BY NAME
S’applique à : Databricks SQL Databricks Runtime 13.3 LTS et versions ultérieures
Lorsque cette clause est utilisée au lieu d’une columnlistexplicite, la commande utilise les noms de column exposés de
query
pour produire le columnlist dans l’ordre dequery
. Comme avec une columnlistexplicite, chaque column doit exister dans le tablecible et ne doit pas être dupliquée. Si un column présent danstable_name
ne fait pas partie des columnlist implicites, la valeur deDEFAULT
est utilisée à la place.BY NAME
correspond également aux attributs des structs par nom.Aucune column dans
query
ne peut correspondre à une column spécifiée dans la clausePARTITION
ou toute column générée.REPLACE WHEREboolean_expression
S’applique à : Databricks SQL Databricks Runtime 12.2 LTS et versions ultérieures
Si
table_name
est un tableDelta Lake, supprimez les lignes correspondantesboolean_expression
avant d’insérer des lignes correspondantesboolean-expression
spécifiées dansquery
. Les lignes dansquery
lesquelles ne correspondentboolean_expression
pas sont ignorées.boolean_expression
peut être toute expression produisant un résultat de typeBOOLEAN
.Consultez Remplacement sélectif arbitraire avec replaceWhere.
-
Requête qui produit les lignes à insérer.
Vous devez faire correspondre le nombre de columns retourné par la requête avec le insertcolumnlistspécifié ou implicite.
Si un type de données ne peut pas être converti en toute sécurité dans le type de données column correspondant, une exception d'exécution est levée.
S’applique à : Databricks SQL Databricks Runtime 11.3 LTS et ultérieur
- Si
query
se compose d’une clause VALUES, laexpression
peut êtreDEFAULT
. - Si
query
se compose d’une clause SELECT, lanamed_expression
peut êtreDEFAULT
. DEFAULT
l’expression insert définieDEFAULT
explicitement de la colonne correspondante columndans ,table_name
ouNULL
si aucune n’est définie.
Si schemal'évolution est activée, de nouvelles columns peuvent exister en tant que dernière columns de votre schema (ou columnsimbriqué) pour que le schema évolue.
- Si
Exemples
Dans cette section :
- INSERT INTO
- Insert avec un columnlist
- Insert avec une spécification partition et un columnlist
- INSERT à l’aide de la clause BY NAME
- REPLACE WHERE
- INSERT OVERWRITE
INSERT INTO
INSERT utilisation de VALUES
> CREATE TABLE students (name VARCHAR(64), address VARCHAR(64) DEFAULT 'unknown', student_id INT)
PARTITIONED BY (student_id);
-- Single row insert using a `VALUES` clause specifying all columns.
> INSERT INTO students VALUES
('Amy Smith', '123 Park Ave, San Jose', 111111);
-- Single row insert using an implicit default for address
> INSERT INTO students(name, student_id) VALUES('Grayson Miller', 222222);
-- Single row insert using an explicit DEFAULT keyword for address
> INSERT INTO students VALUES('Youna Kim', DEFAULT, 333333);
-- Multi-row insert using a `VALUES` clause
> INSERT INTO students VALUES
('Bob Brown', '456 Taylor St, Cupertino', 444444),
('Cathy Johnson', '789 Race Ave, Palo Alto', 555555);
-- Multi-row insert using a mix of DEFAULT and literals
> INSERT INTO students VALUES
('Gwyneth Zhao', '120 Main St, Rockport', 666666),
('Jackson Peterson', DEFAULT, 777777);
> SELECT * FROM students;
name address student_id
---------------- ------------------------ ----------
Amy Smith 123 Park Ave, San Jose 111111
Grayson Miller unknown 222222
Youna Kim unknown 333333
Bob Brown 456 Taylor St, Cupertino 444444
Cathy Johnson 789 Race Ave, Palo Alto 555555
Gwyneth Zhao 120 Main St, Rockport 666666
Jackson Peterson unknown 777777
Insert utilisation d’une sous-requête
-- Assuming the persons table has already been created and populated.
> SELECT * FROM persons;
name address ssn
------------- ------------------------- ---------
Dora Williams 134 Forest Ave, Melo Park 123456789
Eddie Davis 245 Market St, Milpitas 345678901
> INSERT INTO students PARTITION (student_id = 444444)
SELECT name, address FROM persons WHERE name = "Dora Williams";
> SELECT * FROM students;
name address student_id
------------- ------------------------- ----------
Amy Smith 123 Park Ave, San Jose 111111
Bob Brown 456 Taylor St, Cupertino 222222
Cathy Johnson 789 Race Ave, Palo Alto 333333
Dora Williams 134 Forest Ave, Melo Park 444444
-- Use an option specification to influence the write behavior
INSERT INTO t WITH ('write.split-size' = 10) SELECT * FROM s;
Insert utilisation d’une clause TABLE
-- Assuming the visiting_students table has already been created and populated.
> SELECT * FROM visiting_students;
name address student_id
------------- --------------------- ----------
Fleur Laurent 345 Copper St, London 777777
Gordon Martin 779 Lake Ave, Oxford 888888
> INSERT INTO students TABLE visiting_students;
> SELECT * FROM students;
name address student_id
------------- ------------------------- ----------
Amy Smith 123 Park Ave,San Jose 111111
Bob Brown 456 Taylor St, Cupertino 222222
Cathy Johnson 789 Race Ave, Palo Alto 333333
Dora Williams 134 Forest Ave, Melo Park 444444
Fleur Laurent 345 Copper St, London 777777
Gordon Martin 779 Lake Ave, Oxford 888888
Insert dans un répertoire
> CREATE TABLE students (name VARCHAR(64), address VARCHAR(64), student_id INT)
PARTITIONED BY (student_id)
LOCATION "/path/to/students_table";
> INSERT INTO delta.`/path/to/students_table` VALUES
('Amy Smith', '123 Park Ave, San Jose', 111111);
> SELECT * FROM students;
name address student_id
------------- ------------------------- ----------
Amy Smith 123 Park Ave, San Jose 111111
Insert avec un columnlist
> INSERT INTO students (address, name, student_id) VALUES
('Hangzhou, China', 'Kent Yao', 11215016);
> SELECT * FROM students WHERE name = 'Kent Yao';
name address student_id
--------- ---------------------- ----------
Kent Yao Hangzhou, China 11215016
Insert avec une spécification partition et une columnlist
> INSERT INTO students PARTITION (student_id = 11215017) (address, name) VALUES
('Hangzhou, China', 'Kent Yao Jr.');
> SELECT * FROM students WHERE student_id = 11215017;
name address student_id
------------ ---------------------- ----------
Kent Yao Jr. Hangzhou, China 11215017
INSERT en utilisant la clause BY NAME
> CREATE TABLE target(n INT, text STRING, s STRUCT<a INT, b INT>);
> INSERT INTO target BY NAME SELECT named_struct('b', 2, 'a', 1) AS s, 0 AS n, 'data' AS text;
> SELECT * FROM target;
0 data {"a":1,"b":2}
> CREATE OR REPLACE TABLE target(n INT, arr ARRAY<STRUCT<a INT, b INT>>);
> INSERT INTO target BY NAME SELECT array(named_struct('b', 2, 'a', 1)) AS arr, 0 AS n;
> INSERT INTO target BY NAME SELECT array(named_struct('b', 2, 'a', 1)) AS arr;
> SELECT * FROM target;
0 [{"a":1,"b":2}]
NULL [{"a":1,"b":2}]
> INSERT INTO target BY NAME SELECT array(named_struct('b', 2, 'a', 1)) AS arr, 0 AS badname;
Error
> INSERT INTO target BY NAME SELECT array(named_struct('b', 2, 'a', 1)) AS arr, 0 AS n, 1 AS n;
Error: INSERT_COLUMN_ARITY_MISMATCH.TOO_MANY_DATA_COLUMNS
REPLACE WHERE
> CREATE TABLE sales(tx_date DATE, amount INTEGER);
> INSERT INTO sales VALUES
(DATE'2022-10-01', 1234),
(DATE'2022-10-02', 2345),
(DATE'2022-10-03', 3456),
(DATE'2022-11-01', 3214);
-- Replace any rows with a transaction date in October 2022.
> INSERT INTO sales REPLACE WHERE tx_date BETWEEN '2022-10-01' AND '2022-10-31'
VALUES (DATE'2022-10-01', 1237),
(DATE'2022-10-02', 2378),
(DATE'2022-10-04', 2456),
(DATE'2022-10-05', 6328);
> SELECT * FROM sales ORDER BY tx_date;
tx_date amount
---------- ------
2022-10-01 1237
2022-10-02 2378
2022-10-04 2456
2022-10-05 6328
2022-11-01 3214
INSERT OVERWRITE
Insert utilisation d’une clause VALUES
-- Assuming the students table has already been created and populated.
> SELECT * FROM students;
name address student_id
------------- ------------------------- ----------
Amy Smith 123 Park Ave, San Jose 111111
Bob Brown 456 Taylor St, Cupertino 222222
Cathy Johnson 789 Race Ave, Palo Alto 333333
Dora Williams 134 Forest Ave, Melo Park 444444
Fleur Laurent 345 Copper St, London 777777
Gordon Martin 779 Lake Ave, Oxford 888888
Helen Davis 469 Mission St, San Diego 999999
Jason Wang 908 Bird St, Saratoga 121212
> INSERT OVERWRITE students VALUES
('Ashua Hill', '456 Erica Ct, Cupertino', 111111),
('Brian Reed', '723 Kern Ave, Palo Alto', 222222);
> SELECT * FROM students;
name address student_id
---------- ----------------------- ----------
Ashua Hill 456 Erica Ct, Cupertino 111111
Brian Reed 723 Kern Ave, Palo Alto 222222
Insert utilisation d’une sous-requête
-- Assuming the persons table has already been created and populated.
> SELECT * FROM persons;
name address ssn
------------- ------------------------- ---------
Dora Williams 134 Forest Ave, Melo Park 123456789
Eddie Davis 245 Market St,Milpitas 345678901
> INSERT OVERWRITE students PARTITION (student_id = 222222)
SELECT name, address FROM persons WHERE name = "Dora Williams";
> SELECT * FROM students;
name address student_id
------------- ------------------------- ----------
Ashua Hill 456 Erica Ct, Cupertino 111111
Dora Williams 134 Forest Ave, Melo Park 222222
Insert utilisation d’une clause TABLE
-- Assuming the visiting_students table has already been created and populated.
> SELECT * FROM visiting_students;
name address student_id
------------- --------------------- ----------
Fleur Laurent 345 Copper St, London 777777
Gordon Martin 779 Lake Ave, Oxford 888888
> INSERT OVERWRITE students TABLE visiting_students;
> SELECT * FROM students;
name address student_id
------------- --------------------- ----------
Fleur Laurent 345 Copper St, London 777777
Gordon Martin 779 Lake Ave, Oxford 888888
Insert remplacer un répertoire
> CREATE TABLE students (name VARCHAR(64), address VARCHAR(64), student_id INT)
PARTITIONED BY (student_id)
LOCATION "/path/to/students_table";
> INSERT OVERWRITE delta.`/path/to/students_table` VALUES
('Amy Smith', '123 Park Ave, San Jose', 111111);
> SELECT * FROM students;
name address student_id
------------- ------------------------- ----------
Amy Smith 123 Park Ave, San Jose 111111