MySQL是一种常见的关系型数据库,而Python是一种编程语言,两者之间通过一些特定的库进行连接,以实现对MySQL数据库的增删改查操作。在本文中,我们将详细介绍如何使用Python连接MySQL数据库,并进行增删改查操作。
一、连接MySQL数据库
在使用Python对MySQL进行操作之前,首先需要连接到数据库。Python中的MySQL连接库主要有两种,一种是MySQLdb
,一种是PyMySQL
。这里我们将以PyMySQL
为例进行介绍,在使用之前需要先通过pip install PyMySQL
命令进行安装。
import pymysql
# 建立数据库连接
conn = pymysql.connect(
host='localhost', # 连接地址
port=3306, # 端口号
user='root', # 数据库用户名
password='password', # 数据库密码
database='test', # 数据库名称
charset='utf8', # 字符编码
)
# 关闭数据库连接
conn.close()
以上代码中,我们使用pymysql.connect()
方法进行连接,需要传入连接所需的参数:连接地址、端口号、数据库用户名、数据库密码、数据库名称、字符编码。建立连接后,我们可以使用conn.close()
方法进行关闭。
二、查询数据
在连接MySQL数据库之后,我们可以对其中的数据进行查询。查询数据需要使用游标,Python中的pymysql
库提供了两种游标:普通游标和字典游标。普通游标返回的结果是一个元组,而字典游标返回的结果是一个字典。
1. 普通游标
import pymysql
# 建立数据库连接
conn = pymysql.connect(
host='localhost', # 连接地址
port=3306, # 端口号
user='root', # 数据库用户名
password='password', # 数据库密码
database='test', # 数据库名称
charset='utf8', # 字符编码
)
# 建立游标
cur = conn.cursor()
# 执行查询
sql = "SELECT * FROM users"
cur.execute(sql)
# 获取结果集
results = cur.fetchall()
for row in results:
id = row[0]
name = row[1]
age = row[2]
print("id=%d, name=%s, age=%d" % (id, name, age))
# 关闭游标
cur.close()
# 关闭数据库连接
conn.close()
以上代码中, first we create connent and create cursor,then execute query using cursor.execute and then get the reslt retunred using cursor.fetchall.
2. 字典游标
import pymysql
# 建立数据库连接
conn = pymysql.connect(
host='localhost', # 连接地址
port=3306, # 端口号
user='root', # 数据库用户名
password='password', # 数据库密码
database='test', # 数据库名称
charset='utf8', # 字符编码
)
# 建立字典游标
cur = conn.cursor(pymysql.cursors.DictCursor)
# 执行查询
sql = "SELECT * FROM users"
cur.execute(sql)
# 获取结果集
results = cur.fetchall()
for row in results:
id = row['id']
name = row['name']
age = row['age']
print("id=%d, name=%s, age=%d" % (id, name, age))
# 关闭游标
cur.close()
# 关闭数据库连接
conn.close()
以上代码中,我们通过传入pymysql.cursors.DictCursor
参数,创建了字典游标,然后执行查询,获取结果集,并对结果集进行遍历输出。
三、插入数据
在数据库中插入数据需要使用游标,首先需要创建游标,然后执行插入语句,最后提交事务。
import pymysql
# 建立数据库连接
conn = pymysql.connect(
host='localhost', # 连接地址
port=3306, # 端口号
user='root', # 数据库用户名
password='password', # 数据库密码
database='test', # 数据库名称
charset='utf8', # 字符编码
)
# 建立游标
cur = conn.cursor()
# 执行插入
sql = "INSERT INTO users(name,age) VALUES(%s,%s)"
cur.execute(sql, ('Tom', 18))
# 提交事务
conn.commit()
# 关闭游标
cur.close()
# 关闭数据库连接
conn.close()
以上代码中,我们创建游标,然后通过cur.execute()
方法执行插入语句,并向其中传入需要插入的数据。最后,我们需要执行conn.commit()
方法来提交事务。如果不执行conn.commit()
方法,则不会对数据库产生任何修改。
四、更新数据
更新数据与插入数据类似,需要通过游标来实现。需要注意的是,更新语句需要指定更新的数据条件。
import pymysql
# 建立数据库连接
conn = pymysql.connect(
host='localhost', # 连接地址
port=3306, # 端口号
user='root', # 数据库用户名
password='password', # 数据库密码
database='test', # 数据库名称
charset='utf8', # 字符编码
)
# 建立游标
cur = conn.cursor()
# 执行更新
sql = "UPDATE users SET age=%s WHERE name=%s"
cur.execute(sql, (20, 'Tom'))
# 提交事务
conn.commit()
# 关闭游标
cur.close()
# 关闭数据库连接
conn.close()
以上代码中,我们通过游标执行更新语句,其中更新语句指定了更新数据的条件。然后需要执行conn.commit()
方法提交事务。
五、删除数据
删除数据需要使用游标,同样需要指定删除数据的条件,并提交事务。
import pymysql
# 建立数据库连接
conn = pymysql.connect(
host='localhost', # 连接地址
port=3306, # 端口号
user='root', # 数据库用户名
password='password', # 数据库密码
database='test', # 数据库名称
charset='utf8', # 字符编码
)
# 建立游标
cur = conn.cursor()
# 执行删除
sql = "DELETE FROM users WHERE name=%s"
cur.execute(sql, ('Tom',))
# 提交事务
conn.commit()
# 关闭游标
cur.close()
# 关闭数据库连接
conn.close()
以上代码中,我们通过游标执行删除语句,其中删除语句指定了删除数据的条件。然后需要执行conn.commit()
方法提交事务。