mirror of
https://github.com/MariaDB/server.git
synced 2025-01-20 14:02:32 +01:00
b42c29cfe3
The problem is issued because we set wrong start position and stop position of query string into binlog. That two values are stored as part of head info of query string. When we parse binlog, we first get position values then get the query string according position values. But seems that two values are not calculated correctly after the parse of Yacc. We don't want to touch so much of yacc because it may influence other codes. So just add one space after 'INTO' key word when parsing. This can easily resolve the problem. mysql-test/suite/rpl/r/rpl_loaddatalocal.result: Test result mysql-test/suite/rpl/t/rpl_loaddatalocal.test: Test case sql/log_event.cc: Add space after 'INTO'.
100 lines
3 KiB
Text
100 lines
3 KiB
Text
# See if "LOAD DATA LOCAL INFILE" is well replicated
|
|
# (LOAD DATA LOCAL INFILE is not written to the binlog
|
|
# the same way as LOAD DATA INFILE : Append_blocks are smaller).
|
|
# In MySQL 4.0 <4.0.12 there were 2 bugs with LOAD DATA LOCAL INFILE :
|
|
# - the loaded file was not written entirely to the master's binlog,
|
|
# only the first 4KB, 8KB or 16KB usually.
|
|
# - the loaded file's first line was not written entirely to the
|
|
# master's binlog (1st char was absent)
|
|
source include/master-slave.inc;
|
|
|
|
create table t1(a int);
|
|
let $1=10000;
|
|
disable_query_log;
|
|
set SQL_LOG_BIN=0;
|
|
while ($1)
|
|
{
|
|
insert into t1 values(1);
|
|
dec $1;
|
|
}
|
|
set SQL_LOG_BIN=1;
|
|
enable_query_log;
|
|
let $MYSQLD_DATADIR= `select @@datadir`;
|
|
--replace_result $MYSQLD_DATADIR MYSQLD_DATADIR
|
|
eval select * into outfile '$MYSQLD_DATADIR/rpl_loaddatalocal.select_outfile' from t1;
|
|
#This will generate a 20KB file, now test LOAD DATA LOCAL
|
|
truncate table t1;
|
|
--replace_result $MYSQLD_DATADIR MYSQLD_DATADIR
|
|
eval load data local infile '$MYSQLD_DATADIR/rpl_loaddatalocal.select_outfile' into table t1;
|
|
--remove_file $MYSQLD_DATADIR/rpl_loaddatalocal.select_outfile
|
|
save_master_pos;
|
|
connection slave;
|
|
sync_with_master;
|
|
select a,count(*) from t1 group by a;
|
|
connection master;
|
|
drop table t1;
|
|
save_master_pos;
|
|
connection slave;
|
|
sync_with_master;
|
|
|
|
# End of 4.1 tests
|
|
|
|
#
|
|
# Now let us test how well we replicate LOAD DATA LOCAL in situation when
|
|
# we met duplicates in tables to which we are adding rows.
|
|
# (It supposed that LOAD DATA LOCAL ignores such errors)
|
|
#
|
|
connection master;
|
|
create table t1(a int);
|
|
insert into t1 values (1), (2), (2), (3);
|
|
--replace_result $MYSQLD_DATADIR MYSQLD_DATADIR
|
|
eval select * into outfile '$MYSQLD_DATADIR/rpl_loaddatalocal.select_outfile' from t1;
|
|
drop table t1;
|
|
create table t1(a int primary key);
|
|
--replace_result $MYSQLD_DATADIR MYSQLD_DATADIR
|
|
eval load data local infile '$MYSQLD_DATADIR/rpl_loaddatalocal.select_outfile' into table t1;
|
|
--remove_file $MYSQLD_DATADIR/rpl_loaddatalocal.select_outfile
|
|
SELECT * FROM t1 ORDER BY a;
|
|
save_master_pos;
|
|
connection slave;
|
|
sync_with_master;
|
|
SELECT * FROM t1 ORDER BY a;
|
|
connection master;
|
|
drop table t1;
|
|
save_master_pos;
|
|
connection slave;
|
|
sync_with_master;
|
|
|
|
|
|
#
|
|
# Bug22504 load data infile sql statement in replication architecture get error
|
|
#
|
|
--echo ==== Bug22504 Initialize ====
|
|
|
|
--echo [on master]
|
|
--connection master
|
|
|
|
SET sql_mode='ignore_space';
|
|
CREATE TABLE t1(a int);
|
|
insert into t1 values (1), (2), (3), (4);
|
|
--replace_result $MYSQLD_DATADIR MYSQLD_DATADIR
|
|
eval select * into outfile '$MYSQLD_DATADIR/rpl_loaddatalocal.select_outfile' from t1;
|
|
truncate table t1;
|
|
--replace_result $MYSQLD_DATADIR MYSQLD_DATADIR
|
|
eval load data local infile '$MYSQLD_DATADIR/rpl_loaddatalocal.select_outfile' into table t1;
|
|
--remove_file $MYSQLD_DATADIR/rpl_loaddatalocal.select_outfile
|
|
SELECT * FROM t1 ORDER BY a;
|
|
|
|
--echo [on slave]
|
|
sync_slave_with_master;
|
|
SELECT * FROM t1 ORDER BY a;
|
|
|
|
--echo ==== Clean up ====
|
|
|
|
--echo [on master]
|
|
connection master;
|
|
DROP TABLE t1;
|
|
|
|
--echo [on slave]
|
|
sync_slave_with_master;
|
|
|