Python中使用mysql.connector連接與操作MySQL數據庫

MySQL是最常用的關係型數據庫之一，而Python作為一種高級編程語言，已經成為了很多開發者的首選。Python中使用mysql.connector模塊可以非常方便地連接和操作MySQL數據庫，我們將在本文中詳細介紹該模塊的使用方法。

一、連接MySQL數據庫

在使用mysql.connector模塊之前，需要先安裝該模塊（可以使用pip進行安裝），安裝完成後我們就可以進行MySQL連接了。

import mysql.connector

# 連接MySQL數據庫
mydb = mysql.connector.connect(
    host="localhost",
    user="root",
    password="password",
    database="mydatabase"
)

print(mydb)

以上代碼中，我們使用connect()函數連接MySQL數據庫，參數中需要指定數據庫的連接信息。其中host參數為MySQL主機地址，user參數為用戶名，password參數為密碼，database參數為數據庫名稱。

二、創建表

連接MySQL數據庫成功後，我們可以通過創建表的方式來操作數據。下面是一個簡單的創建students表的示例：

import mysql.connector

# 連接MySQL數據庫
mydb = mysql.connector.connect(
    host="localhost",
    user="root",
    password="password",
    database="mydatabase"
)

# 創建表
mycursor = mydb.cursor()

mycursor.execute("CREATE TABLE students (name VARCHAR(255), age INTEGER(10))")

以上代碼中，我們使用execute()函數執行SQL語句，創建一個名為students的表，該表包含兩個列：name和age。

三、插入數據

創建表之後，我們就可以開始插入數據。下面是一個將學生信息插入students表中的示例：

import mysql.connector

# 連接MySQL數據庫
mydb = mysql.connector.connect(
    host="localhost",
    user="root",
    password="password",
    database="mydatabase"
)

# 插入數據
mycursor = mydb.cursor()

sql = "INSERT INTO students (name, age) VALUES (%s, %s)"
val = ("Tom", 20)
mycursor.execute(sql, val)

mydb.commit()

print(mycursor.rowcount, "record inserted.")

以上代碼中，我們使用execute()函數執行SQL語句，並使用佔位符%s和元組來插入數據。使用commit()函數提交數據，並使用rowcount屬性來獲取插入的記錄數。

四、查詢數據

插入數據之後，我們可以通過查詢語句來獲取數據庫中的數據。下面是一個簡單的查詢students表中所有記錄的示例：

import mysql.connector

# 連接MySQL數據庫
mydb = mysql.connector.connect(
    host="localhost",
    user="root",
    password="password",
    database="mydatabase"
)

# 查詢數據
mycursor = mydb.cursor()

mycursor.execute("SELECT * FROM students")

myresult = mycursor.fetchall()

for x in myresult:
  print(x)

以上代碼中，我們使用execute()函數執行SQL語句，並使用fetchall()函數獲取所有數據，並使用for循環遍歷結果集並打印出每條記錄的值。

五、更新數據

如果需要修改數據，可以使用UPDATE語句。下面是一個將Tom的年齡修改為22歲的示例：

import mysql.connector

# 連接MySQL數據庫
mydb = mysql.connector.connect(
    host="localhost",
    user="root",
    password="password",
    database="mydatabase"
)

# 更新數據
mycursor = mydb.cursor()

sql = "UPDATE students SET age = %s WHERE name = %s"
val = (22, "Tom")
mycursor.execute(sql, val)

mydb.commit()

print(mycursor.rowcount, "record(s) affected")

以上代碼中，我們使用execute()函數執行UPDATE語句，並使用佔位符%s和元組來指定更新數據的條件和更新後的值。

六、刪除數據

如果需要刪除數據，可以使用DELETE語句。下面是一個刪除名為Tom的記錄的示例：

import mysql.connector

# 連接MySQL數據庫
mydb = mysql.connector.connect(
    host="localhost",
    user="root",
    password="password",
    database="mydatabase"
)

# 刪除數據
mycursor = mydb.cursor()

sql = "DELETE FROM students WHERE name = %s"
val = ("Tom", )
mycursor.execute(sql, val)

mydb.commit()

print(mycursor.rowcount, "record(s) deleted")

以上代碼中，我們使用execute()函數執行DELETE語句，並使用佔位符%s和元組來指定刪除數據的條件。

結語

本文主要介紹了Python中使用mysql.connector連接與操作MySQL數據庫的方法，包括連接MySQL數據庫、創建表、插入數據、查詢數據、更新數據和刪除數據。希望本文對大家在使用MySQL和Python進行開發時有所幫助。