MySQL存储函数以及触发器详解

admin Mysql

2023-12-01 0 728

MySQL

MySQL是一个关系型数据库管理系统，由瑞典MySQL AB 公司开发，属于 Oracle 旗下产品。MySQL 是最流行的关系型数据库管理系统之一，在 WEB 应用方面，MySQL是最好的 RDBMS (Relational Database Management System，关系数据库管理系统) 应用软件之一。MySQL是一种关系型数据库管理系统，关系数据库将数据保存在不同的表中，而不是将所有数据放在一个大仓库内，这样就增加了速度并提高了灵活性。MySQL所使用的 SQL 语言是用于访问数据库的最常用标准化语言。MySQL 软件采用了双授权政策，分为社区版和商业版，由于其体积小、速度快、总体拥有成本低，尤其是开放源码这一特点，一般中小型和大型网站的开发都选择 MySQL 作为网站数据库。

SQL

结构化查询语言（Structured Query Language）简称SQL，是一种特殊目的的编程语言，是一种数据库查询和程序设计语言，用于存取数据以及查询、更新和管理关系数据库系统。结构化查询语言是高级的非过程化编程语言，允许用户在高层数据结构上工作。它不要求用户指定对数据的存放方法，也不需要用户了解具体的数据存放方式，所以具有完全不同底层结构的不同数据库系统, 可以使用相同的结构化查询语言作为数据输入与管理的接口。结构化查询语言语句可以嵌套，这使它具有极大的灵活性和强大的功能。

存储函数

1).介绍

存储函数是有返回值的存储过程，存储函数的参数只能是IN类型的。具体语法如下：

CREATE FUNCTION 存储函数名称 ([ 参数列表 ])
RETURNS type [characteristic …]
BEGIN
— SQL语句
RETURN …;
END ;

characteristic说明

DETERMINISTIC：相同的输入参数总是产生相同的结果

NO SQL：不包含SQL语句。

READS SQL DATA：包含读取数据的语句，但不包含写入数据的语句。

2).案例

计算从1累加到n的值，n为传入的参数值。

create function fun1(n int)
returns int deterministic
begin
declare total int default 0;
while n>0 do
set total := total + n;
set n := n – 1;
end while;
return total;
end;
select fun1(50);

在 mysql8.0 版本中 binlog 默认是开启的，一旦开启了， mysql 就要求在定义存储过程时，需要指定characteristic 特性，否则就会报如下错误：

触发器

介绍

触发器是与表有关的数据库对象，指在insert/update/delete之前(BEFORE)或之后(AFTER)，触发并执行触发器中定义的SQL语句集合。触发器的这种特性可以协助应用在数据库端确保数据的完整性,日志记录,数据校验等操作。

使用别名OLD和NEW来引用触发器中发生变化的记录内容，这与其他的数据库是相似的。现在触发器还只支持行级触发，不支持语句级触发。

语法

1).创建

CREATE TRIGGER trigger_name
BEFORE/AFTER INSERT/UPDATE/DELETE
ON tbl_name FOR EACH ROW — 行级触发器
BEGIN
trigger_stmt ;
END;

2).查看

SHOW TRIGGERS ;

3).删除

DROP TRIGGER [schema_name.]trigger_name ; — 如果没有指定 schema_name，默认为当前数
据库。

案例

通过触发器记录tb_user表的数据变更日志，将变更日志插入到日志表user_logs中,包含增加,

修改,删除;

表结构准备:

— 准备工作 : 日志表 user_logs
create table user_logs(
id int(11) not null auto_increment,
operation varchar(20) not null comment \’操作类型, insert/update/delete\’,
operate_time datetime not null comment \’操作时间\’,
operate_id int(11) not null comment \’操作的ID\’,
operate_params varchar(500) comment \’操作参数\’,
primary key(`id`)
)engine=innodb default charset=utf8;

A.插入数据触发器

create trigger tb_user_insert_trigger
after insert on tb_user for each row
begin
insert into user_logs(id, operation, operate_time, operate_id, operate_params)
VALUES
(null, \’insert\’, now(), new.id, concat(\’插入的数据内容为:
id=\’,new.id,\’,name=\’,new.name, \’, phone=\’, NEW.phone, \’, email=\’, NEW.email, \’,
profession=\’, NEW.profession));
end;

测试:

— 查看
show triggers ;
— 插入数据到tb_user
insert into tb_user(id, name, phone, email, profession, age, gender, status,
createtime) VALUES (26,\’三皇子\’,\’18809091212\’,\’erhuangzi@163.com\’,\’软件工
程\’,23,\’1\’,\’1\’,now());

测试完毕之后，检查日志表中的数据是否可以正常插入，以及插入数据的正确性。

B. 修改数据触发器

create trigger tb_user_update_trigger
after update on tb_user for each row
begin
insert into user_logs(id, operation, operate_time, operate_id, operate_params)
VALUES
(null, \’update\’, now(), new.id,
concat(\’更新之前的数据: id=\’,old.id,\’,name=\’,old.name, \’, phone=\’,
old.phone, \’, email=\’, old.email, \’, profession=\’, old.profession,
\’ | 更新之后的数据: id=\’,new.id,\’,name=\’,new.name, \’, phone=\’,
NEW.phone, \’, email=\’, NEW.email, \’, profession=\’, NEW.profession));
end;

测试:

— 查看
show triggers ;
— 更新
update tb_user set profession = \’会计\’ where id = 23;
update tb_user set profession = \’会计\’ where id <= 5;

测试完毕之后，检查日志表中的数据是否可以正常插入，以及插入数据的正确性。

C. 删除数据触发器

create trigger tb_user_delete_trigger
after delete on tb_user for each row
begin
insert into user_logs(id, operation, operate_time, operate_id, operate_params)
VALUES
(null, \’delete\’, now(), old.id,
concat(\’删除之前的数据: id=\’,old.id,\’,name=\’,old.name, \’, phone=\’,
old.phone, \’, email=\’, old.email, \’, profession=\’, old.profession));
end;