Python——操作MySQL数据库

🚀前言

😊学习永无止境，记得每天学习新的知识！！

在很多业务场景中，我们或多或少都要对数据库上的数据进行的一系列操作，包括读取数据、写数据、更新或修改数据、删除数据等。这些操作可以通过编写SQL语句来实现，也可以通过使用数据库管理系统提供的API接口来实现。数据库操作是应用程序开发中必不可少的一部分。使用数据库编程接口操作数据库的方式也有很多种，比如Java、Python、C++、PHP等等。其实各种编程语言操作数据库的方式大同小异，其基本原理还是一样的，只是实现方式不同。

本章内容基于Python这门编程语言来实现对MySQL数据库的基本增删改查操作，通过本章内容的学习，希望大家都能有所收获，同时也能掌握使用Python来操作MySQL数据库，实现对数据库进行增删改查操作。

---

🔍数据库编程

🍭数据库编程基本介绍

数据库编程是指使用编程语言来操作和管理数据库的过程。数据库编程通常包括数据库设计、SQL语句编写、数据库连接、数据插入、查询、更新和删除等操作。通过数据库编程，可以实现对数据库的自动化管理和数据的高效处理，提高数据的安全性和可靠性。数据库编程分为数据库客户端编程与数据库服务器端编程。数据库客户端编程主要使用ODBC API、ADO、ADO.NET、OCI、OTL等方法；数据库服务端编程主要使用OLE DB等方法。数据库编程需要掌握一些访问数据库技术方法，还需要注意怎么设计高效的数据库、数据库管理与运行的优化、数据库语句的优化。

🍭数据库编程接口

数据库编程接口（Database Programming Interface，简称DBAPI） 是一组用于访问数据库的规范，它定义了一组API，用于在编程语言中连接数据库、执行SQL语句、获取查询结果等操作。DBAPI的出现，使得不同编程语言之间可以通过统一的接口来访问数据库，从而实现跨语言的数据库编程。DBAPI的实现可以分为两种：一种是基于ODBC（Open Database Connectivity）的实现，如JDBC（Java Database Connectivity）；另一种是基于SQLAPI（SQL Application Programming Interface）的实现，如MySQLdb、pymysql等。

🍭什么情况下会使用Python操作MySQL数据库？

Python操作MySQL数据库通常用于需要在Python程序中对MySQL数据库进行增删改查操作的情况，例如：

1. 开发Web应用程序：Web应用程序通常需要使用数据库存储用户数据、文章数据等，可以使用Python操作MySQL数据库来实现。
2. 数据分析：数据分析师通常需要从MySQL数据库中提取数据进行分析，可以使用Python操作MySQL数据库来实现。
3. 数据迁移：数据迁移是指将数据从一个数据库迁移到另一个数据库，可以使用Python操作MySQL数据库来实现。
4. 自动化脚本：自动化脚本通常需要对MySQL数据库进行操作，例如备份数据库、恢复数据库等，可以使用Python操作MySQL数据库来实现。

🍭Java和Python操作MySQL数据库有何不同？

Java和Python都可以操作MySQL数据库，但它们之间有一些区别：

1. 语言特性：Java是一种面向对象的编程语言，而Python是一种面向对象的解释型语言。Java需要编译后才能运行，而Python可以直接在解释器中运行。
2. 数据库连接方式：Java可以使用JDBC（Java Database Connectivity）来连接MySQL数据库，而Python可以使用多种库来连接MySQL数据库，如MySQLdb、pymysql等。
3. SQL语句：Java和Python都可以使用SQL语句来操作MySQL数据库，但它们的语法略有不同。
4. 数据类型：Java和Python对MySQL数据库中的数据类型支持略有不同。例如，Java中可以使用Long类型来表示MySQL数据库中的整数类型，而Python中需要使用int类型。
5. 性能：Java通常比Python更快，因为Java是编译型语言，而Python是解释型语言。但是，这种差异在实际应用中并不明显，因为Python也可以使用JIT（Just-In-Time）编译器来提高性能。

总之，Java和Python都可以操作MySQL数据库，但它们之间存在一些区别，开发者需要根据实际需求选择适合自己的语言和库。

---

🚢Python数据库编程接口

Python有多种数据库编程接口，其中最常用的是Python标准库中的sqlite3模块、MySQL驱动程序和第三方库pymysql、psycopg2等。

📖pymysql简介

