Python中的pymysql如何使用

本篇內(nèi)容介紹了“Python中的pymysql如何使用”的有關(guān)知識(shí)，在實(shí)際案例的操作過(guò)程中，不少人都會(huì)遇到這樣的困境，接下來(lái)就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧！希望大家仔細(xì)閱讀，能夠?qū)W有所成！

一、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ā)和分析可形成線(xiàn)性腳本。是廣泛使用的庫(kù)。

二、下載

1.下載依賴(lài)

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

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é)果類(lèi)型設(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.獲取查詢(xún)結(jié)果集的方法

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

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

Connection類(lèi)提供了三個(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)。

“Python中的pymysql如何使用”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識(shí)可以關(guān)注億速云網(wǎng)站，小編將為大家輸出更多高質(zhì)量的實(shí)用文章！