百度360必应搜狗淘宝本站头条
当前位置:网站首页 > IT技术 > 正文

技术分享 | 一招解决 MySQL 中 DDL 被阻塞的问题

wptr33 2025-02-11 13:45 17 浏览

作者:许祥

爱可生 MySQL DBA 团队成员,负责处理客户 MySQL 及我司自研 DMP 平台日常运维中的问题。

本文来源:原创投稿

* 爱可生开源社区出品,原创内容未经授权不得随意使用,转载请联系小编并注明来源。



背景

之前碰到客户咨询定位 DDL 阻塞的相关问题,整理了一下方法,如何解决 DDL 被阻塞的问题。下面,就这个问题,整理了一下思路:

  1. 怎么判断一个 DDL 是不是被阻塞了?
  2. 当 DDL 被阻塞时,怎么找出阻塞它的会话?

1. 如何判断一个 DDL 是不是被阻塞了?

测试过程如下:

mysql> use test;
Database changed

mysql> CREATE TABLE `test` (
-> `id` int() AUTO_INCREMENT PRIMARY KEY,
-> `name` varchar()
-> );
Query OK, 0 rows affected (0.01 sec)

# 插入数据
mysql> insert into test values (,'aaa'),(,'bbb'),(,'ccc'),(,'ddd');
Query OK, 1 row affected (0.01 sec)

mysql> begin;
Query OK, 0 rows affected (0.01 sec)


mysql> select * from test;
+----+------+
| id | name |
+----+------+
| 1 | aaa |
| 2 | bbb |
| 3 | ccc |
| 4 | ddd |
+----+------+
4 rows in set (0.00 sec)

# 模拟元数据锁阻塞
# 会话 1
mysql> lock tables test read;
Query OK, 0 rows affected (0.00 sec)

# 会话 2
mysql> alter table test add c1 varchar();
阻塞中

# 会话 3

mysql> show processlist;
+-------+-------------+---------------------+------+------------------+--------+---------------------------------------------------------------+-------------------------------------+
| Id | User | Host | db | Command | Time | State | Info |
+-------+-------------+---------------------+------+------------------+--------+---------------------------------------------------------------+-------------------------------------+
| 1 | universe_op | 127.0.0.1:28904 | | Sleep | 12 | | |
| 2 | universe_op | 127.0.0.1:28912 | | Sleep | 12 | | |
| 5752 | universe_op | 10.186.64.180:51808 | | Binlog Dump GTID | 605454 | Master has sent all binlog to slave; waiting for more updates | |
| 28452 | root | 10.186.65.110:10756 | test | Sleep | 73 | | |
| 28454 | root | 10.186.64.180:45674 | test | Query | 7 | Waiting for table metadata lock | alter table test add c1 varchar() |
| 28497 | root | 10.186.64.180:47026 | test | Query | 0 | starting | show processlist |
+-------+-------------+---------------------+------+------------------+--------+---------------------------------------------------------------+-------------------------------------+

DDL 一旦被阻塞了,后续针对该表的所有操作都会被阻塞,都会显示 Waiting for table metadata lock

上述情况的解决方案:Kill DDL 操作或 Kill 阻塞 DDL 的会话。

下面对于 DDL 的操作,我们需要获取元数据库锁的阶段有两个方面:DDL 开始之初和 DDL 结束之前。如果是后者,就意味着之前的操作都要回滚,成本相对较高。所以,碰到类似情况,我们一般都会 Kill 阻塞 DDL 的会话。

2. 怎么知道是哪些会话阻塞了DDL?


sys.schema_table_lock_waits
是 MySQL 5.7 引入的,用来定位 DDL 被阻塞的问题。

针对上面这个情况。可以查看
sys.schema_table_lock_waits
的输出。

mysql> select * from sys.schema_table_lock_waits\G
*************************** row ***************************
object_schema: test
object_name: test
waiting_thread_id: 28490
waiting_pid: 28454
waiting_account: root@10.186.64.180
waiting_lock_type: EXCLUSIVE
waiting_lock_duration: TRANSACTION
waiting_query: alter table test add c1 varchar()
waiting_query_secs: 179
waiting_query_rows_affected: 0
waiting_query_rows_examined: 0
blocking_thread_id: 28488
blocking_pid: 28452
blocking_account: root@10.186.65.110
blocking_lock_type: SHARED_READ_ONLY
blocking_lock_duration: TRANSACTION
sql_kill_blocking_query: KILL QUERY 28452
sql_kill_blocking_connection: KILL 28452
*************************** row ***************************
object_schema: test
object_name: test
waiting_thread_id: 28490
waiting_pid: 28454
waiting_account: root@10.186.64.180
waiting_lock_type: EXCLUSIVE
waiting_lock_duration: TRANSACTION
waiting_query: alter table test add c1 varchar()
waiting_query_secs: 179
waiting_query_rows_affected: 0
waiting_query_rows_examined: 0
blocking_thread_id: 28490
blocking_pid: 28454
blocking_account: root@10.186.64.180
blocking_lock_type: SHARED_UPGRADABLE
blocking_lock_duration: TRANSACTION
sql_kill_blocking_query: KILL QUERY 28454
sql_kill_blocking_connection: KILL 28454
rows in set (0.00 sec)

