事务

提交事务：commit; 同步数据表，表示操作成功

回滚事务：rollback; 直接清空日志表，表示操作失败

事务transaction

-- 创建一个账户

create table my_account(

id int primary key auto_increment,

number char(16) not null unique comment '账户',

name varchar(20) not null,

money decimal(10,2)default 0.0 comment '账户余额'

)charset utf8;

-- 插入数据

insert into my_account values

(null,'0000000000000001','张三',1000),

(null,'0000000000000002','李四',2000);

-- 张三转账1000元给李四

update my_account set money=money-1000 where id=1;

一、事务操作分两种：自动事务（默认）、手动事务

1）手动事务的操作流程

1> 开启事务：start transaction;

-- 事务安全

-- 开启事务

start transaction;

2> 进行事务操作

-- 事务操作：1、李四账户减少

update my_account set money=money-1000 where id=2;

-- 事务操作：2、张三账户增加

update my_account set money=money+1000 where id=1;

3> 关闭事务

提交事务：commit;同步数据表，表示操作成功

-- 提交事务

commit;

回滚事务：rollback;直接清空日志表，表示操作失败

-- 回滚事务：会清空

rollback;

二、事务操作原理：

事务开启之后，所有的操作都会临时保存到事务日志，而事务日志只有在得到commit命令才会同步到数据表，其他任何情况都会清空，比如rollback、断电、断开连接

三、回滚点

1）设置回滚点语法：savepoint 回滚点名字;

2）回到回滚点语法：rollback to 回滚点名字;

-- 设置回滚点

savepoint sp1;

-- 银行扣税

update my_account set money=money-10000*0.05 where id=2;-- 错误

-- 回滚到回滚点

rollback to sp1;

-- 继续操作

update my_account set money=money-10000*0.05 where id=1;

-- 查看结果

select * from my_account;

-- 提交结果

commit;

-- 如果要注册一个用户用户名》密码》验证码 —— 如果不注册，将全回滚用rollback

-- 如果要注册一个用户用户名》密码》验证码 —— 如果重新输入验证码，将用回滚点rollback to

回滚喝回滚点的不同

rollback ：所有操作都不要了

rollback to：回到某个回滚点之后的错误操作目标

四、自动事务处理

1）show variables like 'autocommit';

2）关闭事务自动提交：set autocommit=off/0;

关闭自动提交后，增、删、改就只能手动提交（commit）

打开事务自动提交：set autocommit=off/;——默认

-- 显示系统变量autocommit（模糊查询）

show variables like 'autocommit';

-- 关闭事务自动提交

set autocommit=0;

update my_account set money=money+10000 where id=2;

commit;

-- 打开事务自动提交

set autocommit=1；

update my_account set money=money-10000*0.05 where id=2;

五、(数据库)事务的四大特性：ACID

A：Atomic，原子性（要么都成功，要么都失败）

C：Consistency，一致性（只要开启事务，没有开启commit，另一个窗口没有影响）

I：Isolation，隔离性（两个窗口都在进行事务，互不影响）

D：Durability，持久性（只要提交了，rollback也没用）

-- 隔离性

start transaction;

-- 给张三返税，反500元

update my_account set money=money+500 where id=1;

-- （在另一个命令行输入）隔离性

start transaction;

-- （在另一个命令行输入）李四淘宝花了500元

update my_account set money=money-500 where id=2;

-- 两个命令行都可以查

select * from my_account;

rollback;

select * from my_account;

六、锁机制（有时候行锁，有时候表锁，有时候页锁）

-- 锁机制

start transaction;

update my_account set money=money+500 where name='张三';-- 整体找，直到找到所有的‘张三’

-- （在另一个命令行输入）李四+1000元

update my_account set money=money+1000 where id=2;

rollback;

准备数据

1、创建数据表

-- 创建 "京东" 数据库createdatabasejdcharset=utf8;-- 使用 "京东" 数据库usejd;-- 创建一个商品goods数据表createtablegoods(idintunsignedprimarykeyauto_incrementnotnull,namevarchar(150)notnull, cate_namevarchar(40)notnull, brand_namevarchar(40)notnull, pricedecimal(10,3)notnulldefault0, is_showbitnotnulldefault1, is_saleoffbitnotnulldefault0);

2、插入数据

