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条记录被删除”的输出。