Hive_JDBC.zip_hive java_hive jdbc_hive jdbc pom_java hive_maven连

package cn.dong.hive; import java.sql.Connection; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; /** * hive基础测试 * @author dong * */ public class HiveTest { public static void main(String[] args) throws SQLException { Connection con = null; Statement stmt = null; ResultSet rs = null; try { con = HiveUtil.getConnection(); stmt = con.createStatement(); //测试的表名 testhivedrivertable // String tableName = "firstTable"; // // //如果已经存在就删除 // stmt.execute("drop table if exists " + tableName); // // //创建这张表 // stmt.execute("create table " + tableName + " (key int, value string) ROW FORMAT DELIMITED FIELDS TERMINATED BY '\t'"); //看下创建是否成功 String sql = "show tables";// + tableName + "'"; System.out.println("Running: " + sql); ResultSet res = stmt.executeQuery(sql); while(res.next()) { System.out.println(res.getString(1)); } // // //看下表结构 // sql = "describe " + tableName; // System.out.println("Running: " + sql); // res = stmt.executeQuery(sql); // while (res.next()) { // System.out.println(res.getString(1) + "\t" + res.getString(2)); // } // // // 加载数据到表里面 // // NOTE: filepath 是本地文件所在的位置，注意这个本地不是你的电脑！ // // 你得先把这个文件上传到服务器，然后这里的路径是服务器上这个文件的路径 // String filepath = "/usr/program/hive.txt"; // sql = "load data local inpath '" + filepath + "' into table " + tableName; // System.out.println("Running: " + sql); // stmt.execute(sql); // // // select * query // sql = "select * from " + tableName; // System.out.println("Running: " + sql); // res = stmt.executeQuery(sql); // while (res.next()) { // System.out.println(String.valueOf(res.getInt(1)) + "\t" + res.getString(2)); // } }catch (Throwable e) { e.printStackTrace(); } finally { if (rs != null) { rs.close(); } if (stmt != null) { stmt.close(); } if (con != null) { con.close(); } } } }