13518219792
这篇文章主要介绍了怎么从MySQL数据库中删除Hive元数据，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。
创新互联建站长期为上千余家客户提供的网站建设服务，团队从业经验10年，关注不同地域、不同群体，并针对不同对象提供差异化的产品和服务；打造开放共赢平台，与合作伙伴共同营造健康的互联网生态环境。为威县企业提供专业的网站设计制作、成都网站建设，威县网站改版等技术服务。拥有十载丰富建站经验和众多成功案例,为您定制开发。
Hive上所有元数据均保存在RDBMS中，所以删除RDBMS中的Hive的元数据，不会影响HDFS上的数据。目前针对MySQL数据库进行分析。
Hive在MySQL数据库中的相关元数据的关系图：
解决办法：先MySQL的库中建个存储过程P_TBL_DATA_DEL后，执行该存储过程就可以了。
存储过程脚本：
DELIMITER $$
DROP PROCEDURE IF EXISTS P_TBL_DATA_DEL$$
CREATE PROCEDURE P_TBL_DATA_DEL(
i_tbl_id int -- 表ID
,outo_outcode integer -- 输出代码
,outo_outmsg varchar(500) -- 输出信息
)
COMMENT '从MySQL数据库中删除Hive元数据'
label_pro:
BEGIN
/*======================================================================
* 交 易 名 称 : 从MySQL数据库中删除Hive元数据
* 功 能 概 述 ：
* 输 入 表 :
* 输 出 表 :
*
* 文 件 名 称 : P_TBL_DATA_DEL.sql
* 设 计 : 设计时间:
* 开 发 : wg 开发时间: 2018-07-31 15:06
*
* 测 试 代 码 : call P_TBL_DATA_DEL(i_tbl_id,@o_outcode,@o_outmsg);
* select @o_outcode,@o_outmsg;
======================================================================*/
-- =========================== 声明变量 ===========================
-- 自定义变量
DECLARE v_sd_id int ; -- 存储配置ID SDS: 该表保存文件存储的基本信息
DECLARE v_part_id int ; -- 分区ID PARTITIONS:该表存储表分区的基本信息
DECLARE v_cd_id int ; -- 表字段信息ID COLUMNS_V2:该表存储表对应的字段信息
DECLARE v_serde_id int ; -- 序列化类配置ID SERDES:该表存储序列化使用的类信息
DECLARE v_tbl_id int ; -- 表ID 用于接收输入参数
-- =========================== 声明异常 ===========================
DECLARE EXIT HANDLER FOR SQLEXCEPTION
BEGIN
ROLLBACK;
-- 发生异常后的返回值
set o_outcode =-1;
set o_outmsg ='failure';
end ;
-- =========================== 变量初始化 ===========================
-- 判断输入的表ID是否为NULL，并进行赋值
IF i_tbl_id IS NOT NULL then
SET v_tbl_id = i_tbl_id ;
ELSE -- 否则默认赋值0
SET v_tbl_id = 0 ;
END IF ;
-- =========================== 业务处理 ===========================
-- START TRANSACTION;
-- todo begin
-- 根据表ID获取 存储配置ID(SDS.SD_ID)
select
SD_ID
into
v_sd_id
from tbls
where TBL_ID = v_tbl_id
;
-- 根据表ID获取 分区ID(PARTITIONS.part_id)
select
part_id
into
v_part_id
from partitions
where tbl_id = v_tbl_id
;
-- 根据存储配置ID(SDS.SD_ID)获取 表字段信息ID(COLUMNS_V2.cd_id)和序列化类配置ID(SERDES.serde_id)
select
cd_id
,serde_id
into
v_cd_id
,v_serde_id
from sds
where sd_id = v_sd_id
;
-- 删除表属性信息数据
delete from table_params where tbl_id = v_tbl_id;
-- 删除表信息数据
delete from tbls where tbl_id = v_tbl_id;
-- 删除文件存储的基本信息数据
delete from sds where sd_id = v_sd_id;
-- 删除存储序列化属性信息数据
delete from serde_params where serde_id = v_serde_id;
-- 删除存储序列化使用的类信息数据
delete from serdes where serde_id = v_serde_id;
-- 删除表的字段信息数据
delete from columns_v2 where cd_id = v_cd_id;
-- 判断是否v_part_id值是否为空,如果不为空,表示分区属性表和分区字段值表有值,进行删除.
if v_part_id is not null then
-- 删除分区属性信息数据
delete from partition_params where part_id = v_part_id;
-- 删除分区字段值表数据
delete from partition_key_vals where part_id = v_part_id;
end if;
-- 删除分区信息数据
delete from partitions where tbl_id = v_tbl_id;
-- 删除分区字段信息数据
delete from partition_keys where tbl_id = v_tbl_id;
-- todo end
-- COMMIT;
-- 处理成功后的返回值
set o_outcode =0;
set o_outmsg = 'succe' ;
END
$$
DELIMITER ;
感谢你能够认真阅读完这篇文章，希望小编分享的“怎么从MySQL数据库中删除Hive元数据”这篇文章对大家有帮助，同时也希望大家多多支持创新互联，关注创新互联行业资讯频道，更多相关知识等着你来学习!
