Hive进阶_Hive的客户端操作

启动远程客户端 # hive --service hiveserver2
获取连接-〉创建运行环境-〉执行HQL-〉处理结果-〉释放资源

工具类

package demo.utils;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;


public class JDBCUtils {
    private static String driverString = "org.apache.hive.jdbc.HiveDriver";
    private static String urlString = "jdbc:hive2://sd-9c1f-2eac:10000/default";
    static {
        try {
            Class.forName(driverString);
        } catch (ClassNotFoundException e) {
            throw new ExceptionInInitializerError(e);
        }
    }


    public static Connection getConnection() {
        try {
            return DriverManager.getConnection(urlString);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return null;
    }
    
    public static void release (Connection conn, Statement st, ResultSet rs){
        if (rs!=null){
            try{
                rs.close();
            }catch(SQLException e){
                e.printStackTrace();
            }finally{
                rs=null;
            }
        }
        if (st!=null){
            try{
                st.close();
            }catch(SQLException e){
                e.printStackTrace();
            }finally{
                st=null;
            }
        }
        if (conn!=null){
            try{
                conn.close();
            }catch(SQLException e){
                e.printStackTrace();
            }finally{
                conn=null;
            }
        }
    }

}

测试类

package demo.hive;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import demo.utils.JDBCUtils;

public class HiveJDBCDemo {
    public static void main(String[] args) {
        Connection conn=null;
        Statement st=null;
        ResultSet rs=null;
        String sql="select * from sampledata";
        conn=JDBCUtils.getConnection();
        try {
            st=conn.createStatement();
            rs = st.executeQuery(sql);
            while(rs.next()){
                String sid = rs.getString(1);
                String sname = rs.getString(2);
                String gender = rs.getString(3);
                System.out.println(sid+" "+sname+" "+gender);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }finally{
            JDBCUtils.release(conn, st, rs);
        }
        
    }


}

SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/C:/Users/PL62716/workspace/HiveDemo/lib/log4j-slf4j-impl-2.4.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/C:/Users/PL62716/workspace/HiveDemo/lib/slf4j-log4j12-1.7.22.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
ERROR StatusLogger No log4j2 configuration file found. Using default configuration: logging only errors to the console.
1 Tom  M
2 Mary F
3 Jerry M
4 Rose M
5 Mike F

add hive/lib->all jar and hadoop->share->hadoop->common->hadoop-common.jar to project build path.