pymysql cursor使用教程

Python之PyMySQL的使用：

在python3.x中，可以使用pymysql来MySQL数据库的连接，并实现数据库的各种操作，本次博客主要介绍了pymysql的安装和使用方法。

PyMySQL的安装

一、.windows上的安装方法：

在python3.6中，自带pip3，所以在python3中可以直接使用pip3去安装所需的模块：

pip3 install pymysql -i https://pypi.douban.com/simple

二、.linux下安装方法：

1.tar包下载及解压

下载tar包
wget https://pypi.python.org/packages/29/f8/919a28976bf0557b7819fd6935bfd839118aff913407ca58346e14fa6c86/PyMySQL-0.7.11.tar.gz#md5=167f28514f4c20cbc6b1ddf831ade772
解压并展开tar包
tar xf PyMySQL-0.7.11.tar.gz

2.安装

[root@localhost PyMySQL-0.7.11]# python36 setup.py install

数据库的连接

本次测试创建的数据及表：

#创建数据库及表，然后插入数据
mysql> create database dbforpymysql;
mysql> create table userinfo(id int not null auto_increment primary key,username varchar(10),passwd varchar(10))engine=innodb default charset=utf8;
mysql> insert into userinfo(username,passwd) values('frank','123'),('rose','321'),('jeff',666);#查看表内容
mysql> select * from userinfo;
+----+----------+--------+
| id | username | passwd |
+----+----------+--------+
|  1 | frank    | 123    |
|  2 | rose     | 321    |
|  3 | jeff     | 666    |
+----+----------+--------+
3 rows in set (0.00 sec)

连接数据库：

import pymysql#连接数据库
db = pymysql.connect("localhost","root","LBLB1212@@","dbforpymysql")#使用cursor()方法创建一个游标对象
cursor = db.cursor()#使用execute()方法执行SQL语句
cursor.execute("SELECT * FROM userinfo")#使用fetall()获取全部数据
data = cursor.fetchall()#打印获取到的数据
print(data)#关闭游标和数据库的连接
cursor.close()
db.close()#运行结果
((1, 'frank', '123'), (2, 'rose', '321'), (3, 'jeff', '666'))

要完成一个MySQL数据的连接，在connect中可以接受以下参数：

pymysql动态传参 pymysql cursor_数据库_05

参数

cursor其实是调用了cursors模块下的Cursor的类，这个模块主要的作用就是用来和数据库交互的，当你实例化了一个对象的时候，你就可以调用对象下面的各种绑定方法：
一些绑定方法

数据库操作

一、数据库增删改操作
commit()方法：在数据库里增、删、改的时候，必须要进行提交，否则插入的数据不生效。

import pymysql
config={"host":"127.0.0.1","user":"root","password":"LBLB1212@@","database":"dbforpymysql"
}
db = pymysql.connect(**config)
cursor = db.cursor()
sql = "INSERT INTO userinfo(username,passwd) VALUES('jack','123')"
cursor.execute(sql)
db.commit()  #提交数据
cursor.close()
db.close()
或者在execute提供插入的数据
import pymysql
config={"host":"127.0.0.1","user":"root","password":"LBLB1212@@","database":"dbforpymysql"
}
db = pymysql.connect(**config)
cursor = db.cursor()
sql = "INSERT INTO userinfo(username,passwd) VALUES(%s,%s)"
cursor.execute(sql,("bob","123"))  
db.commit()  #提交数据
cursor.close()
db.close()

MySQL的注入问题

executemany()：用来同时插入多条数据：

import pymysql
config={"host":"127.0.0.1","user":"root","password":"LBLB1212@@","database":"dbforpymysql"
}
db = pymysql.connect(**config)
cursor = db.cursor()
sql = "INSERT INTO userinfo(username,passwd) VALUES(%s,%s)"
cursor.executemany(sql,[("tom","123"),("alex",'321')])
db.commit()  #提交数据
cursor.close()
db.close()

execute()和executemany()都会返回受影响的行数：

sql = "delete  from  userinfo where username=%s"
res = cursor.executemany(sql,("jack",))
print("res=",res)
#运行结果
res= 1

当表中有自增的主键的时候，可以使用lastrowid来获取最后一次自增的ID：

import pymysql
config={"host":"127.0.0.1","user":"root","password":"LBLB1212@@","database":"dbforpymysql"
}
db = pymysql.connect(**config)
cursor = db.cursor()
sql = "INSERT INTO userinfo(username,passwd) VALUES(%s,%s)"
cursor.execute(sql,("zed","123"))
print("the last rowid is ",cursor.lastrowid)
db.commit()  #提交数据
cursor.close()
db.close()#运行结果
the last rowid is  10

