update dw_rpt_report60010105049 dw set dw.tran_country =(select max(b.char3)from orsuser_kara.para_nationality b where b.char2 = dw.tran_country)where exists(select 1from orsuser_kara.para_nationality p where p.char2=dw.tran_country) 改写成hive 写法
时间: 2024-02-18 07:01:16 浏览: 71
shiyan.rar_Rpt_Hour_shiyan.58.vom
在 Hive 中,可以使用类似以下的语句来实现上述 SQL 语句的功能:
```
UPDATE dw_rpt_report60010105049
SET tran_country = (
SELECT MAX(char3)
FROM orsuser_kara.para_nationality
WHERE char2 = dw_rpt_report60010105049.tran_country
)
WHERE EXISTS (
SELECT 1
FROM orsuser_kara.para_nationality
WHERE char2 = dw_rpt_report60010105049.tran_country
)
```
需要注意的是,在 Hive 中不支持直接使用 UPDATE 语句更新表中的数据,需要使用 INSERT OVERWRITE 语句将更新后的数据重新写入目标表中,类似以下的方式:
```
INSERT OVERWRITE TABLE dw_rpt_report60010105049
SELECT
(
SELECT MAX(char3)
FROM orsuser_kara.para_nationality
WHERE char2 = dw.tran_country
) AS tran_country,
col2,
col3,
...
FROM dw_rpt_report60010105049 dw
WHERE EXISTS (
SELECT 1
FROM orsuser_kara.para_nationality
WHERE char2 = dw.tran_country
)
```
其中 `col2`, `col3`, ... 代表需要保留的其他列名。
阅读全文