python3连接MySQL数据库,并执行数据库的基本增删改查操作

本文涉及的产品
云数据库 RDS MySQL Serverless,0.5-2RCU 50GB
云数据库 RDS MySQL Serverless,价值2615元额度,1个月
简介: python3连接MySQL数据库,并执行数据库的基本增删改查操作

本篇为python连接数据库的详细说明,如果急需用python连接数据库,请看这篇模板文章python3连接MySQL数据库模板

python3连接MySQL数据库我们需要安装pymysql

pip install pymysql

安装好后直接import pymysql就可以导入第三方库

连接数据库

conn = pymysql.connect(
  host="localhost",  # 指示host表明是本地MySQL还是远程
    user="root",  # 用户名
    password="root",  # 密码
    db="db4",  # 要连接的数据库名
    charset="utf8mb4",  # 指定字符集,可以解决中文乱码
    cursorclass=pymysql.cursors.DictCursor  # 固定写法,类似于jdbc里边的加载驱动
)

数据库增删改查(简单写法)

在连接了数据库之后我们就要进行数据库的增删改查

"""
"""
sql = "select * from user"
cursor = conn.cursor()  # 创建一个名为cursor的指针对象
result = cursor.execute(sql)  # 执行查询操作,返回的result是受影响的行数
data = cursor.fetchone()  #该方法是获取数据库结果的第一条数据,用元祖表示,若没有则是null (在python中用None表示)
datas = cursor.fetchall()  # 该方法得到查询的所有结果,用元祖表示出来
# 进行数据处理,数据处理完就可以关闭指针和链接
curosr.close()
conn.close()
'''
如果sql语句中有可变的参数可以进行一下方式的处理
'''
sql = "select * from user where id = %s" % 23  # python的字符串处理
'''
不过这种处理方式容易产生sql注入问题
execute()这个方法其实留有参数的位置,execute(sql语句, 参数位置)
所以我们可以写作如下
'''
sql = "select * from user where id = %s and username = %s"
cursor = conn.cursor()
result = cursor.execute(sql, (12, 'zhangsan'))
# 这样就可以有效防止sql注入,或者我们也可以写做如下
sql = cursor.mogrify(select * from user where id = %s and username=%s, (12, 'zhangsan'))
cursor = conn.cursor()
result = cursor.execute(sql)
"""
"""
conn = pymysql.connect(
  host="localhost",
    user="root",
    password="root",
    db="db4", 
    charset="utf8mb4",
    cursorclass=pymysql.cursors.DictCursor
)
cursor = conn.cursor()
sql = "insert into user (username, password) values(%s, %s)"
result = cursor.execute(sql, ("zhangsan", "123456"))
conn.commit()  ''' 注意这里要提交事务,才可以插入成功 '''
cursor.close()
conn.close()
'''值得一提的是。pymysql还提供了executemany()这个神奇的方法,可以一次插入很多条数据'''
'''如下所示'''
sql = "insert into user (username, password) values(%s, %s)"
params = [('zhanshen','123'), ('lemon', '123'), ('wangsi', '1234')]
result = cursor.executemany(sql, params)
cursor.close()
conn.close()
'''这里的params可以是一个大列表,里边是一个个的元祖参数,或者也可以是一个大元祖,里边是元祖参数'''
params = cursor.
"""
"""
conn = pymysql.connect(
  host="localhost",
    user="root",
    password="root",
    db="db4", 
    charset="utf8mb4",
    cursorclass=pymysql.cursors.DictCursor
)
cursor = conn.cursor()
sql = "update user set password = %s where username = %s"
result = cursor.execute(sql, ("zhangsan", "123456"))
conn.commit()  
cursor.close()
conn.close()
''' 这里并没有什么特别需要注意的,和insert方法一样,删也是一个道理(偷懒省去,滑稽) '''

下面我们可以用with as来改善代码

