Python操作MySQL

本文將從以下幾個方面對Python操作MySQL進行詳細闡述:

一、連接MySQL數據庫

在使用Python操作MySQL之前，我們需要先連接MySQL數據庫。在Python中，我們可以使用MySQL Connector Python庫來實現連接。具體代碼如下：

import mysql.connector

mydb = mysql.connector.connect(
  host="localhost",
  user="yourusername",
  password="yourpassword"
)

print(mydb)

在上述代碼中，我們使用connect()方法來創建一個數據庫連接。參數包括：主機名、用戶名和密碼。在連接成功後，我們可以打印mydb變量，檢查是否連接成功。

二、創建數據庫和表

在連接成功後，我們需要創建數據庫和表，以進行數據操作。在Python中，我們可以使用execute()方法，執行SQL語句。具體代碼如下：

import mysql.connector

mydb = mysql.connector.connect(
  host="localhost",
  user="yourusername",
  password="yourpassword"
)

mycursor = mydb.cursor()

# 創建數據庫
mycursor.execute("CREATE DATABASE mydatabase")

# 創建表
mycursor.execute("CREATE TABLE customers (name VARCHAR(255), address VARCHAR(255))")

在上述代碼中，我們分別創建了一個名為“mydatabase”的數據庫以及一個名為“customers”的表。execute()方法可以執行任何SQL語句。

三、插入數據

在創建好數據庫和表後，我們可以將數據插入到表中。在Python中，我們可以使用execute()方法來實現插入操作。具體代碼如下：

import mysql.connector

mydb = mysql.connector.connect(
  host="localhost",
  user="yourusername",
  password="yourpassword",
  database="mydatabase"
)

mycursor = mydb.cursor()

# 插入數據
sql = "INSERT INTO customers (name, address) VALUES (%s, %s)"
val = ("John", "Highway 21")
mycursor.execute(sql, val)

mydb.commit()
print(mycursor.rowcount, "記錄插入成功。")

在上述代碼中，我們使用execute()方法執行SQL語句，插入一條名為“John”的記錄，並提交這條記錄。如果提交成功，則可以得到“1記錄插入成功”的輸出。

四、查詢數據

在插入數據後，我們可以從表中查詢數據。在Python中，我們可以使用execute()方法來實現查詢操作。具體代碼如下：

import mysql.connector

mydb = mysql.connector.connect(
  host="localhost",
  user="yourusername",
  password="yourpassword",
  database="mydatabase"
)

mycursor = mydb.cursor()

# 查詢數據
mycursor.execute("SELECT * FROM customers")

myresult = mycursor.fetchall()

for x in myresult:
  print(x)

在上述代碼中，我們使用execute()方法執行SQL語句，將表中所有數據查詢出來，並使用fetchall()方法獲取結果。然後使用for循環輸出結果。

五、更新數據

在查詢數據後，我們可以對數據進行更新操作。在Python中，我們可以使用execute()方法來實現更新操作。具體代碼如下：

import mysql.connector

mydb = mysql.connector.connect(
  host="localhost",
  user="yourusername",
  password="yourpassword",
  database="mydatabase"
)

mycursor = mydb.cursor()

# 更新數據
sql = "UPDATE customers SET address = 'Canyon 123' WHERE name = 'John'"
mycursor.execute(sql)

mydb.commit()

print(mycursor.rowcount, "條記錄被修改")

在上述代碼中，我們使用execute()方法執行SQL語句，更新名為“John”的記錄的地址為“Canyon 123”。如果提交成功，則可以得到“1條記錄被修改”的輸出。

六、刪除數據

在更新數據後，我們可以對數據進行刪除操作。在Python中，我們可以使用execute()方法來實現刪除操作。具體代碼如下：

import mysql.connector

mydb = mysql.connector.connect(
  host="localhost",
  user="yourusername",
  password="yourpassword",
  database="mydatabase"
)

mycursor = mydb.cursor()

# 刪除數據
sql = "DELETE FROM customers WHERE address = 'Highway 21'"
mycursor.execute(sql)

mydb.commit()

print(mycursor.rowcount, "條記錄被刪除")

在上述代碼中，我們使用execute()方法執行SQL語句，刪除地址為“Highway 21”的記錄。如果提交成功，則可以得到“1條記錄被刪除”的輸出。