Python使用cx

Python使用cx,第1张

方法笨了点,但是实现了.
用到了cx_Oracle连接Oracle 数据库,
pandas 主要是为了把数据提取成DataFrame结构
pymysql 连接mysql数据库
from sqlalchemy import create_engine 连接mysql数据库并执行SQL语句
其中pymysql和create_engine如果有高手可以给精简一下

具体代码如下:

import cx_Oracle as cx  #连接Oracle 数据库的包
import pandas as pd
import pymysql #连接mysql数据库的包
from sqlalchemy import create_engine #执行SQL语句的包
 
engine = create_engine('mysql+pymysql://用户名:密码@IP:3306/db?charset=utf8') #连接mysql数据库
conn1 = pymysql.connect(host='IP',user='用户',passwd='密码',db='db',charset='utf8') #连接mysql数据库
cursor = conn1.cursor()
 
conn = cx.connect('用户','密码','IP:1521/db')       # 链接Oracle数据库
cur = conn.cursor()
 
data = pd.read_sql('SELECT * FROM 表 WHERE 条件 ',conn,index_col='ID') #读取Oracle数据库的表,索引为ID
cursor.execute('drop table 表 ')  #删除表,初次生成表不需要这一句,也可以用REPLACE做临时表写更新,我这懒得写了,就直接删表
data.to_sql("表 ", con=engine)  #把data写入MySQL数据库中
 
#关闭Oracle连接
cur.close() # 关闭游标
conn.close() # 关闭链接
#关闭MySQL连接
cursor.close()
conn1.close()

欢迎分享,转载请注明来源:内存溢出

原文地址:https://54852.com/langs/793409.html

(0)
打赏 微信扫一扫微信扫一扫 支付宝扫一扫支付宝扫一扫
上一篇 2022-05-06
下一篇2022-05-06

发表评论

登录后才能评论

评论列表(0条)

    保存