推荐文章:
Liunx系列:
2、Linux进阶命令 任务编程系列:
前端技术:
数据库技术:
将查询结果插入到其它表中
1、思考
目前只有一个goods表,我们想要增加一个商品分类信息,比如:移动设备这个分类信息,只通过goods表无法完成商品分类的添加,那么如何实现添加商品分类信息的操作?
答案:
2、创建商品分类表
create table good_cates(
id int not null primary key auto_increment;
name varchar(50) not null;
);
3、把goods表中的商品分类添加到商品分类表
-- 查询goods表中商品的分类信息
select cate_name from goods group by cate_name;
-- 将查询结果插入到good_cates表中
insert into good_cates(name) select cate_name from goods group by cate_name;
-- 添加移动设备分类信息
insert into good_cates(name) values('移动设备');
说明:
4、小结
使用连接更新表中某个字段数据
1、更新goods表中的商品分类信息
上一节创建了一个商品分类表(good_cates),并且完成了商品分类信息的插入,现在需要更新goods表中的商品分类信息,把商品分类名称改成商品分类id。
接下来实现第二步操作:
-- 查看goods表中的商品分类名称对应的商品分类id
select * from goods inner join good_cates on goods.cate_name = good_cates.name;
-- 把该语句中from 后的语句理解为一张虚表
update goods g inner join good_cates gc on g.cate_name=gc.name set g.cate_name=gc.id;
2、小结
创建表并给某个字段添数据
1、上一节完成了商品分类表(good_cate)的创建和商品分类信息的添加以及把商品表(goods)中的商品分类名称改成了对应的商品分类id,加入我们想添加一个品牌,比如:双飞燕这个品牌信息,只通过goods表无法完成品牌信息的添加,那么如何实现添加品牌信息呢?
答案:
2、创建品牌表
-- 查询品牌信息
select brand_name from goods group by brand_name;
-- 通过create table ...select来创建数据表并且同时插入数据
-- 创建商品分类表,注意: 需要对brand_name 用as起别名,否则name字段就没有值
create table good_brands (
id int unsigned primary key auto_increment,
name varchar(40) not null) select brand_name as name from goods group by brand_name;
说明:
3、更新goods表中的品牌信息
-- 将goods表中的品牌名称更改成品牌表中对应的品牌id
update goods as g inner join good_brands gb on g.brand_name = gb.name set g.brand_name = gb.id;
4、小结
修改goods表结构
1、修改goods表结构
目前我们已经把good表中的商品分类和品牌信息已经更改成了商品分类id和品牌id,接下来需要把cate_name和brand_name字段分别改成cate_id和brand_id字段,类型都改成int类型
-- 查看表结构
desc goods;
-- 通过alter table语句修改表结构
alter table goods change cate_name cate_id int not null, change brand_name brand_id int not null;
说明:
2、小结
PyMySQL的使用
1、思考
如何实现将100000条数据插入到MySQL数据库
答案:
如果使用之前学习的MySQL客户端来完成这个操作,那么这个工作量无疑是巨大的,我们可以通过使用程序代码的方式去连接MySQL数据库,然后对MySQL数据库进行增删改查的方式,实现10000条数据的插入,像这样使用代码的方式操作数据库就称为数据库编程。
2、Python程序操作MySQL数据库
安装pymysql第三方包:
sudo pip3 install pymysql
说明:
pymysql的使用:
1.导入pymysql包
import pymysql
2、创建连接对象
调用pymysql模块中的connect()函数来创建连接对象,代码如下:
conn=connect(参数列表)
* 参数host:连接的mysql主机,如果本机是'localhost'
* 参数port:连接的mysql主机的端口,默认是3306
* 参数user:连接的用户名
* 参数password:连接的密码
* 参数database:数据库的名称
* 参数charset:通信采用的编码方式,推荐使用utf8
连接对象操作说明:
3.获取游标对象
获取游标对象的目标就是要执行sql语句,完成对数据库的增、删、改、 查操作。代码如下:
# 调用连接对象的cursor()方法获取游标对象
cur =conn.cursor()
游标操作说明:
4.pymysql完成数据的查询操作
import pymysql
# 创建连接对象
conn = pymysql.connect(host='localhost', port=3306, user='root', password='mysql',database='python', charset='utf8')
# 获取游标对象
cursor = conn.cursor()
# 查询 SQL 语句
sql = "select * from students;"
# 执行 SQL 语句 返回值就是 SQL 语句在执行过程中影响的行数
row_count = cursor.execute(sql)
print("SQL 语句执行影响的行数%d" % row_count)
# 取出结果集中一行数据, 例如:(1, '张三')
# print(cursor.fetchone())
# 取出结果集中的所有数据, 例如:((1, '张三'), (2, '李四'), (3, '王五'))
for line in cursor.fetchall():
print(line)
# 关闭游标
cursor.close()
# 关闭连接
conn.close()
5.pymysql完成对数据的增删改
# -*- codeing = utf-8 -*-
# @Time : 2021/12/16 8:34 上午
# @Author : 李明辉
# @File : ithui_对数据库的增删改.py
# @Software : PyCharm
# 1、导包
import pymysql
if __name__ == '__main__':
# 2、创建连接对象
# connect = Connection = Connect 本质上是一个函数,使用这三个里面的任意一个函数都以创建一个连接对象
# 1、host:服务器主机地址
# 2、port:mysql数据库的端口号
# 3、user:用户名
# 4、password:密码
# 5、database:操作的数据库
# 6、charset:操作数据库的使用编码格式
conn = pymysql.connect(host="localhost",
port=3306,
user="root",
password="LI1944575687",
database="python1",
charset="utf8")
# 3、获取游标,目的就是要执行sql语句
cursor = conn.cursor()
# 准备sql
# 对数据表完成添加、删除、修改操作,需要把修改的数据提交到数据库
# sql = "insert into classes(name) values('python50');"
# sql = "update classes set name = 'python45' where id=5;"
sql = "delete from classes where id=5;"
try:
# 4、执行sql语句
cursor.execute(sql)
# 提交修改的数据到数据库
conn.commit()
except Exception as e:
# 对修改的数据进行撤销,表示数据回滚
conn.rollback()
finally:
# 5、关闭游标
cursor.close()
# 6、关闭连接
conn.close()
说明:
6.防止SQL注入
什么是SQL注入?
用户提交带有恶意的数据与SQL语句进行字符串方式的拼接,从 而影响了SQL语句的语义,最终产生数据泄露的现象。
如何防止SQL注入?
SQL语句参数化
# -*- codeing = utf-8 -*-
# @Time : 2021/12/16 9:02 上午
# @Author : 李明辉
# @File : ithui_防止sql注入多个参数的使用.py
# @Software : PyCharm
import pymysql
if __name__ == '__main__':
# 2、创建连接对象
# connect = Connection = Connect 本质上是一个函数,使用这三个里面的任意一个函数都以创建一个连接对象
# 1、host:服务器主机地址
# 2、port:mysql数据库的端口号
# 3、user:用户名
# 4、password:密码
# 5、database:操作的数据库
# 6、charset:操作数据库的使用编码格式
conn = pymysql.connect(host="localhost",
port=3306,
user="root",
password="LI1944575687",
database="python1",
charset="utf8")
# 3、获取游标,目的就是要执行sql语句
cursor = conn.cursor()
# 准备sql
sql = "insert into students(name, age, gender, c_id) valuse(%s, %s, %s, %s);"
try:
# 4、执行sql语句
# 1.sql语句
# 2.执行sql语句的传入参数,参数类型可以树元组,列表,字典
name = input("请输入姓名")
age = input("请输入年龄")
gender = input("请输入性别")
c_id = input("请输入班级号")
params = [name, age, gender, c_id]
cursor.execute(sql, params)
conn.commit()
except Exception as e:
conn.rollback()
finally:
# 5、关闭游标
cursor.close()
# 6、关闭连接
conn.close()
说明:
3、小结
事物
1、事物的介绍
事务就是用户定义的一系列执行SQL语句的操作, 这些操作要么完全地执行,要么完全地都不执行, 它是一个不可分割的工作执行单元。
事务的使用场景:
在日常生活中,有时我们需要进行银行转账,这个银行转账操作背后就是需要执行多个SQL语句,假如这些SQL执行到一半突然停电了,那么就会导致这个功能只完成了一半,这种情况是不允许出现,要想解决这个问题就需要通过事务来完成。
2、事物的四大特性
原子性:
一个事务必须被视为一个不可分割的最小工作单元,整个事务中的所有操作要么全部提交成功,要么全部失败回滚,对于一个事务来说,不可能只执行其中的一部分操作,这就是事务的原子性
一致性:
数据库总是从一个一致性的状态转换到另一个一致性的状态。(在前面的例子中,一致性确保了,即使在转账过程中系统崩溃,支票账户中也不会损失200美元,因为事务最终没有提交,所以事务中所做的修改也不会保存到数据库中。)
隔离性:
通常来说,一个事务所做的修改操作在提交事务之前,对于其他事务来说是不可见的。(在前面的例子中,当执行完第三条语句、第四条语句还未开始时,此时有另外的一个账户汇总程序开始运行,则其看到支票帐户的余额并没有被减去200美元。)
持久性:
一旦事务提交,则其所做的修改会永久保存到数据库。
说明:
事务能够保证数据的完整性和一致性,让用户的操作更加安全。
3、事务的使用
在使用事务之前,先要确保表的存储引擎是 InnoDB 类型, 只有这个类型才可以使用事务,MySQL数据库中表的存储引擎默认是 InnoDB 类型。
表的存储引擎说明:
表的存储引擎就是提供存储数据一种机制,不同表的存储引擎提供不同的存储机制。
汽车引擎效果图:
说明:
查看MySQL数据库支持的表的存储引擎:
-- 查看MySQL数据库支持的表的存储引擎
show engines;
说明:
查看goods表的创表语句:
-- 选择数据库
use jing_dong;
-- 查看goods表
show create table goods;
mysql root@(none):jing_dong> show create table goods;
+-------+--------------------------------------------------------+
| Table | Create Table |
+-------+--------------------------------------------------------+
| goods | CREATE TABLE `goods` ( |
| | `id` int(10) unsigned NOT NULL AUTO_INCREMENT, |
| | `name` varchar(150) NOT NULL, |
| | `cate_id` int(10) unsigned NOT NULL, |
| | `brand_id` int(10) unsigned NOT NULL, |
| | `price` decimal(10,3) NOT NULL DEFAULT '0.000', |
| | `is_show` bit(1) NOT NULL DEFAULT b'1', |
| | `is_saleoff` bit(1) NOT NULL DEFAULT b'0', |
| | PRIMARY KEY (`id`) |
| | ) ENGINE=InnoDB AUTO_INCREMENT=25 DEFAULT CHARSET=utf8 |
+-------+--------------------------------------------------------+
说明:
开启事务:
begin;
或者
start transaction;
说明:
提交事务:
将本地缓存文件中的数据提交到物理表中,完成数据的更新。
commit;
回滚事务:
放弃本地缓存文件中的缓存数据, 表示回到开始事务前的状态
rollback;
事务演练的SQL语句:
begin;
insert into students(name) values('李白’);
-- 查询数据,此时有新增的数据, 注意: 如果这里后续没有执行提交事务操作,那么数据是没有真正的更新到物理表中
select * from students;
-- 只有这里提交事务,才把数据真正插入到物理表中
commit;
-- 新打开一个终端,重新连接MySQL数据库,查询students表,这时没有显示新增的数据,说明之前的事务没有提交,这就是事务的隔离性
-- 一个事务所做的修改操作在提交事务之前,对于其他事务来说是不可见
select * from students;
4、小结
索引
1、索引的介绍
索引在MySQL中也叫做“键”,它是一个特殊的文件,它保存着数据表里所有记录的位置信息,更通俗的来说,数据库索引好比是一本书前面的目录,能加快数据的查询速度。
应用场景:
当数据库中数据量很大的时候,查找数据会变得很慢,我们就可以通过索引来提高数据库的查询效率
2、索引的使用
查看表中已有索引:
show index from 表名;
说明:
索引的创建:
-- 创建索引的语法格式
-- alter table 表名 add index 索引名[可选](列名, ..)
-- 给name字段添加索引
alter table classes add index my_name (name);
说明:
索引的删除:
-- 删除索引的语法格式
-- alter table 表名 drop index 索引名
-- 如果不知道索引名,可以查看创表sql语句
show create table classes;
alter table classes drop index my_name;
3、案例 - 验证索引查询性能
创建测试表testindex:
create table test_index(title varchar(10));
向表中插入十万条数据:
from pymysql import connect
def main():
# 创建Connection连接
conn = connect(host='localhost',port=3306,database='python',user='root',password='mysql',charset='utf8')
# 获得Cursor对象
cursor = conn.cursor()
# 插入10万次数据
for i in range(100000):
cursor.execute("insert into test_index values('ha-%d')" % i)
# 提交数据
conn.commit()
if __name__ == "__main__":
main()
验证索引性能操作:
-- 开启运行时间监测:
set profiling=1;
-- 查找第1万条数据ha-99999
select * from test_index where title='ha-99999';
-- 查看执行的时间:
show profiles;
-- 给title字段创建索引:
alter table test_index add index (title);
-- 再次执行查询语句
select * from test_index where title='ha-99999';
-- 再次查看执行的时间
show profiles;
4、联合索引
联合索引又叫复合索引,即一个索引覆盖表中两个或者多个字段,一般用在多个字段一起查询的时候
-- 创建teacher表
create table teacher
(
id int not null primary key auto_increment,
name varchar(10),
age int
);
-- 创建联合索引
alter table teacher add index (name,age);
联合索引的好处:
5、联合索引的最左原则
在使用联合索引的时候,我们要遵守一个最左原则,即index(name,age)支持 name 、name 和 age 组合查询,而不支持单独 age 查询,因为没有用到创建的联合索引。
最左原则示例:
-- 下面的查询使用到了联合索引
select * from stu where name='张三' -- 这里使用了联合索引的name部分
select * from stu where name='李四' and age=10 -- 这里完整的使用联合索引,包括 name 和 age 部分
-- 下面的查询没有使用到联合索引
select * from stu where age=10 -- 因为联合索引里面没有这个组合,只有 name | name age 这两种组合
说明:
6、MySQL中索引的优点和缺点和使用原则
7、小结
END