主頁 > 知識庫 > Python3 MySQL 數(shù)據(jù)庫連接的使用示例

Python3 MySQL 數(shù)據(jù)庫連接的使用示例
熱門標簽：老人電話機器人 北京電信外呼系統(tǒng)靠譜嗎 百度地圖標注位置怎么修改 地圖標注視頻廣告 大連crm外呼系統(tǒng) 梅州外呼業(yè)務系統(tǒng) 無錫客服外呼系統(tǒng)一般多少錢 洪澤縣地圖標注 高德地圖標注是免費的嗎

本文我們?yōu)榇蠹医榻B Python3 使用 PyMySQL 連接數(shù)據(jù)庫，并實現(xiàn)簡單的增刪改查。

什么是 PyMySQL？

PyMySQL 是在 Python3.x 版本中用于連接 MySQL 服務器的一個庫，Python2中則使用mysqldb。

PyMySQL 遵循 Python 數(shù)據(jù)庫 API v2.0 規(guī)范，并包含了 pure-Python MySQL 客戶端庫。

PyMySQL 安裝

在使用 PyMySQL 之前，我們需要確保 PyMySQL 已安裝。

PyMySQL 下載地址：https://github.com/PyMySQL/PyMySQL。

如果還未安裝，我們可以使用以下命令安裝最新版的 PyMySQL：

$ pip3 install PyMySQL

如果你的系統(tǒng)不支持 pip 命令，可以使用以下方式安裝：

1、使用 git 命令下載安裝包安裝(你也可以手動下載)：

$ git clone https://github.com/PyMySQL/PyMySQL
$ cd PyMySQL/
$ python3 setup.py install

2、如果需要制定版本號，可以使用 curl 命令來安裝：

$ # X.X 為 PyMySQL 的版本號
$ curl -L https://github.com/PyMySQL/PyMySQL/tarball/pymysql-X.X | tar xz
$ cd PyMySQL*
$ python3 setup.py install
$ # 現(xiàn)在你可以刪除 PyMySQL* 目錄

注意：請確保您有root權(quán)限來安裝上述模塊。

安裝的過程中可能會出現(xiàn)"ImportError: No module named setuptools"的錯誤提示，意思是你沒有安裝setuptools，你可以訪問https://pypi.python.org/pypi/setuptools 找到各個系統(tǒng)的安裝方法。

Linux 系統(tǒng)安裝實例：

$ wget https://bootstrap.pypa.io/ez_setup.py
$ python3 ez_setup.py

數(shù)據(jù)庫連接

連接數(shù)據(jù)庫前，請先確認以下事項：

  • 您已經(jīng)創(chuàng)建了數(shù)據(jù)庫 TESTDB.
  • 在TESTDB數(shù)據(jù)庫中您已經(jīng)創(chuàng)建了表 EMPLOYEE
  • EMPLOYEE表字段為 FIRST_NAME, LAST_NAME, AGE, SEX 和 INCOME。
  • 連接數(shù)據(jù)庫TESTDB使用的用戶名為 "testuser" ，密碼為 "test123",你可以可以自己設定或者直接使用root用戶名及其密碼，Mysql數(shù)據(jù)庫用戶授權(quán)請使用Grant命令。
  • 在你的機子上已經(jīng)安裝了 Python MySQLdb 模塊。
  • 如果您對sql語句不熟悉，可以訪問我們的 SQL基礎教程

實例：

以下實例鏈接 Mysql 的 TESTDB 數(shù)據(jù)庫：

#!/usr/bin/python3
 
import pymysql
 
# 打開數(shù)據(jù)庫連接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )
 
# 使用 cursor() 方法創(chuàng)建一個游標對象 cursor
cursor = db.cursor()
 
# 使用 execute()  方法執(zhí)行 SQL 查詢 
cursor.execute("SELECT VERSION()")
 
# 使用 fetchone() 方法獲取單條數(shù)據(jù).
data = cursor.fetchone()
 
print ("Database version : %s " % data)
 
# 關(guān)閉數(shù)據(jù)庫連接
db.close()

執(zhí)行以上腳本輸出結(jié)果如下：

Database version : 5.5.20-log

創(chuàng)建數(shù)據(jù)庫表