-- 向goods表中插入数据insertintogoodsvalues(0,'r510vc 15.6英寸笔记本','笔记本','华硕','3399',default,default);insertintogoodsvalues(0,'y400n 14.0英寸笔记本电脑','笔记本','联想','4999',default,default);insertintogoodsvalues(0,'g150th 15.6英寸游戏本','游戏本','雷神','8499',default,default);insertintogoodsvalues(0,'x550cc 15.6英寸笔记本','笔记本','华硕','2799',default,default);insertintogoodsvalues(0,'x240 超极本','超级本','联想','4880',default,default);insertintogoodsvalues(0,'u330p 13.3英寸超极本','超级本','联想','4299',default,default);insertintogoodsvalues(0,'svp13226scb 触控超极本','超级本','索尼','7999',default,default);insertintogoodsvalues(0,'ipad mini 7.9英寸平板电脑','平板电脑','苹果','1998',default,default);insertintogoodsvalues(0,'ipad air 9.7英寸平板电脑','平板电脑','苹果','3388',default,default);insertintogoodsvalues(0,'ipad mini 配备 retina 显示屏','平板电脑','苹果','2788',default,default);insertintogoodsvalues(0,'ideacentre c340 20英寸一体电脑 ','台式机','联想','3499',default,default);insertintogoodsvalues(0,'vostro 3800-r1206 台式电脑','台式机','戴尔','2899',default,default);insertintogoodsvalues(0,'imac me086ch/a 21.5英寸一体电脑','台式机','苹果','9188',default,default);insertintogoodsvalues(0,'at7-7414lp 台式电脑 linux ）','台式机','宏碁','3699',default,default);insertintogoodsvalues(0,'z220sff f4f06pa工作站','服务器/工作站','惠普','4288',default,default);insertintogoodsvalues(0,'poweredge ii服务器','服务器/工作站','戴尔','5388',default,default);insertintogoodsvalues(0,'mac pro专业级台式电脑','服务器/工作站','苹果','28888',default,default);insertintogoodsvalues(0,'hmz-t3w 头戴显示设备','笔记本配件','索尼','6999',default,default);insertintogoodsvalues(0,'商务双肩背包','笔记本配件','索尼','99',default,default);insertintogoodsvalues(0,'x3250 m4机架式服务器','服务器/工作站','ibm','6888',default,default);insertintogoodsvalues(0,'商务双肩背包','笔记本配件','索尼','99',default,default);

-- 查询类型cate_name为'超级本的商品

select name as 商品名称,priceas 商品价格from goodswhere cate_name ='超级本';

-- 显示商品的种类

select distinct cate_namefrom goods; -- 去重

select cate_namefrom goodsgroup by cate_name;-- 分组

-- 查询每个种类的商品名称

select cate_name,group_concat(name)from goodsgroup by cate_name;

-- 求所有电脑产品的平均价格，并且保留两位小数

select round(avg(price),2)from goods;

-- 显示每种商品的平均价格

select cate_name,avg(price)from goodsgroup by cate_name;

-- 查询每种类型的商品中最贵、最便宜、平均价、数量

select cate_name,max(price),min(price),avg(price),count(*)from goodsgroup by cate_name;

-- 查询所有价格大于平均价格的商品，并且按价格降序排序

select * from goodswhere price>(select avg(price)from goods)order by pricedesc;

-- 查询每种类型中最贵的电脑信息

select cate_name,max(price)from goodsgroup by cate_name;

select * from goods;

-- 相当于两句结合起来

select * from goods

inner join

(

select

cate_name,

max(price)as max_price,

min(price)as min_price,

avg(price)as avg_price,

count(*)from goodsgroup by cate_name

)as goods_new_info

on goods.cate_name=goods_new_info.cate_nameand goods.price=goods_new_info.max_price;

select * from (select cate_name,max(price)as max_pricefrom goodsgroup by cate_name)as g_new

left join goodsas g

on g_new.cate_name=g.cate_nameand g_new.max_price=g.priceorder by g_new.cate_name;

insert into goodsvalues(0,'东哥牌电脑','笔记本','老王','4999',default,default);

-- 创建商品分类表

create table if not exists goods_cates(

id int unsigned primary key auto_increment,

name varchar(40)not null

);

-- 查询goods商品的种类

select cate_namefrom goodsgroup by cate_name;

insert into goods_cates (name)select cate_namefrom goodsgroup by cate_name;

update goodsas ginner join goods_catesas con g.cate_name=c.name set g.cate_name=c.id;

insert into goods_cates(name)values ('路由器'),('交换机'),('网卡');

insert into goods (name,cate_id,brand_id,price)

values('LaserJet Pro P1606dn 黑白激光打印机', 12, 4,'1849');

alter table goods

change cate_namecate_id int unsigned not null;

alter table goodsadd foreign key (cate_id)references goods_cates(id);-- 外键关联

delete from goodswhere id=23;

-- 创建商品品牌表

create table if not exists goods_brands(

id int unsigned primary key auto_increment,

name varchar(40)not null

);

select brand_namefrom goodsgroup by brand_name;

insert into goods_brands (name)select brand_namefrom goodsgroup by brand_name;

update goodsas ginner join goods_brandsas bon g.brand_name=b.name set g.brand_name=b.id;

alter table goods

change brand_namebrand_id int unsigned not null;

alter table goodsadd foreign key (brand_id)references goods_brands(id);-- 外键关联

insert into goods (name,cate_id,brand_id,price)

values('LaserJet Pro P1606dn 黑白激光打印机', 2, 100,'1849');

-- 创建品牌表

create table goods_brands (

id int unsigned primary key auto_increment,

name varchar(40)not null)select brand_nameas name from goodsgroup by brand_name;

update goodsas ginner join goods_brandsas bon g.brand_name=b.name set g.brand_name=b.id;

alter table goods

change brand_namebrand_id int unsigned not null;

alter table goodsadd foreign key (brand_id)references goods_brands(id);

-- 取消外键

alter table goodsdrop foreign key goods_ibfk_1;

alter table goodsdrop foreign key goods_ibfk_2;

# 在python3中使用数据库

# python2 import MySQLdb

import pymysql

'''

from pymysqlimport connect

# 创建connection连接

conn = connect(host='localhost',port=3306,database='wn',user='root',password='root',charset='utf8')

事务、准备数据

事务、准备数据

事务

准备数据