python3操作pymsql模块

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
云数据库 RDS MySQL,高可用系列 2核4GB
简介: pymysql是python中操作mysql的模块。1.pymysql模块的安装pip3 install pymysql也可以使用pycharm这个IDE工具来安装pymysql这个模块。2.pymysql模块的使用1.

pymysql是python中操作mysql的模块。

1.pymysql模块的安装

pip3 install pymysql

也可以使用pycharm这个IDE工具来安装pymysql这个模块。

2.pymysql模块的使用

1.执行mysql语句,获取查询的结果

代码如下:

#!/usr/bin/env python
#_*_coding:utf-8_*_

import pymysql

#创建连接
conn=pymysql.connect(host="127.0.0.1",port=3306,user="root",passwd="",db="db1")
#创建游标
cursor=conn.cursor()
#执行mysql语句,并返回执行的结果
res=cursor.execute("select name from db1")
#打印执行的结果
print(res)
#把要执行的语句提交,否则无法保存新建或者修改数据
conn.commit()

#关闭游标
cursor.close()
#关闭连接
conn.close()

执行结果为:

4    

因为从db1.db1这张表中检索到四条数据,所以返回的值为4

需要注意的是,查询过程中存在中文的话,连接需要添加**"charset='utf-8'"**,否则中文会显示乱码

2.获取查询的数据

代码如下:

#!/usr/bin/env python
#_*_coding:utf-8_*_

import pymysql

#创建连接
conn=pymysql.connect(host="127.0.0.1",port=3306,user="root",passwd="",db="db1")
#创建游标
cursor=conn.cursor()
#执行mysql语句
cursor.execute("select name from db1")

#获取所有的执行结果
res=cursor.fetchall()
#打印获取到的执行结果
print(res)

#提交要执行的mysql指令
conn.commit()
#关闭游标
cursor.close()
#关闭连接
conn.close()

执行结果为:

(('xiaoming',), ('xiaobing',), ('xiaoyong',), ('xiaojian',))

可以看到,返回的结果是一个元组类型的数据.

还可以在创建游标的时候,使用选项来指定返回的结果为哪种数据类型:

cursor=conn.cursor(cursor=pymysql.cursors.DictCursor)

使用这个指令可以把返回的结果变成字典类型。

在获取执行的结果时,可以指定获取的结果的条数,可以使用的选项如下:

fetchone()          取得检索结果的一条数据
fetchmany(n)        取得检索结果的n条数据
fetchall()          取得检索结果的所有数据

需要注意的是,与读取文件时的指针类似.如果在同一段代码中,先使用fetchone()获取检索结果的第一条数据,

然后再使用fetchmany(2)的话,指针会在检索结果的当前位置向后读取执行结果,而不会从头开始重新读取检索的结果.

代码如下:

#!/usr/bin/env python
#_*_coding:utf-8_*_

import pymysql

#创建连接
conn=pymysql.connect(host="127.0.0.1",port=3306,user="root",passwd="",db="db1")
#创建游标
cursor=conn.cursor(cursor=pymysql.cursors.DictCursor)
#执行mysql语句,并返回执行的结果
cursor.execute("select name from db1")

#取执行结果的第一条数据,并打印
res1=cursor.fetchone()
print("this is first result:",res1)
#从剩下的执行结果中再取两条数据,并打印
res2=cursor.fetchmany(2)
print("this is second result:",res2)
#再从剩下的数据中取所有的数据,并打印
res3=cursor.getchall()
print("this is third result:",res3)

#提交要执行的命令
conn.commit()
#关闭游标
cursor.close()
#关闭连接
conn.close()

执行结果如下:

this is first result: {'name': 'xiaoming'}
this is second result: [{'name': 'xiaobing'}, {'name': 'xiaoyong'}]
this is third result: [{'name': 'xiaojian'}]

第一次取第一行的检索结果,第二次取两行的时候,第三次取剩下的所有的结果.
因为数据表中只有四条记录,而第一次已经取走一行了,
第二次从第一次取得的结果又向后继续取两个值,所以最后取所有的值时,只剩下一个,所以第三次取得一个值。
在创建游标的时候,指定了返回的数据类型为字典类型,所以返回的结果是字典数据类型。

在使用fetch时,按照顺序进行取得数据,可以使用cursor.scroll(num,mode)来移动游标位置

mode指定位置,是相对当前位置,还是绝对位置
num指定移动的位数,正数向后移动,负数向前移动

例如:

cursor.scroll(1,mode="relative")        #相对于当前的指针位置取一个值
cursor.scroll(2,mode="absolute")        #在当前的绝对位置取一个值

"relative"与"absolute"的区别,看下面两段代码:
第一段代码:

#!/usr/bin/env python
#_*_coding:utf-8_*_

import pymysql

