pymysql操作mysql数据库的方法(pymysql连接mysql)奔走相告

随心笔谈2年前发布 编辑
139 0
🌐 经济型:买域名、轻量云服务器、用途:游戏 网站等 《腾讯云》特点:特价机便宜 适合初学者用 点我优惠购买
🚀 拓展型:买域名、轻量云服务器、用途:游戏 网站等 《阿里云》特点:中档服务器便宜 域名备案事多 点我优惠购买
🛡️ 稳定型:买域名、轻量云服务器、用途:游戏 网站等 《西部数码》 特点:比上两家略贵但是稳定性超好事也少 点我优惠购买



目录前言1、pymysql.connent2、conn.cursor()3、cursor.execute()4、cursor.executemany()5、cursor.fetchone()6、cursor.scroll()7、cursor.fetchmany()8、cursor.fetchall()9、cursor.lastrowid()10、今日练习

本篇博客主要讲的是一些基础的pymysql操作mysql数据库的方法,如果有不足之处,欢迎各位指正

用法:创建链接

语法:conn=pymysql.connect(host=‘127.0.0.1’, port=端口号, user=‘数据库用户名’, passwd=‘密码’, db=‘数据库名’)

conn=pymysql.connect(host=’127.0.0.1′,
port=3306, user=’root’, passwd=’@123456′, db=’db4′)

用法:创建光标

cursor=conn.cursor()

游标设置为字典类型

# 游标设置为字典类型
cursor=conn.cursor(“cursor”=pymysql.cursors.DictCursor)

栗子:
sql=”select * from department;”
# 执行sql语句的函数,使用下面函数进行拼接,防止SQL注入
cursor.execute(sql)
# cursor.scroll(1,mode=’relative’)
result=cursor.fetchone()
print(result)
输出结果:
{‘id’: 1, ‘title’: ‘财务’}

用法:执行sql语句

cursor.execute(sql)

用法:批量执行sql语句

cursor.executemany(sql,[(‘销售’), (‘经理’)])

用法:SQL执行select默认只是拿一个结果,多次执行该语句可以依次向下拿数据

import pymysql
# 创建链接,跟socket服务类似
conn=pymysql.connect(host=’127.0.0.1′, port=3306,
user=’root’, passwd=’@123456′, db=’db4′)
# 创建游标(相当与创建一个拿数据的手)
cursor=conn.cursor()
# 创建要执行的SQL语句
sql=”select * from department;”
# 执行sql语句的函数,使用下面函数进行拼接,防止SQL注入
cursor.execute(sql)
result=cursor.fetchone()
print(result)
result=cursor.fetchone()
print(result)
result=cursor.fetchone()
print(result)
# 关闭链接
cursor.close()
conn.close()
·
输出结果:
(1, ‘财务’)
(2, ‘公关’)
(3, ‘测试’)

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

cursor.scroll(1,mode=‘relative’) # 相对当前位置移动cursor.scroll(2,mode=‘absolute’) # 相对绝对位置移动

表结构:

在这里插入图片描述

栗子:

1、
cursor.execute(sql)
result=cursor.fetchone()
print(result)
输出结果:
(1, ‘财务’)
2、
cursor.execute(sql)
cursor.scroll(1,mode=’absolute’)
result=cursor.fetchone()
print(result)
输出结果:
(2, ‘公关’)
3、
cursor.execute(sql)
cursor.scroll(1,mode=’relative’)
result=cursor.fetchone()
print(result)
输出结果:
(2, ‘公关’)

用法:可以设置返回值的个数cursor.fetchmany(num)

cursor.execute(sql)
# cursor.scroll(1,mode=’relative’)
# result=cursor.fetchone()
# print(result)
result=cursor.fetchmany(2)
print(result)
输出结果:
((1, ‘财务’), (2, ‘公关’))

用法:顾名思义就是拿到所有的结果

sql=”select * from department;”
# 执行sql语句的函数,使用下面函数进行拼接,防止SQL注入
cursor.execute(sql)
# cursor.scroll(1,mode=’relative’)
# result=cursor.fetchone()
# print(result)
# result=cursor.fetchmany(2)
# print(result)
result=cursor.fetchall()
print(result)
输出结果:
((1, ‘财务’), (2, ‘公关’), (3, ‘测试’), (4, ‘运维’), (5, ‘销售’))

用法:获取新创建数据自增ID,如果新增加了多条数据只返回最后插入的那条数据的自增id

PS:如果只想一个一个拿id只能够一个一个插入?

sql=”insert into department(title) values(%s)”

cursor.executemany(sql,[(‘经理’)])
# 获取插入值的自增id
print(cursor.lastrowid)
# 将执行的结果提交到表中,否则表不会发生变换
conn.commit()
输出结果:
6

题目要求:

练习:

    权限管理

        权限表:

            1、订单管理

            2、用户管理

            3、菜单管理

            4、权限分配

            5、Bug管理

        用户表:

            1、蔡徐坤

            2、鸡哥

            3、坤哥

        用户关系权限表:

            1    1

            1    2

            2    1

Python实现:

    某个用户登入后,可以查看自己的所有权限

题目答案:

【1、创建权限表】

CREATE TABLE power (
pid INT auto_increment PRIMARY KEY,
purview CHAR(10)
)ENGINE=INNODB DEFAULT CHARSET=utf8;

【2、创建用户表】
CREATE TABLE users (
uid INT auto_increment PRIMARY KEY,
username CHAR(10)
)ENGINE=INNODB DEFAULT CHARSET=utf8;

【3、创建用户权限关系表】
CREATE TABLE use_pow (
upid INT auto_increment PRIMARY KEY,
power_id INT,
user_id INT,
UNIQUE uq_pid_uid(power_id, user_id),
CONSTRAINT fk_pow FOREIGN KEY (power_id) REFERENCES power(pid),
CONSTRAINT fk_user FOREIGN KEY (user_id) REFERENCES users(uid)
)ENGINE=INNODB DEFAULT CHARSET=utf8;

py文件:
import pymysql
user=input(‘请输入用户名称>>>’)
# 连接数据库
conn=pymysql.connect(host=’127.0.0.1′, port=3306,
user=’root’, passwd=’@123456′, db=’db_grant’)

# 创建光标
cursor=conn.cursor()

# 查询是否存在该用户
sql=”SELECT uid FROM users WHERE username=%(u)s”

cursor.execute(sql, {‘u’: user})
# 获取到用户的id
uid=cursor.fetchone()
# print(uid[0], type(uid[0]))
if uid:
# 这里的%s如果换成%d就会报错因为execute无论传入什么类型都要用%s来占位
sql2=”SELECT purview from power WHERE pid in
(SELECT power_id FROM use_pow WHERE user_id=%s)”
cursor.execute(sql2, uid[0])
result=cursor.fetchall()
print(result)
else:
print(“没有该用户”)
cursor.close()
conn.close()

到此这篇关于pymysql简单操作mysql数据库的方法的文章就介绍到这了,更多相关pymysql操作mysql数据库内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

您可能感兴趣的文章:python?实现?pymysql?数据库操作方法python pymysql链接数据库查询结果转为Dataframe实例使用pymysql查询数据库,把结果保存为列表并获取指定元素下标实例python数据库操作mysql:pymysql、sqlalchemy常见用法详解在python中使用pymysql往mysql数据库中插入(insert)数据实例Python使用pymysql从MySQL数据库中读出数据的方法python3.6使用pymysql连接Mysql数据库

© 版权声明

相关文章