一、安装MySQL客户端
要使用Python连接MySQL数据库,需要先安装MySQL客户端。可以使用以下命令在Ubuntu系统上安装:
sudo apt-get install mysql-client
如果是Windows系统,可以在MySQL官网下载安装包进行安装。
二、安装Python MySQL Connector
Python连接MySQL数据库还需要安装Python MySQL Connector模块,可以使用以下命令进行安装:
pip install mysql-connector-python
三、连接MySQL数据库
连接MySQL数据库需要使用MySQL Connector模块提供的connect()函数,并传入主机、用户名、密码和数据库名称等参数,代码示例如下:
import mysql.connector
mydb = mysql.connector.connect(
host="localhost",
user="root",
password="password",
database="mydatabase"
)
print(mydb)
该代码创建了一个名为mydb的连接对象,可以用来执行MySQL相关操作。
四、创建表
要在MySQL数据库中创建表,可以使用execute()函数执行SQL语句,代码示例如下:
mycursor = mydb.cursor()
mycursor.execute("CREATE TABLE customers (name VARCHAR(255), address VARCHAR(255))")
该代码创建了一个名为customers的表,包含两个列:name和address。
五、插入数据
插入数据需要使用execute()函数执行INSERT INTO语句,代码示例如下:
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.")
该代码将一个名为John的客户信息插入到customers表中,并输出插入的记录数为1。
六、查询数据
查询数据需要使用execute()函数执行SELECT语句,并使用fetchall()函数获取查询结果,代码示例如下:
mycursor = mydb.cursor()
mycursor.execute("SELECT * FROM customers")
myresult = mycursor.fetchall()
for x in myresult:
print(x)
该代码查询了customers表中的所有记录,并输出每条记录的内容。
七、更新数据
更新数据需要使用execute()函数执行UPDATE语句,代码示例如下:
mycursor = mydb.cursor()
sql = "UPDATE customers SET address = 'Canyon 123' WHERE name = 'John'"
mycursor.execute(sql)
mydb.commit()
print(mycursor.rowcount, "record(s) affected")
该代码将名为John的客户信息的地址更新为Canyon 123,并输出受影响的记录数。
八、删除数据
删除数据需要使用execute()函数执行DELETE语句,代码示例如下:
mycursor = mydb.cursor()
sql = "DELETE FROM customers WHERE name = 'John'"
mycursor.execute(sql)
mydb.commit()
print(mycursor.rowcount, "record(s) deleted")
该代码删除了名为John的客户信息,并输出删除的记录数。
九、总结
Python连接MySQL数据库,实现数据CRUD操作,需要先安装MySQL客户端和Python MySQL Connector模块,然后使用connect()函数连接MySQL数据库,使用execute()函数执行相关SQL语句,实现数据的CRUD操作。通过对MySQL数据库的操作,可以实现对数据的存储、查询、更新和删除等功能。