二、数据库的查询操作

这里主要介绍三个绑定方法：

fetchone():获取下一行数据，第一次为首行；
fetchall():获取所有行数据源
fetchmany(4):获取下4行数据

先来查看表的内容：

mysql> select * from userinfo;
+----+----------+--------+
| id | username | passwd |
+----+----------+--------+
|  1 | frank    | 123    |
|  2 | rose     | 321    |
|  3 | jeff     | 666    |
|  5 | bob      | 123    |
|  8 | jack     | 123    |
| 10 | zed      | 123    |
+----+----------+--------+
6 rows in set (0.00 sec)

import pymysql
config={"host":"127.0.0.1","user":"root","password":"LBLB1212@@","database":"dbforpymysql"
}
db = pymysql.connect(**config)
cursor = db.cursor()
sql = "SELECT * FROM userinfo"
cursor.execute(sql)
res = cursor.fetchone() #第一次执行
print(res)
res = cursor.fetchone() #第二次执行
print(res)
cursor.close()
db.close()#运行结果
(1, 'frank', '123')
(2, 'rose', '321')

使用fetchall()：

import pymysql
config={"host":"127.0.0.1","user":"root","password":"LBLB1212@@","database":"dbforpymysql"
}
db = pymysql.connect(**config)
cursor = db.cursor()
sql = "SELECT * FROM userinfo"
cursor.execute(sql)
res = cursor.fetchall() #第一次执行
print(res)
res = cursor.fetchall()  #第二次执行
print(res)
cursor.close()
db.close()
#运行结果
((1, 'frank', '123'), (2, 'rose', '321'), (3, 'jeff', '666'), (5, 'bob', '123'), (8, 'jack', '123'), (10, 'zed', '123'))
()

可以看到，第二次获取的时候，什么数据都没有获取到，这个类似于文件的读取操作。

默认情况下，我们获取到的返回值是元组，只能看到每行的数据，却不知道每一列代表的是什么，这个时候可以使用以下方式来返回字典，每一行的数据都会生成一个字典：

cursor = db.cursor(cursor=pymysql.cursors.DictCursor)  #在实例化的时候，将属性cursor设置为pymysql.cursors.DictCursor

使用fetchall获取所有行的数据，每一行都被生成一个字典放在列表里面：

import pymysql
config={"host":"127.0.0.1","user":"root","password":"LBLB1212@@","database":"dbforpymysql"
}
db = pymysql.connect(**config)
cursor = db.cursor(cursor=pymysql.cursors.DictCursor)
sql = "SELECT * FROM userinfo"
cursor.execute(sql)
res = cursor.fetchall()
print(res)
cursor.close()
db.close()
#运行结果
[{'id': 1, 'username': 'frank', 'passwd': '123'}, {'id': 2, 'username': 'rose', 'passwd': '321'}, {'id': 3, 'username': 'jeff', 'passwd': '666'}, {'id': 5, 'username': 'bob', 'passwd': '123'}, {'id': 8, 'username': 'jack', 'passwd': '123'}, {'id': 10, 'username': 'zed', 'passwd': '123'}]

这样获取到的内容就能够容易被理解和使用了！

在获取行数据的时候，可以理解开始的时候，有一个行指针指着第一行的上方，获取一行，它就向下移动一行，所以当行指针到最后一行的时候，就不能再获取到行的内容，所以我们可以使用如下方法来移动行指针：

cursor.scroll(1,mode='relative')  # 相对当前位置移动
cursor.scroll(2,mode='absolute') # 相对绝对位置移动
第一个值为移动的行数，整数为向下移动，负数为向上移动，mode指定了是相对当前位置移动，还是相对于首行移动

例如：

sql = "SELECT * FROM userinfo"
cursor.execute(sql)
res = cursor.fetchall()
print(res)
cursor.scroll(0,mode='absolute') #相对首行移动了0，就是把行指针移动到了首行
res = cursor.fetchall()  #第二次获取到的内容
print(res)#运行结果
[{'id': 1, 'username': 'frank', 'passwd': '123'}, {'id': 2, 'username': 'rose', 'passwd': '321'}, {'id': 3, 'username': 'jeff', 'passwd': '666'}, {'id': 5, 'username': 'bob', 'passwd': '123'}, {'id': 8, 'username': 'jack', 'passwd': '123'}, {'id': 10, 'username': 'zed', 'passwd': '123'}]
[{'id': 1, 'username': 'frank', 'passwd': '123'}, {'id': 2, 'username': 'rose', 'passwd': '321'}, {'id': 3, 'username': 'jeff', 'passwd': '666'}, {'id': 5, 'username': 'bob', 'passwd': '123'}, {'id': 8, 'username': 'jack', 'passwd': '123'}, {'id': 10, 'username': 'zed', 'passwd': '123'}]

