本文使用Python3.7和MySQL8.0.11作為從測試:

1、PyMySQL安裝方法：

$ pip3 install PyMySQL

2、資料庫連線

首先確認：

• 您已經建立了資料庫 SYS.
• 在SYS資料庫中您已經建立了表 EMPLOYEE
• EMPLOYEE表字段為 FIRST_NAME, LAST_NAME, AGE, SEX 和 INCOME。
• 連線資料庫TESTDB使用的使用者名稱為 "root" ，密碼為 "test123"，Mysql資料庫使用者授權請使用Grant命令。
• 在你的機子上已經安裝了 Python MySQLdb 模組。

測試1：（測試連線資料庫是否正常）

#!/usr/bin/python3
 
import pymysql
 
# 開啟資料庫連線
db = pymysql.connect("localhost","root","test123","SYS" )
 
# 使用 cursor() 方法建立一個遊標物件 cursor
cursor = db.cursor()
 
# 使用 execute()  方法執行 SQL 查詢 
cursor.execute("SELECT VERSION()")
 
# 使用 fetchone() 方法獲取單條資料.
data = cursor.fetchone()
 
print ("Database version : %s " % data)
 
# 關閉資料庫連線
db.close()
 

輸出結果：

Database version : 8.0.11

測試2：（建立資料庫表）

#!/usr/bin/python3
 
import pymysql
 
# 開啟資料庫連線
db = pymysql.connect("localhost","root","test123","sys" )
 
# 使用 cursor() 方法建立一個遊標物件 cursor
cursor = db.cursor()
 
# 使用 execute() 方法執行 SQL，如果表存在則刪除
cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")
 
# 使用預處理語句建立表
sql = """CREATE TABLE EMPLOYEE (
         FIRST_NAME  CHAR(20) NOT NULL,
         LAST_NAME  CHAR(20),
         AGE INT,  
         SEX CHAR(1),
         INCOME FLOAT )"""
 
cursor.execute(sql)
 
# 關閉資料庫連線
db.close()
 

測試3：（資料庫插入操作1）

#!/usr/bin/python3
 
import pymysql
 
# 開啟資料庫連線
db = pymysql.connect("localhost","root","test123","sys" )
 
# 使用cursor()方法獲取操作遊標 
cursor = db.cursor()
 
# SQL 插入語句
sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
         LAST_NAME, AGE, SEX, INCOME)
         VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""
try:
   # 執行sql語句
   cursor.execute(sql)
   # 提交到資料庫執行
   db.commit()
except:
   # 如果發生錯誤則回滾
   db.rollback()
 
# 關閉資料庫連線
db.close()

測試4：（資料庫插入操作2）

#!/usr/bin/python3
 
import pymysql
 
# 開啟資料庫連線
db = pymysql.connect("localhost","root","test123","sys" )
 
# 使用cursor()方法獲取操作遊標 
cursor = db.cursor()
 
# SQL 插入語句
sql = "INSERT INTO EMPLOYEE(FIRST_NAME, \
       LAST_NAME, AGE, SEX, INCOME) \
       VALUES ('%s', '%s', '%d', '%c', '%d' )" % \
       ('Mac', 'Mohan', 20, 'M', 2000) 
try:
   # 執行sql語句
   cursor.execute(sql)
   # 執行sql語句
   db.commit()
except:
   # 發生錯誤時回滾
   db.rollback()
 
# 關閉資料庫連線
db.close()

測試5：（資料庫查詢操作）

#!/usr/bin/python3
 
import pymysql
 
# 開啟資料庫連線
db = pymysql.connect("localhost","root","test123","SYS" )
 
# 使用cursor()方法獲取操作遊標 
cursor = db.cursor()
 
# SQL 查詢語句
sql = "SELECT * FROM EMPLOYEE \
       WHERE INCOME > '%d'" % (1000)
try:
   # 執行SQL語句
   cursor.execute(sql)
   # 獲取所有記錄列表
   results = cursor.fetchall()
   for row in results:
      fname = row[0]
      lname = row[1]
      age = row[2]
      sex = row[3]
      income = row[4]
       # 列印結果
      print ("fname=%s,lname=%s,age=%d,sex=%s,income=%d" % \
             (fname, lname, age, sex, income ))
except:
   print ("Error: unable to fetch data")
 
# 關閉資料庫連線
db.close()

指令碼執行結果如下：

fname=Mac, lname=Mohan, age=20, sex=M, income=2000

測試6：（資料庫更新操作）

#!/usr/bin/python3
 
import pymysql
 
# 開啟資料庫連線
db = pymysql.connect("localhost","root","test123","sys" )
 
# 使用cursor()方法獲取操作遊標 
cursor = db.cursor()
 
# SQL 更新語句
sql = "UPDATE EMPLOYEE SET AGE = AGE + 1 WHERE SEX = '%c'" % ('M')
try:
   # 執行SQL語句
   cursor.execute(sql)
   # 提交到資料庫執行
   db.commit()
except:
   # 發生錯誤時回滾
   db.rollback()
 
# 關閉資料庫連線
db.close()

測試7:(資料庫刪除操作)

#!/usr/bin/python3
 
import pymysql
 
# 開啟資料庫連線
db = pymysql.connect("localhost","root","test123","sys" )
 
# 使用cursor()方法獲取操作遊標 
cursor = db.cursor()
 
# SQL 刪除語句
sql = "DELETE FROM EMPLOYEE WHERE AGE > '%d'" % (20)
try:
   # 執行SQL語句
   cursor.execute(sql)
   # 提交修改
   db.commit()
except:
   # 發生錯誤時回滾
   db.rollback()
 
# 關閉連線
db.close()

以上就是Python 連線MySQL資料庫的增刪改查操作。