日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

hive插入多条数据sql_HIVE sql使用总结

發布時間:2023/12/18 编程问答 27 豆豆
生活随笔 收集整理的這篇文章主要介紹了 hive插入多条数据sql_HIVE sql使用总结 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

一、常用數據庫命令

1、查詢有哪些數據庫show databases

2、查詢有哪些數據表:show tables

3、顯示所有函數:show functions

4、使用use databasename;可以切換到某個數據庫下

示例(切換到test數據庫):usetest

5、查看當前數據庫:select current_database()

6、查詢數據表有哪些字段及字段詳情:describe tablename

示例(查詢staged_employees數據表):describe staged_employees

可以簡寫為desc staged_employees

結果如下:

7、查看指定數據庫里有哪些數據表:SHOW TABLES IN DbName;

示例:查看xiaoxiao數據庫下面有哪些表

SHOW TABLES IN xiaoxiao

8、獲得表的建表語句:

示例(查看創建emailtest這個表使用的語句方法):show create table emailtest

9、查看數據庫的描述信息和文件目錄位置路徑信息

示例(查看datetest數據庫的描述信息和文件目錄位置信息):describe databasedatetest;

二、創建數據庫

創建xiaoxiao數據庫:

create database xiaoxiao;

二、創建數據表

create ? table staged_employees (

id int ? comment 'id',

user_name ? string comment 'user name')

三、刪除數據庫

刪除數據庫的時候,不允許刪除有數據的數據庫,如果數據庫里面有數據則會報錯。如果要忽略這些內容,則在后面增加CASCADE關鍵字,則忽略報錯,刪除數據庫。

DROP DATABASE DbName CASCADE(可選);

DROP DATABASE IF EXISTS DbName CASCADE;

三、刪除數據表

drop table staged_employees

四、刪除數據表中所有內容

刪除emaitest數據表中的所有內容。

insert overwrite table emailtest select * from emailtest where 1=0

五、更改表名

1、更改表名

-- 重命名表名 ALTER TABLE table_name RENAME TO new_table_name;

六、數據表添加字段:

alter table lemailtest add columns(time int comment 'now time')

七、HIVE統計函數

1、count(1)與count(*)得到的結果一致,包含null值。count(字段)不計算null值

2、集合統計函數

2.1個數統計函數: count

語法: count(*), count(expr), count(DISTINCT expr[, expr_.])

返回值: int

說明: count(*)統計檢索出的行的個數,包括NULL值的行;count(expr)返回指定字段的非空值的個數;count(DISTINCTexpr[, expr_.])返回指定字段的不同的非空值的個數

舉例:

hive> select count(*) from lxw_dual;

20

hive> select count(distinct t) from lxw_dual;

10

2.2總和統計函數: sum

語法: sum(col), sum(DISTINCT col)

返回值: double

說明: sum(col)統計結果集中col的相加的結果;sum(DISTINCT col)統計結果中col不同值相加的結果

舉例:

hive> select sum(t) from lxw_dual;

100

hive> select sum(distinct t) from lxw_dual;

70

七、插入數據到emailtest數據表中(追加數據到原有的數據表中)

讀取fx01數據表數據的一行,然后插入到emailtest數據表,對emailtest數據表原有的數據不會動的。

insert into table emailtest

select * from fx01 limit 1

八、插入數據倒emailtest數據表中(覆蓋原有數據表的數據,相當于把原有數據表先清空,再寫入新的數據)

從fx01數據表讀取數據寫入到emailtest數據表,對原有emailtest數據表數據清空處理。

INSERT OVERWRITE TABLE emailtest

SELECT email,y,m,d

FROMfx01where m=06 and d=19

九、關鍵詞匹配——like

1、從fx01表中查找列content中包含"制度"的行數信息

Select* from fx01 where content like '%制度%'

十、根據某個關鍵字去匹配,然后去設置新的關鍵詞case…when..方法

1、case用法一:CASE? 條件判斷函數 CASE a WHEN b THEN c [WHEN d THEN e]* [ELSE f] END

如果a等于b,那么返回c;如果a等于d,那么返回e;否則返回f

select policy,case policy when 'abc' then '測試' else 'ccc' end as policy from fx01 limit 6

2、case用法二:

假如要用到case when又要用到like這樣的功能,即如果字符串包含‘語文’就怎么怎么樣,包含‘數學’就怎么怎么樣,包含‘英語’就怎么怎么樣,like是用于where中的,放在case when里面是無效的,可以用instr()這個函數來查找這些字符出現的位置,代替like的功能,這樣寫就好吶。

case when instr(t.str,’語文’) > 0 then 0

when instr(t.str,’語文’) > 0 then 1

when instr(t.str,’語文’) > 0 then 2

else 3 end

示例:

select t1.policy,case when instr(t1.policy,'信托') > 0 then '信托'

when instr(t1.policy,'張三') > 0? then '張三1'

when instr(t1.policy,'李四') > 0? then '李四1'

when instr(t1.policy,'小明') > 0? then '小明1' else '小紅' end from (select distinct policy from fx01 limit 6) t1

十一、order by——TOP N

hive實現topN,使用order by和limit組合方式實現。Order by是進行降序排列,limit是選取多少。默認按升序排列,如果要按降序排列在末尾加上DESC,ASC是升序。

取排名TOP 5的數據。

select distinct company,count(company) as num from fx01 where m=05 group by company order by num DESC limit5

十二、數據表多表連接——join

多表連接——join兩個以上的表

SELECT a.val, b.val, c.val FROM a JOIN b ON (a.key = b.key1) JOIN c ON (c.key = b.key2);

join支持left join(左連接)、right join(右連接)、full join(全連接)

1、兩表相關聯示例

select fx01_lanjie.company,fx01_lanjie.lanjie,fx01_yujing.yujing,fx01_lanjie.y,fx01_lanjie.m from fx01_lanjie left join fx01_yujing ON fx01_lanjie.company=fx01_yujing.company

2、三表相關聯示例

select fx01_lanjie.company,fx01_lanjie.lanjie,fx01_yujing.yujing,fx01_fangxing.fangxing,fx01_lanjie.y,fx01_lanjie.m from fx01_lanjie left join fx01_yujing ON fx01_lanjie.company=fx01_yujing.company? join fx01_fangxing on fx01_lanjie.company=fx01_fangxing.company

十三、實現某一列字段關鍵詞統計——split+explode函數

0stu表數據:

stu:

idname

hello,youzm2008

hello,mezm2015

1實現單詞計數:(列轉行)---> split切分+explode(炸開)

1.0數據拆分成數組

select split(id,',') fromstu;得到數組

[hello,you]

[hello,me]

1.1繼續將數組拆分(hive explode函數會將數組繼續拆分成單個字符)

select explode(split(id,','))from stu;窗體函數

hello

you

hello

me

1.2分組統計:

select t1.c1, count(1) from (select explode(split(id,',')) as c1from stu)t1 group by t1.c1;

hello 2

you 1

me 1

案例實現需求:統計“關鍵詞”這一列每個關鍵詞出現的次數,把數字去掉,只統計中文關鍵詞

表名:TesttableIDkewordymd

1北京;廣州;深圳;貴州201728

2重慶;河南201725

712345555201795

實現語句:

Select explode(split(keyword, ';')) asc1from testtable? where keword' rlike '^[\\u4e00-\\u9fa5]+$'

總結

以上是生活随笔為你收集整理的hive插入多条数据sql_HIVE sql使用总结的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。