上下文管理器

在python的文件操作中支持上下文管理器，在操作数据库的时候也可以使用：

import pymysql
config={"host":"127.0.0.1","user":"root","password":"LBLB1212@@","database":"dbforpymysql"
}
db = pymysql.connect(**config)
with db.cursor(cursor=pymysql.cursors.DictCursor) as cursor:  #获取数据库连接的对象sql = "SELECT * FROM userinfo"   cursor.execute(sql)res = cursor.fetchone()print(res)cursor.scroll(2,mode='relative')res = cursor.fetchone()print(res)cursor.close()
db.close()#运行结果
{'id': 1, 'username': 'frank', 'passwd': '123'}
{'id': 5, 'username': 'bob', 'passwd': '123'}

Cursor常用API

1、cursor.execute(query, args=None)：执行sql语句。

参数:

query (str)：sql语句。

args (tuple, list or dict)：sql语句中如果有变量，或者格式化输出，会在这里填充数据。

Returns：返回一个int值，表示sql语句影响到的行数。

下面演示插入数据的四种方式：

import pymysql.cursors
# 连接数据库
connect = pymysql.connect(
    host=‘127.0.0.1’,
    user=‘root’,
    password=‘123’,
    db=‘demo_temp’,
    charset=‘utf8’,
    cursorclass=pymysql.cursors.DictCursor
)
with connect.cursor() as cursor:   # 创建游标
    # 第一种方式向表中插入数据
    sql = “”"
        INSERT INTO users (user,passwd) VALUES (‘123’,‘123’)
        “”"
    cursor.execute(sql)
    # 第二种方式向表中插入数据
    sql = “”"
           INSERT INTO users (user,passwd) VALUES (%s,%s)
           “”"
    cursor.execute(sql,[‘456’,‘456’])
    # 第三种方式向表中插入数据
    sql = “”"
               INSERT INTO users (user,passwd) VALUES (%s,%s)
               “”"
    cursor.execute(sql, (‘789’, ‘789’))
    # 第四种方式向表中插入数据
    sql = “”"
               INSERT INTO users (user,passwd) VALUES (%(a)s,%(b)s)  
               “”"
    cursor.execute(sql, {‘a’:‘abc’,‘b’:‘123’})  # 这里的’a’和’b’要和上面VALUES中对应
    connect.commit()  # 插入数据后必须更新
    # 查询数据
    sql = “”"
        select * from users
        “”"
    cursor.execute(sql)
    ret = cursor.fetchall()  # 提取查询数据
    print(ret)
connect.close()   # 关闭数据库连接

2、cursor.executemany(query, args)：可以执行多条sql语句。

参数:

query ：sql语句

args：可迭代对象

Returns：返回sql语句影响到的行数。

下面是方法实例：

import pymysql.cursors
# 连接数据库
connect = pymysql.connect(
    host=‘127.0.0.1’,
    user=‘root’,
    password=‘123’,
    db=‘demo_temp’,
    charset=‘utf8’,
    cursorclass=pymysql.cursors.DictCursor
)
with connect.cursor() as cursor:   # 创建游标
    # 插入多条数据
    sql = “”"
               INSERT INTO users (user,passwd) VALUES (%s,%s)  
               “”"
    ret_row = cursor.executemany(sql,[[‘a’,‘123’],[‘b’,‘234’],[‘c’,‘456’]])  # 在args中传入一个可迭代对象。
    connect.commit()  # 插入数据后必须更新
    print(f’当前受影响了{ret_row}行’)
    # 查询数据
    sql = “”"
        select * from users
        “”"
    cursor.execute(sql)
    ret = cursor.fetchall()  # 提取查询数据
    print(ret)
connect.close()   # 关闭数据库连接

3、cursor.fetchone()：从查询语句中获取一条查询结果。

4、cursor.fetchall()：获取所有查询到的结果。

5、cursor.fetchmany(size)：根据size获取相应的行数。

6、cursor.mogrify(query, args=None)：返回执行的sql语句，下面是示例：

import pymysql.cursors
# 连接数据库
connect = pymysql.connect(
    host=‘127.0.0.1’,
    user=‘root’,
    password=‘123’,
    db=‘demo_temp’,
    charset=‘utf8’,
    cursorclass=pymysql.cursors.DictCursor
)
with connect.cursor() as cursor:   # 创建游标
    sql = “”"
        select * from users
        “”"
    cursor.execute(sql)
    ret_sql = cursor.mogrify(sql)   # 返回执行的sql语句
    cursor.fetchmany(2)             # 提取查询数据
    print(ret_sql)
