java通過JDBC連接hive數據庫

（1）首先在命令框中打開hadoop，

（2）然后 cd ～；hive --service hiveserver2 &

打開hive連接的權限

 

 （3）新建一個java項目，在項目根目錄下新建一個lib文件夾，並將mysql的兩個包放入，然后右鍵——》build path——》add to library（由於我已經導入了所以下面的圖里沒這個選項）

由於hive在安裝時是關聯着mysql的，所以這兩個包必須導入。

 

（4） 右擊項目build path——》configue build path

 

（5）選擇 add external jars 找到hadoop和hive目錄下lib中的所有jar包全部導入，hive是在根目錄下的lib中hadoop是在share/hadoop/common/lib的目錄下

 

 （6）新建一個java類輸入以下代碼

package hivetest;

import java.sql.*;
import java.sql.SQLException;

public class test {

	private static String driverName = "org.apache.hive.jdbc.HiveDriver";
	public static void main(String[] args) throws SQLException {
	    try {
	      Class.forName(driverName);
	    }catch (ClassNotFoundException e) {
	      // TODO Auto-generated catch block
	      e.printStackTrace();
	      System.exit(1);
	    }
	    Connection con = DriverManager.getConnection("jdbc:hive2://localhost:10000/default", "hadoop", "hadoop");//后兩個參數是用戶名密碼
	    if(con==null)
	        System.out.println("連接失敗");
	    else {
	    Statement stmt = con.createStatement();
	    String sql = "SELECT * FROM action limit 10";	   
	    System.out.println("Running: " + sql);
	    ResultSet res = stmt.executeQuery(sql);
	   int a=0;
	    while (res.next()) {
	      System.out.println(res.getString(1));
	    }
	    }
	  }


}

 

結果如下