MySQL的match函数在sp中使用的BUG解析

未来很美好

一、问题发现

在一次开发中在sp中使用MySQL PREPARE以后，使用match AGAINST语句作为prepare stmt的参数后，发现执行第二遍call会导致数据库crash，于是开始动手调查问题发生的原因。

注：本次使用的 MySQL 数据库版本为最新的debug版本。

SQL语句示例：

1. CREATE TABLE t1 (a INT, b VARCHAR(10));
2. DELIMITER $$
3. CREATE PROCEDURE p1()
4. begin
5.   declare a VARCHAR(200);
6.   declare b TEXT;
7.   set a = 'Only MyISAM tables';
8.   set b ='support collections';
9.   set @bb := match(a,b) AGAINST ('collections');   
10.   prepare stmt1 from 'select * from t1 where ?';   
11.   execute stmt1 using @bb;  
12. end$$
13. DELIMITER ;
14. 执行结果：
15. mysql> call p1;
16. ERROR 1210 (HY000): Incorrect arguments to MATCH
17. mysql> call p1; 这里发现代码crash了
18. ERROR 2013 (HY000): Lost connection to MySQL server during query

复制代码

二、问题调查过程

1、首先查看错误堆栈信息，可以看到Item_func_match::val_real函数的item->real_item()->type()不等于FIELD_ITEM引起的，打印堆栈看了一下，此时的item->real_item()为Item_splocal，明显不是FIELD_ITEM。

1. #0  __GI_raise (sig=sig@entry=6) at ../sysdeps/unix/sysv/linux/raise.c:50
2. #1  0x00007ffff7568859 in __GI_abort () at abort.c:79
3. #2  0x00007ffff7568729 in __assert_fail_base (fmt=0x7ffff76fe588 "%s%s%s:%u: %s%sAssertion `%s' failed.\n%n",
4.     assertion=0x55555bd2e340 "std::all_of(args, args + arg_count, [](const Item *item) { return item->real_item()->type() == FIELD_ITEM; })", file=0x55555bd2a9e0 "/mysql/sql/item_func.cc",
5.     line=9769, function=<optimized out>) at assert.c:92
6. #3  0x00007ffff7579fd6 in __GI___assert_fail (
7.     assertion=0x55555bd2e340 "std::all_of(args, args + arg_count, [](const Item *item) { return item->real_item()->type() == FIELD_ITEM; })", file=0x55555bd2a9e0 "/mysql/sql/item_func.cc",
8.     line=9769, function=0x55555bd2e300 "virtual double Item_func_match::val_real()") at assert.c:101
9. #4  0x0000555558f9e17e in Item_func_match::val_real (this=0x7fff2cc86928) 这里导致的crash
10.     at /mysql/sql/item_func.cc:9769
11. #5  0x0000555558f97f7e in Item_func_set_user_var::check (this=0x7fff2cc88200, use_result_field=false)
12.     at /mysql/sql/item_func.cc:8238
13. #6  0x00005555592d74d3 in set_var_user::check (this=0x7fff2cc88388)
14.     at /mysql/sql/set_var.cc:1874
15. #7  0x00005555592d5cd6 in sql_set_variables (thd=0x7fff2c001050, var_list=0x7fff2cc87210, opened=true)
16.     at /mysql/sql/set_var.cc:1442
17. #8  0x00005555594d89ed in mysql_execute_command (thd=0x7fff2c001050, first_level=false)
18.     at /mysql/sql/sql_parse.cc:4051
19. #9  0x000055555930c7a8 in sp_instr_stmt::exec_core (this=0x7fff2cc883d8, thd=0x7fff2c001050,
20.     nextp=0x7fffe02ed8b4) at /mysql/sql/sp_instr.cc:1039
21. #10 0x000055555930ae0b in sp_lex_instr::reset_lex_and_exec_core (this=0x7fff2cc883d8, thd=0x7fff2c001050,
22.     nextp=0x7fffe02ed8b4, open_tables=false) at /mysql/sql/sp_instr.cc:457
23. #11 0x000055555930bc74 in sp_lex_instr::validate_lex_and_execute_core (this=0x7fff2cc883d8, thd=0x7fff2c001050,
24.     nextp=0x7fffe02ed8b4, open_tables=false) at /mysql/sql/sp_instr.cc:771
25. #12 0x000055555930c3ad in sp_instr_stmt::execute (this=0x7fff2cc883d8, thd=0x7fff2c001050, nextp=0x7fffe02ed8b4)
26.     at /mysql/sql/sp_instr.cc:956
27. #13 0x00005555592fa772 in sp_head::execute (this=0x7fff2cc76da0, thd=0x7fff2c001050, merge_da_on_success=true)
28.     at /mysql/sql/sp_head.cc:2279
29. #14 0x00005555592fcec2 in sp_head::execute_procedure (this=0x7fff2cc76da0, thd=0x7fff2c001050, args=0x0)
30.     at /mysql/sql/sp_head.cc:2995
31. #15 0x00005555593661c9 in do_execute_sp (thd=0x7fff2c001050, sp=0x7fff2cc76da0, args=0x0)
32.     at /mysql/sql/sql_call.cc:86

