python鏈接mysql-PyMySql模塊

安裝

pip3 install pymysql

使用

輸出mysql版本

 1 import pymysql
 2 
 3 # 打開數據庫鏈接
 4 db = pymysql.connect("localhost", "root", "root", "mysql")
 5 # 使用 cursor() 方法建立一個遊標對象 cursor
 6 cursor = db.cursor()
 7 # 使用 execute()  方法執行 SQL 查詢
 8 cursor.execute("SELECT VERSION()")
 9 # 使用 fetchone() 方法獲取單條數據.
10 data = cursor.fetchone()
11 print("Database version : %s " % data)
12 # 關閉數據庫鏈接
13 db.close()
14 
15 '''
16 result;
17     Database version : 5.6.19 
18 '''

Code

建立表

 1 import pymysql
 2 
 3 # 打開數據庫鏈接
 4 db = pymysql.connect("localhost", "root", "root", "testdb")
 5 # 使用 cursor() 方法建立一個遊標對象 cursor
 6 cursor = db.cursor()
 7 # 使用 execute() 方法執行 SQL，若是表存在則刪除
 8 cursor.execute("DROP TABLE IF EXISTS UserInfo")
 9 # 使用預處理語句建立表
10 sql = """CREATE TABLE UserInfo (
11          Name  CHAR(20) NOT NULL,
12          AGE INT,  
13          SEX CHAR(1) )"""
14 cursor.execute(sql)
15 # 關閉數據庫鏈接
16 db.close()

Code

執行sql

 1 import pymysql
 2 
 3 # 打開數據庫鏈接
 4 db = pymysql.connect("localhost", "root", "root", "testdb")
 5 # 使用cursor()方法獲取操做遊標
 6 cursor = db.cursor()
 7 # SQL 插入語句
 8 sql = """INSERT INTO UserInfo(Name,AGE, SEX)
 9          VALUES ('張三', 18, '男')"""
10 try:
11     # 執行sql語句
12     cursor.execute(sql)
13     # 提交到數據庫執行
14     db.commit()
15 except:
16     # 若是發生錯誤則回滾
17     db.rollback()
18 # 關閉數據庫鏈接
19 db.close()

Code

查詢

• cursor.fetchall()

  接收所有的返回結果行.

   1 import pymysql
   2 
   3 # 打開數據庫鏈接
   4 db = pymysql.connect("localhost", "root", "root", "testdb")
   5 # 使用cursor()方法獲取操做遊標
   6 cursor = db.cursor()
   7 # SQL 查詢語句
   8 sql = "SELECT * FROM UserInfo"
   9 try:
  10     # 執行SQL語句
  11     cursor.execute(sql)
  12     # 獲取全部記錄列表
  13     results = cursor.fetchall()
  14     for row in results:
  15         name = row[0]
  16         age = row[1]
  17         sex = row[2]
  18         # 打印結果
  19         print("name=%s,age=%d,sex=%s" %
  20               (name, age, sex))
  21 except:
  22     print("Error: unable to fetch data")
  23 # 關閉數據庫鏈接
  24 db.close()
  25 '''
  26 result:
  27     name=張三,age=18,sex=男
  28     name=李四,age=19,sex=女
  29 '''

  Code

• cursor.fetchone()

  該方法獲取下一個查詢結果集。結果集是一個對象

   1 import pymysql
   2 
   3 # 打開數據庫鏈接
   4 db = pymysql.connect("localhost", "root", "root", "testdb")
   5 # 使用cursor()方法獲取操做遊標
   6 cursor = db.cursor()
   7 # SQL 查詢語句
   8 sql = "SELECT * FROM UserInfo"
   9 try:
  10     # 執行SQL語句
  11     cursor.execute(sql)
  12     # 獲取全部記錄列表
  13     while 1:
  14         one = cursor.fetchone()
  15         if one:
  16             print(one)
  17         else:
  18             break
  19 except:
  20     print("Error: unable to fetch data")
  21 # 關閉數據庫鏈接
  22 db.close()
  23 '''
  24 result:
  25     ('張三', 18, '男')
  26     ('李四', 19, '女')
  27 '''

  Code

注：可經過 cursor = db.cursor(cursor=pymysql.cursors.DictCursor) 的方式讓遊標以字典方式返回數據。

執行事務

對於支持事務的數據庫， 在Python數據庫編程中，當遊標創建之時，就自動開始了一個隱形的數據庫事務。 commit()方法提交全部更新操做，rollback()方法回滾當前遊標的全部操做。

 1 import pymysql
 2 
 3 # 打開數據庫鏈接
 4 db = pymysql.connect("localhost", "root", "root", "testdb")
 5 # 使用cursor()方法獲取操做遊標
 6 cursor = db.cursor()
 7 # SQL 刪除語句
 8 sql = "DELETE FROM UserInfo WHERE AGE > '%d'" % (18)
 9 try:
10     # 執行SQL語句
11     cursor.execute(sql)
12     # 提交修改
13     db.commit()
14 except:
15     # 發生錯誤時回滾
16     db.rollback()
17 # 關閉鏈接
18 db.close()

事務控制的刪除操做

錯誤處理

異常	描述
Warning	當有嚴重警告時觸發，例如插入數據是被截斷等等。必須是 StandardError 的子類。
Error	警告之外全部其餘錯誤類。必須是 StandardError 的子類。
InterfaceError	當有數據庫接口模塊自己的錯誤（而不是數據庫的錯誤）發生時觸發。 必須是Error的子類。
DatabaseError	和數據庫有關的錯誤發生時觸發。 必須是Error的子類。
DataError	當有數據處理時的錯誤發生時觸發，例如：除零錯誤，數據超範圍等等。 必須是DatabaseError的子類。
OperationalError	指非用戶控制的，而是操做數據庫時發生的錯誤。例如：鏈接意外斷開、 數據庫名未找到、事務處理失敗、內存分配錯誤等等操做數據庫是發生的錯誤。 必須是DatabaseError的子類。
IntegrityError	完整性相關的錯誤，例如外鍵檢查失敗等。必須是DatabaseError子類。
InternalError	數據庫的內部錯誤，例如遊標（cursor）失效了、事務同步失敗等等。 必須是DatabaseError子類。
ProgrammingError	程序錯誤，例如數據表（table）沒找到或已存在、SQL語句語法錯誤、 參數數量錯誤等等。必須是DatabaseError的子類。
NotSupportedError	不支持錯誤，指使用了數據庫不支持的函數或API等。例如在鏈接對象上 使用.rollback()函數，然而數據庫並不支持事務或者事務已關閉。 必須是DatabaseError的子類。