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数据表;