一、准备数据
1、创建数据表
2、插入数据
二、SQL演练
1. SQL语句的强化
查询类型cate_name为 '超极本' 的商品名称、价格
selectname,pricefromgoodswherecate_name ='超级本';
显示商品的种类
selectcate_namefromgoodsgroupbycate_name;
求所有电脑产品的平均价格,并且保留两位小数
selectround(avg(price),2)asavg_pricefromgoods;
显示每种商品的平均价格
selectcate_name,avg(price)fromgoodsgroupbycate_name;
查询每种类型的商品中 最贵、最便宜、平均价、数量
selectcate_name,max(price),min(price),avg(price),count(*)fromgoodsgroupbycate_name;
查询所有价格大于平均价格的商品,并且按价格降序排序
查询每种类型中最贵的电脑信息
2. 创建 "商品分类"表
查询goods表中商品的种类
selectcate_namefromgoodsgroupbycate_name;
将分组结果写入到goods_cates数据表
insertintogoods_cates (name)selectcate_namefromgoodsgroupbycate_name;
3. 同步表数据
通过goods_cates数据表来更新goods表
updategoodsasginnerjoingoods_catesascong.cate_name=c.namesetg.cate_name=c.id;
4. 创建 "商品品牌表" 表
通过create...select来创建数据表并且同时写入记录,一步到位
5. 同步数据
通过goods_brands数据表来更新goods数据表
updategoodsasginnerjoingoods_brandsasbong.brand_name=b.namesetg.brand_name=b.id;
6. 修改表结构
查看 goods 的数据表结构,会发现 cate_name 和 brand_name对应的类型为 varchar 但是存储的都是数字
desc goods;
通过alter table语句修改表结构
altertablegoodschangecate_name cate_idintunsignednotnull,changebrand_name brand_idintunsignednotnull;
7. 外键
分别在 goods_cates 和 goods_brands表中插入记录
在 goods 数据表中写入任意记录
查询所有商品的详细信息 (通过内连接)
查询所有商品的详细信息 (通过左连接)
如何防止无效信息的插入,就是可以在插入前判断类型或者品牌名称是否存在呢? 可以使用之前讲过的外键来解决
外键约束:对数据的有效性进行验证
关键字: foreign key,只有 innodb数据库引擎 支持外键约束
对于已经存在的数据表 如何更新外键约束
如何在创建数据表的时候就设置外键约束呢?
注意: goods 中的 cate_id 的类型一定要和 goods_cates 表中的 id 类型一致
如何取消外键约束
在实际开发中,很少会使用到外键约束,会极大的降低表更新的效率
三、Python 中操作 MySQL 步骤
1、引入模块
在py文件中引入pymysql模块
frompymysqlimport*
2、Connection 对象
用于建立与数据库的连接
创建对象:调用connect()方法
conn=connect(参数列表)
参数host:连接的mysql主机,如果本机是'localhost'
参数port:连接的mysql主机的端口,默认是3306
参数database:数据库的名称
参数user:连接的用户名
参数password:连接的密码
参数charset:通信采用的编码方式,推荐使用utf8
对象的方法
close()关闭连接
commit()提交
cursor()返回Cursor对象,用于执行sql语句并获得结果
3、Cursor对象
用于执行sql语句,使用频度最高的语句为select、insert、update、delete
获取Cursor对象:调用Connection对象的cursor()方法
cs1=conn.cursor()
对象的方法
close()关闭
execute(operation [, parameters ])执行语句,返回受影响的行数,主要用于执行insert、update、delete语句,也可以执行create、alter、drop等语句
fetchone()执行查询语句时,获取查询结果集的第一个行数据,返回一个元组
fetchall()执行查询时,获取结果集的所有行,一行构成一个元组,再将这些元组装入一个元组返回
对象的属性
rowcount只读属性,表示最近一次execute()执行后受影响的行数
connection获得当前连接对象
四、增删改查
1、增删改
2、查询一行数据
3、查询多行数据
五、参数化
sql语句的参数化,可以有效防止sql注入
注意:此处不同于python的字符串格式化,全部使用%s占位