📅  最后修改于: 2023-12-03 15:34:02.462000             🧑  作者: Mango
Python 是一种广泛使用的高级编程语言,可以与多种关系型数据库进行交互,MySQL 是其中之一。在Python中,使用 mysql-connector
模块可以方便地与 MySQL 进行交互。
首先,需要安装 mysql-connector
模块:
pip install mysql-connector
接着,需要安装 MySQL 数据库并创建一张表来存储数据。
在 Python 中,连接 MySQL 数据库需要使用 connect()
方法。以下是一个连接 MySQL 数据库的示例:
import mysql.connector
mydb = mysql.connector.connect(
host="localhost",
user="yourusername",
password="yourpassword",
database="mydatabase"
)
print(mydb)
在上面的代码中,host
参数是指 MySQL 数据库所在的服务器地址,user
参数是指用户名,password
参数是指密码,database
参数是指需要连接的数据库名称。
连接成功后,connect()
方法返回一个 MySQLConnection 对象,可以使用该对象进行数据库操作。
使用 execute()
方法可以向 MySQL 数据库中插入数据。以下是一个向表中插入数据的示例:
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, "record inserted.")
在上面的代码中,首先通过 cursor()
方法创建一个游标对象(用于执行 SQL 命令),然后定义 SQL 命令,将需要插入的数据以元组的形式传递给 execute()
方法,并通过 commit()
方法将数据提交到数据库中。最后,打印插入的记录数。
使用 execute()
方法可以从 MySQL 数据库中查询数据。以下是一个查询表中所有数据的示例:
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)
在上面的代码中,使用 SELECT
命令从 customers
表中查询数据。fetchall()
方法以元组的形式返回所有查询结果。
使用 execute()
方法可以更新 MySQL 数据库中的数据。以下是一个更新表中数据的示例:
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 address = 'Highway 21'"
mycursor.execute(sql)
mydb.commit()
print(mycursor.rowcount, "record(s) affected")
在上面的代码中,通过 UPDATE
命令更新 customers
表中 address
字段为 Highway 21
的记录。最后,打印更新的记录数。
使用 execute()
方法可以从 MySQL 数据库中删除数据。以下是一个删除表中数据的示例:
import mysql.connector
mydb = mysql.connector.connect(
host="localhost",
user="yourusername",
password="yourpassword",
database="mydatabase"
)
mycursor = mydb.cursor()
sql = "DELETE FROM customers WHERE address = 'Mountain 21'"
mycursor.execute(sql)
mydb.commit()
print(mycursor.rowcount, "record(s) deleted")
在上面的代码中,通过 DELETE
命令删除 customers
表中 address
字段为 Mountain 21
的记录。最后,打印删除的记录数。
以上就是 Python MySQL - 加入 的介绍。通过 mysql-connector
模块,我们可以方便地与 MySQL 数据库进行交互,进行插入、查询、更新、删除等操作。