#coding:utf-8 import pymysql#導入mysql包 import pymongo#導入MongoDB包 #打開MySQL數據庫鏈接 #獲取一個數據庫連接,注意如果是UTF-8類型的,需要制定數據庫 #port 必須是數字不能為字符串 db = pymysql.connect(host="主機名",user="用戶名",password="密碼",db="數據庫名稱",port=3306,charset='utf8') #使用cursor() cur = db.cursor() #連接MongoDB數據庫 mongo_client = pymongo.MongoClient('MongoDB主機名', 27017) mongo_auth = mongo_client['數據庫名稱'] mongo_auth.authenticate('用戶名', '密碼') #1. 查詢操作 #編寫查詢語句bus_equipment對應我的表名 sql = "select * from 表名" count1 = 0 count2 = 0 try: cur.execute(sql) #執行sql語句 results = cur.fetchall() #獲取查詢的所有記錄 #遍歷結果 for row in results: gatherID = row[3] count1 += 1 collection = mongo_auth[gatherID] for item in collection.find(): count2 += 1 print("總數據條數:"+count2) print("gather_id總數:"+count1) # 關閉連接 mongo_client.close() except Exception as e: raise e finally: db.close()

