美文网首页
MySQL与Python交互

MySQL与Python交互

作者: BJ000 | 来源:发表于2019-12-03 11:48 被阅读0次

    一、准备数据

    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占位

    相关文章

      网友评论

          本文标题:MySQL与Python交互

          本文链接:https://www.haomeiwen.com/subject/qblcgctx.html