Python——操作MySQL数据库
😊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数据库进行增删改查操作的情况,例如:
- 开发Web应用程序:Web应用程序通常需要使用数据库存储用户数据、文章数据等,可以使用Python操作MySQL数据库来实现。
- 数据分析:数据分析师通常需要从MySQL数据库中提取数据进行分析,可以使用Python操作MySQL数据库来实现。
- 数据迁移:数据迁移是指将数据从一个数据库迁移到另一个数据库,可以使用Python操作MySQL数据库来实现。
- 自动化脚本:自动化脚本通常需要对MySQL数据库进行操作,例如备份数据库、恢复数据库等,可以使用Python操作MySQL数据库来实现。
🍭Java和Python操作MySQL数据库有何不同?
Java和Python都可以操作MySQL数据库,但它们之间有一些区别:
- 语言特性:Java是一种面向对象的编程语言,而Python是一种面向对象的解释型语言。Java需要编译后才能运行,而Python可以直接在解释器中运行。
- 数据库连接方式:Java可以使用
JDBC(Java Database Connectivity)
来连接MySQL数据库,而Python可以使用多种库来连接MySQL数据库,如MySQLdb、pymysql
等。 - SQL语句:Java和Python都可以使用SQL语句来操作MySQL数据库,但它们的语法略有不同。
- 数据类型:Java和Python对MySQL数据库中的数据类型支持略有不同。例如,Java中可以使用
Long类型
来表示MySQL数据库中的整数类型,而Python中需要使用int类型
。 - 性能: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
可以通过命令查看第三方库是否安装成功
执行命令
pip list
当然,有些小伙伴在执行上述命令可能会出现以下这种情况(这里我做举例),这是因为在安装Python的时候没有配置环境变量,只需要配置以下Python的环境变量即可。
接下来,就可以新建一个项目,然后进行对MySQL数据库的操作了。
# 导入第三方库
import pymysql
# 连接数据库
conn = pymysql.connect(host='localhost', user='root', password='123456', database='test')
✨补充
connect函数的参数说明
参数 | 说明 |
---|---|
host | 数据库的地址,可以是IP地址或者主机名 |
user | 用户名 |
password | 密码 |
database | 数据库名 |
port | 数据库的端口号,默认为3306 |
charset | 数据库的字符集,默认为utf8mb4 |
cursorclass | 游标的类,默认为pymysql.cursors.DictCursor |
use_unicode | 是否使用Unicode编码,默认为True |
connect_timeout | 用于设置连接超时时间,其默认值为10秒 |
connect函数的返回值是一个连接对象
,用于建立与MySQL服务器的连接。连接对象可以用于执行SQL语句、获取查询结果等操作。
接下来需要创建一个游标对象,游标对象用于管理查询结果集。游标对象可以用于遍历查询结果集,也可以用于执行多条SQL语句。然后执行SQL查询语句查询数据,并将查询到的结果返回并打印,最后关闭连接。
# 创建游标
cursor = conn.cursor()
# 执行SQL语句
cursor.execute("SELECT * FROM users")
# 获取查询结果
rows = cursor.fetchall()
# 打印查询结果
print(rows)
# 关闭游标和连接
cursor.close()
conn.close()
✨补充
connect函数常用方法
方法 | 语法 | 说明 |
---|---|---|
close() | conn.close() | 关闭连接 |
cursor() | cursor = conn.cursor() | 创建游标对象 |
execute() | cursor.execute(sql) | 执行SQL语句,sql表示要执行的SQL语句 |
executemany() | cursor.executemany(sql, args) | 批量执行SQL语句,sql表示要执行的SQL语句,args表示SQL语句中的参数 |
commit() | conn.commit() | 提交事务 |
ollback() | conn.rollback() | 回滚事务 |
setinputsizes() | cursor.setinputsizes(size1, size2, …) | 设置输入参数的大小,size1、size2等表示输入参数的大小 |
setoutputsize() | cursor.setoutputsize(size) | 设置输出参数的大小,size表示输出参数的大小 |
description属性 | description = cursor.description | 获取查询结果的描述信息 |
游标对象的常用方法
方法 | 语法 | 说明 |
---|---|---|
fetchone() | row = cursor.fetchone() | 获取查询结果的第一行数据 |
fetchmany() | row = cursor.fetchone() | 获取查询结果的多行数据,size表示要获取的数据行数 |
fetchall() | rows = cursor.fetchall() | 获取查询结果的所有数据 |
nextset() | cursor.nextset() | 获取下一个查询结果集 |
close() | cursor.close() | 关闭游标对象 |
lastrowid属性 | id = cursor.lastrowid | 获取最后一行数据的ID |
以上就是对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()
运行结果
📖查询数据
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()
📖新增数据
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()
🎯值得注意的是,如果遇到插入数据不报错但是未成功插入的情况,这是因为在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()
📖删除数据
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()
以上就是基于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()
上述代码只是一个简单的封装,具体封装步骤要根据自己的业务实现逻辑进行设计,同时也只是提供封装的思路,供小伙伴们学习和参考。将数据库的具体操作操作封装成一个类的话,又比上述代码复杂一点,但实际运用也更为广泛,同时,也进一步简化了对数据库的具体操作,只需要用到的时候调用即可。
🔊总结
以上就是Python数据库编程的基本操作,对数据库的操作在实际开发过程中也很常用,所以,希望小伙伴们在看完文章后,能够掌握Python连接以及操作MySQL数据库的方法,在实际应用场景中,根据自己业务需要,对数据库操作进行具体设计,对数据库操作进行封装,提高代码的可读性、可维护性、复用性和安全性。同时,注意连接数据库时要指定正确的数据库地址、用户名、密码和数据库名;执行SQL语句时要注意SQL语句的正确性;获取查询结果时要注意查询结果的类型和数量;关闭游标和连接时要确保游标和连接已经正确关闭。
🎨觉得不错的话记得点赞收藏呀!!🎨
😀别忘了给我关注~~😀
更多推荐
所有评论(0)