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

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

1
2
hive --service metastore &
hive --service hiveserver2 &

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
< 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需要添加两个依赖：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
<!--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  -->

代码演示：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
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; // 返回所建立的数据库连接
    }
}