[Python]Python hive JDBC 연결하기

 

python이랑 hive JDBC 연결하는 방법

hive 말고 다른 DB 서버랑도 연결 가능!

 

https://pypi.org/project/JayDeBeApi/

JayDeBeApi

 

#pip install 설치
import jaydebeapi as jp
import os
import pandas as pd


path = 'jar 파일 있는 디렉토리'

#jar 파일 전체 들고오기
file_list = os.listdir(path)
jar_list = [path + file for file in file_list if file.endswith(".jar")] # .jar로 끝나는 모든 파일 들고오기


con = jp.connect(
		"org.apache.hive.jdbc.HiveDriver",
        "jdbc:hive2:// 서버",
        [id,pw],
        jar_list
        )

cur = con.cursor()
cur.execute("select * from test")
result = cur.fetchall()
col = [column[0] for column in cur.description]

#dataframe
df = pd.DataFrame(result,columns=col)