前言

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

一、pymysql用途

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

二、下載

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數據庫

在連接數據庫之前，你數據庫里面肯定要有東西，不然會報錯?？梢韵仍跀祿熘袆?chuàng)建一個數據庫，創(chuàng)建表格并寫入數據。

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：進入你數據庫的密碼。創(chuàng)建mysql的時候需要設定密碼，就是那個密碼。
• database：使用的數據庫名字
• port:端口號，一般為3306
• charset：編碼格式，一般為utf8.
• cursorclass：[數據庫連接池]返回結果類型設置。

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

2.創(chuàng)建游標對象

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

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

 3.執(zhí)行函數

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

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

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

該語句執(zhí)行成果后會返回語句數量

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

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

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

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

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

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

database.commit()

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

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

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

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

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

最新評論