#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()