前言

首先使用python很大一部分人是用于數(shù)據(jù)分析或者是開(kāi)發(fā)，而數(shù)據(jù)來(lái)源一般都是存儲(chǔ)在數(shù)據(jù)庫(kù)中。作為python怎么能不會(huì)從mysql里面獲取到數(shù)據(jù)呢。而pymysql就是聯(lián)通mysql實(shí)現(xiàn)python窗口與mysql數(shù)據(jù)庫(kù)交互的庫(kù)，十分方便操作。此篇文章將詳細(xì)說(shuō)明如何掌握并使用該庫(kù)。mysql庫(kù)官方文檔：PyMySQL

一、pymysql用途

pymysql是可用于[連接mysql]數(shù)據(jù)庫(kù)，且能夠提供mysql與python窗口來(lái)交互創(chuàng)立通道的工具庫(kù)。可以通過(guò)創(chuàng)建引擎，建立游標(biāo)直接通過(guò)python編程實(shí)現(xiàn)mysql數(shù)據(jù)庫(kù)操作。在開(kāi)發(fā)和分析可形成線性腳本。是廣泛使用的庫(kù)。

二、下載

1.下載依賴

首先要安裝mysql庫(kù)的話要提前加載該庫(kù)的依賴：

ython – one of the following:

• CPython >= 3.6
• Latest PyPy 3

MySQL Server – one of the following:

• MySQL >= 5.6
• MariaDB >= 10.0

python版本3.6就可，mysql版本需5.6以上。

2.下載方式

打開(kāi)cmd，在菜單打入cmd即可進(jìn)入黑框命令提示符：

輸入：

pip install PyMySQL

若有anaconda直接在Enviroment上搜索pymysql：

下載完即可使用。

三、使用

這里使用Jupyter展示使用：

首先先導(dǎo)入庫(kù)：

import pymysql

 1.連接Mysql數(shù)據(jù)庫(kù)

在連接數(shù)據(jù)庫(kù)之前，你數(shù)據(jù)庫(kù)里面肯定要有東西，不然會(huì)報(bào)錯(cuò)?？梢韵仍跀?shù)據(jù)庫(kù)中創(chuàng)建一個(gè)數(shù)據(jù)庫(kù)，創(chuàng)建表格并寫(xiě)入數(shù)據(jù)。

create database mysql
use mysql
create table metric_valuestest 

數(shù)據(jù)用插入得到方式或是在圖形界面工具，如Navicat上插入都可：

已有數(shù)據(jù)庫(kù)記得打開(kāi)數(shù)據(jù)庫(kù)：

net start mysql

官方文檔連接格式：

# Connect to the database
connection = pymysql.connect(host='localhost',
                             user='user',
                             password='passwd',
                             database='db',
                             port = '3306'
                             charset='utf8mb4',
                             cursorclass=pymysql.cursors.DictCursor)

參數(shù)說(shuō)明：

• host：為本機(jī)IP地址，當(dāng)然hosts文件里面localhost就是本機(jī)ip地址127.0.0.1所以不需要修改。
• user：使用者的名字，可寫(xiě)可不寫(xiě)。一般為admin管理員。
• password：進(jìn)入你數(shù)據(jù)庫(kù)的密碼。創(chuàng)建mysql的時(shí)候需要設(shè)定密碼，就是那個(gè)密碼。
• database：使用的數(shù)據(jù)庫(kù)名字
• port:端口號(hào)，一般為3306
• charset：編碼格式，一般為utf8.
• cursorclass：[數(shù)據(jù)庫(kù)連接池]返回結(jié)果類型設(shè)置。

運(yùn)行測(cè)試連接是否成功。成功便可進(jìn)行下一步

2.創(chuàng)建游標(biāo)對(duì)象

連接好了數(shù)據(jù)庫(kù)，我們需要?jiǎng)?chuàng)建一個(gè)游標(biāo)用于模擬我們使用mysql的行為。創(chuàng)建游標(biāo)后在沒(méi)關(guān)閉數(shù)據(jù)庫(kù)之前都可以正常使用且可以不限次數(shù)使用。

# 使用 cursor() 方法創(chuàng)建一個(gè)游標(biāo)對(duì)象 cursor                      
cursor = conn.cursor()

 3.執(zhí)行函數(shù)

創(chuàng)建游標(biāo)后，游標(biāo)cursor自帶execute()函數(shù)可以執(zhí)行SQL語(yǔ)句，成功則返回結(jié)果：

如我們想要顯示所有的數(shù)據(jù)庫(kù)：

sql='show databases'
cursor.execute(sql)

該語(yǔ)句執(zhí)行成果后會(huì)返回語(yǔ)句數(shù)量

想要具體看到執(zhí)行結(jié)果可以添加fetchall()函數(shù)：

sql='show databases'
response1=cursor.execute(sql)
response2=cursor.fetchall()
response2

4.獲取查詢結(jié)果集的方法

當(dāng)使用游標(biāo)cursor.execute(sql)方法查詢數(shù)據(jù)執(zhí)行成功后，我們可以通過(guò)后綴函數(shù)獲取查詢的結(jié)果集：

其中max_stmt_length= 1024000。 所有的增刪改查都可以以字符串的形式傳入sql，再有execute傳入sql進(jìn)行操作執(zhí)行。

Connection類提供了三個(gè)方法： begin 開(kāi)始事務(wù)， commit 提交事務(wù)， rollback 回滾事務(wù)，如果通過(guò) sql 語(yǔ)句對(duì)數(shù)據(jù)庫(kù)中的數(shù)據(jù)進(jìn)行了修改， 則需要提交事務(wù)。

database.commit()

rollback()為回退到上一步操作，若發(fā)生其他錯(cuò)誤帶來(lái)不可預(yù)知的錯(cuò)誤，可以與try except聯(lián)合起來(lái)一起使用，返回到語(yǔ)句沒(méi)有執(zhí)行的狀態(tài)。

主要使用方式：結(jié)合try except捕獲異常，將事務(wù)進(jìn)行rollback回滾。

try:
     db.commit()
except Exception as e:
     db.rollback()

關(guān)閉有close()方法，在程序結(jié)束時(shí)需要建立的連接即建立的游標(biāo)資源釋放掉，避免資源的浪費(fèi)。

到此這篇關(guān)于一文帶你了解Python中pymysql的使用的文章就介紹到這了,更多相關(guān)Python pymysql使用內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論