pymysql是一个Python库，用于连接MySQL数据库并执行SQL语句。它是基于MySQLdb的升级版，支持Python3.x和MySQL5.x及以上版本。pymysql提供了简单易用的API，可以方便地进行数据库操作，如连接数据库、执行SQL语句、获取查询结果等。pymysql还支持事务处理、连接池、数据库连接监控等功能，可以满足不同场景的需求。

📖使用Python操作MySQL数据库

首先，使用Python操作MySQL数据库这里我们需要使用到三方库PyMySQl，利用本地的pip来下载我们所需要的第三方库。win + R ---> 输入cmd打开控制台，输入代码完成下载。

执行命令
pip install pymysql
1
2

可以通过命令查看第三方库是否安装成功

执行命令
pip list
1
2

当然，有些小伙伴在执行上述命令可能会出现以下这种情况（这里我做举例），这是因为在安装Python的时候没有配置环境变量，只需要配置以下Python的环境变量即可。

接下来，就可以新建一个项目，然后进行对MySQL数据库的操作了。

# 导入第三方库
import pymysql

# 连接数据库
conn = pymysql.connect(host='localhost', user='root', password='123456', database='test')
1
2
3
4
5

✨补充

connect函数的参数说明

connect函数的返回值是一个连接对象，用于建立与MySQL服务器的连接。连接对象可以用于执行SQL语句、获取查询结果等操作。

接下来需要创建一个游标对象，游标对象用于管理查询结果集。游标对象可以用于遍历查询结果集，也可以用于执行多条SQL语句。然后执行SQL查询语句查询数据，并将查询到的结果返回并打印，最后关闭连接。

# 创建游标
cursor = conn.cursor()

# 执行SQL语句
cursor.execute("SELECT * FROM users")

# 获取查询结果
rows = cursor.fetchall()

# 打印查询结果
print(rows)

# 关闭游标和连接
cursor.close()
conn.close()
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

✨补充

connect函数常用方法

游标对象的常用方法

以上就是对MySQL数据库的基本操作，完整代码和运行结果如下：

完整代码

import pymysql

# 连接数据库
conn = pymysql.connect(host='localhost', user='root', password='123456', database='test')

# 创建游标
cursor = conn.cursor()

# 执行SQL语句
cursor.execute("SELECT * FROM users")

# 获取查询结果
rows = cursor.fetchall()

# 打印查询结果
print(rows)

# 关闭游标和连接
cursor.close()
conn.close()
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

运行结果

📖查询数据

import pymysql

# 连接数据库
# host表示数据库的地址，user表示用户名，password表示密码，database表示数据库名。
coon = pymysql.connect(host='localhost', user='root', password='123456', database='test')


# 创建游标
cursor = coon.cursor()

# 执行SQL语句 查询全部数据
cursor.execute("SELECT * FROM users")

# 获取查询结果 此时获取全部数据
rows = cursor.fetchall()

# 获取查询结果 此时获取第一条数据
# rows = cursor.fetchone()

# 获取查询结果 此时获取多条数据
# rows = cursor.fetchmany(2)

# 打印结果
print(rows)

# 关闭游标和连接
cursor.close()
coon.close()
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

📖新增数据

import pymysql

# 连接数据库
# host表示数据库的地址，user表示用户名，password表示密码，database表示数据库名。
coon = pymysql.connect(host='localhost', user='root', password='123456', database='test', autocommit=True)


# 创建游标
cursor = coon.cursor()

# 执行SQL语句 新增数据 并返回影响行数
rows = cursor.execute('INSERT INTO user(name, age) VALUES ("小明", 20)')

# 手动提交
# coon.commit()

# 打印结果
print(rows)

# 关闭游标和连接
cursor.close()
coon.close()
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

🎯值得注意的是，如果遇到插入数据不报错但是未成功插入的情况，这是因为在Java中，jdbc默认自动帮我们提交事务。但在Python中，则需要自己手动提交一下，有两种解决方式：

1.在连接数据库时加上autocommit=True（自动提交事务），这种方式在执行execute时就会立即向数据库发出操作请求，完成插入操作

2.在进行数据库的增删改操作时，需要在具体操作后添加commit()函数，手动提交事务，保证在执行操作的时候，能立刻向数据库发送请求。

📖修改数据

import pymysql

# 连接数据库
# host表示数据库的地址，user表示用户名，password表示密码，database表示数据库名。
coon = pymysql.connect(host='localhost', user='root', password='123456', database='tset', autocommit=True)


