hive存储过程怎么用

发布时间：2021-12-10 14:22:54 阅读：339 作者：小新栏目：大数据

开发者测试专用服务器限时活动，0元免费领，库存有限，领完即止！点击查看>>

这篇文章主要介绍了hive存储过程怎么用，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。

1、hive存储过程简介

1.x版本的hive中没有提供类似存储过程的功能，使用Hive做数据开发时候，一般是将一段一段的HQL语句封装在Shell或者其他脚本中，然后以命令行的方式调用，完成一个业务或者一张报表的统计分析。好消息是，现在已经有了Hive存储过程的解决方案（HPL/SQL –Procedural SQL on hadoop），并且在未来的Hive的版本（2.0）中，会将该模块集成进来。该解决方案不仅支持Hive，还支持在SparkSQL，其他NoSQL，甚至是RDBMS中使用类似于Oracle PL/SQL的功能，这将极大的方便数据开发者的工作，Hive中很多之前比较难实现的功能，现在可以很方便的实现，比如自定义变量、基于一个结果集的游标、循环等等。

2、hplsql安装和存储过程案例

下载：

官网下载地址：自行下载哈，不附链接了

0.3.31版本下载地址：自行下载哈，不附链接了

安装hplsql：

[root@hadoop01 home]# tar -zxvf /home/hplsql-0.3.31.tar.gz -C /usr/local/

配置hplsql：

vi ./hplsql

内容如下:

#!/bin/bashexport "HADOOP_CLASSPATH=$HADOOP_CLASSPATH:$HADOOP_HOME/lib/*"export "HADOOP_CLASSPATH=$HADOOP_CLASSPATH:$HADOOP_CONF_DIR/"                                           export "HADOOP_CLASSPATH=$HADOOP_CLASSPATH:$HADOOP_HOME/share/hadoop/mapreduce/*"export "HADOOP_CLASSPATH=$HADOOP_CLASSPATH:$HADOOP_HOME/share/hadoop/mapreduce/lib/*"                                                        export "HADOOP_CLASSPATH=$HADOOP_CLASSPATH:$HADOOP_HOME/share/hadoop/hdfs/*"export "HADOOP_CLASSPATH=$HADOOP_CLASSPATH:$HADOOP_HOME/share/hadoop/hdfs/lib/*"                                                        export "HADOOP_CLASSPATH=$HADOOP_CLASSPATH:$HADOOP_HOME/share/hadoop/yarn/*"export "HADOOP_CLASSPATH=$HADOOP_CLASSPATH:$HADOOP_HOME/share/hadoop/yarn/lib/*"export "HADOOP_CLASSPATH=$HADOOP_CLASSPATH:$HADOOP_HOME/share/hadoop/common/*"export "HADOOP_CLASSPATH=$HADOOP_CLASSPATH:$HADOOP_HOME/share/hadoop/common/lib/*"                                                        export "HADOOP_CLASSPATH=$HADOOP_CLASSPATH:$HIVE_HOME/lib/*"export "HADOOP_CLASSPATH=$HADOOP_CLASSPATH:$HIVE_HOME/conf"export HADOOP_OPTS="$HADOOP_OPTS -Djava.library.path=$HADOOP_HOME/lib/native"SCRIPTPATH=${0%/*}java -cp $SCRIPTPATH:$HADOOP_CLASSPATH:$SCRIPTPATH/hplsql-0.3.31.jar:$SCRIPTPATH/antlr-runtime-4.5.jar $HADOOP_OPTS org.apache.hive.hplsql.Hplsql "$@"

配置hive2的服务：

vi ./conf/hive-site.xml

追加内容如下：

  <property>    <name>hive.server2.thrift.bind.host</name>    <value>hadoop01</value>  </property>  <property>    <name>hive.server2.thrift.port</name>    <value>10000</value>  </property>

重启hiveserver2：

nohup hive --service hiveserver2 > hiveserver2.log 2>&1 &

配置HPL/SQL与Hive的连接：

vi ./hplsql-site.xml

hive存储过程怎么用

使用hplsql -e执行命令：

[root@hadoop01 hplsql-0.3.31]# ./hplsql -e "CURRENT_DATE + 1"2019-09-18[root@hadoop01 hplsql-0.3.31]# ./hplsql -e "for i in 1 .. 10 loop print i;end loop;"12345678910

hplsql -f执行脚本：

测试表：

hive>select * from qf24.u5;

7 yy

3 cc

2 bb

创建脚本hp.sql

create function hello(text string)returnS stringBEGINRETRUEN 'Hello,' || text || '!';END;FOR item IN(SELECT id,name FROM qf24.u5 limit 3)loop        println item.id || '|' || item.name || '|' || hello(item.name);end loop;

测试：

[root@hadoop01 hplsql-0.3.31]# ./hplsql -f /home/hivedata/hp.sql7|yy|Hello,yy!3|cc|Hello,cc!2|bb|Hello,bb!

创建存储过程的格式：

use database;create procedurebegin......end;

调用存储过程:

include path/sp namecall sp name;

案例：

创建存储过程：

use qf24;create procedure select_u5()beginselect * from qf24.u5;end;

调用：

include 文件路径 (在代码文件中引入)

执行执行文件：

[root@hadoop01 hplsql-0.3.31]# ./hplsql -f /home/hivedata/ps.sql

调用指定存储过程或者方法：

[root@hadoop01 hplsql-0.3.31]# ./hplsql -f /home/hivedata/ps.sql -main select_u5

感谢你能够认真阅读完这篇文章，希望小编分享的“hive存储过程怎么用”这篇文章对大家有帮助，同时也希望大家多多支持亿速云，关注亿速云行业资讯频道，更多相关知识等着你来学习!

亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>

向AI问一下细节

hive存储过程怎么用

猜你喜欢

最新资讯

相关推荐

开发者交流群：

相关标签