安装mysql模块
我们先确认是否已经安装了mysql模块。通过以下步骤可以快速检查：
打开终端或命令提示符。
输入命令pip freeze，查看当前已安装的Python模块列表。
在输出结果中查找是否包含mysql-connector-python或类似的条目。
如果没有找到mysql-connector-python，则说明尚未安装mysql模块，我们需要进行安装。
在确认未安装mysql模块后，我们需要使用pip命令来安装mysql-connector-python模块。执行以下命令：
pip install mysql-connector-python
安装完成后，我们需要在Python代码中导入mysql模块，以便在代码中正确使用该模块。在需要使用mysql模块的代码文件的开头添加以下代码：
import mysql.connector
创建数据库和表
在MySQL中创建一个名为test的数据库，并在其中创建一个名为user的表：
CREATE DATABASE test;
USE test;
CREATE TABLE user (
id INT AUTO_INCREMENT PRIMARY KEY,
name VARCHAR(255),
age INT
);
连接数据库
在Python中连接MySQL数据库需要使用mysql-connector-python库中的connect()方法，需要传入host、user、password和database等参数。如果连接成功，我们可以得到一个连接对象。
import mysql.connector
mydb = mysql.connector.connect(
host="localhost",
user="root",
password="123456",
database="test"
)
print(mydb)
插入数据
接下来我们可以通过连接对象的cursor()方法得到一个游标对象，使用execute()方法执行SQL语句。下面是插入数据的示例代码：
import mysql.connector
mydb = mysql.connector.connect(
host="localhost",
user="root",
password="123456",
database="test"
)
mycursor = mydb.cursor()
sql = "INSERT INTO user (name, age) VALUES (%s, %s)"
val = ("Tom", 18)
mycursor.execute(sql, val)
mydb.commit()
print(mycursor.rowcount, "record inserted.")
查询数据
我们可以使用SELECT语句查询数据，使用fetchall()方法获取全部数据或使用fetchone()方法获取一条数据。下面是查询数据的示例代码：
import mysql.connector
mydb = mysql.connector.connect(
host="localhost",
user="root",
password="123456",
database="test"
)
mycursor = mydb.cursor()
mycursor.execute("SELECT * FROM user")
myresult = mycursor.fetchall()
for x in myresult:
print(x)
更新数据
我们可以使用UPDATE语句更新数据，使用execute()方法执行SQL语句。下面是更新数据的示例代码：
import mysql.connector
mydb = mysql.connector.connect(
host="localhost",
user="root",
password="123456",
database="test"
)
mycursor = mydb.cursor()
sql = "UPDATE user SET age = %s WHERE name = %s"
val = (20, "Tom")
mycursor.execute(sql, val)
mydb.commit()
print(mycursor.rowcount, "record(s) affected")
删除数据
我们可以使用DELETE语句删除数据，使用execute()方法执行SQL语句。下面是删除数据的示例代码：
import mysql.connector
mydb = mysql.connector.connect(
host="localhost",
user="root",
password="123456",
database="test"
)
mycursor = mydb.cursor()
sql = "DELETE FROM user WHERE name = %s"
val = ("Tom",)
mycursor.execute(sql, val)
mydb.commit()
print(mycursor.rowcount, "record(s) deleted")
评论 (0)