hive 查詢並寫入新錶操作案例

命令和結果

統計城市酒店數量和房間數量, 以城市房間數降序排列, 並列印前10條統計結果

將結果寫入table3_1中

檢視table3_1的前5行資料

資料表樣式

資料項欄位名

省份provice

城市city

酒店數量

hotel_num

房間數量

room_num

資料樣式:

province

city

hotel_num

room_num

貴州貴陽

1234

123456.0

首先我們要有乙個資料表來儲存原始資料,我們把它命名為htl, 字段之間用』\t』分隔;

create

table htl(
province string,
city string,
hotel_num int
,room_num float
)row format delimited
fields
terminated
by'\t'
;

貴州 貴陽 2134 213423.0

山東 濟南 2314 324123.0

吉林 吉林 3324 234123.0

吉林 長春 1245 453232.0

山東 威海 1245 125132.0

山東 濰坊 1236 243252.0

浙江 溫州 4136 125315.0

浙江 紹興 5425 324521.0

河北 滄州 2634 342623.0

河北 洛陽 4562 546123.0

河北 石家莊 5613 346315.0

海南 三亞 5432 143562.0

海南 海口 3426 456154.0

load

data
local inpath '/data/h3c1/data.txt' overwrite into
table htl;

然後我們查詢一下, 驗證表裡的資料是否有誤;

我們表裡資料沒有什麼問題,我們就可以實現需求1了;

要以城市房間數降序查詢,要用到order by, desc關鍵字;

輸出前十行要用到limit關鍵字;

命令和結果如下:

實現需求2,首先我們要新建乙個table3_1,表結構和htl表是一樣的;然後把htl的搜尋結果匯入到table3_1中;

命令和結果如下:

然後我們要檢視table3_1的前五行資料;

查詢Mysql並寫入檔案

conding utf 8 import pymysql import os import sys 開啟資料庫連線 db pymysql.connect 10.33.85.145 root uxx 2013 使用 cursor 方法建立乙個游標物件 cursor runsql db.cursor 使...

sqlserver 將union查詢寫入新錶

寫入臨時表 select into temp 寫入新錶 use report goif exists select name from sys.objects where name 消費 月 drop table 消費 月 gouse account management goselect t.in...

hive表查詢 排序

1.全域性排序 order by 使用orderby對全域性進行排序的前提是只能有乙個reduce。order by asc公升序，order by desc降序。order by 列別名 按照別名公升序排序 order by 列名1 列名2 先按照列名1的公升序排序，如果相等再按照列名2進行排序 ...