一个jdbc链接hive的小例子

最新推荐文章于 2024-09-25 10:43:25 发布

java_doom

最新推荐文章于 2024-09-25 10:43:25 发布

阅读量166

点赞数

分类专栏： hadoop 文章标签： java 大数据数据库

hadoop 专栏收录该内容

31 篇文章

订阅专栏

本文提供了一个使用Java API连接并查询Hive数据库的例子。通过示例代码展示了如何加载Hive驱动、建立连接、获取元数据及打印列信息等操作。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

先启动Hive远程服务接口

hive --service hiveserver

import java.sql.Connection;  
import java.sql.DriverManager;  
import java.sql.ResultSet;  
import java.sql.ResultSetMetaData;
import java.sql.Statement;
import org.apache.hadoop.hive.jdbc.HiveDriver;;
public class HiveTest {

	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 person";  
          
        Connection con = DriverManager.getConnection("jdbc:hive://127.0.0.1:10000/default", "", "");  
        Statement stmt = con.createStatement();  
        ResultSet rs = null;
        
        
       // rs = stmt.executeQuery("select * from rc_box_office");
        ResultSetMetaData meta2 = stmt.executeQuery("SELECT * FROM person").getMetaData();
        
        System.out.println(meta2.getColumnCount()+"  *0");
        
        System.out.println(meta2.getColumnName(1)+"  *1");
        
        System.out.println(meta2.getColumnType(1)+"  *2");
        System.out.println(meta2.getColumnType(2)+"  *3");
        System.out.println(meta2.getColumnType(3)+"  *4");
        //System.out.println(meta2.getCatalogName(1)+"  *4");
        
        
        //        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));  
        } */ 
    }  
}

那天写个同步oracle和hive表的程序试试