hive ddl dml hivesql命令大全

news/2025/12/8 21:52:10/文章来源:https://www.cnblogs.com/wuzaipei/p/19323754
SELECT T.sname,T.ctfid,T.gender,t.address,count(*) OVER(PARTITION BY T.sname) AS FM_CNTFROM test_db.room3 T WHERE  T.address like "%北京%" AND instr(T.ctfid,'310')>0
ORDER BY FM_CNT DESC;select gender,sum(cnt) as cnt from test_db.room2_view where length(trim(gender))>0 group by gender order by cnt desc;desc test_db.room2;-- DROP TABLE default.room2_gender_out PURGE ;-- 删除数据库
//DROP DATABASE db_hive1;// 1.创建数据库
CREATE DATABASE IF NOT EXISTS db_hive1COMMENT "hive学习教程数据库" --数据库备注LOCATION '/hivedata/db_hive1' --数据库存储hdfs路径WITH DBPROPERTIES ("create_dt"="2025-12-07","create_user"="hadoop") --数据库信息k,v
;//查看数据库
SHOW DATABASES LIKE "*db*";//查看数据库的信息
describe DATABASE EXTENDED db_hive1;//查看更多信息
DESC DATABASE EXTENDED db_hive1;//2.修改数据库
ALTER DATABASE db_hive1 set DBPROPERTIES ("create_dt"="2025-12-08","create_user"="wwwdp") ;
ALTER DATABASE db_hive1 set LOCATION '/hivedata/db_hive1'; --数据库存储hdfs路径
ALTER DATABASE db_hive1 set OWNER USER hadoop; -- 修改数据库归属用户-- 删除数据库
//DROP DATABASE db_hive1 RESTRICT ; --数据库不为空删除失败
//DROP DATABASE db_hive1 CASCADE ; -- 将表和库一并 删除//切换数据库
use test_db;// 3 建表操作
-- 内部表
drop table db_hive1.tb_test1 purge ;
CREATE TABLE db_hive1.tb_test1
(dat_dt date COMMENT "DATE",
idky bigint COMMENT "主键",
amt decimal(30,4) COMMENT "AMT",
name varchar(4000) COMMENT "NAME",
work_list array<string> COMMENT "ARRAY",
addr_map MAP<string,string> COMMENT "Map"
)
COMMENT "nei bu biao"
--location "/hivedata/db_hive1/tb_test1"
-- row format delimited
-- ROW FORMAT SERDE ''
STORED AS orc -- textfile/orc/parquet
TBLPROPERTIES ("create_dt"="20251207")
;
INSERT INTO db_hive1.tb_test1 VALUES
(date '2023-10-01', 123456789, 1234.5678, 'John Doe',array('work1', 'work2'), map('city', 'New York', 'country', 'USA'));select * from db_hive1.tb_test1 t;
select t.dat_dt,t.idky,t.name,t.work_list[0],t.work_list[1],t.addr_map["city"],t.addr_map["country"]from db_hive1.tb_test1 t;-- 查看建表信息
desc extended db_hive1.tb_test1;//会话临时表
CREATE TEMPORARY TABLE db_hive1.tb_test2
(dat_dt date,
idky int,
name string)
COMMENT "nei bu biao"
STORED AS ORC -- textfile/orc/parquet
;
-- select * from db_hive1.tb_test2;--外部表
CREATE EXTERNAL TABLE db_hive1.tb_test3
(dat_dt date,
idky int,
name string)
COMMENT "nei bu biao"
location "/hivedata/db_hive1/tb_test3"
STORED AS orc -- textfile/orc/parquet
TBLPROPERTIES ("tab"="tb_test3")
;desc extended db_hive1.tb_test3;select date '2024-10-01' dat;-- 数据类型
select cast('908.342' as decimal(30,4)) as vles;-- 建表 like语法
CREATE TABLE db_hive1.room4 like db_hive1.tb_test1;-- 建表 as语法
drop table  db_hive1.room4 purge ;
create table db_hive1.room4 asselect * from test_db.room3;use db_hive1;select * from db_hive1.room4 r where r.address like "%剑河%";-- 查看 ddl 建表语句
show create table db_hive1.tb_test1;SELECT T.sname,T.ctfid,T.gender,t.address,count(*) OVER(PARTITION BY T.sname) AS FM_CNTFROM db_hive1.room4 T WHERE  T.address like "%北京%" AND instr(T.ctfid,'310')>0
ORDER BY FM_CNT DESC;-- 建表指定分隔符
CREATE TABLE db_hive1.tb_test5
(dat_dt date,
idky int,
name string)
COMMENT "nei bu biao"
location "/hivedata/db_hive1/tb_test5"
ROW FORMAT DELIMITED FIELDS TERMINATED BY "|@|"
STORED AS orc -- textfile/orc/parquet
TBLPROPERTIES ("tab"="tb_test3")
;-- 可以使用 hdfs 提交数据值 tb_test5 要求 input.txt 每行字段直接分隔符苇 |@|
-- hdfs dfs -put input.txt /hivedata/db_hive1/tb_test5-- 创建json对接hive表可以直接 put就可以插入数据
drop table db_hive1.teacher;
create table db_hive1.teacher(name string comment "name",friend array<varchar(256)> comment "fred",students map<string,int> comment "students",adderss struct<city:string,amt:decimal(30,4),room:array<int>> comment "adderss"
)
--row format serde 'org.apache.hadoop.hive.serde2.JsonSerDe'  -- 指定 json
--location "/hivedata/db_hive1/teacher"
;INSERT INTO db_hive1.teacher
select "hadoop1" as name,array("fdaf","fdafdfff") as friend,map("city",64) as students,struct("guiyangshi",123.543,array(9,0,32)) as adderss;INSERT INTO db_hive1.teacher
values ("hadoop1",array("fdaf", "fdaffdas"),map("city", 64),struct("guiyangshi", 123.543, `array`(1,2,3,4)));select * from teacher;// 查看表信息
desc extended teacher;
desc formatted teacher;
show tables in db_hive1 "teacher" ;//修改表的语法
drop table stu;
create table db_hive1.stu
(id int,
name string)
row format delimited fields terminated by ",";ALTER TABLE stu RENAME TO  stu1;
//添加字段
ALTER TABLE stu add columns(gender string);
-- 修改字段
set hive.metastore.disallow.incompatible.col.type.changes=false;alter table stu1 change column gender  gend string after name;alter table db_hive1.stu1 replace columns(id int,name string,gend string);-- 清空表只对内部表有用,对外部表无效
truncate table db_hive1.stu;desc stu;-- 二、 数据增删改查  DML
-- 本地导入  OVERWRITE 覆盖的意思,不加则 追加。 inpath 对应的local 节点是 你服务启动的 节点
LOAD DATA LOCAL INPATH "/home/hadoop/stu.txt"  INTO TABLE db_hive1.stu;
-- HDFS分布式文件路径
LOAD DATA INPATH "" OVERWRITE INTO TABLE db_hive1.stu;-- 分区表
-- LOAD DATA INPATH "" OVERWRITE INTO TABLE db_hive1.stu PARTITION (....);select * from db_hive1.stu;//多条数据插入
insert into db_hive1.stu
values(1,"faf"),(2,"test");-- 把查询sql的数据 写入到本地对应路径的
insert overwrite local directory "/home/hadoop/data/stu" row format serde "org.apache.hadoop.hive.serde2.JsonSerDe"
select id,name from db_hive1.stu;-- 导出和导入EXPORT TABLE db_hive1.stu to "/hivedata/stuout"; -- 导出数据及元数据,到hdfs 文件系统上
IMPORT /*external*/ TABLE stu from "hivedata/stuout"; -- 导入表元数据及数据 external 声明外部表// 三、hive查询语句
//SELECT * FROM stu WHERE ID = 1 GROUP BY id HAVING count(*)>1 ORDER BY id LIMIT 1,10;SELECT * FROM test_db.room2_view limit 4;SELECT * FROM test_db.room2_view w where not w.gender ='12';SELECT * FROM db_hive1.stu T WHERE T.id BETWEEN 0 AND 2;SELECT * FROM db_hive1.stu T WHERE nvl(T.id,1) IN(0,1);SELECT * FROM db_hive1.stu T where T.name like "%f%";SELECT * FROM db_hive1.stu T where T.name regexp "正则表达式";
-- 逻辑语句 and or not
-- 聚合函数 count(*) avg() max() min(*)-- 本地模式
// set mapreduce.framework.name local;

  

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/993602.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

