IDEA 에 서 는 자바 로 Hive 를 연결 하고 데 이 터 를 읽 습 니 다.
1666 단어 스파크 기초 학습
org.apache.hive
hive-jdbc
0.13.1
가상 컴퓨터 에서 Hive 를 시작 하고 Hive 를 시작 하기 전에 Zookeeper 와 Hadoop 을 시작 합 니 다.
zkServer.sh start; // Zookeeper
sbin/start-all.sh start; // Hadoop
// jps
bin/hive; // Hive
그리고 연결 부분의 코드 는:
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
public class HiveConnec {
public static void main(String [] args) throws Exception{
Class.forName("org.apache.hive.jdbc.HiveDriver");
Connection connection = DriverManager.getConnection("jdbc:hive2://192.168.199.3:10000/test_db", "hadoop000", "123456");
Statement statement = connection.createStatement();
String querySQL = "select * from u_data_new limit 20";
ResultSet resultSet = statement.executeQuery(querySQL);
while(resultSet.next()){
System.out.println(resultSet.getInt(1));
}
}
}
그 중에서 DriverManager. getConnection ("jdbc: hive 2:/92.168.199.3: 10000/test db", "hadop 000", "123456");주로 자신의 가상 컴퓨터 에 있 는 Hive 데이터 베 이 스 를 연결 합 니 다. 192.168.109.3 은 개인의 가상 컴퓨터 주소 이 고 hadop 00 과 123456 은 각각 가상 컴퓨터 의 사용자 이름과 비밀번호 입 니 다.
그 중에서 주의해 야 할 부분: 일부 데이터 베 이 스 를 연결 하 는 코드 에 서 는 반드시 이상 을 던 져 야 합 니 다. 즉, "throws Exception"은 데이터 베 이 스 를 조작 할 때 많은 이상 이 있 을 수 있 으 므 로 Exception 을 던 지면 됩 니 다.