首页 > 数据库 >连表操作、子查询、pymysql 模块、sql注入问题(感觉已没有)

连表操作、子查询、pymysql 模块、sql注入问题(感觉已没有)

时间:2024-05-19 18:51:24浏览次数:22  
标签:cursor emp1 pymysql 连表 dep1 sql id select

【连表操作】

 1 建表
 2 create table dep1(
 3     id int,
 4     name varchar(20)
 5     );
 6 create table emp1(
 7     id int primary key auto_increment,
 8     name varchar(20),
 9     sex enum('male','female') not null default 'male',
10     age int,
11     dep_id int
12     );
13 
14 
15 插入数据
16     insert into dep1 values
17     (200,'技术'),
18     (201,'人力资源'),
19     (202,'销售'),
20     (203,'运营');
21 
22 insert into emp1(name,sex,age,dep_id) values
23 ('jason','male',18,200),
24 ('egon','female',48,201),
25 ('kevin','male',18,201),
26 ('nick','male',28,202),
27 ('owen','male',18,203),
28 ('jerry','female',18,204);
29 
30 select * from dep1;
31 select * from emp1;
32 
33 ----------------------------------------------操作
34 1.查询jason这个人的部门名称
35     拼表操作:
36     select * from dep1,emp1;     将两张表拼成一张表,结果叫:笛卡尔积
37     或是
38     select * from emp1,dep1 where emp1.dep_id=dep1.id;
39 
40 MySQL在后面查询数据的过程中,肯定会经常用到拼表操作
41 所以特地开始了对应的方法:
42 *********************************重要
43     inner join: 内连接
44     left join:  左连接
45     right join: 右连接
46     union:      全连接
47 
48 
49 使用场景
50 inner join:内连接             on依据
51     select * from emp1 inner join dep1 on dep1.id=emp1.dep_id;
52     但这时候发现,有数据丢失,原因是,内连接,只拼接两张表共有的数据部分
53 
54 left join:左连接
55     select * from emp1 left join dep1 on dep1.id=emp1.dep_id;
56     左边的表所有的数据都展示出来,没有对应的项就用null填充
57 
58 right join:右连接
59     select * from emp1 right join dep1 on dep1.id=emp1.dep_id;
60     右边的表所有的数据都展示出来,没有对应的项就用null填充,(但是我的显示数据丢失)
61 
62 union:       全连接,左右两个表所有的数据都展示出来
63     select * from emp1 left join dep1 on dep1.id=emp1.dep_id
64     union
65     select * from emp1 right join dep1 on dep1.id=emp1.dep_id;

【子查询】

子查询就是我们平时解决问题的思路
    分步骤解决问题
    第一步........
    第二步........
将一个查询语句的结果当作另外一个查询语句的条件取使用

1.查询部门是技术部门或者是人力字段的员工信息
    1).获取部门的id号
    2).再去员工表里面筛选出对应的员工
    select id from dep1 where name='技术' or name='人力资源';
    select name from emp1 where dep1_id in (200,201);

精简写法:
    select * from emp1 where dep_id in (select id from dep1 where  name='技术' or name='人力资源');

总结:
    表的查询结果可以作为其他表的查询条件,也可以通过起别名的方式把它当作一个虚拟表根其他表关联
    多表查询就两种方式:1.先拼接表再查询 2.子查询一步一步来


------------------------------------------------------
练习
查询平均年龄在25岁以上的部门名称
只要涉及到多表查询,就有两种思路:
方式一:连表操作
先拿到部门和员工表,拼接之后的结果
得出需要进行分组
select dep1.name from emp1 inner join dep1 on emp1.dep_id=dep1.id
group by dep1.name
having avg(age)>25;

2.子查询
select name from dep1 where id in (
select dep_id from emp1 group by dep_id
having avg(age)>25
);

3.关键字 exists
只返回T or N
返回T的时候外层查询语句执行
返回F的时候外层查询语句不执行
select * from emp1 where exists (
select * from dep1 where id>3);

select * from emp1 where exists (
select * from dep1 where id>300); (后面不执行)

【python操作数据库pymysql】

基本使用

安装
    pip3 install pymysql

创建文件名不要和模块名一样

import pymysql

# 连接数据库
conn = pymysql.connect(
    host='127.0.0.1',
    user='root',
    password='199721',
    charset='utf8',  # 不要加 -
    port=3306,
    database='day4')

cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)  # 产生一个游标对象,来帮我们执行命令的
# cursor=pymysql.cursor.DictCursor # 查询结果以字典的形式返回

