HiveConnect.java

package hive;

import java.sql.*;

public class HiveConnect {

    private static String driverName = “org.apache.hive.jdbc.HiveDriver“;//hive驱动名称
    private static String url = “jdbc:hive2://vm-201:10000/myhive“;//连接hive2服务的连接地址，Hive0.11.0以上版本提供了一个全新的服务：HiveServer2
    private static String user = “root“;//对HDFS有操作权限的用户
    private static String password = “Bd123456!“;//在非安全模式下，指定一个用户运行查询，忽略密码
    private static String sql = ““;
    private static ResultSet res;

    public static void main（String[] args） {
        try {
            Class.forName（driverName）;//加载HiveServer2驱动程序
            Connection conn = DriverManager.getConnection（url user password）;//根据URL连接指定的数据库
            Statement stmt = conn.createStatement（）;

            //创建的表名
            String tableName = “word_table“;

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

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

            // 执行“show tables”操作
            sql = “show tables“;
            res = stmt.executeQuery（sql）;
            System.out.println（“----- 执行“show tables”操作-------“）;
            if （res.next（）） {
                System.out.println（res.getString（1） ）;
            }

            // 执行“describe table”操作
            sql = “desc “ + tableName;
            res = stmt.executeQuery