复制代码

2、要想获取sp参数的实际item，应该调用this_item()方法，但是也许作者本来就不想让match支持sp参数，因此这里的写法是对的。但是本来代码不应该运行到这里，因为本来应该直接报错。

1. double Item_func_match::val_real() {
2.   assert(fixed);
3.   assert(!has_rollup_expr());
4.   assert(std::all_of(args, args + arg_count, [](const Item *item) {
5.     return item->real_item()->type() == FIELD_ITEM; ==>这里的item->real_item()->type()说明不支持Item_splocal
6.   }));

复制代码

3、接着继续调查，查看第一次报错的地方的代码，找到Item_func_match::fix_fields，看到了第一次报错的地方的代码item->type() != Item::FIELD_ITEM，因此代码运行应该在这里报错。但是为何第二次执行会运行到Item_func_match::val_real而不是在Item_func_match::fix_fields就直接报错返回呢？仔细查看下面的代码，发现下面的代码有1个地方有错误。

1. bool Item_func_match::fix_fields(THD *thd, Item **ref) {
2.   if (Item_func::fix_fields(thd, ref) || fix_func_arg(thd, &against) ||
3.   上面这里Item_func::fix_fields执行完后使fixed=true
4.   但是如果后面有任何报错的地方导致返回的话，这个值没有修改回false
5.   会导致第二次call sp不会再次执行Item_func_match::fix_fields。
6.       !against->const_for_execution()) {
7.     thd->mark_used_columns = save_mark_used_columns;
8.     my_error(ER_WRONG_ARGUMENTS, MYF(0), "AGAINST");
9.     return true;
10.   }
11.   for (uint i = 0; i < arg_count; i++) {
12.     item = args[i] = args[i]->real_item();
13.     if (item->type() != Item::FIELD_ITEM ||
14.         /* Cannot use FTS index with outer table field */
15.         item->is_outer_reference()) {
16.       my_error(ER_WRONG_ARGUMENTS, MYF(0), "MATCH");
17.       return true;
18.     }

复制代码

三、问题解决方案

通过以上代码解析后作如下修改，正确给fixed赋值，这样就可以保证每次call sp的时候如果遇到报错再次运行还会重新执行fix_fields。

1. bool Item_func_match::fix_fields(THD *thd, Item **ref) {
2.   if (Item_func::fix_fields(thd, ref) || fix_func_arg(thd, &against) ||
3.       !against->const_for_execution()) {
4.     fixed = false; ==>这里需要重新把fixed赋值为false
5.     thd->mark_used_columns = save_mark_used_columns;
6.     my_error(ER_WRONG_ARGUMENTS, MYF(0), "AGAINST");
7.     return true;
8.   }
9.   thd->mark_used_columns = save_mark_used_columns;
10.   fixed = false;  ==>这里需要重新把fixed赋值为false
11.     for (uint i = 0; i < arg_count; i++) {
12.     item = args[i] = args[i]->real_item()->this_item();
13.     if (item->type() != Item::FIELD_ITEM ||
14.         /* Cannot use FTS index with outer table field */
15.         item->is_outer_reference()) {
16.       my_error(ER_WRONG_ARGUMENTS, MYF(0), "MATCH");
17.       return true;
18.     }
19.     中间省略
20.    fixed = true; ==>最后没有问题了再赋值为true
21.    return false;

复制代码

现在重新执行call sp，没有问题了。

1. mysql> call p1;
2. ERROR 1210 (HY000): Incorrect arguments to MATCH
3. mysql> call p1;
4. ERROR 1210 (HY000): Incorrect arguments to MATCH

复制代码

四、问题总结

本次只是解决了match的fix_fields问题，但是如果想让 match 支持 sp 的参数，即Item_splocal的参数的话，代码里面还要做相应修改，包括set @bb := match(a,b) AGAINST ('collections'); 这里面生成的Item_func_match会在这句执行完以后被 cleanup 掉，等到下一句 prepare 想再次使用它的时候会因为找不到该item发生问题，这个是重构 match函数支持 sp 参数需要注意的点。

Enjoy GreatSQL
来源:https://www.cnblogs.com/greatsql/p/17527756.html
免责声明：由于采集信息均来自互联网，如果侵犯了您的权益，请联系我们【E-Mail:cb@itdo.tech】 我们会及时删除侵权内容，谢谢合作！