conn = pymysql.connect(
  host="localhost",
    user="root",
    password="root",
    db="db4", 
    charset="utf8mb4",
    cursorclass=pymysql.cursors.DictCursor
)
try:
  with conn.cursor() as cursor:
    sql = "select * from user"
    result = cursor.execute(sql)
    print(result)
  with conn.cursor() as cursor:
    sql = "insert into user (username, password) values (%s, %s)"
    result = cursor.execute(sql, ('zhanshen', '123'))
    conn.commit()
finally:
  conn.close()
'''有木有发现用了with as就可以不用关闭cursor,因为with as会自动帮我们关闭'''
相关实践学习
基于CentOS快速搭建LAMP环境
本教程介绍如何搭建LAMP环境,其中LAMP分别代表Linux、Apache、MySQL和PHP。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
|
1天前
|
关系型数据库 MySQL Go
数据库的事务操作
数据库的事务操作
|
1天前
|
关系型数据库 MySQL Go
数据库的事务操作 | 青训营
数据库的事务操作 | 青训营
|
1天前
|
SQL 关系型数据库 MySQL
【Go语言专栏】使用Go语言连接MySQL数据库
【4月更文挑战第30天】本文介绍了如何使用Go语言连接和操作MySQL数据库,包括选择`go-sql-driver/mysql`驱动、安装导入、建立连接、执行SQL查询、插入/更新/删除操作、事务处理以及性能优化和最佳实践。通过示例代码,展示了连接数据库、使用连接池、事务管理和性能调优的方法,帮助开发者构建高效、稳定的Web应用。
|
1天前
|
存储 SQL 关系型数据库
mysql查询数据库表大小怎么操作
mysql查询数据库表大小怎么操作
|
1天前
|
SQL 关系型数据库 数据库
【MySQL】:DDL数据库定义与操作
【MySQL】:DDL数据库定义与操作
8 0
|
1天前
|
SQL DataWorks 网络安全
DataWorks操作报错合集之DataWorks连接Hive数据库时出现连接超时的问题如何解决
DataWorks是阿里云提供的一站式大数据开发与治理平台,支持数据集成、数据开发、数据服务、数据质量管理、数据安全管理等全流程数据处理。在使用DataWorks过程中,可能会遇到各种操作报错。以下是一些常见的报错情况及其可能的原因和解决方法。
7 1
|
2天前
|
弹性计算 关系型数据库 MySQL
检测MySQL 数据库连接数量
【4月更文挑战第29天】
5 0
|
2天前
|
关系型数据库 MySQL 测试技术
【专栏】将 PostgreSQL 迁移到 MySQL 数据库
【4月更文挑战第29天】本文探讨了PostgreSQL数据库向MySQL迁移的过程、挑战及策略。迁移步骤包括评估规划、数据导出与转换、创建MySQL数据库、数据导入。挑战包括数据类型不匹配、函数和语法差异、数据完整性和性能问题。应对策略涉及数据类型映射、代码调整、数据校验和性能优化。迁移后需进行数据验证、性能测试和业务验证,确保顺利过渡。在数字化时代,掌握数据库迁移技能对技术人员至关重要。
|
2天前
|
Java 关系型数据库 MySQL
Java基础教程(20)-Java连接mysql数据库CURD
【4月更文挑战第19天】MySQL是流行的关系型数据库管理系统,支持SQL语法。在IDEA中加载jar包到项目类路径:右击项目,选择“Open Module Settings”,添加库文件。使用JDBC连接MySQL,首先下载JDBC驱动,然后通过`Class.forName()`加载驱动,`DriverManager.getConnection()`建立连接。执行CRUD操作,例如创建表、插入数据和查询,使用`Statement`或`PreparedStatement`,并确保正确关闭数据库资源。
|
2天前
|
弹性计算 关系型数据库 MySQL
检测 MySQL 数据库连接数量
【4月更文挑战第28天】
8 0