Python使用cx_oracle提取表数据,并且转存到MySQL数据库
目录
Python使用cx_oracle提取表数据，并且转存到MySQL数据库
方法笨了点，但是实现了.
用到了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()如果运行python代码的电脑没有Oracle数据库，可以参考下我另一篇文章：