sql = 'select * from teacher'
res = cursor.execute(sql)
# print(res)  # execute返回的是当前sql语句所影响的行数,该返回值我们一般不用
# 获取命令执行的查询结果
print(cursor.fetchone())  # 只拿一条,并打印第一个元素{'id': 100, 'cl_name': '高三1班 '}
print(cursor.fetchmany(2))  # 可以指定拿几条
print(cursor.fetchall())  # 读取所有的数据
cursor.scroll(1, 'relative')  # 相对于光标所在的位置继续往后移动1位
cursor.scroll(1, 'absolute')  # 相对于数据的开头位置继续往后移动1位
conn.close()  # 关闭连接

===================================

 1 pymysql操作数据库
 2 
 3 增删改查
 4 
 5 #  1. pymysql操作数据库的增删改查
 6 import pymysql
 7 
 8 conn = pymysql.connect(
 9     host='127.0.0.1',
10     user='root',
11     password='199721',
12     charset='utf8',
13     port=3306,
14     database='day4')
15 
16 cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)  # 产生一个游标对象,来帮我们执行命令的
17 
18 # 增
19 sql = 'insert into user(name,password) values(%s,%s)'
20 rows = cursor.execute(sql, ('jackson', 1234))  # 放的是元组
21 # rows=cursor.executemany(sql,[('jason',123456),('jason2',123456),('jason3',123456)])  # 列表套元组
22 print(rows)  # 到这里其实没有增加
23 conn.commit()  # 我们需要确认
24 
25 
26 # 修改
27 sql = 'update user set name="jasonNB" where id=1'
28 rows = cursor.execute(sql)
29 print(rows)  # 在表中还是没有修改
30 conn.commit()  # 确认
31 
32 # 删
33 sql = 'delete from user where id=1'
34 rows = cursor.execute(sql)
35 print(rows)  # 也没有用
36 conn.commit()  # 确认
37 
38 
39 # 查
40 sql = 'select * from user'
41 rows = cursor.execute(sql)
42 print(rows)  # 有
43 
44 # 增删改查中,查的结果是返回一个数字,表示影响的行数,其他操作返回的数字表示操作的行数
45 # 需要二次确认,才能增删改

------------------------------------------------------------------------------

(在pymysql模块中如何调用存储过程)

 1 import pymysql
 2 
 3 conn = pymysql.connect(
 4     host='127.0.0.1',
 5     user='root',
 6     password='199721',
 7     charset='utf8',
 8     port=3306,
 9     database='day4')
10 
11 cursor = conn.cursor(pymysql.cursors.DictCursor)
12 # # 调用存储过程
13 # cursor.callproc('proc_test', [1, 2])
14 # print(cursor.fetchall())
15 cursor.execute('select * from user')
16 print(cursor.fetchall())

 

【sql注入问题及解决办法】

SQL语言主要用于存取数据、查询数据、更新数据和管理关系数据库系统,SQL语言由IBM开发。

SQL语言分为3种类型:

  1、DDL语句 数据库定义语言: 数据库、表、视图、索引、存储过程,例如CREATE DROP ALTER

  2、DML语句 数据库操纵语言: 插入数据INSERT、删除数据DELETE、更新数据UPDATE、查询数据SELECT

  3、DCL语句 数据库控制语言: 例如控制用户的访问权限GRANT、REVOKE

sql注入: 利用现有的程序,将恶意的sql命令注入到后台的数据库引擎执行的能力 像符号--会注释掉之后的sql,根本 原理就是字符串的拼接name=‘%s' 原生sql中让execute帮做拼接就可以,django的orm种就不会存在这个问题

 1 import pymysql
 2 
 3 conn = pymysql.connect(
 4     host='127.0.0.1',
 5     user='root',
 6     password='199721',
 7     charset='utf8',
 8     port=3306,
 9     database='day4')
10 
11 cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)  # 产生一个游标对象,来帮我们执行命令的
12 username = input('请输入用户名:')
13 password = input('请输入密码:')
14 sql = "select* from user where name='%s' and password='%s'"%(username,password)
15 rows = cursor.execute(sql)
16 if rows:
17     print('登录成功')
18     print(cursor.fetchall())
19 else:
20     print('用户名或密码错误')
21 
22 ---------------------------------------------
23 上述输入密码账号看似没有问题,但是当我们不输入密码的时候,提示我们也能登录成功,其实这就是sql注入问题
24 解决办法
25 
26 sql = "select * from user where name=%s and password=%s"
27 # 不要手动拼接数据,先用%s占位,然后将需要拼接的数据直接交给execute方法即可
28 rows = cursor.execute(sql, (username, password))
29 # 自动识别sql里面的%s,然后将数据替换进去
30 if rows:
31     print('登录成功')
32 else:
33     print('用户名或密码错误')
34 
35 ----------------------------------------------
36 PS:2024.5.19我重新测试了sql注入问题,发现这个漏洞已经解决了,不知道是我测试方法不对还是什么

