1、使用python中的mysql.connector库MySQL数据库:import mysql.connector,使用pymongo连接mongodb数据库:import pymongo。
2、从MySQL中读取数据，包括数据的字段名称：
sql = 'select * from %s where id = %s'%(table_names[1],order_id)cursor.execute(sql)rows = cursor.fetchall()column_names = [d[0] for d in cursor.description]
3、使用继承子dict的类将读取到的数据转换成字典的数组，以便于存入mongodb中
#定义一个继承自dict的类class Row(dict): """A dict that allows for object-like property access syntax.""" def __getattr__(self, name): try: return self[name] except KeyError: raise AttributeError(name)
4、将数据转换成json格式：
item = [Row(zip(column_names, row)) for row in rows]item = item[0]if item: '''merge_set_by_set是我定义的把多个表相关联的数据表的数据存放到一起组合成一个json的函数''' merge_set_by_set(mongo_item, item,table_names[0])
5、将数据存放到mongodb中
if mongo_items: try: mongo.order_info1.insert_many(mongo_items) print('=success insert into mongodb') except: print('fail')