杭州刑事案件法律咨询找谁?刑事律师推荐

遇到刑事案件,时间就是生命。杭州刑事案件法律咨询找谁?今天给大家推荐一家专业的刑事辩护律所。 刑事案件为什么要尽早找律师? 黄金37天很关键,刑事拘留期:最长37天这个阶段律师能做什么:会见当事人了解案情;申…

【AI】第一篇:语言模型的前世 n-gram的简单介绍

1. N-gram 是什么?核心逻辑与“N”的含义 N-gram 是自然语言处理(NLP)中一种基于统计的语言模型,其核心思想是:一个词的出现概率,可以由它前面 N-1 个词来预测。它把文本按照连续的 N 个词(或字符)切分成片段(…

【12.11 直播】时序数据库 IoTDB FAQ 全面解答|下一期聊什么?你来决定!

集中解答你最想知道的问题,你还想了解什么?请告诉我们!🤔你在用时序数据库 IoTDB 时,是否也遇到过这些“灵魂拷问”: 🚀为什么我的查询无法执行? 💡树模型、表模型到底该如何选? 🔑如何与现有系统进行高…

12/8

今天满课,全是专业课,写了个Java系统,后端打不开,气死我了,晚上还要写统一建模语言

洛谷 P8189

洛谷 P8189有 \(n\) 个礼物分配给 \(n\) 个人,第 \(i\) 个人原本拥有第 \(i\) 个礼物,每个人都要一个喜欢程度的列表,现在他们可以交换礼物,但每个人最后得到的礼物的喜欢程度不能低于原本的礼物。 \(T\) 组询问,…

计算机毕业设计springboot图书销售框架设计与构建 基于 SpringBoot 的在线书城营销平台构建与实战 SpringBoot 驱动的数字化图书商城系统研发

pre { white-space: pre !important; word-wrap: normal !important; overflow-x: auto !important; display: block !important; font-family: "Consolas", "Monaco", "Courier New", …

12月8日

你永远无法想象未来会发生什么!

2025常州会计师事务所实力榜:汇丰所以审计创新与税务筹划优势领跑,江苏八城专业服务机构深度解析

2025常州会计师事务所实力榜:汇丰所以审计创新与税务筹划优势领跑,江苏八城专业服务机构深度解析 在长三角经济一体化与产业升级的宏观背景下,江苏省内企业的财务合规、战略咨询与风险管理需求日益精细化、专业化。…

题解:P14666 [KenOI 2025] 游走题

很好的数数题。 思路 观察样例,猜一个结论:游走的终点只可能是节点 \(1\)。考虑证明,一个节点如果往儿子走最终显然是可以再走回父亲的,但如果走到了父亲就不能再走回去了。所以只有走到一个没有父亲的点且把这个点…

你在用什么免费ip库?

事情是这样的,这几天我们站一直被不明ip频繁抓取数据! 6bdd3bee5195c13f7f6b00464f4fcda7 看了下都是越南的ip,你们遇到这种情况是怎么处理的? 导致我们的ip138经常使用过量。 老板让我找免费的ip库,找来找去找到了…

Python核心容器类型教程:列表、字典、元组、集合用法与实战

容器类型是Python处理数据的核心工具,掌握列表(List)、字典(Dict)、元组(Tuple)、集合(Set)这四类核心容器,能让你高效存储、遍历、操作数据——从简单的数据分析到复杂的业务逻辑开发,都离不开这些基础容器…

doc-llm-autotest 基于大模型的文档自动化测试平台:worker服务的可靠性增强

一、可靠性分析 从架构图上,我们可以看出worker调用大模型服务过程中,会发生阻塞等待,如果此时worker异常容器挂掉了,那么此次任务状态会一直为processing,并且因为redis关联task_id的消息已经被消费了,那么这个…

个人电脑本地私有知识库:访答知识库深度解析

个人电脑本地私有知识库:访答知识库深度解析 什么是本地私有知识库? 本地私有知识库是一种将知识数据存储在个人电脑本地的管理工具,与云端存储不同,它提供了更高的数据安全性和隐私保护。用户可以在不依赖网络的情…

58

所学时间:11小时

TB710FU原厂刷机包下载_CN_ZUI_17.0.04.279_ST_250808

联想小新平板Pro GT原厂刷机包下载原厂刷机包下载https://pan.quark.cn/s/8e72cb38987b联想小新平板Pro GT原厂刷机包下载

Python service Flask generate list data and display in web view via html and javscript

python -m pip install flask python -m pip install flask-cors //Flaskfrom flask import Flask,jsonify,send_from_directory from flask_cors import CORS import uuid import time import os from datetime impor…

仿真分析工具 Abaqus 2024 下载安装教程:含安装包下载 + 配置教程,新手也能一次成功

一、Abaqus 2024 核心功能 做机械设计、土木工程、航空航天仿真的朋友,对 Abaqus 肯定不陌生 —— 它是 DS SIMULIA Suite 旗下的顶尖有限元分析软件,2024 版本在稳定性、计算效率和模块兼容性上又做了升级,不管是常…

香橙派上进行 Livox Mid-360 激光雷达开发(二)移植FAST_LIO

香橙派上进行 Livox Mid-360 激光雷达开发(二)移植FAST_LIO基本信息 主机:Orangepi5max 16G (ARM64 架构) + 64G tf卡 系统:Orangepi5max_1.0.0_ubuntu_jammy_desktop_xfce_linux5.10.160(ubuntu 22.04) 系统配…

Mybatis拦截器原理解析

一、概述 在Mybatis开发体系中,“过滤器”是开发者对Mybatis拦截器(Plugin)的通俗称呼,它是Mybatis提供的核心扩展机制——无需修改框架源码,就能对SQL执行全流程进行增强,比如分页插件、通用字段自动填充、数据…

10406_基于Springboot的社交平台系统

1、项目包含 项目源码、项目文档、数据库脚本、软件工具等资料; 带你从零开始部署运行本套系统。 2、项目介绍 本文采用SpringBoot进行设计,采用java技术开发,选用MySQL作为后台数据库。系统针对社交平台的需求,包…