# 创建游标
cursor = coon.cursor()

# 执行SQL语句 新增数据 并返回影响行数
rows = cursor.execute('UPDATE user SET age=25 WHERE name="张三"')

# 手动提交
# coon.commit()

# 打印结果
print(rows)

# 关闭游标和连接
cursor.close()
coon.close()
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

📖删除数据

import pymysql

# 连接数据库
# host表示数据库的地址，user表示用户名，password表示密码，database表示数据库名。
coon = pymysql.connect(host='localhost', user='root', password='123456', database='test', autocommit=True)


# 创建游标
cursor = coon.cursor()

# 执行SQL语句 新增数据 并返回影响行数
rows = cursor.execute('DELETE FROM user WHERE name="张丽"')

# 手动提交
# coon.commit()

# 打印结果
print(rows)

# 关闭游标和连接
cursor.close()
coon.close()
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

以上就是基于Python对MySQL数据库的一些基本操作，在编写代码的同时，需要注意数据库连接的信息是否有误，SQL语句是否正确，以及使用方法是否规范，以保证在运行时，不会出错。当然，遇到错误时，应及时寻找错误并纠正，保证程序可执行性。

---

☃️封装数据库操作

在实际开发当中，我们并不是每一次连接数据库都需要单独再创建一个新的文件，然后一次又一次反复的配置和具体操作，这样做无疑加大了业务工作量，同时也降低了代码的可维护性和安全性，所以，通常，我们都是单独把数据库操作封装成一个类，需要使用的时候，只需要调用这个类就可以实现具体操作，并且，封装数据库操作可以将数据库操作相关的代码集中在一起，便于阅读和维护，将常用的数据库操作封装成函数，可以在多个地方复用，避免重复编写相同的代码，同时，我们可以根据需要修改数据库操作的实现，而不需要修改调用方的代码，又避免了直接操作数据库，减少了出错的可能性，提高了代码的安全性。

# 简单封装
# 导入第三方库
import pymysql

#连接数据库
conn = pymysql.connect(host='localhost', user='root', password='123456', database='test')

# 创建游标对象
cursor = conn.cursor()

# 定义数据库操作函数
# 添加数据
def add_user(name, age):
    #具体SQL语句可根据自己实际需求编写
    sql = "INSERT INTO users(name, age) VALUES (%s, %s)"
    cursor.execute(sql, (name, age))
    #提交事务
    conn.commit()

# 修改数据
def update_user(name, age):
    #具体SQL语句可根据自己实际需求编写
    sql = "UPDATE users SET age=%s WHERE name=%s"
    cursor.execute(sql, (age, name))
    #提交事务
    conn.commit()

# 删除数据
def delete_user(name):
    #具体SQL语句可根据自己实际需求编写
    sql = "DELETE FROM users WHERE name=%s"
    cursor.execute(sql, (name,))
    #提交事务
    conn.commit()

# 查询数据
def query_user():
    #具体SQL语句可根据自己实际需求编写
    sql = "SELECT * FROM users"
    cursor.execute(sql)
    result = cursor.fetchall()
    return result

# 调用数据库操作函数
add_user('Tom', 20)
update_user('Tom', 21)
delete_user('Tom')
result = query_user()

#关闭游标和连接
cursor.close()
conn.close()
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52

上述代码只是一个简单的封装，具体封装步骤要根据自己的业务实现逻辑进行设计，同时也只是提供封装的思路，供小伙伴们学习和参考。将数据库的具体操作操作封装成一个类的话，又比上述代码复杂一点，但实际运用也更为广泛，同时，也进一步简化了对数据库的具体操作，只需要用到的时候调用即可。

---

🔊总结

以上就是Python数据库编程的基本操作，对数据库的操作在实际开发过程中也很常用，所以，希望小伙伴们在看完文章后，能够掌握Python连接以及操作MySQL数据库的方法，在实际应用场景中，根据自己业务需要，对数据库操作进行具体设计，对数据库操作进行封装，提高代码的可读性、可维护性、复用性和安全性。同时，注意连接数据库时要指定正确的数据库地址、用户名、密码和数据库名；执行SQL语句时要注意SQL语句的正确性；获取查询结果时要注意查询结果的类型和数量；关闭游标和连接时要确保游标和连接已经正确关闭。

🎨觉得不错的话记得点赞收藏呀！！🎨

😀别忘了给我关注~~😀