MySQL基础-触发器
在实际开发中,我们经常会遇到这样的情况:有 2 个或者多个相互关联的表,如商品信息
和库存信息
分别存放在 2 个不同的数据表中,我们在添加一条新商品记录的时候,为了保证数据的完整性
,必须同时在库存表中添加一条库存记录。
这样一来,我们就必须把这两个关联的操作步骤写到程序里面,而且要用事务
包裹起来,确保这两个操作成为一个原子
操作,要么全部执行,要么全部不执行。要是遇到特殊情况,可能还需要对数据进行手动维护,这样就很 容易忘记其中的一步,导致数据缺失。
这个时候,我们可以使用触发器,==可以创建一个触发器,让商品信息数据的插入操作自动触发库存数据的插入操作==。这样一来,就不用担心因为忘记添加库存数据而导致的数据缺失了。
一、触发器概述
MySQL 从 5.0.2
版本开始支持触发器。MySQL的触发器和存储过程一样,都是嵌入到 MySQL 服务器的一段程序。
触发器是由事件
来触发某个操作,这些事件包括 INSERT
、UPDATE
、DELETE
事件。所谓事件就是指用户的动作或者触发某项行为。如果定义了触发程序,当数据库执行这些语句时候,就相当于事件发生了,就会自动
激发触发器执行相应的操作。 当对数据表中的数据执行插入、更新和删除操作,需要自动执行一些数据库逻辑时,可以使用触发器来实现。
二、触发器的创建
1 2 3 4
| CREATE TRIGGER 触发器名称 {BEFORE|AFTER} {INSERT|UPDATE|DELETE} ON 表名 FOR EACH ROW 触发器执行的语句块
|
- 表名 :表示触发器监控的对象。
- BEFORE | AFTER :表示触发的时间。BEFORE 表示在事件之前触发;AFTER 表示在事件之后触发。
- INSERT | UPDATE | DELETE :表示触发的事件。
- INSERT 表示插入记录时触发;
- UPDATE 表示更新记录时触发;
- DELETE 表示删除记录时触发。
- 触发器执行的语句块 :可以是单条 SQL 语句,也可以是由 BEGIN…END 结构组成的复合语句块。
三、触发器的案例
演示案例1:日志记录/数据备份
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42
| mysql> CREATE TABLE emp -> AS -> SELECT employee_id, last_name, salary, manager_id FROM employees WHERE NULL; Query OK, 0 rows affected, 1 warning (0.01 sec) Records: 0 Duplicates: 0 Warnings: 1
mysql> SELECT * FROM emp; Empty set (0.00 sec)
mysql> CREATE TABLE emp_log -> AS -> SELECT employee_id, last_name, salary, manager_id FROM employees WHERE NULL; Query OK, 0 rows affected, 1 warning (0.01 sec) Records: 0 Duplicates: 0 Warnings: 1
mysql> SELECT * FROM emp_log; Empty set (0.00 sec)
mysql> CREATE TRIGGER befor_insert_trigger -> BEFORE INSERT ON emp -> FOR EACH ROW -> INSERT INTO emp_log VALUES(NEW.employee_id,NEW.last_name,NEW.salary,NEW.manager_id); Query OK, 0 rows affected (0.01 sec)
mysql> INSERT INTO emp VALUES(100,'Manager',56000,NULL); Query OK, 1 row affected (0.01 sec)
mysql> SELECT * FROM emp; + | employee_id | last_name | salary | manager_id | + | 100 | Manager | 56000.00 | NULL | + 1 row in set (0.00 sec)
mysql> SELECT * FROM emp_log; + | employee_id | last_name | salary | manager_id | + | 100 | Manager | 56000.00 | NULL | + 1 row in set (0.00 sec)
|
演示案例2:数据校验
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44
| mysql> DELIMITER // mysql> CREATE TRIGGER salary_check_trigger -> BEFORE INSERT ON emp -> FOR EACH ROW -> BEGIN -> DECLARE mgrsalary DOUBLE; -> SELECT salary INTO mgrsalary FROM emp WHERE employee_id = NEW.manager_id; -> IF NEW.salary > mgrsalary THEN -> SIGNAL SQLSTATE 'HY000' SET MESSAGE_TEXT = '薪资高于领导,薪资错误'; -> END IF; -> END // mysql> DELIMITER ; Query OK, 0 rows affected (0.01 sec)
mysql> INSERT INTO emp VALUES(101,'Employee',60000,100); ERROR 1644 (HY000): 薪资高于领导,薪资错误 mysql> SELECT * FROM emp; + | employee_id | last_name | salary | manager_id | + | 100 | Manager | 56000.00 | NULL | + 1 row in set (0.00 sec)
mysql> INSERT INTO emp VALUES(101,'Employee',26000,100); Query OK, 1 row affected (0.01 sec)
mysql> SELECT * FROM emp; + | employee_id | last_name | salary | manager_id | + | 100 | Manager | 56000.00 | NULL | | 101 | Employee | 26000.00 | 100 | + 2 rows in set (0.00 sec)
mysql> SELECT * FROM emp_log; + | employee_id | last_name | salary | manager_id | + | 100 | Manager | 56000.00 | NULL | | 101 | Employee | 26000.00 | 100 | + 2 rows in set (0.00 sec)
|
演示案例3:数据回收
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30
| mysql> CREATE TABLE emp_back -> AS -> SELECT employee_id, last_name, salary, manager_id FROM employees WHERE NULL; Query OK, 0 rows affected, 1 warning (0.01 sec) Records: 0 Duplicates: 0 Warnings: 1
mysql> CREATE TRIGGER save_data_trigger -> BEFORE DELETE ON emp -> FOR EACH ROW -> INSERT INTO emp_back VALUES(OLD.employee_id,OLD.last_name,OLD.salary,OLD.manager_id); Query OK, 0 rows affected (0.01 sec)
mysql> DELETE FROM emp WHERE employee_id=101; Query OK, 1 row affected (0.01 sec)
mysql> SELECT * FROM emp; + | employee_id | last_name | salary | manager_id | + | 100 | Manager | 56000.00 | NULL | + 1 row in set (0.00 sec)
mysql> SELECT * FROM emp_back; + | employee_id | last_name | salary | manager_id | + | 101 | Employee | 26000.00 | 100 | + 1 row in set (0.00 sec)
|
四、触发器的查看
查看触发器是查看数据库中已经存在的触发器的定义、状态和语法信息等。
方式1:查看当前数据库的所有触发器的定义
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47
| SHOW TRIGGERS\G
mysql> SHOW TRIGGERS\G *************************** 1. row *************************** Trigger: befor_insert_trigger Event: INSERT Table: emp Statement: INSERT INTO emp_log VALUES(NEW.employee_id,NEW.last_name,NEW.salary,NEW.manager_id) Timing: BEFORE Created: 2023-10-17 21:43:54.13 sql_mode: STRICT_TRANS_TABLES,NO_ENGINE_SUBSTITUTION Definer: root@localhost character_set_client: gbk collation_connection: gbk_chinese_ci Database Collation: utf8mb3_general_ci *************************** 2. row *************************** Trigger: salary_check_trigger Event: INSERT Table: emp Statement: BEGIN DECLARE mgrsalary DOUBLE; SELECT salary INTO mgrsalary FROM emp WHERE employee_id = NEW.manager_id; IF NEW.salary > mgrsalary THEN SIGNAL SQLSTATE 'HY000' SET MESSAGE_TEXT = '薪资高于领导,薪资错误'; END IF; END Timing: BEFORE Created: 2023-10-17 21:49:55.44 sql_mode: STRICT_TRANS_TABLES,NO_ENGINE_SUBSTITUTION Definer: root@localhost character_set_client: gbk collation_connection: gbk_chinese_ci Database Collation: utf8mb3_general_ci *************************** 3. row *************************** Trigger: save_data_trigger Event: DELETE Table: emp Statement: INSERT INTO emp_back VALUES(OLD.employee_id,OLD.last_name,OLD.salary,OLD.manager_id) Timing: BEFORE Created: 2023-10-17 22:10:46.47 sql_mode: STRICT_TRANS_TABLES,NO_ENGINE_SUBSTITUTION Definer: root@localhost character_set_client: gbk collation_connection: gbk_chinese_ci Database Collation: utf8mb3_general_ci 3 rows in set (0.00 sec)
|
方式2:查看当前数据库中某个触发器的定义
1 2 3 4 5 6 7 8 9 10 11 12 13
| SHOW CREATE TRIGGER 触发器名
mysql> SHOW CREATE TRIGGER save_data_trigger\G *************************** 1. row *************************** Trigger: save_data_trigger sql_mode: STRICT_TRANS_TABLES,NO_ENGINE_SUBSTITUTION SQL Original Statement: CREATE DEFINER=`root`@`localhost` TRIGGER `save_data_trigger` BEFORE DELETE ON `emp` FOR EACH ROW INSERT INTO emp_back VALUES(OLD.employee_id,OLD.last_name,OLD.salary,OLD.manager_id) character_set_client: gbk collation_connection: gbk_chinese_ci Database Collation: utf8mb3_general_ci Created: 2023-10-17 22:10:46.47 1 row in set (0.00 sec)
|
方式3:从系统库 information_schema 的 TRIGGERS 表中查询“salary_check_trigger”触发器的信息
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34
| SELECT * FROM information_schema.TRIGGERS;
mysql> SELECT * FROM information_schema.TRIGGERS WHERE TRIGGER_NAME='salary_check_trigger'\G *************************** 1. row *************************** TRIGGER_CATALOG: def TRIGGER_SCHEMA: atguigudb TRIGGER_NAME: salary_check_trigger EVENT_MANIPULATION: INSERT EVENT_OBJECT_CATALOG: def EVENT_OBJECT_SCHEMA: atguigudb EVENT_OBJECT_TABLE: emp ACTION_ORDER: 2 ACTION_CONDITION: NULL ACTION_STATEMENT: BEGIN DECLARE mgrsalary DOUBLE; SELECT salary INTO mgrsalary FROM emp WHERE employee_id = NEW.manager_id; IF NEW.salary > mgrsalary THEN SIGNAL SQLSTATE 'HY000' SET MESSAGE_TEXT = '薪资高于领导,薪资错误'; END IF; END ACTION_ORIENTATION: ROW ACTION_TIMING: BEFORE ACTION_REFERENCE_OLD_TABLE: NULL ACTION_REFERENCE_NEW_TABLE: NULL ACTION_REFERENCE_OLD_ROW: OLD ACTION_REFERENCE_NEW_ROW: NEW CREATED: 2023-10-17 21:49:55.44 SQL_MODE: STRICT_TRANS_TABLES,NO_ENGINE_SUBSTITUTION DEFINER: root@localhost CHARACTER_SET_CLIENT: gbk COLLATION_CONNECTION: gbk_chinese_ci DATABASE_COLLATION: utf8mb3_general_ci 1 row in set (0.00 sec)
|
五、触发器的删除
触发器也是数据库对象,删除触发器也用DROP语句,语法格式如下:
1 2 3 4 5 6 7 8 9 10 11 12 13 14
| DROP TRIGGER IF EXISTS 触发器名称;
mysql> DROP TRIGGER IF EXISTS befor_insert_trigger; Query OK, 0 rows affected (0.01 sec)
mysql> DROP TRIGGER IF EXISTS salary_check_trigger; Query OK, 0 rows affected (0.01 sec)
mysql> DROP TRIGGER IF EXISTS save_data_trigger; Query OK, 0 rows affected (0.01 sec)
mysql> SHOW TRIGGERS\G Empty set (0.00 sec)
|
六、触发器的优缺点
1.触发器的优点
触发器可以确保数据的完整性
假设我们用进货单头表
(demo.importhead)来保存进货单的总体信息,包括进货单编号、供货商编号、仓库编号、总计进货数量、总计进货金额和验收日期。
listnumber (进货单编号) |
supplierid (进货商编号) |
stockid (参库编号) |
quantity (总计数量) |
importvalue (总计金额) |
confirmationdate (验收日期) |
用进货单明细表
(demo.importdetails)来保存进货商品的明细,包括进货单编号、商品编号、进货数量、进货价格和进货金额。
listnumber (进货单编号) |
itemnumber (商品编号) |
quantity (进货数量) |
importprice (进货价格) |
importvalue (进货金额) |
每当我们录入、删除和修改一条进货单明细数据的时候,进货单明细表里的数据就会发生变动。这个时候,在进货单头表中的总计数量和总计金额就必须重新计算,否则,进货单头表中的总计数量和总计金额就不等于进货单明细表中数量合计和金额合计了,这就是数据不一致。
为了解决这个问题,我们就可以使用触发器,规定每当进货单明细表有数据插入、修改和删除的操作时,自动触发 2 步操作:
- 重新计算进货单明细表中的数量合计和金额合计;
- 用第一步中计算出来的值更新进货单头表中的合计数量与合计金额。
这样一来,进货单头表中的合计数量与合计金额的值,就始终与进货单明细表中计算出来的合计数量与合计金额的值相同,数据就是一致的,不会互相矛盾。
触发器可以帮助我们记录操作日志
利用触发器,可以具体记录什么时间发生了什么。比如,记录修改会员储值金额的触发器,就是一个很好的例子。这对我们还原操作执行时的具体场景,更好地定位问题原因
很有帮助。
触发器还可以用在操作数据前对数据进行合法性检查
比如,超市进货的时候,需要库管录入进货价格。但是,人为操作很容易犯错误,比如说在录入数量的时候,把条形码扫进去了;录入金额的时候,看串了行,录入的价格远超售价,导致账面上的巨亏…… 这些都可以通过触发器,在实际插入或者更新操作之前,对相应的数据进行检查,及时提示错误,防止错误数据进入系统。
2.触发器的缺点
触发器最大的一个问题就是可读性差
因为触发器存储在数据库中,并且由事件驱动,这就意味着触发器有可能不受应用层的控制。这对系统维护是非常有挑战的。
相关数据的变更,可能会导致触发器出错
特别是数据表结构的变更,都可能会导致触发器出错,进而影响数据操作的正常运行。这些都会由于触发器本身的隐蔽性,影响到应用中错误原因排查的效率。
3.注意点
注意,如果在子表中定义了外键约束,并且外键指定了ON UPDATE/DELETE CASCADE/SET NULL子句,此时修改父表被引用的键值或删除父表被引用的记录行时,也会引起子表的修改和删除操作,此时基于子表的UPDATE和DELETE语句定义的触发器并不会被激活。