MySQL中的Online DDL

2024-06-03 11:48
文章标签 mysql ddl online database

本文主要是介绍MySQL中的Online DDL,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

MySQL中的Online DDL

记得有一天快下班的时候,一位开发同事找到我说,需要对一个表做变更,数据量据说有上千万,而当时是使用的MySQL版本是5.5,这可如何是好,对于在线业务要求高的情况下,这种需求真是让人头疼。

而在早期的版本中,这种问题就更让人无语了。在Oracle中这个问题解决的较早,当然在很多技术实现细节上,Oracle和MySQL还是蛮大的差距。Oracle中有在线重定义的方案物化视图prebuilt和在线重定义 (r10笔记第25天),而且本身对于一些DDL的操作代价要比MySQL低。不过在碰到添加字段且加默认值的情况,在Exadata上跑性能测试,问题依旧是很棘手。以至于在有些业务中,对某些核心的大表,有些公司是使用视图来达到这种动态的字段扩展而非直接添加字段。这,应该算是一场技术上的硬仗。

这类问题的根本和数据的存储也密不可分。有兴趣可以看看。MySQL和Oracle的添加字段的处理差别 (r10笔记第73天)

MySQL中这类问题有了一种叫OSC的工具之后,情况有了很大的改观。最早是facebook来做的这件事情,后来Percona进行了改变,使用perl实现,因为功能全面,支持的完善,现在基本上成了标准的行业工具。简称pt-osc。

在MySQL 5.5中,这类问题使用pt-osc来处理就很有效了,在MySQL 5.6推出的online DDL中,已经原生支持,在5.7中已经发展很不错了,如此一来,pt-osc的支持算是一种可选的方式。而也可以由此看出,技术上的重大突破会逐步降低维护的复杂度,所以水航船高,各行各业都有相似之处。

pt工具本身的安装部署很简单,可以参考 Percona-toolkit的安装和配置(r8笔记第86天)

简单的使用pt-table-checksu和pt-table-sync可以参考MySQL主从不一致的修复过程(r10笔记第96天)

首先说明不是所有的DDL都会持续很长时间,比如修改表名,这是一个很有意思的操作,无论表大小,操作效率都很高。

比如我们存在一个表 t_user_login_record,数据量2000万。

-rw-rw---- 1 mysql mysql 8840 Oct 13 17:04 t_user_login_record.frm

-rw-rw---- 1 mysql mysql 3162505216 Oct 13 17:09 t_user_login_record.ibd

如果想修改为newtest

> alter table t_user_login_record rename to newtest;

Query OK, 0 rows affected (0.03 sec)

这个过程本质上就是数据字典信息的修改。如果你可以理解的更通俗一点,就是修改文件名。

-rw-rw---- 1 mysql mysql 8840 Oct 13 17:04 newtest.frm

-rw-rw---- 1 mysql mysql 3162505216 Oct 13 17:09 newtest.ibd

MySQL 5.5原生的DDL代价

为什么MySQL5.5中很多DDL操作的代价很高呢。因为很多场景的处理都是在做数据的复制。

比如我们添加一个字段,添加默认值。

alter table newtest add column newcol varchar(10) default '';

MySQL原生的操作就是创建一个临时的表,开始表数据的复制。

-rw-rw---- 1 mysql mysql 8840 Oct 13 17:04 newtest.frm

-rw-rw---- 1 mysql mysql 3162505216 Oct 13 17:09 newtest.ibd

-rw-rw---- 1 mysql mysql 8874 Dec 5 11:25 #sql-2931_4807af.frm

-rw-rw---- 1 mysql mysql 58720256 Dec 5 11:25 #sql-2931_4807af.ibd

在MySQL5.5中,如果在DDL执行的过程中,在另外一个窗口中做一个insert操作,不好意思,这类操作就会阻塞,持续时间会很长。

insert into newtest(game_type,login_time,login_account,cn_master,client_ip) values(1,'2013-08-16 16:22:10','150581500032','572031626','183.128.143.113');

如果查看show processlist的结果,就会发现临时表复制的信息和锁的信息。

State | Info

--------------------------------+--------------------------------------------------------------

Waiting on empty queue | NULL

copy to tmp table | alter table newtest add column newcol varchar(10) default ''

