MySQL学习14_游标

皮大大

发布于 2021-03-02 15:08:30

2.2K00

代码可运行

文章被收录于专栏：机器学习/数据可视化机器学习/数据可视化

运行总次数：0

代码可运行

游标

SQL检索操作返回的是一行或者多行称为结果集的行。

有时候我们是需要在检索的结果中，前进或者后退一行或者多行，这个时候需要使用游标cursor。

游标是一个存在DBMS服务器上的数据库查询，它不仅是一条SELECT语句，而是被该语句检索出来的结果集。在存储了游标之后，应用程序可以根据V需要滚动或者浏览其中的数据。不同的DBMS支持不同的游标选项和特性：

能够标记游标为只读，使得数据能够被读取，但是不能更新和删除
能控制执行定向的操作（向前，向后，第一，最后，绝对位置，相对位置等）
标记某些列能够编辑，有些列不能被编辑
规定范围，使得游标对创建它的特定请求或者所有请求可访问

使用游标

使用步骤

declare：在使用游标之前，必须先进行声明
open：一旦声明了游标，就必须打开游标
对于填有数据的游标，根据需要取出检索的各行
close：在结束的时候，必须关闭游标；有的DBMS还需要释放游标

创建、打开游标

使用declare语句创建游标
使用open语句进行打开

-- 创建游标
declare CustCursor cursor
for 
select * from Customers 
where cust_email is null;

-- 打开游标
open cursor CustCurosr;

访问游标数据

访问游标数据使用的关键字是fetch，功能：

检索哪些行
从何处开始检索
将检索的结果置于何处

闭游标

关闭游标的关键词是close。游标一旦关闭，如果不再次打开，将无法使用；第二次使用的时候，不需要声明，直接open即可

close Custcursor

Python操作游标

连接数据库

使用的是pymysql模块，需要先进行导入

import pymysql

host：主机名或者IP地址
port：默认是3306
user：用户名
passwd：user账户登录mysql的密码
db：创建的数据库
charset：防止中文出错，编码格式设置为charset="utf8"

使用模块的connect()方法进行连接

import pymysql
conn = pymysql.connect(host=“localhost”,  # 主机名
                       port=3306,  # 端口
                       user="root",  # 用户名
                       passwd="123456",   # 密码
                       db="bookdb",   # 数据库名字
                       charset="utf8")  # 指定字符集

操作数据库

Python建立了和数据库的连接，实际上就是建立了一个pymysql.connect()的实例对象，或者称之为连接对象。 Python就是通过连接对象和数据库进行对话。pymysql.connect()实例对象的方法有：

commit：提交数据
rollback：如果有权限，取消当前的操作，否则会报错
cursor([cursorclass])：返回连接的游标对象，执行SQL语句
close()：关闭连接

游标对象cur的操作方法

名称	描述
close	关闭游标
execute	执行一条SQL语句，可以带上参数；执行之后需要conn.commit()，数据库中才会真正建立
fetchone	返回一条语句
fetchall	返回所有的语句
fetchmany	返回many条语句
nextset()	移动到下一个结果

插入

import pymysql    # 导入模块
conn = pymysql.connect(host=“localhost”,  # 建立python和数据库的连接
                       port=3306, 
                       user="root", 
                       passwd="123456", 
                       db="bookdb", 
                       charset="utf8")      
cur = conn.cursor()  # 建立游标对象cur
cur.execute("insert into users (username, passwd, email) values (%s,  %s, %s)", ("python", "123456", "python@gmail.com"))   
conn.commit()  # 需要再执行conn.commit()

# 同时执行插入多条信息：多条信息用元组的形式表示
cur.executemany("insert into users (username, passwd, email) values (%s,  %s, %s)", (("python", "123456", "python@gmail.com"), ("java", "456789", "java@gmail.com"), ("php", "123789", "php@gmail.com")))
conn.commit()  # 需要再执行conn.commit()

查询

>>cur.execute("select * from users")
>>lines = cur.fetchall()   # 返回所有的查询结果
>>for line in lines:   # 遍历返回所有的结果
    print(line)
    
# 只想返回一条结果
>>cur.execute("select * from users where id=1")  # 查询id=1

>>cur.execute("select * from users")
>>cur.fetchone()   # 返回一条结果；游标会跟着移动，直到将所有的数据取完
>>cur.fetchone() 
>>cur.fetchone()

游标移动scroll到指定位置
操作存储在内存中的对象时候游标会移动，可以指定游标到某个位置：

>>cur.scroll(2)  # 相对于当前位置移动2个单位
>>cur.fetchone()  # 显示数据
>>cur.scroll(2, "absolute")   # 加上参数，实现“绝对移动”，到第三条

绝对移动的数字不能是负数，相对移动可以是负数

Python的连接对象的游标方法中提供一个参数，将读取到的数据保存成字典形式：

>>cur = conn.cursor(pymysql.cursors.DictCursor)
>>cur.execute("select * from users")
>>conn.commit()  # 需要再执行conn.commit()
>>cur.fetchall()

更新

>>cur.execute("update users set username=s% where id=2", ("mypython"))   # 更新第二条语句
>>cur.execute("select * from users where id=2")
>>conn.commit()  # 需要再执行conn.commit()
>>cur.fetchone()

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2019-10-12，如有侵权请联系 cloudcommunity@tencent.com 删除

python