如果數(shù)據(jù)庫連接存在我們可以使用execute()方法來為數(shù)據(jù)庫創(chuàng)建表，如下所示創(chuàng)建表EMPLOYEE：

#!/usr/bin/python3
 
import pymysql
 
# 打開數(shù)據(jù)庫連接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )
 
# 使用 cursor() 方法創(chuàng)建一個游標對象 cursor
cursor = db.cursor()
 
# 使用 execute() 方法執(zhí)行 SQL，如果表存在則刪除
cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")
 
# 使用預處理語句創(chuàng)建表
sql = """CREATE TABLE EMPLOYEE (
         FIRST_NAME  CHAR(20) NOT NULL,
         LAST_NAME  CHAR(20),
         AGE INT,  
         SEX CHAR(1),
         INCOME FLOAT )"""
 
cursor.execute(sql)
 
# 關(guān)閉數(shù)據(jù)庫連接
db.close()

數(shù)據(jù)庫插入操作

以下實例使用執(zhí)行 SQL INSERT 語句向表 EMPLOYEE 插入記錄：

#!/usr/bin/python3
 
import pymysql
 
# 打開數(shù)據(jù)庫連接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )
 
# 使用cursor()方法獲取操作游標 
cursor = db.cursor()
 
# SQL 插入語句
sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
         LAST_NAME, AGE, SEX, INCOME)
         VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""
try:
   # 執(zhí)行sql語句
   cursor.execute(sql)
   # 提交到數(shù)據(jù)庫執(zhí)行
   db.commit()
except:
   # 如果發(fā)生錯誤則回滾
   db.rollback()
 
# 關(guān)閉數(shù)據(jù)庫連接
db.close()

以上例子也可以寫成如下形式：

#!/usr/bin/python3
 
import pymysql
 
# 打開數(shù)據(jù)庫連接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )
 
# 使用cursor()方法獲取操作游標 
cursor = db.cursor()
 
# SQL 插入語句
sql = "INSERT INTO EMPLOYEE(FIRST_NAME, \

       LAST_NAME, AGE, SEX, INCOME) \

       VALUES ('%s', '%s',  %s,  '%s',  %s)" % \

       ('Mac', 'Mohan', 20, 'M', 2000)
try:
   # 執(zhí)行sql語句
   cursor.execute(sql)
   # 執(zhí)行sql語句
   db.commit()
except:
   # 發(fā)生錯誤時回滾
   db.rollback()
 
# 關(guān)閉數(shù)據(jù)庫連接
db.close()

以下代碼使用變量向SQL語句中傳遞參數(shù):

..................................
user_id = "test123"
password = "password"

con.execute('insert into Login values( %s,  %s)' % \

             (user_id, password))
..................................

數(shù)據(jù)庫查詢操作

Python查詢Mysql使用 fetchone() 方法獲取單條數(shù)據(jù), 使用fetchall() 方法獲取多條數(shù)據(jù)。

  • fetchone(): 該方法獲取下一個查詢結(jié)果集。結(jié)果集是一個對象
  • fetchall(): 接收全部的返回結(jié)果行.
  • rowcount: 這是一個只讀屬性，并返回執(zhí)行execute()方法后影響的行數(shù)。

實例：

查詢EMPLOYEE表中salary（工資）字段大于1000的所有數(shù)據(jù)：

#!/usr/bin/python3
 
import pymysql
 
# 打開數(shù)據(jù)庫連接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )
 
# 使用cursor()方法獲取操作游標 
cursor = db.cursor()
 
# SQL 查詢語句
sql = "SELECT * FROM EMPLOYEE \

       WHERE INCOME > %s" % (1000)
try:
   # 執(zhí)行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]
       # 打印結(jié)果
      print ("fname=%s,lname=%s,age=%s,sex=%s,income=%s" % \

             (fname, lname, age, sex, income ))
except:
   print ("Error: unable to fetch data")
 
# 關(guān)閉數(shù)據(jù)庫連接
db.close()

以上腳本執(zhí)行結(jié)果如下：

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

數(shù)據(jù)庫更新操作

更新操作用于更新數(shù)據(jù)表的的數(shù)據(jù)，以下實例將 TESTDB 表中 SEX 為 'M' 的 AGE 字段遞增 1：

#!/usr/bin/python3
 
import pymysql
 
# 打開數(shù)據(jù)庫連接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )
 