只有一个 alter 操作,却产生了两条记录,而且两条记录的 Kill 对象还不一样。如果对表结构不熟悉或不仔细看记录内容的话,难免会 Kill 错对象。

两条记录的 blocking_lock_type 类型分别为 SHARED_READ_ONLYSHARED_UPGRADABLE。我们需要 Kill 掉的是 SHARED_READ_ONLY

在 DDL 操作被阻塞后,如果后续有多个查询被 DDL 操作堵塞,还会产生 2N 多个条记录。

在定位问题时,这 2N 条记录看起来就比较难以定位了。这个时候,我们需要对上述 2N 条记录进行过滤。过滤的关键是 blocking_lock_type 不等于 SHARED_UPGRADABLE

SHARED_UPGRADABLE 是一个可升级的共享元数据锁,加锁期间,允许并发查询和更新。所以,阻塞 DDL 的不会是 SHARED_UPGRADABLE

针对上面这个场景,我们可以通过下面这个查询来精确地定位出需要 Kill 的会话。

mysql> SELECT sql_kill_blocking_connection FROM sys.schema_table_lock_waits WHERE blocking_lock_type <> 'SHARED_UPGRADABLE' AND waiting_query = 'alter table test add c1 varchar(25)';
+------------------------------+
| sql_kill_blocking_connection |
+------------------------------+
| KILL 28452 |
+------------------------------+
row in set (0.00 sec)

MySQL 5.7 中使用 sys.schema_table_lock_waits 的注意事项


sys.schema_table_lock_waits
视图依赖了一张 MDL 相关的表
performance_schema.metadata_locks
。该表是 MySQL 5.7 引入的,会显示 MDL 的相关信息,包括作用对象、锁的类型及锁的状态等。但在 MySQL 5.7 中,该表默认为空,因为与之相关的 instrument 默认没有开启,MySQL 8.0 才默认开启。

mysql> select * from performance_schema.setup_instruments where name='wait/lock/metadata/sql/mdl';
+----------------------------+---------+-------+
| NAME | ENABLED | TIMED |
+----------------------------+---------+-------+
| wait/lock/metadata/sql/mdl | NO | NO |
+----------------------------+---------+-------+
row in set (0.00 sec)

所以,在 MySQL 5.7 中,如果我们要使用
sys.schema_table_lock_waits
,必须首先开启 MDL 相关的 instrument。

开启方式: 直接修改
performance_schema.setup_instruments
表即可。具体 SQL 如下。

mysql> UPDATE PERFORMANCE_SCHEMA.setup_instruments SET ENABLED = 'YES', TIMED = 'YES' WHERE NAME = 'wait/lock/metadata/sql/mdl';

但这种方式是临时生效,实例重启后,又会恢复为默认值。

建议:同步修改配置文件或者在部署 MySQL 集群时一开始配置文件的参数就修改成功。

[mysqld]
performance-schema-instrument ='wait/lock/metadata/sql/mdl=ON'

总结

  1. 执行 show processlist,如果 DDL 的状态是 Waiting for table metadata lock ,则意味着这个 DDL 被阻塞了。
  2. 定位导致 DDL 被阻塞的会话,常用的方法如下:sys.schema_table_lock_waits
select sql_kill_blocking_connection from sys.schema_table_lock_waits WHERE blocking_lock_type <> 'SHARED_UPGRADABLE' and (waiting_query like 'alter%' OR waiting_query like 'create%' OR waiting_query like 'drop%' OR waiting_query like 'truncate%' OR waiting_query like 'rename%');

这种方法适用于 MySQL 5.7 和 8.0。

注意,MySQL 5.7 中,MDL 相关的 instrument 默认没有打开。

Kill DDL 之前的会话。

select concat('kill',i.trx_mysql_thread_id,';') from information_schema.innodb_trx i, ( select max(time) as max_time from information_schema.processlist where state = 'Waiting for table metadata lock' and (info like 'alter%' OR info like 'create%' OR info like 'drop%' OR info like 'truncate%' OR info like 'rename%')) p WHERE timestampdiff(second, i.trx_started ,now()) > p.max_time;

如果 MySQL 5.7 中 MDL 相关的 instrument 没有打开,可使用该方法。



本文关键字:#MySQL# #阻塞#

文章推荐:

故障分析 | MySQL 升级到 8.0 变慢问题分析

故障分析 | 一条本该记录到慢日志的 SQL 是如何被漏掉的

