Hive로 테이블 읽어오기(select table)

Hive로 테이블 읽어오기(select table)

1. 프로젝트에서 마우스 우클릭 -> Build Path -> Add Libraries -> User Libraries 로 라이브러리를 추가한다.

이름은 HIVE_LIB 로 하고

Hadoop 폴더의 hadoop-client-1.2.1jar 와 hadoop-core-1.2.1.jar 를 추가.

Hive 폴더 내의 lib폴더 내의 모든 jar파일을 추가한다.

 

자바프로젝트를 만들어서 아래 소스를 입력한다.

 

MainClass.java

package com.sist;

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

import org.omg.CORBA.portable.ValueOutputStream;

public class MainClass {
    private static String driverName=”org.apache.hadoop.hive.jdbc.HiveDriver”;
    public static void main(String[] args) throws Exception {
        // TODO Auto-generated method stub
        try{
            Class.forName(driverName);
        }catch(Exception ex){
            System.out.println(ex.getMessage());
            System.exit(1);
        }
       
        String url=”jdbc:hive://localhost:10000/default”;
        Connection con=DriverManager.getConnection(url,”hive”,”hive”);
        System.out.println(“con: “+con);
        String sql=”select * from dept”;
        System.out.println(“Running: “+sql);
        Statement stmt=con.createStatement();
        ResultSet res=stmt.executeQuery(sql);
        while(res.next()){
            System.out.println(String.valueOf(res.getString(1))+”\t”
                    + res.getString(2)+”\t”+res.getInt(3));
        }
    }

}