java 通過jdbc驅動連線hive操作
阿新 • • 發佈：2019-02-08
String insterSQL="LOAD DATA LOCAL INPATH
'/work/hive/examples/files/kv1.txt' OVERWRITE INTO TABLE javabloger";
String querySQL="SELECT a.* FROM javabloger a";
Connection con = DriverManager.getConnection("jdbc:hive://192.168.X.X:10000/default", "", "");
Statement stmt = con.createStatement();
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));
}
}
}
String querySQL="SELECT a.* FROM javabloger a";
Connection con = DriverManager.getConnection("jdbc:hive://192.168.X.X:10000/default", "", "");
Statement stmt = con.createStatement();
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));
}
}
}