Wrong character set info of Query_log_event and the query in Query_log_event constructed by different charsets cause error when slave apply the event.

--disable_warnings

--source include/master-slave.inc

--enable_warnings

# view with chinese when charset not utf.

create table t(c1 int);

SET @@session.character_set_client=gbk;

set @@session.collation_connection=gbk_chinese_ci;

set @@session.collation_server=utf8_general_ci;

create view `收费明细` as select * from t;

drop view `收费明细`;

show tables;

--sync_slave_with_master

connection slave;

show tables;

connection master;

drop table t;

# memory table

SET @@session.character_set_client=utf8;

set @@session.collation_connection=utf8_general_ci;

set @@session.collation_server=utf8_general_ci;

create table `收费明细表`(c1 int) engine=memory;

create view tv as select * from `收费明细表`;

--connection slave

-- source include/stop_slave.inc

--let $rpl_server_number= 1

--source include/rpl_restart_server.inc

# access memory table after restarting server cause binlog 'delete from tableName'

connection master;

SET @@session.character_set_client=gbk;

set @@session.collation_connection=gbk_chinese_ci;

set @@session.collation_server=utf8_general_ci;

select * from tv;

--connection slave

-- source include/start_slave.inc

connection master;

--sync_slave_with_master

# procedure with chinese when charset not utf.

connection master;

delimiter $$;

create procedure 收费明细()

begin

  select 'hello world';

end $$

delimiter ;$$

drop procedure `收费明细`;

connection master;

SET @@session.character_set_client=utf8;

set @@session.collation_connection=utf8_general_ci;

set @@session.collation_server=utf8_general_ci;

drop view tv;

drop table `收费明细表`;

## column comment in chinese.

connection master;

set character_set_client = utf8;

set character_set_connection = utf8;

set character_set_database = utf8;

set character_set_results = utf8;

set character_set_server = utf8;

CREATE TABLE `t1` (

  `id` int(11) NOT NULL,

  `orderType` char(6) NOT NULL DEFAULT '已创建',

  PRIMARY KEY (`id`)

);

show create table t1;

## switch client charset

set character_set_client = latin1;

CREATE TABLE t2 SELECT * FROM t1;

drop table t1;

drop table t2;

--sync_slave_with_master

connection slave;

show tables;

--source include/rpl_end.inc

sql/sql_view.cc:  mysql_create_view 

  /*The identifier parsed by parser would change to system_info character. The table name is in utf8 character.*/

669    append_identifier(thd, &buff, views->table_name,

                      views->table_name_length);

/* The source.str is in character_set_client.*/

685     buff.append(views->source.str, views->source.length); 

log_event.cc:  Query_log_event::Query_log_event(THD* thd_arg, const char* query_arg,...)

/* The Query_log_event store charset of thd's variable.  But the view name is utf8.*/

 4037   int2store(charset, thd_arg->variables.character_set_client->number);

 4038   int2store(charset+2, thd_arg->variables.collation_connection->number);

 4039   int2store(charset+4, thd_arg->variables.collation_server->number);

The character of identifier  parsed by parser is system charset info. The source string may be other character. The view definition constructed by server contains two characters in one string. This problem also exist in procedure.

sql/sp.cc:

1281     log_query.set_charset(system_charset_info);

1283     if (!show_create_sp(thd, &log_query,

1284                        sp->m_type,

1285                        (sp->m_explicit_name ? sp->m_db.str : NULL),  //!these identifiers use system charset.

1286                        (sp->m_explicit_name ? sp->m_db.length : 0),

1287                        sp->m_name.str, sp->m_name.length,

1288                        sp->m_params.str, sp->m_params.length,

1289                        retstr.ptr(), retstr.length(),

1290                        sp->m_body.str, sp->m_body.length, //!the body use character_set_client

1291                        sp->m_chistics, &(thd->lex->definer->user),

1292                        &(thd->lex->definer->host),

1293                        saved_mode))

sql/sql_base.cc

2645 static bool open_table_entry_fini

2667       append_identifier(thd, &query, share->table_name.str,

2668                           share->table_name.length);  //system charset info

    ...

2674       Query_log_event qinfo(thd, query.ptr(), query.length(),

2675                             FALSE, TRUE, TRUE, 0);  //use thd charset info

2676       if (mysql_bin_log.write(&qinfo))

The create table statement generated by server.

sql/sql_insert.cc   select_create::binlog_show_create_table

4365 select_create::binlog_show_create_table  //Query use system charset info