如何使用Pandas庫讀寫MySQL數(shù)據(jù)庫

本篇文章為大家展示了如何使用Pandas庫讀寫MySQL數(shù)據(jù)庫，內(nèi)容簡明扼要并且容易理解，絕對能使你眼前一亮，通過這篇文章的詳細介紹希望你能有所收獲。

創(chuàng)新互聯(lián)公司網(wǎng)站建設提供從項目策劃、軟件開發(fā)，軟件安全維護、網(wǎng)站優(yōu)化(SEO)、網(wǎng)站分析、效果評估等整套的建站服務，主營業(yè)務為成都網(wǎng)站設計、成都做網(wǎng)站，app開發(fā)定制以傳統(tǒng)方式定制建設網(wǎng)站，并提供域名空間備案等一條龍服務，秉承以專業(yè)、用心的態(tài)度為用戶提供真誠的服務。創(chuàng)新互聯(lián)公司深信只要達到每一位用戶的要求，就會得到認可，從而選擇與我們長期合作。這樣，我們也可以走得更遠！

ORM技術

對象關系映射技術，即ORM（Object-Relational Mapping）技術，指的是把關系數(shù)據(jù)庫的表結構映射到對象上，通過使用描述對象和數(shù)據(jù)庫之間映射的元數(shù)據(jù)，將程序中的對象自動持久化到關系數(shù)據(jù)庫中。

在Python中，最有名的ORM框架是SQLAlchemy。Java中典型的ORM中間件有: Hibernate, ibatis, speedframework。

SQLAlchemy 

SQLAlchemy是Python編程語言下的一款開源軟件。提供了SQL工具包及對象關系映射（ORM）工具，使用MIT許可證發(fā)行。

可以使用pip命令安裝SQLAlchemy模塊：

pip install sqlalchemy

SQLAlchemy模塊提供了create_engine()函數(shù)用來初始化數(shù)據(jù)庫連接，SQLAlchemy用一個字符串表示連接信息：

'數(shù)據(jù)庫類型+數(shù)據(jù)庫驅動名稱://用戶名:口令@機器地址:端口號/數(shù)據(jù)庫名'

Pandas讀寫MySQL數(shù)據(jù)庫

我們需要以下三個庫來實現(xiàn)Pandas讀寫MySQL數(shù)據(jù)庫：

• pandas

• sqlalchemy

• pymysql

其中，pandas模塊提供了read_sql_query（）函數(shù)實現(xiàn)了對數(shù)據(jù)庫的查詢，to_sql（）函數(shù)實現(xiàn)了對數(shù)據(jù)庫的寫入，并不需要實現(xiàn)新建MySQL數(shù)據(jù)表。sqlalchemy模塊實現(xiàn)了與不同數(shù)據(jù)庫的連接，而pymysql模塊則使得Python能夠操作MySQL數(shù)據(jù)庫。

我們將使用MySQL數(shù)據(jù)庫中的mydb數(shù)據(jù)庫以及employee表，內(nèi)容如下：

mydb數(shù)據(jù)庫以及employee表

下面將介紹一個簡單的例子來展示如何在pandas中實現(xiàn)對MySQL數(shù)據(jù)庫的讀寫：

# -*- coding: utf-8 -*- # 導入必要模塊 import pandas as pd from sqlalchemy import create_engine # 初始化數(shù)據(jù)庫連接，使用pymysql模塊 # MySQL的用戶：root, 密碼:147369, 端口：3306,數(shù)據(jù)庫：mydb engine = create_engine('mysql+pymysql://root:147369@localhost:3306/mydb') # 查詢語句，選出employee表中的所有數(shù)據(jù) sql = '''  select * from employee;  ''' # read_sql_query的兩個參數(shù): sql語句， 數(shù)據(jù)庫連接 df = pd.read_sql_query(sql, engine) # 輸出employee表的查詢結果 print(df) # 新建pandas中的DataFrame, 只有id,num兩列 df = pd.DataFrame({'id':[1,2,3,4],'num':[12,34,56,89]}) # 將新建的DataFrame儲存為MySQL中的數(shù)據(jù)表，不儲存index列 df.to_sql('mydf', engine, index= False) print('Read from and write to Mysql table successfully!')

程序的運行結果如下：

程序的運行結果

在MySQL中查看mydf表格：

mydf表格

這說明我們確實將pandas中新建的DataFrame寫入到了MySQL中！

將CSV文件寫入到MySQL中

以上的例子實現(xiàn)了使用Pandas庫實現(xiàn)MySQL數(shù)據(jù)庫的讀寫，我們將再介紹一個實例：將CSV文件寫入到MySQL中，示例的mpg.CSV文件前10行如下：

mpg.CSV文件前10行

示例的Python代碼如下：

# -*- coding: utf-8 -*- # 導入必要模塊 import pandas as pd from sqlalchemy import create_engine # 初始化數(shù)據(jù)庫連接，使用pymysql模塊 engine = create_engine('mysql+pymysql://root:147369@localhost:3306/mydb') # 讀取本地CSV文件 df = pd.read_csv("E://mpg.csv", sep=',') # 將新建的DataFrame儲存為MySQL中的數(shù)據(jù)表，不儲存index列 df.to_sql('mpg', engine, index= False) print("Write to MySQL successfully!")

在MySQL中查看mpg表格：

上述內(nèi)容就是如何使用Pandas庫讀寫MySQL數(shù)據(jù)庫，你們學到知識或技能了嗎？如果還想學到更多技能或者豐富自己的知識儲備，歡迎關注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

當前標題：如何使用Pandas庫讀寫MySQL數(shù)據(jù)庫
標題路徑：http://muchs.cn/article4/picjie.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供電子商務、網(wǎng)站策劃、微信公眾號、網(wǎng)站內(nèi)鏈、動態(tài)網(wǎng)站、網(wǎng)站制作

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉載內(nèi)容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)