連接Oracle

#依賴包
import cx_Oracle
#連接數據庫
conn_oracle=cx_Oracle.connect('user/password@172.0.0.1:1521/severname')
#獲取游標
cursor_oracle=conn_oracle.cursor()
#寫查詢
query="select * from emp"
#執(zhí)行并生成Dataframe
df = pd.read_sql(query,conn_oracle)
#關閉連接
cursor_oracle.close()
conn_oracle.close()

連接MySQL

#依賴包
import pymysql
#連接數據庫
conn_mysql = pymysql.connect(host='172.0.0.1',  #host地址
                             user='user',
                             passwd='password',
                             db='database',
                             port=3306,
                             charset='utf8')
#獲取游標
cursor_mysql = conn_mysql.cursor() 
#寫查詢
query="select * from emp"
#執(zhí)行并生成Dataframe
df = pd.read_sql(query,conn_mysql)
#關閉連接
cursor_mysql.cloe()
conn_mysql.close()

連接HIVE

#依賴包
from impala.dbapi import connect
#連接數據庫
conn_hive = connect(host='172.0.0.1',  #host地址
                    port=10000,
                    auth_mechanism='PLAIN',
                    user='hadoop',
                    database='database')
cursor_hive = conn_hive.cursor()
#獲取游標
cursor_hive= conn_hive.cursor() 
#寫查詢
query="select * from emp"
#執(zhí)行并生成Dataframe
df = pd.read_sql(query,conn_hive)
#關閉連接
cursor_hive.cloe()
conn_hive.close()