Hive学习（三）Hive的Java客户端操作

Hive的Java客户端操作分为JDBC和Thrifit Client,首先启动Hive远程服务：

hive  --service hiveserver

一、JDBC

在MyEclipse中首先创建连接

import java.sql.DriverManager;
import java.sql.SQLException;

public class JDBCUtils {
    private static String driver="org.apache.hadoop.hive.jdbc.HiveDrive";
    private static String url="jdbc:hive://192.168.133.100:10000/default";

    //注册驱动
    static{
        try{
            Class.forName(driver);
        }catch(ClassNotFoundException e){
            throw new ExceptionInInitializerError(e);
        }
    }
    //获取连接
    public static Connection getConnection(){
        try{
            return DriverManager.getConnection(url);
        }catch(SQLException e){
            e.printStackTrace();
        }
    return null;
    }
    //释放资源
    public static void release(Connection conn,Statement st,ResultSet rs){
       if(conn!=null){
           try{
               conn.close();
           }catch(SQLException e){
               e.printStackTrace();
           }finally{
               conn=null;
           }
       }

        if(st!=null){
            try{
                st.close();
            }catch(SQLException e){
                e.printStackTrace();
            }finally{
                st=null;
            }
        }

        if(rs!=null){
            try{
                rs.close();
            }catch(SQLException e){
                e.printStackTrace();
            }finally{
                rs=null;
            }
        }


    }
}

然后执行HQL

public class HIveJDBCDemo {
    public static void main(String[] args){
        Connection conn=null;
        Statement st=null;
        ResultSet rs=null;
        String sql ="select * from test";
        try{
            //获取连接
            conn=JDBCUtils.getConnection();
            //创建运行环境
            st=conn.createStatement();
            //运行HQL
            rs=st.executeQuery(sql);
            //处理数据
            while(rs.next()){
                String  name=rs.getString("name");
                System.out.println(name);
            }
        }catch(Exception e){
            e.printStackTrace();
        }finally{
            JDBCUtils.release(conn,st,rs);
        }
    }
}

二、Thrifit Client