JDBC连接HIVE

  hive是大数据技术簇中进行数据仓库应用的基础组件，是其它类似数据仓库应用的对比基准。基础的数据操作我们可以通过脚本方式以hive-client进行处理。若需要开发应用程序，则需要使用hive的jdbc驱动进行连接.

代码连接hive需要先启动hive的metastore和hiveserver2

hive --service metastore &
hive --service hiveserver2 &

其中hive-site.xml的配置为：

<configuration>
<property>
<name>javax.jdo.option.ConnectionURL</name>
<value>jdbc:mysql://192.168.174.131:3306/hive?createDatabaseIfNotExist=true</value>
<description>JDBC connect string for a JDBC metastore</description>
</property>

<property>
<name>javax.jdo.option.ConnectionDriverName</name>
<value>com.mysql.jdbc.Driver</value>
<description>Driver class name for a JDBC metastore</description>
</property>

<property>
<name>javax.jdo.option.ConnectionUserName</name>
<value>root</value>
<description>username to use against metastore database</description>
</property>

<property>
<name>javax.jdo.option.ConnectionPassword</name>
<value>123456</value>
<description>password to use against metastore database</description>
</property>

<property>  
<name>hive.metastore.uris</name>  
<value>thrift://192.168.174.131:9083</value>  
</property>

<property>
<name>hive.support.sql11.reserved.keywords</name>
<value>false</value>
</property>
</configuration>

代码要想连接hive需要添加两个依赖：

<!--S：连接hive  -->
<!-- https://mvnrepository.com/artifact/org.apache.hive/hive-jdbc -->
 <dependency>
   <groupId>org.apache.hive</groupId>
   <artifactId>hive-jdbc</artifactId>
    <!--注：此处的版本要和hive的lib中对应jar包的版本一致-->
   <version>1.2.1</version>
</dependency>

<dependency>
   <groupId>org.apache.hadoop</groupId>
   <artifactId>hadoop-common</artifactId>
   <version>2.6.4</version>
</dependency>
<!--E：连接hive  -->

代码演示：

package com.fwmagic.jdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;


import com.mysql.jdbc.Statement;

public class JdbcHive {
   private static Connection conn;

   private static Statement st;
   
   public static void main(String[] args) throws Exception {
      Connection connection = getConnection();
      System.out.println("connection:"+connection);
      String sql = "show tables";
      PreparedStatement prepareStatement = connection.prepareStatement(sql);
      ResultSet rs = prepareStatement.executeQuery();
      while(rs.next()){
         String db = rs.getString(1);
         System.out.println(db);
      }
   }
   /* 获取数据库连接的函数 */
   private static Connection getConnection() {
      Connection con = null; // 创建用于连接数据库的Connection对象
      try {
         Class.forName("org.apache.hive.jdbc.HiveDriver");// 加载hive2数据驱动

         con = DriverManager.getConnection(
               "jdbc:hive2://192.168.174.131:10000/default", "root", null);// 创建数据连接

      } catch (Exception e) {
         System.out.println("hive数据库连接失败" + e.getMessage());
      }
      return con; // 返回所建立的数据库连接
   }
}