PyMySQL實現增刪查改的簡單使用

Posted on by

我們在使用MySQL的時候，可以在MySQL的客戶終端來操作數據庫中的表，同時，也可以使用navicat等可視化的工具來操作數據表。但是，這隻是操作個別數據，如果我們想要插入10萬條數據，那肯定就不能這麼做瞭。
我們可以通過程序寫一個循環來自動插入，因此，PyMySQL就是使用python語言來直接操作數據庫的一個接口。
明確瞭這一點，我們再開始介紹PyMySQL包：

1、PyMySQL的使用步驟：

在這裡插入圖片描述

在這裡插入圖片描述

在這裡插入圖片描述

在這裡插入圖片描述

2、案例：

2.1 查詢數據庫中的表的信息：

 # 需求：查詢數據庫person中info表的信息

 # 1.導包
import pymysql

try:
     # 2.連接MySQL數據庫的服務
    connc = pymysql.Connect(
                    user="root",  # The first four arguments is based on DB-API 2.0 recommendation.
                    password="4412",
                    host='127.0.0.1',  # mysql服務端的IP,默認是127.0.0.1/localhost,或者寫真實的ip
                    database='person',
                    port=3306,
                    charset="utf8")
     # 3.創建遊標對象
    cur = connc.cursor()
     # 4.編寫SQL語句
    sql = 'select * from info;'
     # 5.使用遊標對象調用SQL
    cur.execute(sql)
     # 6.獲取查詢的結果
    result= cur.fetchall()
    print(result)
    # 7.關閉遊標對象
    cur.close()
    # 8.關閉連接
    connc.close()

except Exception as e:
    print(e)

運行結果：

在這裡插入圖片描述

2.2 增加數據：

大部分的步驟都和前面一樣，直接在程序中註釋看：

# 需求：
# 增加數據 劉德華56 男 數據 到 數據庫person--的info表中
# 修改數據 小王 的名字為 小王吧 到 數據庫person--的info表中
# 刪除數據 張三      數據庫person--的info表中

# 1.導包
import pymysql

# 2.連接MySQL服務
connc = pymysql.Connect(
    user="root",  # The first four arguments is based on DB-API 2.0 recommendation.
    password="4412",
    host='127.0.0.1',  # mysql服務端的IP,默認是127.0.0.1/localhost,或者寫真實的ip
    database='person',
    port=3306,
    charset="utf8")

# 3.創建遊標對象
cur = connc.cursor()

try:
    # 4.編寫、增加、刪除的SQL語句    
    # 增加數據 劉德華 56 男
    sql = 'insert into info values(%s, %s, %s, %s)'
    add_data = [0,"劉德華", 56, "男"]
    
    # 5.使用遊標對象執行SQL語句
    cur.execute(sql, add_data)
    
    # 6.提交操作
    connc.commit()
    
except Exception as e:
    print(e)
    # 操作失敗，數據回滾
    connc.rollback()
    
finally:
    # 7.關閉遊標對象
    cur.close()
    
    # 8.關閉連接
    connc.close()

print("結束！")

運行之後，看看person數據庫中 表info 的數據，確實增加成功瞭：

在這裡插入圖片描述

2.3 修改數據：

# 需求：
# 增加數據 劉德華56 男 數據 到 數據庫person--的info表中
# 修改數據 小王 的名字為 小王吧 到 數據庫person--的info表中
# 刪除數據 張三      數據庫person--的info表中

# 1.導包
import pymysql

# 2.連接MySQL服務
connc = pymysql.Connect(
    user="root",  # The first four arguments is based on DB-API 2.0 recommendation.
    password="4412",
    host='127.0.0.1',  # mysql服務端的IP,默認是127.0.0.1/localhost,或者寫真實的ip
    database='person',
    port=3306,
    charset="utf8")

# 3.創建遊標對象
cur = connc.cursor()

try:
    # 4.編寫、增加、刪除的SQL語句
    # 修改數據 李四 的名字為 李四的爸爸
    sql = 'update info set name=%s where name="李四"'
    update_data = ["李四的爸爸"]
        
    # 5.使用遊標對象執行SQL語句
    cur.execute(sql, update_data)
    
    # 6.提交操作
    connc.commit()
    
except Exception as e:
    print(e)
    #  操作失敗，數據回滾
    connc.rollback()
    
finally:
    # 7.關閉遊標對象
    cur.close()
    
    # 8.關閉連接
    connc.close()

print("結束！")

運行之後，看看person數據庫中 表info 的數據，確實修改成功瞭：

在這裡插入圖片描述

2.3 刪除數據：

# 需求：
# 增加數據 劉德華56 男 數據 到 數據庫person--的info表中
# 修改數據 小王 的名字為 小王吧 到 數據庫person--的info表中
# 刪除數據 張三      數據庫person--的info表中

# 1.導包
import pymysql

# 2.連接MySQL服務
connc = pymysql.Connect(
    user="root",  # The first four arguments is based on DB-API 2.0 recommendation.
    password="4412",
    host='127.0.0.1',  # mysql服務端的IP,默認是127.0.0.1/localhost,或者寫真實的ip
    database='person',
    port=3306,
    charset="utf8")

# 3.創建遊標對象
cur = connc.cursor()

try:
    # 4.編寫、增加、刪除的SQL語句
    # 修改數據 李四 的名字為 李四的爸爸
    sql = 'update info set name=%s where name="李四"'
    update_data = ["李四的爸爸"]
        
    # 5.使用遊標對象執行SQL語句
    cur.execute(sql, update_data)
    
    # 6.提交操作
    connc.commit()
    
except Exception as e:
    print(e)
    #  操作失敗，數據回滾
    connc.rollback()
    
finally:
    # 7.關閉遊標對象
    cur.close()
    
    # 8.關閉連接
    connc.close()

print("結束！")

運行之後，看看person數據庫中 表info 的數據，確實刪除成功瞭：

在這裡插入圖片描述

到此這篇關於PyMySQL實現增刪查改的簡單使用的文章就介紹到這瞭,更多相關PyMySQL 增刪查改內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet！

推薦閱讀：