直接代碼吧：記得要開啟hive jdbc服務hive --service hiveserver

package hive;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.Statement;

public class HiveDemo {

static{

//注冊jdbc驅動

try {

Class.forName("org.apache.hadoop.hive.jdbc.HiveDriver");

} catch (ClassNotFoundException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

public static void main(String[] args) throws Exception {

//創建連接

Connection conn = DriverManager.getConnection("jdbc:hive://hadoop:10000/default","","");

//System.out.println(conn);

Statement st = conn.createStatement();

String tableName = "u1_data";

//刪除表

st.executeQuery("drop table "+tableName);

//創建表

ResultSet rs = st.executeQuery("create table "+tableName+"("

+ "userid int,"

+ "movieid int,"

+ "rating int,"

+ "city string,"

+ "viewTime string"

+ ")"

+ "row format delimited "

+ "fields terminated by ‘\t‘ "

+ "stored as textfile");

//顯示所有的表

String sql = "show tables";

System.out.println("running:"+sql);

rs = st.executeQuery(sql);

if(rs.next()){

System.out.println(rs.getString(1));

}

//得到表信息

sql = "describe "+tableName;

System.out.println("running:"+sql);

rs = st.executeQuery(sql);

while(rs.next()){

System.out.println(rs.getString(1)+"\t"+rs.getString(2));

}

//加載數據

String filePath = "hdfs://hadoop:9000/input";

sql = "load data inpath ‘"+filePath+"‘ overwrite into table "+tableName;

System.out.println("running:"+sql);

rs = st.executeQuery(sql);

//查詢數據

sql = "select * from "+tableName+" limit 5";

System.out.println("running:"+sql);

rs = st.executeQuery(sql);

while(rs.next()){

System.out.println(rs.getString(3)+"\t"+rs.getString(4));

}

//查詢數量

sql = "select count(*) from "+tableName;

System.out.println("running:"+sql);

rs = st.executeQuery(sql);

while(rs.next()){

System.out.println(rs.getString(1));

}

//關閉資源

rs.close();

st.close();

conn.close();

}

}

原文：http://www.cnblogs.com/jsunday/p/3872763.html

總結

以上是生活随笔為你收集整理的java hive demo_java 操作hive通过jdbc的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。