Java HIVE 使用Jdbc连接Hive-蒲公英云

Java HIVE 使用Jdbc连接Hive

1，使用Jdbc方式链接hive,首先需要启动hive的Thrift Server，否则会导致错误

hive —service hiveserver 是两”-“，

Could not establish connection to localhost:10000/default: java.net.ConnectException: Connection refused

2，简单的Java代码实现；

——通过Class.forName(“org.apache.hadoop.hive.jdbc.HiveDriver”);加载hive驱动

——通过Connection conn = DriverManager.getConnection(“jdbc//localhost:10000/default”,””,””);建立与数据库的连接

eg:

package hive.jdbc;

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

public class HiveJdbcDriver {

public static void main(String\[\] args) throws Exception \{  
    Class.forName("org.apache.hadoop.hive.jdbc.HiveDriver");  
    Connection conn = DriverManager.getConnection("jdbc:hive://localhost:1000/default","","");  
    Statement stmt = conn.createStatement();  
    String tablename = "u\_data\_new";  
    String quary\_sql = "select weekday,count(\*) from " + tablename + " group by weekday";  
    ResultSet rs = stmt.executeQuery(quary\_sql);  
    while(rs.next())\{  
        System.out.println("weekday: "+rs.getInt(1)+"count: "+rs.getInt(2));  
    \}  
\}