Hive JDBC 操作 例子

pom.xml配置

<dependency>
            <groupId>org.apache.hive</groupId>
            <artifactId>hive-jdbc</artifactId>
            <version>0.13.1</version>
 </dependency>

测试例程

import org.junit.Test;

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

/**
 * Created by Administrator on 2017/7/29.
 */
public class TestHiveJDBC {

    private static String driverName = "org.apache.hive.jdbc.HiveDriver";

    @Test
    public void TestConnection() throws SQLException {
        try {
            Class.forName(driverName);
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            System.exit(1);
        }
        Connection con = null;
        Statement stmt = null;
        try{
            con = DriverManager.getConnection("jdbc:hive2://hadoop-senior.jason.com:10000/db_hive", "jason", "abc123");
            stmt = con.createStatement();
            // show tables
            String sql = "select * from bf_log_20170712";
            ResultSet res = stmt.executeQuery(sql);
            while(res.next()){
                System.out.println("ip: "+res.getString(1)+" name: "+res.getString(2)+" website: "+res.getString(3));
        }
        }catch(SQLException e){
            e.printStackTrace();
        }finally {
            stmt.close();
            con.close();
        }
    }

}