- ubuntu12.04环境下使用kvm ioctl接口实现最简单的虚拟机
- Ubuntu 通过无线网络安装Ubuntu Server启动系统后连接无线网络的方法
- 在Ubuntu上搭建网桥的方法
- ubuntu 虚拟机上网方式及相关配置详解
CFSDN坚持开源创造价值,我们致力于搭建一个资源共享平台,让每一个IT人在这里找到属于你的精彩世界.
这篇CFSDN的博客文章mysql触发器实时检测一条语句进行备份删除思路详解由作者收集整理,如果你对这篇文章有兴趣,记得点赞哟.
问题描述:用户有一个这样一个需求,在一张表里会不时出现 “违规” 字样的字段,需要在出现这个字段的时候,把整行的数据删掉。这是个采集任务,如果发现有“违规”字样的数据,会整点或者什么时间进行统一上报,也无法对源头进行控制让这种数据不生成.
1.实时检测这条数据的产生,发现后删除 。
2.在删除之前作备份这条数据 。
需要明确解决思路, 。
1.首先是如何实时探测删除?询问开发,这条数据的生成方式为insert,就可以做一个当表做插入的时候,然后做一个after insert 做delete数据的触发器 。
2.如何进行备份?何种方式备份?能不能备份到一个表里,这个表里记录每次插入的时间,建立这个备份表可以取与原表结构基本相同,但是备份表要删除原表的自增属性,主键,外键等属性,新增一个时间戳字段,方便记录每次备份数据的时间,删除以上属性是为了能够把数据写入备份表中 。
3.如何在删除之前做备份呢?一开始想的是放到一个触发器就行,先把数据进行备份,然后后面跟着一条删除,测试的时候行不通 。
先准备一些测试数据和测试表 。
1.建立测试数据 。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
mysql> show
create
table
student;
+
---------+--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
|
Table
|
Create
Table
|
+
---------+--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| student |
CREATE
TABLE
`student` (
`Sno`
char
(9)
NOT
NULL
,
`Sname`
char
(20)
NOT
NULL
,
`Ssex`
char
(2)
DEFAULT
NULL
,
`Sage`
smallint
DEFAULT
NULL
,
`Sdept`
char
(20)
DEFAULT
NULL
,
PRIMARY
KEY
(`Sno`)
) ENGINE=InnoDB
DEFAULT
CHARSET=utf8mb4
COLLATE
=utf8mb4_0900_ai_ci |
+
---------+--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
1 row
in
set
(0.01 sec)
|
2.建立备份表。查看建表语句,正式环境是不知道原表的表结构的,需要有改原表结构,并创建新备份表的操作的 。
原表建表语句 。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
mysql> show
create
table
student;
+
---------+--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
|
Table
|
Create
Table
|
+
---------+--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| student |
CREATE
TABLE
`student` (
`Sno`
char
(9)
NOT
NULL
,
`Sname`
char
(20)
NOT
NULL
,
`Ssex`
char
(2)
DEFAULT
NULL
,
`Sage`
smallint
DEFAULT
NULL
,
`Sdept`
char
(20)
DEFAULT
NULL
,
PRIMARY
KEY
(`Sno`)
) ENGINE=InnoDB
DEFAULT
CHARSET=utf8mb4
COLLATE
=utf8mb4_0900_ai_ci |
+
---------+--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
1 row
in
set
(0.01 sec)
|
3.准备备份语句,删除语句,插入测试语句 。
备份语句(因为备份表多一个时间戳的字段,所以备份语句要做修改一下) 。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
mysql> show
create
table
student_bak;
+
-------------+---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
|
Table
|
Create
Table
|
+
-------------+---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| student_bak |
CREATE
TABLE
`student_bak` (
`Sno`
char
(9)
NOT
NULL
,
`Sname`
char
(20)
NOT
NULL
,
`Ssex`
char
(2)
DEFAULT
NULL
,
`Sage`
smallint
DEFAULT
NULL
,
`Sdept`
char
(20)
DEFAULT
NULL
,
`create_date`
timestamp
NOT
NULL
DEFAULT
CURRENT_TIMESTAMP
) ENGINE=InnoDB
DEFAULT
CHARSET=utf8mb4
COLLATE
=utf8mb4_0900_ai_ci |
+
-------------+---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
1 row
in
set
(0.00 sec)
|
备份效果 。
插入测试语句:
1
|
insert
into
student
values
(
'201215124'
,
'张三'
,
'男'
,20,
'EL'
);
|
删除语句(删除数据一定要写精准了,到时候删什么,就要备份什么) 。
1
|
delete
from
student
where
Sdept=
'EL'
;
|
4.实际测试方案 。
4.1 把两条语句写进一个触发器(操作失败,逻辑执行不成功) 。
1
2
3
4
5
6
7
8
9
10
11
|
drop
trigger
if exists test_trigger;
DELIMITER $
CREATE
TRIGGER
test_trigger
AFTER
INSERT
ON
student2
FOR
EACH ROW
BEGIN
insert
into
student_bak(Sno,Sname,Ssex,Sage,Sdept)
select
*
from
student
where
Sdept=
'EL'
;
delete
from
student
where
Sdept=
'EL'
;
END
$
DELIMITER ;
|
4.2 准备两个单独的触发器,一个是当原表出现这条数据时,插入到备份表实现备份的效果。第二个触发器是做备份表备份完数据之后,在做一个删除原表该条数据的触发器,然后实现备份完删除的效果(还是操作失败),执行报错,说的是触发器有冲突还是什么的,这样做让数据库不知道执行逻辑了.
4.3 做一个在原表如果进行删除目标数据,然后备份该条数据到备份表的触发器。最后再实现实时探测目标数据出现然后删除的操作就行了,不局限于触发器的思维,做一个定时任务就可以了(操作成功) 。
比如下面测试的当数据库的表中Sdept字段出现了一个叫‘EL'的字段时,需要把整行数据删除掉 。
1
2
3
4
5
6
7
8
9
10
|
drop
trigger
if exists student_bak_trigger;
DELIMITER $
CREATE
TRIGGER
student_bak_trigger
BEFORE
DELETE
ON
student
FOR
EACH ROW
BEGIN
insert
into
student_bak(Sno,Sname,Ssex,Sage,Sdept)
select
*
from
student
where
Sdept=
'EL'
;
END
$
DELIMITER ;
|
这个触发器就实现了,如果原表的目标数据被删除了,触发器触发了就会备份该条数据 。
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
48
49
50
51
52
53
|
mysql>
select
*
from
student;
+
-----------+--------+------+------+-------+
| Sno | Sname | Ssex | Sage | Sdept |
+
-----------+--------+------+------+-------+
| 201215121 | 李勇 | 男 | 20 | CS |
| 201215122 | 刘晨 | 女 | 19 | CS |
| 201215123 | 王敏 | 女 | 18 | MA |
| 201215130 | 兵丁 | 男 | 20 | CH |
+
-----------+--------+------+------+-------+
4
rows
in
set
(0.00 sec)
mysql>
select
*
from
student_bak;
+
-----------+--------+------+------+-------+---------------------+
| Sno | Sname | Ssex | Sage | Sdept | create_date |
+
-----------+--------+------+------+-------+---------------------+
| 201215124 | 张三 | 男 | 20 | EL | 2021-09-18 15:42:20 |
+
-----------+--------+------+------+-------+---------------------+
1 row
in
set
(0.00 sec)
mysql>
insert
into
student
values
(
'201215125'
,
'王五'
,
'男'
,30,
'EL'
);
Query OK, 1 row affected (0.00 sec)
mysql>
select
*
from
student;
+
-----------+--------+------+------+-------+
| Sno | Sname | Ssex | Sage | Sdept |
+
-----------+--------+------+------+-------+
| 201215121 | 李勇 | 男 | 20 | CS |
| 201215122 | 刘晨 | 女 | 19 | CS |
| 201215123 | 王敏 | 女 | 18 | MA |
| 201215125 | 王五 | 男 | 30 | EL |
| 201215130 | 兵丁 | 男 | 20 | CH |
+
-----------+--------+------+------+-------+
5
rows
in
set
(0.00 sec)
mysql>
select
*
from
student_bak;
+
-----------+--------+------+------+-------+---------------------+
| Sno | Sname | Ssex | Sage | Sdept | create_date |
+
-----------+--------+------+------+-------+---------------------+
| 201215124 | 张三 | 男 | 20 | EL | 2021-09-18 15:42:20 |
+
-----------+--------+------+------+-------+---------------------+
1 row
in
set
(0.00 sec)
mysql>
delete
from
student
where
Sdept=
'EL'
;
Query OK, 1 row affected (0.01 sec)
mysql>
select
*
from
student_bak;
+
-----------+--------+------+------+-------+---------------------+
| Sno | Sname | Ssex | Sage | Sdept | create_date |
+
-----------+--------+------+------+-------+---------------------+
| 201215124 | 张三 | 男 | 20 | EL | 2021-09-18 15:42:20 |
| 201215125 | 王五 | 男 | 30 | EL | 2021-09-18 15:47:28 |
+
-----------+--------+------+------+-------+---------------------+
2
rows
in
set
(0.00 sec)
|
最后实现一个定时任务,来循环的删除一个叫‘EL'的字段的整行数据,这里的定时任务是面向全局的,一定要加上数据库名和具体表名,定时任务的执行速度是可以手动调整的,下面为3s/次,以便实现需要的效果 。
1
2
3
4
|
create
event if
not
exists e_test_event
on
schedule every 3
second
on
completion preserve
do
delete
from
abc.student
where
Sdept=
'EL'
;
|
关闭定时任务:
1
2
|
mysql>
alter
event e_test_event
ON
COMPLETION PRESERVE DISABLE;
Query OK, 0
rows
affected (0.00 sec)
|
查看定时任务:
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
|
mysql>
select
*
from
information_schema.events\G;*************************** 4. row ***************************
EVENT_CATALOG: def
EVENT_SCHEMA: abc
EVENT_NAME: e_test_event
DEFINER: root@%
TIME_ZONE: SYSTEM
EVENT_BODY: SQL
EVENT_DEFINITION:
delete
from
abc.student
where
Sdept=
'EL'
EVENT_TYPE: RECURRING
EXECUTE_AT:
NULL
INTERVAL_VALUE: 3
INTERVAL_FIELD:
SECOND
SQL_MODE: ONLY_FULL_GROUP_BY,STRICT_TRANS_TABLES,NO_ZERO_IN_DATE,NO_ZERO_DATE,ERROR_FOR_DIVISION_BY_ZERO,NO_ENGINE_SUBSTITUTION
STARTS: 2021-09-17 13:35:44
ENDS:
NULL
STATUS: ENABLED
ON_COMPLETION: PRESERVE
CREATED: 2021-09-17 13:35:44
LAST_ALTERED: 2021-09-17 13:35:44
LAST_EXECUTED: 2021-09-18 15:43:35
EVENT_COMMENT:
ORIGINATOR: 3330614
CHARACTER_SET_CLIENT: utf8mb4
COLLATION_CONNECTION: utf8mb4_0900_ai_ci
DATABASE_COLLATION: utf8mb4_0900_ai_ci
4
rows
in
set
(0.00 sec)
|
查看触发器:
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
|
mysql>
select
*
from
information_schema.triggers\G;
*************************** 5. row ***************************
TRIGGER_CATALOG: def
TRIGGER_SCHEMA: abc
TRIGGER_NAME: student_bak_trigger
EVENT_MANIPULATION:
DELETE
EVENT_OBJECT_CATALOG: def
EVENT_OBJECT_SCHEMA: abc
EVENT_OBJECT_TABLE: student
ACTION_ORDER: 1
ACTION_CONDITION:
NULL
ACTION_STATEMENT:
BEGIN
insert
into
student_bak(Sno,Sname,Ssex,Sage,Sdept)
select
*
from
student
where
Sdept=
'EL'
;
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: 2021-09-18 15:41:48.53
SQL_MODE: ONLY_FULL_GROUP_BY,STRICT_TRANS_TABLES,NO_ZERO_IN_DATE,NO_ZERO_DATE,ERROR_FOR_DIVISION_BY_ZERO,NO_ENGINE_SUBSTITUTION
DEFINER: root@%
CHARACTER_SET_CLIENT: utf8mb4
COLLATION_CONNECTION: utf8mb4_0900_ai_ci
DATABASE_COLLATION: utf8mb4_0900_ai_ci
5
rows
in
set
(0.00 sec)
|
实现效果:
到此这篇关于mysql触发器实时检测一条语句进行备份删除思路详解的文章就介绍到这了,更多相关mysql触发器备份删除内容请搜索我以前的文章或继续浏览下面的相关文章希望大家以后多多支持我! 。
原文链接:https://www.cnblogs.com/houzhiheng/p/15309058.html 。
最后此篇关于mysql触发器实时检测一条语句进行备份删除思路详解的文章就讲到这里了,如果你想了解更多关于mysql触发器实时检测一条语句进行备份删除思路详解的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。
目前我正在构建相当大的网络系统,我需要强大的 SQL 数据库解决方案。我选择 Mysql 而不是 Postgres,因为一些任务需要只读(MyISAM 引擎)而其他任务需要大量写入(InnoDB)。
我在 mysql 中使用如下命令。当它显示表格数据时,它被格式化为一个非常干净的表格,间距均匀且 |作为列分隔符。 SELECT * FROM TABLE_NAME; 当我从 CLI 运行命令时,如下
我知道这个问题之前已经被问过好几次了,我已经解决了很多问题,但到目前为止没有任何效果。 MySQL 试图将自身安装到的目录 (usr/local/mysql) 肯定有问题。关于我的错误的奇怪之处在于我
以下是我的 SQL 数据结构,我正在尝试如下两个查询: Select Wrk_ID, Wrk_LastName, Skill_Desc from Worker, Skill where
我们有一个本地 mysql 服务器(不在公共(public)域上),并希望将该服务器复制到我们拥有的 google 云 sql 实例。我的问题是:1.这可能吗?2.我们的本地服务器只能在本地网络上访问
我有一个表(test_table),其中一些字段值(例如字段 A、B 和 C)是从外部应用程序插入的,还有一个字段(字段 D),我想从现有表(store_table)插入其值,但在插入前者(A、B 和
我想创建一个 AWS RDS 实例,然后使用 terraform 管理数据库用户。因此,首先,我创建了一个 RDS 实例,然后使用创建的 RDS 实例初始化 mysql 提供程序,以进一步将其用于用户
当用户在我的网站上注册时,他们会在我的一个数据库中创建自己的表格。该表存储用户发布的所有帖子。我还想做的是也为他们生成自己的 MySql 用户——该用户仅有权从他们的表中读取、写入和删除。 创建它应该
我有一个关于 ColdFusion 和 Mysql 的问题。我有两个表:PRODUCT 和 PRODUCT_CAT。我想列出包含一些标记为:IS_EXTRANET=1 的特殊产品的类别。所以我写了这个
我想获取 recipes_id 列的值,以获取包含 ingredient_id 的 2,17 和 26 条目的值。 假设 ingredient_id 2 丢失则不获取记录。 我已经尝试过 IN 运算符
在 Ubuntu 中,我通常安装两者,但 MySQL 的客户端和服务器之间有什么区别。 作为奖励,当一个新语句提到它需要 MySQL 5.x 时,它是指客户端、服务器还是两者兼而有之。例如这个链接ht
我重新访问了我的数据库并注意到我有一些 INT 类型的主键。 这还不够独特,所以我想我会有一个指导。 我来自微软 sql 背景,在 ssms 中你可以 选择类型为“uniqeidentifier”并自
我的系统上有 MySQL,我正在尝试确定它是 Oracle MySQL 还是 MySQL。 Oracle MySQL 有区别吗: http://www.oracle.com/us/products/m
我是在生产 MySQL 中运行的应用程序的新维护者。之前的维护者已经离开,留下的文档很少,而且联系不上了。 我面临的问题是执行以下请求大约需要 10 秒: SELECT COUNT(*) FROM `
我有两个位于不同机器上的 MySQL 数据库。我想自动将数据从一台服务器传输到另一台服务器。比方说,我希望每天早上 4:00 进行数据传输。 可以吗?是否有任何 MySQL 内置功能可以让我们做到这一
有什么方法可以使用 jdbc 查询位于 mysql 根目录之外的目录中的 mysql 表,还是必须将它们移动到 mysql 根目录内的数据库文件夹中?我在 Google 上搜索时没有找到任何东西。 最
我在 mysql 数据库中有两个表。成员和 ClassNumbers。两个表都有一个付费年份字段,都有一个代码字段。我想用代码数字表中的值更新成员表中的付费年份,其中成员中的代码与 ClassNumb
情况:我有 2 台服务器,其中一台当前托管一个实时 WordPress 站点,我希望能够将该站点转移到另一台服务器,以防第一台服务器出现故障。传输源文件很容易;传输数据库是我需要弄清楚如何做的。两台服
Phpmyadmin 有一个功能是“复制数据库到”..有没有mysql查询来写这个函数?类似于将 db A 复制到新的 db B。 最佳答案 首先创建复制数据库: CREATE DATABASE du
我有一个使用 mySQL 作为后端的库存软件。我已经在我的计算机上对其进行了测试,并且运行良好。 当我在计算机上安装我的软件时,我必须执行以下步骤: 安装 mySQL 服务器 将用户名指定为“root
我是一名优秀的程序员,十分优秀!