Python pymysql模塊詳解

一、連接數據庫

Python pymysql模塊是連接和操作MySQL數據庫的一種方法。在使用pymysql模塊前，我們需要先安裝pymysql這個庫。

我們可以通過以下方式來安裝pymysql庫：

pip install pymysql

在連接MySQL數據庫之前，我們需要先建立一個數據庫。以下示例演示如何建立一個名為testdb的數據庫：

import pymysql
conn=pymysql.connect(host='localhost', port=3306, user='root',password='yourpassword',charset='utf8')
cursor=conn.cursor()
cursor.execute("create database testdb")
conn.close()

在成功連接到MySQL服務器之後，我們可以在conn.cursor（）上調用.execute()方法來向MySQL服務器發送任意SQL語句。例如，可以使用以下代碼顯示所有數據庫：

conn = pymysql.connect(host='localhost', port=3306, user='root', password='yourpassword', db='testdb', charset='utf8')
cursor = conn.cursor()
cursor.execute("SHOW DATABASES")
for x in cursor:
    print(x)
conn.close()

以上示例中，我們使用了conn.cursor（）對象的execute（）方法發送SQL語句來查詢數據庫。在查詢完畢之後，我們需要通過conn.close()方法關閉數據庫連接。

二、創建數據表

在MySQL中，數據由表組成。一個表包含記錄和字段。在Python和pymysql中，我們可以使用CREATE TABLE語句來創建一個新的表。

以下示例演示如何創建一個名為person的表，其中包含id、name和age三個字段：

conn = pymysql.connect(host='localhost', port=3306, user='root', password='yourpassword', db='testdb', charset='utf8')
cursor = conn.cursor()
sql = "CREATE TABLE person (id INT(6) UNSIGNED AUTO_INCREMENT PRIMARY KEY, name VARCHAR(30) NOT NULL, age INT(3))"
cursor.execute(sql)
conn.close()

在創建表之後，我們可以使用以下命令來查看錶的結構：

DESCRIBE person;

三、插入數據

使用INSERT INTO語句向表中插入數據。INSERT INTO語句將帶有數據的字段列和值列表組合起來，然後將它們插入到表中。

以下示例演示如何向名為person的表中插入一條數據：

conn = pymysql.connect(host='localhost', port=3306, user='root', password='yourpassword', db='testdb', charset='utf8')
cursor = conn.cursor()
sql = "INSERT INTO person (name, age) VALUES (%s, %s)"
val = ("Mike", 25)
cursor.execute(sql, val)
conn.commit()
conn.close()

以上代碼使用了參數綁定將插入的值傳入到insert語句中，這種方式可以有效的避免SQL注入攻擊。

四、查詢數據

使用SELECT語句從表中檢索數據。SELECT語句使用列名清單來指定要從表中檢索的數據。可以使用WHERE子句來指定過濾條件。

以下示例演示如何從名為person的表中檢索數據：

conn = pymysql.connect(host='localhost', port=3306, user='root', password='yourpassword', db='testdb', charset='utf8')
cursor = conn.cursor()
sql = "SELECT * FROM person WHERE age > %s"
vals = (20,)
cursor.execute(sql, vals)
result = cursor.fetchall()
for row in result:
    id = row[0]
    name = row[1]
    age = row[2]
    print(f"id={id}, name={name}, age={age}")
conn.close()

以上代碼展示如何使用SELECT語句從名為person的表中檢索符合條件的數據，並通過fetchall（）方法來獲取所有記錄。

五、更新數據

使用UPDATE語句來更新表中的數據。UPDATE語句使用SET子句來指定要更新的列及其新值，並使用WHERE子句來指定過濾條件。

以下示例展示如何更新名為person的表中一個指定id的記錄的數據：

conn = pymysql.connect(host='localhost', port=3306, user='root', password='yourpassword', db='testdb', charset='utf8')
cursor = conn.cursor()
sql = "UPDATE person SET age = %s WHERE id = %s"
vals = (26, 1)
cursor.execute(sql, vals)
conn.commit()
conn.close()

以上代碼展示如何使用UPDATE語句來更新名為person的表中指定id的記錄的年齡值。

六、刪除數據

使用DELETE語句從表中刪除數據。DELETE語句使用WHERE子句來指定要刪除的記錄。如果省略WHERE子句，將會刪除表中的所有記錄！

以下示例展示如何從名為person的表中刪除id為1的一條記錄：

conn = pymysql.connect(host='localhost', port=3306, user='root', password='yourpassword', db='testdb', charset='utf8')
cursor = conn.cursor()
sql = "DELETE FROM person WHERE id = %s"
vals = (1,)
cursor.execute(sql, vals)
conn.commit()
conn.close()

以上代碼展示如何使用DELETE語句從名為person的表中刪除id為1的一條記錄。