4.5.3 将hive中的数据导入到lsql中

1. 直接追加数据

insert into table s_y_s_t_loadjson 
 select '{lsql表名称}', '{lsql表分区名}', '',
    CL_JSON(
    'amtdouble',amtdouble,
    'amtfloat',amtfloat,
    'tradetime',tradetime,
    'amtint',amtint    )
from xxxhive数据表;

注:hive表中字段名与lsql表中字段名不需要一致。带引号的字段是要插入数据的表字段,不带的引号的字段是查询表的字段。

2. 覆盖数据

insert overwrite table s_y_s_t_loadjson 
 select '{lsql表名称}', '{lsql表分区名}', '',
    CL_JSON(
    'amtdouble',amtdouble,
    'amtfloat',amtfloat,
    'tradetime',tradetime,
    'amtint',amtint    )
from xxxhive数据表;

3. 在追加数据前,先根据条件删除旧的数据

insert into table s_y_s_t_loadjson 
 select '{lsql表名称}', '{lsql表分区名}', '{筛选条件}',
    CL_JSON(
    'amtdouble',amtdouble,
    'amtfloat',amtfloat,
    'tradetime',tradetime,
    'amtint',amtint    )
from xxxhive数据表;
Copyright © lucene.xin 2020 all right reserved修改时间: 2021-07-02 11:42:23

results matching ""

    No results matching ""