python数据库迁移
时间: 2023-11-07 08:04:30 浏览: 41
Python数据库迁移可以使用pymysql和sqlalchemy两种方法。对于pymysql模块,可以使用游标来逐条或批量插入数据。对于sqlalchemy模块,可以结合pandas来执行SQL查询并将结果插入到库表中。下面是具体的示例代码:
使用pymysql模块:
```python
import pandas as pd
import pymysql
conn_mysql = pymysql.connect(host='数据库主机名', user='用户名', password='密码', db='数据库名', port=端口号, charset='utf8')
# 读取数据
data = pd.read_sql('select * from 表名;', conn_mysql)
print(data.head())
# 导入数据到另一个数据库
engine_ADB = create_engine('mysql+pymysql://user:password@host/db', encoding='utf8')
data.to_sql('目标表名', con=engine_ADB, if_exists='append', index=False)
```
使用sqlalchemy模块:
```python
import pandas as pd
from sqlalchemy import create_engine
# 连接MySQL库
engine = create_engine('mysql+pymysql://user:password@ip/db', encoding='utf8')
# 读取数据
data = engine.execute("select 语句") # 执行sql
res = data.fetchall() # 获取结果
# 导出数据
res.to_sql('目标表名', con=engine, if_exists='append', index=False)
```