一、連線資料庫

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

二、建表

# 開啟資料庫連線
db = pymysql.connect(host='localhost',
                     user='testuser',
                     password='test123',
                     database='TESTDB')
 
# 使用 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()

三、插入資料

 
import pymysql
 
# 開啟資料庫連線
db = pymysql.connect(host='localhost',
                     user='testuser',
                     password='test123',
                     database='TESTDB')
 
# 使用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()

四、查詢資料

Python查詢Mysql使用 fetchone() 方法獲取單條資料, 使用fetchall() 方法獲取多條資料。

• fetchone():該方法獲取下一個查詢結果集。結果集是一個物件
• fetchall():接收全部的返回結果行.
• rowcount:這是一個只讀屬性，並返回執行execute()方法後影響的行數。

import pymysql
 
# 開啟資料庫連線
db = pymysql.connect(host='localhost',
                     user='testuser',
                     password='test123',
                     database='TESTDB')
 
# 使用cursor()方法獲取操作遊標 
cursor = db.cursor()
 
# SQL 查詢語句
sql = "SELECT * FROM EMPLOYEE \
       WHERE INCOME > %s" % (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=%s,sex=%s,income=%s" % \
             (fname, lname, age, sex, income ))
except:
   print ("Error: unable to fetch data")
 
# 關閉資料庫連線
db.close()

五、修改資料

import pymysql
 
# 開啟資料庫連線
db = pymysql.connect(host='localhost',
                     user='testuser',
                     password='test123',
                     database='TESTDB')
 
# 使用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()

六、刪除資料

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

七、事務

對於支援事務的資料庫， 在Python資料庫程式設計中，當遊標建立之時，就自動開始了一個隱形的資料庫事務。

commit()方法遊標的所有更新操作，rollback（）方法回滾當前遊標的所有操作。每一個方法都開始了一個新的事務。

# SQL刪除記錄語句
sql = "DELETE FROM EMPLOYEE WHERE AGE > %s" % (20)
try:
   # 執行SQL語句
   cursor.execute(sql)
   # 向資料庫提交
   db.commit()
except:
   # 發生錯誤時回滾
   db.rollback()

八、錯誤處理

DB API中定義了一些資料庫操作的錯誤及異常，下表列出了這些錯誤和異常：