hivejavaapi002

默认开启10000端口
开启前&＃xff0c;编辑hive-site.xml设置impersonation&＃xff0c;防止hdfs权限问题&＃xff0c;这样hive server会以提交用户的身份去执行语句&＃xff0c;如果设置为false&＃xff0c;则会以起hive server daemon的admin user来执行语句

pom.xml

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
//Hive0.11.0版本提供了一个全新的服务&＃xff1a;HiveServer2&＃xff0c;这个很好的解决HiveServer存在的安全性、并发性等问题。这个服务启动程序在${HIVE_HOME}/bin/hiveserver2里面&＃xff0c;你可以通过下面的方式来启动HiveServer2服务&＃xff1a;
//nohup ./hive --service hiveserver2 >/dev/null 2>1 &
//默认开启10000端口
//开启前&＃xff0c;编辑hive-site.xml设置impersonation&＃xff0c;防止hdfs权限问题&＃xff0c;这样hive server会以提交用户的身份去执行语句&＃xff0c;如果设置为false&＃xff0c;则会以起hive server daemon的admin user来执行语句
public class HiveTest { private static String driverName &＃61; "org.apache.hive.jdbc.HiveDriver"; private static String url &＃61; "jdbc:hive2://192.168.231.137:10000/default"; private static String username &＃61; "hadoop"; private static String password &＃61; "hadoop"; private static Connection conn &＃61; null; private static Statement stmt &＃61; null; private static String sql &＃61; ""; private static ResultSet res &＃61; null; static { try { Class.forName(driverName); conn &＃61; DriverManager.getConnection(url, username, password); stmt &＃61; conn.createStatement(); } catch (Exception e) { e.printStackTrace(); } } public static void main(String[] args) throws Exception { dropTable("hivetest"); createTable("hivetest"); showTables("hivetest"); describeTables("hivetest"); insert("hivetest", new String[]{"10000","tom","23"}); insert("hivetest", new String[]{"10001","zhangshan","80"}); insert("hivetest", new String[]{"10002","lisi","30"}); insert("hivetest", new String[]{"10003","lucy","40"}); selectData("hivetest");
// dropTable("hivetest");
} // 查询数据 public static void selectData(String tableName) throws SQLException { sql &＃61; "select * from " &＃43; tableName; res &＃61; stmt.executeQuery(sql); while (res.next()) { System.out.println(res.getInt(1) &＃43; "\t" &＃43; res.getString(2)); } } // 添加数据 public static void insert(String tableName, String[] datas) throws SQLException { sql &＃61; "insert into table " &＃43; tableName &＃43; " values (&＃39;" &＃43; datas[0] &＃43; "&＃39;,&＃39;" &＃43; datas[1] &＃43; "&＃39;," &＃43; Integer.valueOf(datas[2]) &＃43; ")"; stmt.execute(sql); } // 查询表结构 public static void describeTables(String tableName) throws SQLException { sql &＃61; "describe " &＃43; tableName; res &＃61; stmt.executeQuery(sql); while (res.next()) { System.out.println(res.getString(1) &＃43; "\t" &＃43; res.getString(2)); } } // 查看表 public static void showTables(String tableName) throws SQLException { sql &＃61; "show tables &＃39;" &＃43; tableName &＃43; "&＃39;"; res &＃61; stmt.executeQuery(sql); if (res.next()) { System.out.println(res.getString(1)); } } // 创建表 public static void createTable(String tableName) throws SQLException { sql &＃61; "create table " &＃43; tableName &＃43; " (id string, name string,age int) row format delimited fields terminated by &＃39;\t&＃39;"; stmt.execute(sql); } // 删除表 public static String dropTable(String tableName) throws SQLException { // 创建的表名 sql &＃61; "drop table " &＃43; tableName; stmt.execute(sql); return tableName; }
} //
//hivetest
//id string
//name string
//age int
//10000 tom
//10001 zhangshan
//10002 lisi
//10003 lucy