connect.close()   # 关闭数据库连接

7、cursor.close()：关闭游标，关闭游标后，游标内所有数据将被清空。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/411342.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

基于SpringBoot的校园闲置物品交易管理系统

基于SpringBoot的校园闲置物品交易管理系统

基于SpringBootVue的校园闲置物品交易管理系统【附源码文档】、前后端分离 开发语言：Java数据库：MySQL技术：SpringBoot、Vue、Mybaits Plus、ELementUI工具：IDEA/Ecilpse、Navicat、Maven 系统展示 摘要 基于SpringBoot与Vue的校…
阅读更多...
Linux驱动开发—创建总线，创建属性文件

Linux驱动开发—创建总线，创建属性文件

文章目录 1.什么是BUS？1.1总线的主要概念1.2总线的操作1.3总线的实现 2.创建总线关键结构体解析2.1注册总线到系统2.2 struct bus_type *bus 解析 3.实验结果分析1. devices 目录2. drivers 目录3. drivers_autoprobe 文件4. drivers_probe 文件5. uevent 文件 4.在…
阅读更多...
vscode远程连接服务器并根据项目配置setting.json

vscode远程连接服务器并根据项目配置setting.json

vscode连接好远程服务器，打开项目文件，按下快捷键：CtrlShiftP 搜索setting.json 这边可以看到不同范围的setting.json，这边以文件夹（项目）为单位，即在打开的文件夹内创建setting.json&#xff…
阅读更多...
axure9树形元件节点的添加

axure9树形元件节点的添加

树形元件 | AxureChina 在需要添加节点处右键添加->添加子节点
阅读更多...
World of Warcraft [CLASSIC][80][Grandel] Call to Arms: Strand of the Ancients

World of Warcraft [CLASSIC][80][Grandel] Call to Arms: Strand of the Ancients

Call to Arms: Strand of the Ancients - Quest - 魔兽世界怀旧服CTM4.34《大地的裂变》数据库_大灾变85级魔兽数据库_ctm数据库 Call to Arms: Strand of the Ancients 战斗的召唤：远古海滩 打掉最后一个门【古代圣物之厅】，人跳进去就赢了 拿【炸弹】…
阅读更多...
SpringBoot集成kafka-监听器注解

SpringBoot集成kafka-监听器注解

SpringBoot集成kafka-监听器注解 1、application.yml2、生产者3、消费者4、测试类5、测试 1、application.yml #自定义配置 kafka:topic:name: helloTopicconsumer:group: helloGroup2、生产者 package com.power.producer;import com.power.model.User; import com.power.uti…
阅读更多...
UnQLite：多语言支持的嵌入式NoSQL数据库深入解析

UnQLite：多语言支持的嵌入式NoSQL数据库深入解析

文章目录 1. 引言2. Key/Value 存储接口2.1 关键函数2.2 使用示例2.3 高级操作：批量文件存储 3. 游标的使用4. UnQLite-Python使用示例4. UnQLite数据库引擎架构5.1 Key/Value存储层5.2 文档存储层5.3 可插拔的存储引擎5.4 事务管理器与分页模块5.5 虚拟文件系统 6.…
阅读更多...
游戏开发设计模式之模板方法模式

游戏开发设计模式之模板方法模式

目录 模板方法模式在游戏开发中的具体应用案例是什么？ 如何在不同类型的游戏（如角色扮演游戏、策略游戏等）中实现模板方法模式？ 模板方法模式与其他设计模式（如观察者模式、状态模式等）相比，…
阅读更多...
物联网平台与边缘计算平台，ThingsKit与AIoTedge

物联网平台与边缘计算平台，ThingsKit与AIoTedge

物联网平台和边缘计算平台是现代智能系统中不可或缺的组成部分，它们共同支撑着设备的连接、数据的收集和智能分析等功能。ThingsKit和AIoTedge是两个专注于不同层面的平台，它们各自具有独特的特点和优势。 ThingsKit是一个运行在云端的通用物联网平台&am…
阅读更多...
深度学习项目实践——qq聊天机器人（transformer）（一）原理介绍

深度学习项目实践——qq聊天机器人（transformer）（一）原理介绍

文章目录 首先第一步——QQ是如何实现实时聊天数据传输过程1. 用户发送消息的开始2. 数据封装与加密3. 建立连接：WebSocket协议的应用4. 消息的传输过程5. 接收者获取消息6. 双向通信与实时性保障7. 保持连接与断线重连 第二步——聊天机器人是如何来接管QQ账号的组…
阅读更多...
论文阅读笔记:RepViT: Revisiting Mobile CNN From Vit Perspective

