package?hive;

import?java.sql.*;

public?class?HiveConnect?{

????private?static?String?driverName?=?“org.apache.hive.jdbc.HiveDriver“;//hive驅(qū)動名稱
????private?static?String?url?=?“jdbc:hive2://vm-201:10000/myhive“;//連接hive2服務(wù)的連接地址，Hive0.11.0以上版本提供了一個(gè)全新的服務(wù)：HiveServer2
????private?static?String?user?=?“root“;//對HDFS有操作權(quán)限的用戶
????private?static?String?password?=?“Bd123456!“;//在非安全模式下，指定一個(gè)用戶運(yùn)行查詢，忽略密碼
????private?static?String?sql?=?““;
????private?static?ResultSet?res;

????public?static?void?main（String[]?args）?{
????????try?{
????????????Class.forName（driverName）;//加載HiveServer2驅(qū)動程序
????????????Connection?conn?=?DriverManager.getConnection（url?user?password）;//根據(jù)URL連接指定的數(shù)據(jù)庫
????????????Statement?stmt?=?conn.createStatement（）;

????????????//創(chuàng)建的表名
????????????String?tableName?=?“word_table“;

????????????/**?第一步:表存在就先刪除?**/
????????????sql?=?“drop?table?“?+?tableName;
????????????stmt.execute（sql）;

????????????/**?第二步:表不存在就創(chuàng)建?**/
????????????sql?=?“create?table?“?+?tableName?+?“?（word10?string?word20?string?word30?string）??row?format?delimited?fields?terminated?by?‘\t‘?“;
????????????stmt.execute（sql）;

????????????//?執(zhí)行“show?tables”操作
????????????sql?=?“show?tables“;
????????????res?=?stmt.executeQuery（sql）;
????????????System.out.println（“-----?執(zhí)行“show?tables”操作-------“）;
????????????if?（res.next（））?{
????????????????System.out.println（res.getString（1）?）;
????????????}

????????????//?執(zhí)行“describe?table”操作
????????????sql?=?“desc?“?+?tableName;
????????????res?=?stmt.executeQuery