MongoDB数据迁移MySQL
为了从MySQL数据库迁移到MongoDB,你需要执行以下步骤:
- 设置MySQL数据源。
- 设置MongoDB数据目标。
- 创建数据迁移计划。
- 执行迁移。
以下是使用Python的pymongo
和pymysql
模块进行数据迁移的示例代码:
import pymongo
import pymysql
# 连接到MySQL
mysql_conn = pymysql.connect(host='your_mysql_host', user='your_mysql_user', password='your_mysql_password', db='your_mysql_db')
mysql_cursor = mysql_conn.cursor()
# 连接到MongoDB
mongo_client = pymongo.MongoClient('mongodb://your_mongo_host:your_mongo_port/')
db = mongo_client['your_mongo_db']
collection = db['your_mongo_collection']
# 查询MySQL数据
mysql_cursor.execute("SELECT * FROM your_mysql_table")
rows = mysql_cursor.fetchall()
# 插入数据到MongoDB
for row in rows:
document = {
'column1': row[0],
'column2': row[1],
# 其他列...
}
collection.insert_one(document)
# 关闭连接
mysql_cursor.close()
mysql_conn.close()
请确保替换your_mysql_host
, your_mysql_user
, your_mysql_password
, your_mysql_db
, your_mysql_table
以及your_mongo_host
, your_mongo_port
, your_mongo_db
, your_mongo_collection
为你的实际数据库信息。同时,确保你的MongoDB服务器可以接受连接,并且你有足够的权限来写入数据。
注意:这个代码示例假设你的MySQL表和MongoDB集合的结构是一致的。如果表结构不同,你需要调整字段映射。此外,如果表很大,你可能需要分批查询和迁移数据来管理内存使用量。
评论已关闭