Python中的pymysql如何使用

本篇內容介紹了“Python中的pymysql如何使用”的有關知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領大家學習一下如何處理這些情況吧！希望大家仔細閱讀，能夠學有所成！

一、pymysql用途

pymysql是可用于[連接mysql]數據庫，且能夠提供mysql與python窗口來交互創立通道的工具庫。可以通過創建引擎，建立游標直接通過python編程實現mysql數據庫操作。在開發和分析可形成線性腳本。是廣泛使用的庫。

二、下載

1.下載依賴

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

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.下載方式

打開cmd，在菜單打入cmd即可進入黑框命令提示符：

輸入：

pip install PyMySQL

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

下載完即可使用。

三、使用

這里使用Jupyter展示使用：

首先先導入庫：

import pymysql

 1.連接Mysql數據庫

在連接數據庫之前，你數據庫里面肯定要有東西，不然會報錯。可以先在數據庫中創建一個數據庫，創建表格并寫入數據。

create database mysql
use mysql
create table metric_valuestest

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

已有數據庫記得打開數據庫：

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)

參數說明：

• host：為本機IP地址，當然hosts文件里面localhost就是本機ip地址127.0.0.1所以不需要修改。

• user：使用者的名字，可寫可不寫。一般為admin管理員。

• password：進入你數據庫的密碼。創建mysql的時候需要設定密碼，就是那個密碼。

• database：使用的數據庫名字

• port:端口號，一般為3306

• charset：編碼格式，一般為utf8.

• cursorclass：[數據庫連接池]返回結果類型設置。

運行測試連接是否成功。成功便可進行下一步

2.創建游標對象

連接好了數據庫，我們需要創建一個游標用于模擬我們使用mysql的行為。創建游標后在沒關閉數據庫之前都可以正常使用且可以不限次數使用。

# 使用 cursor() 方法創建一個游標對象 cursor                      
cursor = conn.cursor()

 3.執行函數

創建游標后，游標cursor自帶execute()函數可以執行SQL語句，成功則返回結果：

如我們想要顯示所有的數據庫：

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

該語句執行成果后會返回語句數量

想要具體看到執行結果可以添加fetchall()函數：

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

4.獲取查詢結果集的方法

當使用游標cursor.execute(sql)方法查詢數據執行成功后，我們可以通過后綴函數獲取查詢的結果集：

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

Connection類提供了三個方法： begin 開始事務， commit 提交事務， rollback 回滾事務，如果通過 sql 語句對數據庫中的數據進行了修改， 則需要提交事務。

database.commit()

rollback()為回退到上一步操作，若發生其他錯誤帶來不可預知的錯誤，可以與try except聯合起來一起使用，返回到語句沒有執行的狀態。

主要使用方式：結合try except捕獲異常，將事務進行rollback回滾。

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

關閉有close()方法，在程序結束時需要建立的連接即建立的游標資源釋放掉，避免資源的浪費。

“Python中的pymysql如何使用”的內容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業相關的知識可以關注億速云網站，小編將為大家輸出更多高質量的實用文章！