论文阅读笔记:RepViT: Revisiting Mobile CNN From Vit Perspective

文章目录 RepViT: Revisiting Mobile CNN From Vit Perspective动机现状问题 贡献实现Block设置独立的token融合器和通道融合器减少膨胀并增加宽度 宏观设计stem的早期卷积简单分类器整体阶段比率 微观设计内核大小选择Squeeze-and-excitation层放置网络架构 实验ImageNet-1K上…
阅读更多...
Jmeter（十四）Jmeter分布式部署测试

Jmeter（十四）Jmeter分布式部署测试

单个接口测试，我们使用谷歌的插件postman 多个接口测试，我们使用Jmeter进行测试 一、使用工具测试 1、使用Jmeter对接口测试 首先我们说一下为什么用Posman测试后我们还要用Jmeter做接口测试，在用posman测试时候会发现的是一个接口一个接…
阅读更多...
存储架构模式之复制架构

存储架构模式之复制架构

存储类问题处理框架图 故障：机器挂掉 灾难：自然灾害 多活：技术复杂度高、成本高 高可用的关键指标 stag1是正常状态，系统和业务都是正常的 stag2是故障状态，系统和业务都是异常的 stag3是系统恢复正常&#xff0c…
阅读更多...
docker maven 构建的找不到 ClassNotFoundException

docker maven 构建的找不到 ClassNotFoundException

Exception in thread "main" java.lang.ClassNotFoundException: com.baimeidashu.springbootdemo1.Springbootdemo1Application 我用idea 自带的 maven 构建的jiar包没，没问题， 但是用 docker 镜像 maven:3.6.0-jdk-8-alpine 构建的就出问…
阅读更多...
Oracle发邮件时SMTP服务器配置方法与步骤？

Oracle发邮件时SMTP服务器配置方法与步骤？

Oracle发邮件功能如何配置？如何优化Oracle发信性能？ 为了实现自动化报告和通知，Oracle发邮件功能变得尤为重要。通过配置SMTP服务器，Oracle可以轻松地发送电子邮件。AokSend将详细介绍如何配置Oracle发邮件时的SMTP服务器&#x…
阅读更多...
收藏夹里的“小网站”被误报违规不让上怎么办？如何将Chrome和Edge安装到 D 盘（含用户数据），重装系统也不会丢失收藏夹和密码？

收藏夹里的“小网站”被误报违规不让上怎么办？如何将Chrome和Edge安装到 D 盘（含用户数据），重装系统也不会丢失收藏夹和密码？

当你用国产浏览器访问网站的时候，有时候会显示这个： 如果确实是违规网站，不让访问也没什么，但是很多都是误报啊，你这样直接来个大红横幅，还让人活不？ 那遇到这种误报应当怎么办呢？有…
阅读更多...
爆火的《黑神话：悟空》对LabVIEW软件开发的启示

爆火的《黑神话：悟空》对LabVIEW软件开发的启示

近期，《黑神话：悟空》在全球范围内爆火，引发了游戏行业和玩家群体的广泛关注。作为一款由中国开发团队Game Science历时多年打造的动作角色扮演游戏，它的成功不仅源于卓越的技术创新和对中国传统文化的深度挖掘，更在于…
阅读更多...
翻译_Clock Domain Crossing Design

翻译_Clock Domain Crossing Design

翻译_Clock Domain Crossing Design 原文标题及连接：Clock Domain Crossing (CDC) Design & Verification Techniques Using SystemVerilog. 作者：Clifford E. Cummings Sunburst Design, Inc. cliffc@sunburst-design.com 摘要 在多时钟设计中，需要在时钟域交叉（…
阅读更多...
【Java】—— Java面向对象基础：使用Java模拟银行账户与客户交易系统

【Java】—— Java面向对象基础：使用Java模拟银行账户与客户交易系统

目录 账户类（Account） 客户类（Customer） 测试类（CustomerTest） 运行结果 在今天的博文中，我们将通过Java编程语言来模拟一个简单的银行账户与客户交易系统。这个系统将包括两个主要类&#…
阅读更多...
09.定时器02

09.定时器02

#include "reg52.h"sbit led P3^6;void delay10ms() { //1. 配置定时器0工作模式位16位计时TMOD 0x01;//2. 给初值，定一个10ms出来TL00x00;TH00xDC;//3. 开始计时TR0 1;TF0 0; } void main() {int cnt 0;led 1;while(1){if(TF0 1)//当爆表的时候&a…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023