Help Center/ Data Lake Insight/ Spark SQL Syntax Reference/ Datasource Connections/ Creating a Datasource Connection with an HBase Table/ Inserting Data to an HBase Table
Updated on 2024-08-19 GMT+08:00
View PDF

Inserting Data to an HBase Table

Function

This statement is used to insert data in a DLI table to the associated HBase table.

Syntax

  • Insert the SELECT query result into a table. 
    1
2
3
4
5
6
7
    		 
    INSERT INTO DLI_TABLE
  SELECT field1,field2...
  [FROM DLI_TEST]
  [WHERE where_condition]
  [LIMIT num]
  [GROUP BY field]
  [ORDER BY field] ...;
  • Insert a data record into a table. 
    1
2
    		 
    INSERT INTO DLI_TABLE
  VALUES values_row [, values_row ...];

Keywords

For details about the SELECT keywords, see Basic Statements.

Parameters

Table 1 Parameters

Parameter

Description

DLI_TABLE

Name of the DLI table for which a datasource connection has been created.

DLI_TEST

indicates the table that contains the data to be queried.

field1,field2..., field

Column values in the DLI_TEST table must match the column values and types in the DLI_TABLE table.

where_condition

Query condition.

num

Limit the query result. The num parameter supports only the INT type.

values_row

Value to be inserted to a table. Use commas (,) to separate columns.

Precautions

  • A DLI table is available.
  • In the column family created in Creating a Table and Associating It with HBase, if the column family specified by Cols in OPTIONS does not exist, an error is reported when INSERT INTO is executed.
  • If the row key, column family, or column you need to insert to the HBase table already exists, the existing data in HBase table will be overwritten.
  • You are advised not to concurrently insert data into a table. If you concurrently insert data into a table, there is a possibility that conflicts occur, leading to failed data insertion.
  • INSERT OVERWRITE is not supported.

Example

  • Query data in the user table and insert the data into the test table. 
    1
2
3
4
5
6
    		 
    INSERT INTO test
  SELECT ATTR_EXPR
  FROM user
  WHERE user_name='cyz'
  LIMIT 3
  GROUP BY user_age
  • Insert data 1 into the test table. 
    INSERT INTO test 
  VALUES (1);