技术分享 | OceanBase写入限速源码解读

技术分享 | MySQL级联复制下进行大表的字段扩容



关于 SQLE

爱可生开源社区的 SQLE 是一款面向数据库使用者和管理者,支持多场景审核,支持标准化上线流程,原生支持 MySQL 审核且数据库类型可扩展的 SQL 审核工具。

SQLE 获取

类型地址
版本库https://github.com/actiontech/sqle
文档https://actiontech.github.io/sqle-docs-cn/
发布信息https://github.com/actiontech/sqle/releases
数据审核插件开发文档https://actiontech.github.io/sqle-docs-cn/3.modules/3.7_auditplugin/auditplugin_development.html

相关推荐

每天一个编程技巧!掌握这7个神技,代码效率飙升200%

“同事6点下班,你却为改BUG加班到凌晨?不是你不努力,而是没掌握‘偷懒’的艺术!本文揭秘谷歌工程师私藏的7个编程神技,每天1分钟,让你的代码从‘能用’变‘逆天’。文末附《Python高效代码模板》,...

Git重置到某个历史节点(Sourcetree工具)

前言Sourcetree回滚提交和重置当前分支到此次提交的区别?回滚提交是指将改动的代码提交到本地仓库,但未推送到远端仓库的时候。...

git工作区、暂存区、本地仓库、远程仓库的区别和联系

很多程序员天天写代码,提交代码,拉取代码,对git操作非常熟练,但是对git的原理并不甚了解,借助豆包AI,写个文章总结一下。Git的四个核心区域(工作区、暂存区、本地仓库、远程仓库)是版本控制的核...

解锁人生新剧本的密钥:学会让往事退场

开篇:敦煌莫高窟的千年启示在莫高窟321窟的《降魔变》壁画前,讲解员指着斑驳色彩说:"画师刻意保留了历代修补痕迹,因为真正的传承不是定格,而是流动。"就像我们的人生剧本,精彩章节永远...

Reset local repository branch to be just like remote repository HEAD

技术背景在使用Git进行版本控制时,有时会遇到本地分支与远程分支不一致的情况。可能是因为误操作、多人协作时远程分支被更新等原因。这时就需要将本地分支重置为与远程分支的...

Git恢复至之前版本(git恢复到pull之前的版本)

让程序回到提交前的样子:两种解决方法:回退(reset)、反做(revert)方法一:gitreset...

如何将文件重置或回退到特定版本(怎么让文件回到初始状态)

技术背景在使用Git进行版本控制时,经常会遇到需要将文件回退到特定版本的情况。可能是因为当前版本出现了错误,或者想要恢复到之前某个稳定的版本。Git提供了多种方式来实现这一需求。...

git如何正确回滚代码(git命令回滚代码)

方法一,删除远程分支再提交①首先两步保证当前工作区是干净的,并且和远程分支代码一致$gitcocurrentBranch$gitpullorigincurrentBranch$gi...

[git]撤销的相关命令:reset、revert、checkout

基本概念如果不清晰上面的四个概念,请查看廖老师的git教程这里我多说几句:最开始我使用git的时候,我并不明白我为什么写完代码要用git的一些列指令把我的修改存起来。后来用多了,也就明白了为什么。gi...

利用shell脚本将Mysql错误日志保存到数据库中

说明:利用shell脚本将MYSQL的错误日志提取并保存到数据库中步骤:1)创建数据库,创建表CreatedatabaseMysqlCenter;UseMysqlCenter;CREATET...

MySQL 9.3 引入增强的JavaScript支持

MySQL,这一广泛采用的开源关系型数据库管理系统(RDBMS),发布了其9.x系列的第三个更新版本——9.3版,带来了多项新功能。...

python 连接 mysql 数据库(python连接MySQL数据库案例)

用PyMySQL包来连接Python和MySQL。在使用前需要先通过pip来安装PyMySQL包:在windows系统中打开cmd,输入pipinstallPyMySQL ...

mysql导入导出命令(mysql 导入命令)

mysql导入导出命令mysqldump命令的输入是在bin目录下.1.导出整个数据库  mysqldump-u用户名-p数据库名>导出的文件名  mysqldump-uw...

MySQL-SQL介绍(mysql sqlyog)

介绍结构化查询语言是高级的非过程化编程语言,允许用户在高层数据结构上工作。它不要求用户指定对数据的存放方法,也不需要用户了解具体的数据存放方式,所以具有完全不同底层结构的不同数据库系统,可以使用相同...

MySQL 误删除数据恢复全攻略:基于 Binlog 的实战指南

在MySQL的世界里,二进制日志(Binlog)就是我们的"时光机"。它默默记录着数据库的每一个重要变更,就像一位忠实的史官,为我们在数据灾难中提供最后的救命稻草。本文将带您深入掌握如...