1、JDBC

（1）工具类

package 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 driver = "org.apache.hadoop.hive.jdbc.HiveDriver";
	private static String url = "jdbc:hive://192.168.6.180:10000/deault";
	
	//注册驱动
	static{
		try {
			Class.forName(driver);
		} catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
	//获取连接
	public static Connection getConnection(){
		try {
			return DriverManager.getConnection(url);
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return null;
	}
	
	//释放资源
	public static void release(Connection conn,Statement st,ResultSet rs){
		if(rs!=null){
			try {
				rs.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}finally{
				rs = null;
			}
		}
		if(rs!=null){
			try {
				rs.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}finally{
				rs = null;
			}
		}
		
		if(conn!=null){
			try {
				conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}finally{
				conn = null;
			}
		}
	}
}

package client;

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

import utils.JDBCUtils;

public class HiveJDBCDemo {

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

}

package client;

import java.util.List;

import org.apache.hadoop.hive.service.HiveClient;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocol;
import org.apache.thrift.transport.TSocket;


public class HiveThriftDemo {

	/**
	 * @param args
	 */
	public static void main(String[] args) throws Exception{
		final TSocket tSocket = new TSocket("192.168.6.180",10000);
		
		//创建一个协议
		final TProtocol tProtocol = new TBinaryProtocol(tSocket);
		
		//创建Hive Client
		final HiveClient client = new HiveClient(tProtocol);
		
		//打开Socket
		tSocket.open();
		
		client.execute("desc user");
		
		List<String> columns = client.fetchAll();
		for(String s :columns){
			System.out.println(s);
		}
		
		//free
		tSocket.close();
	}

}