# 使用cursor()方法獲取操作游標 
cursor = db.cursor()
 
# SQL 更新語句
sql = "UPDATE EMPLOYEE SET AGE = AGE + 1 WHERE SEX = '%c'" % ('M')
try:
   # 執(zhí)行SQL語句
   cursor.execute(sql)
   # 提交到數(shù)據(jù)庫執(zhí)行
   db.commit()
except:
   # 發(fā)生錯誤時回滾
   db.rollback()
 
# 關(guān)閉數(shù)據(jù)庫連接
db.close()

刪除操作

刪除操作用于刪除數(shù)據(jù)表中的數(shù)據(jù)，以下實例演示了刪除數(shù)據(jù)表 EMPLOYEE 中 AGE 大于 20 的所有數(shù)據(jù)：

#!/usr/bin/python3
 
import pymysql
 
# 打開數(shù)據(jù)庫連接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )
 
# 使用cursor()方法獲取操作游標 
cursor = db.cursor()
 
# SQL 刪除語句
sql = "DELETE FROM EMPLOYEE WHERE AGE > %s" % (20)
try:
   # 執(zhí)行SQL語句
   cursor.execute(sql)
   # 提交修改
   db.commit()
except:
   # 發(fā)生錯誤時回滾
   db.rollback()
 
# 關(guān)閉連接
db.close()

執(zhí)行事務

事務機制可以確保數(shù)據(jù)一致性。

事務應該具有4個屬性：原子性、一致性、隔離性、持久性。這四個屬性通常稱為ACID特性。

  • 原子性（atomicity）。一個事務是一個不可分割的工作單位，事務中包括的諸操作要么都做，要么都不做。
  • 一致性（consistency）。事務必須是使數(shù)據(jù)庫從一個一致性狀態(tài)變到另一個一致性狀態(tài)。一致性與原子性是密切相關(guān)的。
  • 隔離性（isolation）。一個事務的執(zhí)行不能被其他事務干擾。即一個事務內(nèi)部的操作及使用的數(shù)據(jù)對并發(fā)的其他事務是隔離的，并發(fā)執(zhí)行的各個事務之間不能互相干擾。
  • 持久性（durability）。持續(xù)性也稱永久性（permanence），指一個事務一旦提交，它對數(shù)據(jù)庫中數(shù)據(jù)的改變就應該是永久性的。接下來的其他操作或故障不應該對其有任何影響。

Python DB API 2.0 的事務提供了兩個方法 commit 或 rollback。

實例

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

對于支持事務的數(shù)據(jù)庫， 在Python數(shù)據(jù)庫編程中，當游標建立之時，就自動開始了一個隱形的數(shù)據(jù)庫事務。

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

錯誤處理

DB API中定義了一些數(shù)據(jù)庫操作的錯誤及異常，下表列出了這些錯誤和異常:

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

到此這篇關(guān)于Python3 MySQL 數(shù)據(jù)庫連接的使用示例 的文章就介紹到這了,更多相關(guān)Python3 MySQL 數(shù)據(jù)庫連接 內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章:
  • python數(shù)據(jù)庫如何連接SQLite詳解
  • python實現(xiàn)sqlalchemy的使用概述
  • Python流行ORM框架sqlalchemy的簡單使用
  • python中的mysql數(shù)據(jù)庫LIKE操作符詳解
  • python配置mssql連接的方法
  • python 操作sqlite數(shù)據(jù)庫的方法
  • 適合Python項目的五大SQL連接器

標簽：泉州 清遠 洛陽 長春 安慶 吉林 怒江 岳陽

巨人網(wǎng)絡通訊聲明：本文標題《Python3 MySQL 數(shù)據(jù)庫連接的使用示例》，本文關(guān)鍵詞  Python3,MySQL,數(shù)據(jù)庫,連接,；如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問題，煩請?zhí)峁┫嚓P(guān)信息告之我們，我們將及時溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡，涉及言論、版權(quán)與本站無關(guān)。
  • 相關(guān)文章
  • 下面列出與本文章《Python3 MySQL 數(shù)據(jù)庫連接的使用示例》相關(guān)的同類信息！
  • 本頁收集關(guān)于Python3 MySQL 數(shù)據(jù)庫連接的使用示例的相關(guān)信息資訊供網(wǎng)民參考！
    • 推薦文章