Python_连接数据库

连接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"
#执行并生成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"
#执行并生成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"
#执行并生成Dataframe
df = pd.read_sql(query,conn_hive)
#关闭连接
cursor_hive.cloe()
conn_hive.close()