Python操作MySQL數據庫實例分析

本篇內容主要講解“Python操作MySQL數據庫實例分析”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學習“Python操作MySQL數據庫實例分析”吧!

1、安裝

通過Python連接MySQL數據庫有很多庫，這里使用官方推薦的MySQL Connector/Python庫，其官網為：https://dev.mysql.com/doc/connector-python/en/。

通過pip命令安裝：

pip install mysql-connector-python

默認安裝的是最新的版本，我安裝的是8.0.17，對應MySQL的8.0版本。MySQL統一了其相關工具的大版本號，必須相同或更高才可以兼容。例如我使用的是MySQL8.0，如果使用低于8的mysql-connector就會報錯。事實上也是這樣，在某些舊的文檔中提示安裝pip install mysql-connector，就會安裝較低的版本，在連接MySQL時，會報錯如下：

mysql.connector.errors.NotSupportedError: Authentication plugin 'caching_sha2_password' is not supported

這是由于mysql8.0使用了Use Strong Password Encryption for Authentication即強密碼加密，而低版本的mysql-connector采用舊的mysql_native_password加密方式，導致無法連接，因此注意使用和數據庫相兼容的版本。

2、連接

可以通過connector類的connect()方法進行數據庫的連接，傳入服務器、端口號、用戶名、密碼、數據庫等參數，其中服務器與端口號可省略，默認為localhost:3306。

import mysql.connectordb = mysql.connector.connect(  host='localhost',  port='3306',  user="root",  password="123456",  database="test")

3、數據庫、表操作

對數據庫、數據表的操作屬于模式定義語言(DDL)，所有DDL語句的執行都是依賴于一個叫cursor的數據結構進行操作的。通過從connect對象中獲取cursor對象后就可以進行數據庫、表的相關操作了。例如創建一個數據庫、數據表

# 獲取數據庫的cursorcursor = db.cursor()# 創建數據庫cursor.execute("CREATE DATABASE mydatabase")# 創建數據表dbcursor.execute("CREATE TABLE customers (name varchar(255),address varchar(255))")# 修改表操作dbcursor.execute('ALTER TABLE customers ADD COLUMN id INT PRIMARY KEY AUTO_INCREMENT')# 查詢并打印數據庫中的所有表cursor.execute("show tables")for table in cursor:  print(table)

4、增刪改

插入、刪除、修改操作依舊是通過cursor對象來實現，通過cursor的execute()方法執行SQL操作，第一個參數是要執行的SQL語句，第二個參數是語句中要填充的變量。

在執行完所有的SQL操作后記得要通過數據庫對象的commit()將操作事務提交到數據庫，如果需要撤銷則通過rollback()方法回滾操作。

SQL語句中的變量可以用%s的形式作為占位符，然后再以python中元組的形式在執行時將變量填入，如下所示：

值得注意的是無論是什么類型的數據在傳入時都被當做字符串類型，然后在執行SQL操作時會將字符串轉化為相應的類型，因此此處的占位符都是%s，而沒有%d、%f等。

# 要執行的SQL語句sql = "INSERT INTO customers (name, address) VALUES (%s, %s)"# 以元組的形式填入數據val = ('Mike', 'Main street 20')# 執行操作cursor.execute(sql, val)# 提交事務db.commit()

也可以用python中字典的形式填充變量，在SQL語句中的占位符需要使用對應的變量名

# 在SQL語句中指明變量名sql = "INSERT INTO customers (name, address) VALUES (%(name)s, %(address)s)"# 以字典的形式填入數據val = {  'name': 'Alice',  'address': 'Center street 22'}cursor.execute(sql, val)

如果需要一次插入多條數據，可以使用executemany()方法，將多條數據以數組的方式傳給第二個參數。

通過cursor的rowcount屬性可以返回成功操作的數據條數，lastrowid屬性是最后一個成功插入的行的id

sql = "INSERT INTO customers (name, address) VALUES (%s, %s)"# 以數組的形式填充數據val = [ ('Peter', 'Lowstreet 4'), ('Amy', 'Apple st 652'), ('Hannah', 'Mountain 21'),]cursor.executemany(sql, val)print("成功插入%d條數據,最后一條的id為:%d" % (cursor.rowcount, cursor.lastrowid))

修改、刪除數據的方法與插入類似，只需要把對應的SQL語句和變量值傳給execute()函數即可。可以看出MySQL-connector庫的操作是非常貼近原生SQL語言的。

# 修改數據sql = "UPDATE customers SET address=%s WHERE name=%s"val = ('Center street 21', 'Mike')cursor.execute(sql, val)# 刪除數據sql = "DELETE FROM customers WHERE name=%s"val = ('Hannah',)cursor.execute(sql, val)

5、查詢

執行查詢操作和之前類似，都是通過execute()執行對應的SQL語句，在執行時將相應的數據填入即可。查詢結束后，結果集會保存在cursor當中，可以直接把cursor當作迭代器iterator來進行展開取得結果集中每條數據的對應字段。也可以通過cursor的fetchall()、fetchone()方法取得所有或一條結果集。

# 查詢customers表中id介于6到8之間的數據并返回name、address字段query = "SELECT name,address FROM customers WHERE id BETWEEN %s AND %s"cursor.execute(query, (6, 8))# 循環取出結果集中的每條數據并打印for (name, address) in cursor:  print("%s家的地址是%s" % (name, address))# 輸出結果為：# Peter家的地址是Lowstreet 4# Amy家的地址是Apple st 652# Hannah家的地址是Mountain 21

通過原生的SQL語句可以進行更為復雜的查詢操作，例如通過where設置查詢條件、Order by進行字段排序、Limit設置返回結果條數、OFFSET查詢結果集的偏移、Join進行表連接操作

到此，相信大家對“Python操作MySQL數據庫實例分析”有了更深的了解，不妨來實際操作一番吧！這里是億速云網站，更多相關內容可以進入相關頻道進行查詢，關注我們，繼續學習！