码迷,mamicode.com
首页 > 数据库 > 详细

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

时间:2016-10-20 07:20:31      阅读:343      评论:0      收藏:0      [点我收藏+]

标签:

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));
        }
    }
}

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

标签:

原文地址:http://www.cnblogs.com/Soulcarrier/p/5979295.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!