欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

Hive篇.Hive的三种使用方式

程序员文章站 2022-05-23 17:26:43
...

第一种:控制台模式

//查看所有的表
hive>show tables;
//创建表
hive>create table t1(id int,name string);
//插入表数据,和mysql的操作一样,会转化成mapReduce程序
hive>insert into t1(id,name) values (1,'zs');
//查询表数据
hive>select * from t1;
//退出控制台
hive>quit;

第二种:脚本文件方式【实际生产中用的最多的方式】

##第一种:封装到shell脚本中调用【工作中常用】
//执行hive查询命令,不用进入控制台模式
hive -e "select * from t1"
//将查询命令输出到脚本文件中
echo "hive -e \"select * from t1\"" > t1.sh
//执行脚本
sh -x t1.sh
##第二种:把sql语句保存到文件中
//将建表语句输出到脚本文件中
echo "create table t1(id int,name string);" > t1.sql
//执行脚本
hive -f t1.sql
##注:这种方式一般用在初始化表结构或者数据的时候使用

第三种:JDBC方式

//hive远程服务(端口号10000)启动方式
hive --service hiveserver2 
//示例代码可以在这里找到
https://cwiki.apache.org/confluence/display/Hive/HiveServer2+Clients#HiveServer2Clients-JDBC
//下面是代码
import java.sql.DriverManager;
import java.sql.Connection;
import java.sql.Statement;
import java.sql.ResultSet;

public class HiveDemo {
    public static void main(String[] args) throws Exception{
        Class.forName("org.apache.hive.jdbc.HiveDriver");
        Connection connection = DriverManager.getConnection("jdbc:hive2://bigdata11:10000/default", "root", "");
        Statement statement = connection.createStatement();
        ResultSet resultSet = statement.executeQuery("select * from t1");
        while (resultSet.next()){
            System.out.println(resultSet.getInt("id") + "\t" + resultSet.getString("name"));
        }
    }
}
//下面是引用的依赖
<dependencies>
    <!-- https://mvnrepository.com/artifact/org.apache.hive/hive-jdbc -->
    <dependency>
        <groupId>org.apache.hive</groupId>
        <artifactId>hive-jdbc</artifactId>
        <version>1.2.2</version>
    </dependency>
    <!-- https://mvnrepository.com/artifact/org.apache.hadoop/hadoop-client -->
    <dependency>
        <groupId>org.apache.hadoop</groupId>
        <artifactId>hadoop-client</artifactId>
        <version>2.7.5</version>
    </dependency>
</dependencies>