我們在使用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 增刪查改內容請搜索腳本之家以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持腳本之家！
您可能感興趣的文章:- Python中操作mysql的pymysql模塊詳解
- Python MySQL數據庫連接池組件pymysqlpool詳解
- python使用pymysql實現操作mysql
- python3使用PyMysql連接mysql數據庫實例
- flask + pymysql操作Mysql數據庫的實例
- Python中pymysql 模塊的使用詳解
- pymysql模塊的使用(增刪改查)詳解
- python3.6使用pymysql連接Mysql數據庫