conn=pymysql.connect(host="127.0.0.1",port=3306,user="root",passwd="",db="db1")
cursor=conn.cursor()

cursor.execute("SELECT * FROM db1")
cursor.fetchone()
cursor.scroll(1,mode="relative")
print(cursor.fetchone())

conn.commit()
cursor.close()
conn.close()

执行结果如下:

(3, 'xiaoyong', 'xiaoyong')

第二段代码:

#!/usr/bin/env python
#_*_coding:utf-8_*_

import pymysql

conn=pymysql.connect(host="127.0.0.1",port=3306,user="root",passwd="",db="db1")

cursor=conn.cursor()

cursor.execute("SELECT * FROM db1")
cursor.fetchone()
cursor.scroll(1,mode="absolute")
print(cursor.fetchone())

conn.commit()
cursor.close()
conn.close()

执行结果如下:

(2, 'xiaobing', 'xiaobing')

3.获取新创建数据的自增ID

代码如下:

#!/usr/bin/env python
# _*_coding:utf-8_*_

import pymysql

conn=pymysql.connect(host="127.0.0.1",port=3306,user="root",passwd="",db="db1")

cursor=conn.cursor()

cursor.execute('INSERT INTO db1(name,password) VALUES("xiaofei","xiaofei")')

conn.commit()
cursor.close()
conn.close()

res=cursor.lastrowid
print(res)

执行结果为:

5

数据表db1中本来有四条数据,现在新增一条,其ID为自增类型,所以返回结果为5

相关实践学习
如何快速连接云数据库RDS MySQL
本场景介绍如何通过阿里云数据管理服务DMS快速连接云数据库RDS MySQL,然后进行数据表的CRUD操作。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
目录
相关文章
|
2月前
|
开发者 Python
如何在Python中管理模块和包的依赖关系?
在实际开发中,通常会结合多种方法来管理模块和包的依赖关系,以确保项目的顺利进行和可维护性。同时,要及时更新和解决依赖冲突等问题,以保证代码的稳定性和可靠性
59 4
|
22天前
|
Python
Python Internet 模块
Python Internet 模块。
119 74
|
2月前
|
算法 数据安全/隐私保护 开发者
马特赛特旋转算法:Python的随机模块背后的力量
马特赛特旋转算法是Python `random`模块的核心,由松本真和西村拓士于1997年提出。它基于线性反馈移位寄存器,具有超长周期和高维均匀性,适用于模拟、密码学等领域。Python中通过设置种子值初始化状态数组,经状态更新和输出提取生成随机数,代码简单高效。
123 63
|
2月前
|
测试技术 Python
手动解决Python模块和包依赖冲突的具体步骤是什么?
需要注意的是,手动解决依赖冲突可能需要一定的时间和经验,并且需要谨慎操作,避免引入新的问题。在实际操作中,还可以结合使用其他方法,如虚拟环境等,来更好地管理和解决依赖冲突😉。
|
1天前
|
Python
[oeasy]python057_如何删除print函数_dunder_builtins_系统内建模块
本文介绍了如何删除Python中的`print`函数,并探讨了系统内建模块`__builtins__`的作用。主要内容包括: 1. **回忆上次内容**:上次提到使用下划线避免命名冲突。 2. **双下划线变量**:解释了双下划线(如`__name__`、`__doc__`、`__builtins__`)是系统定义的标识符,具有特殊含义。
14 3
|
2月前
|
持续交付 Python
如何在Python中自动解决模块和包的依赖冲突?
完全自动解决所有依赖冲突可能并不总是可行,特别是在复杂的项目中。有时候仍然需要人工干预和判断。自动解决的方法主要是提供辅助和便捷,但不能完全替代人工的分析和决策😉。
|
2月前
|
JSON Linux 数据格式
Python模块:从入门到精通,只需一篇文章!
Python中的模块是将相关代码组织在一起的单元,便于重用和维护。模块可以是Python文件或C/C++扩展,Python标准库中包含大量模块,如os、sys、time等,用于执行各种任务。定义模块只需创建.py文件并编写代码,导入模块使用import语句。此外,Python还支持自定义模块和包,以及虚拟环境来管理项目依赖。
Python模块:从入门到精通,只需一篇文章!
|
2月前
|
Python
Python的模块和包
总之,模块和包是 Python 编程中非常重要的概念,掌握它们可以帮助我们更好地组织和管理代码,提高开发效率和代码质量
45 5
|
2月前
|
数据可视化 Python
如何在Python中解决模块和包的依赖冲突?
解决模块和包的依赖冲突需要综合运用多种方法,并且需要团队成员的共同努力和协作。通过合理的管理和解决冲突,可以提高项目的稳定性和可扩展性
|
2月前
|
Python
在Python中,可以使用内置的`re`模块来处理正则表达式
在Python中,可以使用内置的`re`模块来处理正则表达式
66 5