通过JDBC驱动连接Hive操作实例

我们在编程过程中数据库连接比较常用的，如果连接hive可以作为参考：虽然内容较短，但是里面仍有文章：

1.连接涉及到那些包？
2.Class.forName的作用是什么？
3.如何启动远程服务器借口？
4.Statement与传统数据库那个类型作用相似？


启动Hive远程服务接口：
bin/hive --service hiveserver

测试代码如下

package com.yuxipacific;

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

public class Hive {

        public static void main(String[] args) throws Exception {
                
                Class.forName("org.apache.hadoop.hive.jdbc.HiveDriver");
                
                //String dropSQL="drop table javabloger";
        //String createSQL="create table javabloger (key int, value string)";
        //String insterSQL="LOAD DATA LOCAL INPATH '/work/hive/examples/files/kv1.txt' OVERWRITE INTO TABLE javabloger";
        //String querySQL="SELECT a.* FROM javabloger a";
                String querySQL="SELECT * FROM pokes";
        
        Connection con = DriverManager.getConnection("jdbc:hive://192.168.11.124:10000/default", "", "");
        Statement stmt = con.createStatement();
//        stmt.executeQuery(dropSQL);
//        stmt.executeQuery(createSQL);
//        stmt.executeQuery(insterSQL);
        ResultSet res = stmt.executeQuery(querySQL);
        
        while (res.next()) {
            System.out.println("Result: key:"+res.getString(1) +"  –>  value:" +res.getString(2));
        }
        }
}
复制代码

我连接的时候也是报错Exception in thread "main" java.lang.IncompatibleClassChangeError: class com.facebook.fb303.FacebookService$Client has interface org.apache.thrift.TServiceClient as super class
求解  。。。。

我连接的时候也是报错Exception in thread "main" java.lang.IncompatibleClassChangeError: class com.facebook.fb303.FacebookService$Client has interface org.apache.thrift.TServiceClient as super class
求解  。。。。

hdwmp123 发表于 2015-10-12 15:00
我连接的时候也是报错Exception in thread "main" java.lang.IncompatibleClassChangeError: class com.f ...

libfb303-0.9.0.jar从hive里面把这个包拷贝出来放到程序里面试试

感谢楼主分享

感觉和普通的jdbc编程一样的啊