Waiting for table metadata lock | insert into newtest(game_type,login_time,login_account,cn_mas

NULL | show processlist

如果查看show engine innodb status\G的结果,会发现一些很细致的锁信息。

---TRANSACTION 481BF2, not started

MySQL thread id 4721141, OS thread handle 0x7f99780bc700, query id 18882493 localhost root Waiting for table metadata lock

insert into newtest(game_type,login_time,login_account,cn_master,client_ip) values(1,'2013-08-16 16:22:10','150581500032','572031626','183.128.143.113')

---TRANSACTION 4821A2, ACTIVE 1 sec inserting, thread declared inside InnoDB 253

mysql tables in use 2, locked 2

46 lock struct(s), heap size 6960, 6887 row lock(s), undo log entries 6887

MySQL thread id 4720559, OS thread handle 0x7f93710b9700, query id 18881573 localhost root copy to tmp table

alter table newtest add column newcol varchar(10) default ''

TABLE LOCK table `test`.`newtest` trx id 4821A2 lock mode IS

TABLE LOCK table `test`.`#sql-2931_4807af` trx id 4821A2 lock mode IX

TABLE LOCK table `test`.`#sql-2931_4807af` trx id 4821A2 lock mode AUTO-INC

可以看到锁的信息比我们想的要复杂一些。

当然这个阻塞的时长还是很不乐观的,可能十分钟,数十分钟,取决于DDL的时长。

> insert into newtest(game_type,login_time,login_account,cn_master,client_ip) values(1,'2013-08-16 16:22:10','150581500032','572031626','183.128.143.113');

Query OK, 1 row affected (5 min 33.04 sec)

MySQL 5.7中的DDL对比

在MySQL 5.7中差别就很大了,一模一样的操作,在MySQL 5.7中还是创建一个临时数据表的数据复制。

-rw-r----- 1 mysql mysql 8874 Dec 5 16:47 newtest.frm

-rw-r----- 1 mysql mysql 3900702720 Dec 5 17:05 newtest.ibd

-rw-r----- 1 mysql mysql 8840 Dec 5 17:33 #sql-6273_9989e.frm

-rw-r----- 1 mysql mysql 46137344 Dec 5 17:33 #sql-ib276-3638407390.ibd

同样的DML语句全然没有压力。

> insert into newtest(game_type,login_time,login_account,cn_master,client_ip) values(1,'2013-08-16 16:22:10','150581500032','572031626','183.128.143.113');

Query OK, 1 row affected (0.01 sec)

查看show engine innodb status\G的结果就有很大的差别。

mysql tables in use 1, locked 1

0 lock struct(s), heap size 1136, 0 row lock(s)

MySQL thread id 628894, OS thread handle 140140882102016, query id 9565763 localhost root altering table

alter table newtest drop column newcol

Trx read view will not see trx with id >= 909683, sees < 909682 怎么去理解online DDL的一些实现原理呢。我们还是可以使用pt-osc来做。

我们就配置一个用户,在5.7下面的语句有了改进,最好使用create user的方式。

GRANT ALL ON *.* TO 'pt_osc'@'test%' identified by 'pt_osc';

然后使用pt-online-schema-change来完成。这里我们需要给表newtest添加一个索引,基于login_time字段

./pt-online-schema-change --host=10.11.128.99 -u pt_osc -p pt_osc --alter='add index ind_login_time_newtest(login_time)' --print --execute D=test,t=newtest

这个时候看看数据目录,内容就很丰富了。-rw-r----- 1 mysql mysql 8840 Dec 5 17:33 newtest.frm

-rw-r----- 1 mysql mysql 3527409664 Dec 5 17:37 newtest.ibd

-rw-r----- 1 mysql mysql 8840 Dec 5 18:13 _newtest_new.frm

-rw-r----- 1 mysql mysql 15728640 Dec 5 18:13 _newtest_new.ibd

-rw-r----- 1 mysql mysql 1213 Dec 5 18:13 newtest.TRG

-rw-r----- 1 mysql mysql 39 Dec 5 18:13 pt_osc_test_newtest_del.TRN

-rw-r----- 1 mysql mysql 39 Dec 5 18:13 pt_osc_test_newtest_ins.TRN

-rw-r----- 1 mysql mysql 39 Dec 5 18:13 pt_osc_test_newtest_upd.TRN

可以很明显看到创建了3个触发器(针对增删改操作),创建了临时的表复制数据。

命令的部分输出如下:

Altering `test`.`newtest`...

Creating new table...

CREATE TABLE `test`.`_newtest_new` (

`id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键,自增长',

。。。,

PRIMARY KEY (`id`),

KEY `ind_tmp_account1` (`login_account`)

) ENGINE=InnoDB AUTO_INCREMENT=22681849 DEFAULT CHARSET=utf8

Created new table test._newtest_new OK.

Waiting forever for new table `test`.`_newtest_new` to replicate to teststd.test.com...

Altering new table...

ALTER TABLE `test`.`_newtest_new` add index ind_login_time_newtest(login_time)

Altered `test`.`_newtest_new` OK.

2016-12-05T18:13:31 Creating triggers...

CREATE TRIGGER `pt_osc_test_newtest_del` AFTER DELETE ON `test`.`newtest` FOR EACH ROW DELETE IGNORE FROM `test`.`_newtest_new` WHERE `test`.`_newtest_new`.`id` <=> OLD.`id`

。。。创建INSERT,DELETE TRIGGER

2016-12-05T18:13:31 Created triggers OK.

2016-12-05T18:13:31 Copying approximately 22571280 rows...

INSERT LOW_PRIORITY IGNORE INTO `test`.`_newtest_new` (`id`, `game_type`, `login_time`, `login_account`, `cn_master`, `client_ip`) SELECT `id`, `game_type`, `login_time`, `login_account`, `cn_master`, `client_ip` FROM `test`.`newtest` FORCE INDEX(`PRIMARY`) WHERE ((`id` >= ?)) AND ((`id` <= ?)) LOCK IN SHARE MODE /*pt-online-schema-change 5214 copy nibble*/

SELECT /*!40001 SQL_NO_CACHE */ `id` FROM `test`.`newtest` FORCE INDEX(`PRIMARY`) WHERE ((`id` >= ?)) ORDER BY `id` LIMIT ?, 2 /*next chunk boundary*/

Copying `test`.`newtest`: 1% 27:54 remain

Copying `test`.`newtest`: 3% 27:43 remain

Copying `test`.`newtest`: 98% 00:25 remain

2016-12-05T18:45:16 Copied rows OK.

2016-12-05T18:45:16 Analyzing new table...

2016-12-05T18:45:16 Swapping tables...

RENAME TABLE `test`.`newtest` TO `test`.`_newtest_old`, `test`.`_newtest_new` TO `test`.`newtest`

2016-12-05T18:45:16 Swapped original and new tables OK.

2016-12-05T18:45:16 Dropping old table...

DROP TABLE IF EXISTS `test`.`_newtest_old`

2016-12-05T18:45:17 Dropped old table `test`.`_newtest_old` OK.

2016-12-05T18:45:17 Dropping triggers...

DROP TRIGGER IF EXISTS `test`.`pt_osc_test_newtest_del`;

DROP TRIGGER IF EXISTS `test`.`pt_osc_test_newtest_upd`;

DROP TRIGGER IF EXISTS `test`.`pt_osc_test_newtest_ins`;

2016-12-05T18:45:17 Dropped triggers OK.

Successfully altered `test`.`newtest`.

这个过程用Percona的一张图来说明,用流程化的方式来解读。

简单题几个问题来加深对于online DDL的理解。

1.如果创建索引,这个过程中创建的索引是在源表上还是新表上?

答:要简单来论证可以使用strings来解读临时创建的数据表,这里是_newtest_new.frm,新创建的索引ind_login_time_newtest赫然在列。

# strings _newtest_new.frm

PRIMARY

ind_tmp_account1

ind_login_time_newtest

InnoDB ....

2. pt-osc在系统层面文件的变化情况是怎么样的?

答:我们可以去一些临界点来验证。

开始pt-osc的操作时,文件的情况如下。

-rw-r----- 1 mysql mysql 8840 Dec 5 17:33 newtest.frm

-rw-r----- 1 mysql mysql 3527409664 Dec 5 18:36 newtest.ibd

-rw-r----- 1 mysql mysql 8840 Dec 5 18:13 _newtest_new.frm

-rw-r----- 1 mysql mysql 4345298944 Dec 5 18:45 _newtest_new.ibd

-rw-r----- 1 mysql mysql 1213 Dec 5 18:13 newtest.TRG

-rw-r----- 1 mysql mysql 39 Dec 5 18:13 pt_osc_test_newtest_del.TRN

-rw-r----- 1 mysql mysql 39 Dec 5 18:13 pt_osc_test_newtest_ins.TRN

-rw-r----- 1 mysql mysql 39 Dec 5 18:13 pt_osc_test_newtest_upd.TRN

在变更完成前的一瞬间,文件情况如下,可以看到newtest.ibd和_newtest_new.ibd的切换。

-rw-r----- 1 mysql mysql 8840 Dec 5 17:33 newtest.frm

-rw-r----- 1 mysql mysql 3527409664 Dec 5 18:36 newtest.ibd

-rw-r----- 1 mysql mysql 8840 Dec 5 18:13 _newtest_new.frm

-rw-r----- 1 mysql mysql 4345298944 Dec 5 18:45 _newtest_new.ibd

-rw-r----- 1 mysql mysql 1213 Dec 5 18:13 newtest.TRG

-rw-r----- 1 mysql mysql 39 Dec 5 18:13 pt_osc_test_newtest_del.TRN

-rw-r----- 1 mysql mysql 39 Dec 5 18:13 pt_osc_test_newtest_ins.TRN

-rw-r----- 1 mysql mysql 39 Dec 5 18:13 pt_osc_test_newtest_upd.TRN

再次查看,触发器都会一一删除。

-rw-r----- 1 mysql mysql 8840 Dec 5 18:13 newtest.frm

-rw-r----- 1 mysql mysql 4353687552 Dec 5 18:45 newtest.ibd

通过这个过程可以加深对于online DDL的实现原理的理解,不过MySQL 5.7中原生的online DDL原理和pt-osc还是有一些差别,仅仅作为一个参考。

所测试的场景都是使用了默认的选项copy而非inplace

ALTER TABLE的补充语法为:ALGORITHM [=] {DEFAULT|INPLACE|COPY}

对于online DDL的操作,更多的细节稍后再来一篇继续补充完善。

欢迎关注我的公众号(jianrong-notes),真知灼见谈不上,重在技术分享交流。

本文为头条号作者发布,不代表今日头条立场。

这篇关于MySQL中的Online DDL的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1026906

相关文章

一文详解MySQL如何设置自动备份任务

《一文详解MySQL如何设置自动备份任务》设置自动备份任务可以确保你的数据库定期备份,防止数据丢失,下面我们就来详细介绍一下如何使用Bash脚本和Cron任务在Linux系统上设置MySQL数据库的自... 目录1. 编写备份脚本1.1 创建并编辑备份脚本1.2 给予脚本执行权限2. 设置 Cron 任务2

SQL Server修改数据库名及物理数据文件名操作步骤

《SQLServer修改数据库名及物理数据文件名操作步骤》在SQLServer中重命名数据库是一个常见的操作,但需要确保用户具有足够的权限来执行此操作,:本文主要介绍SQLServer修改数据... 目录一、背景介绍二、操作步骤2.1 设置为单用户模式(断开连接)2.2 修改数据库名称2.3 查找逻辑文件名

SQL Server数据库死锁处理超详细攻略

《SQLServer数据库死锁处理超详细攻略》SQLServer作为主流数据库管理系统,在高并发场景下可能面临死锁问题,影响系统性能和稳定性,这篇文章主要给大家介绍了关于SQLServer数据库死... 目录一、引言二、查询 Sqlserver 中造成死锁的 SPID三、用内置函数查询执行信息1. sp_w

canal实现mysql数据同步的详细过程

《canal实现mysql数据同步的详细过程》:本文主要介绍canal实现mysql数据同步的详细过程,本文通过实例图文相结合给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的... 目录1、canal下载2、mysql同步用户创建和授权3、canal admin安装和启动4、canal

SQL中JOIN操作的条件使用总结与实践

《SQL中JOIN操作的条件使用总结与实践》在SQL查询中,JOIN操作是多表关联的核心工具,本文将从原理,场景和最佳实践三个方面总结JOIN条件的使用规则,希望可以帮助开发者精准控制查询逻辑... 目录一、ON与WHERE的本质区别二、场景化条件使用规则三、最佳实践建议1.优先使用ON条件2.WHERE用

MySQL存储过程之循环遍历查询的结果集详解

《MySQL存储过程之循环遍历查询的结果集详解》:本文主要介绍MySQL存储过程之循环遍历查询的结果集,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录前言1. 表结构2. 存储过程3. 关于存储过程的SQL补充总结前言近来碰到这样一个问题:在生产上导入的数据发现

MySQL 衍生表(Derived Tables)的使用

《MySQL衍生表(DerivedTables)的使用》本文主要介绍了MySQL衍生表(DerivedTables)的使用,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学... 目录一、衍生表简介1.1 衍生表基本用法1.2 自定义列名1.3 衍生表的局限在SQL的查询语句select

MySQL 横向衍生表(Lateral Derived Tables)的实现

《MySQL横向衍生表(LateralDerivedTables)的实现》横向衍生表适用于在需要通过子查询获取中间结果集的场景,相对于普通衍生表,横向衍生表可以引用在其之前出现过的表名,本文就来... 目录一、横向衍生表用法示例1.1 用法示例1.2 使用建议前面我们介绍过mysql中的衍生表(From子句

六个案例搞懂mysql间隙锁

《六个案例搞懂mysql间隙锁》MySQL中的间隙是指索引中两个索引键之间的空间,间隙锁用于防止范围查询期间的幻读,本文主要介绍了六个案例搞懂mysql间隙锁,具有一定的参考价值,感兴趣的可以了解一下... 目录概念解释间隙锁详解间隙锁触发条件间隙锁加锁规则案例演示案例一:唯一索引等值锁定存在的数据案例二:

MySQL JSON 查询中的对象与数组技巧及查询示例

《MySQLJSON查询中的对象与数组技巧及查询示例》MySQL中JSON对象和JSON数组查询的详细介绍及带有WHERE条件的查询示例,本文给大家介绍的非常详细,mysqljson查询示例相关知... 目录jsON 对象查询1. JSON_CONTAINS2. JSON_EXTRACT3. JSON_TA