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

时间：2016-10-20 07:20:00 阅读：247 评论：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));

}

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

踩

(0)

评论一句话评论（0）

分享档案

更多>

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