【connect中一些参数的意思】

 1 conn = pymysql.connect(
 2     host='127.0.0.1',
 3     user='root',   %
 4     password='199721',
 5     charset='utf8',
 6     port=3306,
 7     database='day4')
 8 
 9 host:代表地址,
10 user:登录mysql 的用户名,
11 password:登录mysql 的密码,
12 charser:代表编码格式,
13 port:端口号,常规的很多都是3306也有自定义,
14 database:数据库名称

 

标签:cursor,emp1,pymysql,连表,dep1,sql,id,select
From: https://www.cnblogs.com/liuliu1/p/18200597

相关文章

  • net.sf.jsqlparser.schema.Column.withColumnName(Ljava/lang/String;)Lnet/sf/jsqlpar
    https://blog.csdn.net/yuanzhugen/article/details/133648431 SpringBoot整合mybatisplus报错:net.sf.jsqlparser.schema.Column,isavailablefromthefollowinglocationsAnattemptwasmadetocallthemethodnet.sf.jsqlparser.schema.Column.withColumnName(Ljava/l......
  • 快速理解MySQL null的10大坑
    创建表时应当设置notnull,添加一个默认值0或''去替代null。sum('field')的坑若一列的所有值都是null,那么sum函数的结果不是0,而是null,所以可能会因为值的类型兼容问题,出现意料之外的情况。null值会有NPE问题。count('field')的坑有null的列,count不会+1。where('field')的坑n......
  • mysql 统一修改字符集和字段属性
    --修改表字符集SELECTCONCAT("ALTERTABLE`",TABLE_NAME,"`CONVERTTOCHARACTERSETutf8mb4COLLATEutf8mb4_general_ci;")AStarget_tablesFROMINFORMATION_SCHEMA.TABLESWHERETABLE_SCHEMA="uat-zpg"ANDTABLE_TYPE="BASETABLE&q......
  • MySQL的索引优化
    一、索引的使用场景1、全值匹配通过主键索引查询mysql>explainselect*fromt_goodswhereid=1\G;***************************1.row***************************id:1select_type:SIMPLEtable:t_goodspartitions:NULLtyp......
  • java+mybatis+easyExcel快速导入excel数据到MySQL
    这里有一些数据需要导入数据库。demo地址:importExcel使用步骤如下:一、修改database相关内容 1.修改application.properties文件中数据库地址及信息二、新建实体类1.新建excel数据所符合的实体类,这里举例Excel中有如下数据,表头字段为“username”。数据......
  • Mysql新建日历表
    新建最近几十年的天 CREATETABLEifnotexistscalendar(account_daydate);INSERTINTOcalendar(account_day)SELECTDATE_ADD('2024-01-01',INTERVALnDAY)FROM(SELECTa.N+b.N*10+c.N*100+d.N*1000ASnFROM(SELECT0ASNUNIONSELECT1......
  • F-logic_DataCube3存在SQL注入漏洞(CVE-2024-31750)
    漏洞描述该漏洞是一个影响F-logicDataCube3v1.0的SQL注入漏洞,这个漏洞源于'req_id'参数的用户输入没有得到适当的清理或过滤。通过在'req_id'参数中注入恶意的SQL代码,远程攻击者可以执行任意SQL命令,从而可能访问、修改或删除数据库中的敏感信息Fofa:title=="DataCube3"POC:P......
  • MySQL精度问题-hekui
    一、MySQL中datetime类型怎么处理毫秒MySQL中datetime日期类型,默认是精确到秒的。从MySQL5.6.4版本开始,可以设置精度,如datetime(3)表示精确到毫秒类型说明插入时赋值DB实际存储datetime(0)或datetime精确到秒2024-05-1900:00:00:4992024-05-1900:00:00:500202......
  • mysql5.7 报错:[ERROR] InnoDB: Ignoring the redo log due to missing MLOG_CHECKPOIN
    mysql5.7启动报错:2024-05-19T02:02:14.453082Z0[Warning]TIMESTAMPwithimplicitDEFAULTvalueisdeprecated.Pleaseuse--explicit_defaults_for_timestampserveroption(seedocumentationformoredetails).2024-05-19T02:02:14.453139Z0[Note]--secure-file......
  • SQL教程
    SELECT语句--Websites:+----+--------------+---------------------------+-------+---------+|id|name|url|alexa|country|+----+--------------+---------------------------+-------+---------+|1|Google|https:/......