mysql數據導入mongodb中

# 把mysql數據庫中的數據導入mongodb中
import pymysql
import pymongo

# 創建mysql的數據庫連接
con = pymysql.connect(host='localhost', port=3306, user='root', password='123456', db='pp')
# 獲取游標
cur = con.cursor(cursor=pymysql.cursors.DictCursor)
# 查詢student表
try:
  cur.execute('select * from student')
  # 創建mongodb數據庫連接
  client = pymongo.MongoClient(host='localhost', port=27017)
  # 獲取數據庫
  db = client['pp']#或者db=client.pp,相當於數據庫中的use pp;
  for row in cur.fetchall():
    row['birthday'] = str(row['birthday']) #因為mongodb沒有datetime類型，因此必須先轉為字符串才能導入mongodb,否則可省略此步
    db.student.insert_one(row)
except Exception as e:
  print(e)
finally:
  con.close()
  client.close()
#The achievement is attributed to teacher Peng!