?

先启动Hive远程服务接口

hive --service hiveserver

?

import java.sql.Connection;  
import java.sql.DriverManager;  
import java.sql.ResultSet;  
import java.sql.ResultSetMetaData;
import java.sql.Statement;
import org.apache.hadoop.hive.jdbc.HiveDriver;;
public class HiveTest {

	public static void main(String[] args) throws Exception {  
        
        Class.forName("org.apache.hadoop.hive.jdbc.HiveDriver");  
          
        //String dropSQL="drop table javabloger";  
        //String createSQL="create table javabloger (key int, value string)";  
        //String insterSQL="LOAD DATA LOCAL INPATH '/work/hive/examples/files/kv1.txt' OVERWRITE INTO TABLE javabloger";  
        //String querySQL="SELECT a.* FROM javabloger a";  
        String querySQL="SELECT * FROM person";  
          
        Connection con = DriverManager.getConnection("jdbc:hive://127.0.0.1:10000/default", "", "");  
        Statement stmt = con.createStatement();  
        ResultSet rs = null;
        
        
       // rs = stmt.executeQuery("select * from rc_box_office");
        ResultSetMetaData meta2 = stmt.executeQuery("SELECT * FROM person").getMetaData();
        
        System.out.println(meta2.getColumnCount()+"  *0");
        
        System.out.println(meta2.getColumnName(1)+"  *1");
        
        System.out.println(meta2.getColumnType(1)+"  *2");
        System.out.println(meta2.getColumnType(2)+"  *3");
        System.out.println(meta2.getColumnType(3)+"  *4");
        //System.out.println(meta2.getCatalogName(1)+"  *4");
        
        
        //        stmt.executeQuery(dropSQL);  
//        stmt.executeQuery(createSQL);  
//        stmt.executeQuery(insterSQL);  
       /* ResultSet res = stmt.executeQuery(querySQL);  
          
        while (res.next()) {  
            System.out.println("Result: key:"+res.getString(1) +"  –>  value:" +res.getString(2));  
        } */ 
    }  
}  

?那天写个同步oracle和hive表的程序试试