技術標籤：定期查詢mysql資料

1. 匯入第三方庫

import pymssqlimport numpy as npimport pandas as pd

2. 建立資料庫連線

'''pymysql.Connect()引數說明host(str):      MySQL伺服器地址port(int):      MySQL伺服器埠號user(str):      使用者名稱passwd(str):    密碼db(str):        資料庫名稱charset(str):   連線編碼'''def conn():    try:        connect = pymssql.connect(host='', user='', password='', database='')        if connect:            return connect        else:            return     except Exception as ex:        return 
 

3. 根據 sql 語句進行查詢

根據 sql 語句對資料庫進行 (查詢)，返回值為字典集合

def selSql(sql):    #sql 執行資料庫語句    lst = []    try:        # 呼叫函式建立連線        connect = conn()        #根據語句進行查詢，返回值為DataFrame        df = pd.read_sql(sql, connect)        #DataFrame轉為ndarray        df1 = np.array(df)        # 獲取列名        column_list = list(df.columns)        for row in df1:            # 迴圈每一行資料，組裝成一個字典，然後得到字典的列表            lst.append(dict(zip(column_list, list(row))))    except Exception as ex:        lst = []        print(ex)    finally:        # 關閉資料庫連線        if connect:            connect.close()    return lst
 

4. 查詢結果如下

輸出結果是我們需要的字典集合，key 為欄位名，value 是欄位的值，這樣使用查詢出來的欄位時就會非常方便。