~drizzle-trunk/drizzle/development

load data infile '../std_data_ln/rpl_loaddata2.dat' into table t2 fields terminated by ',' optionally enclosed by '%' escaped by '@' lines terminated by '\n##\n' starting by '>' ignore 1 lines;

create table t3 (day date,id int(9),category enum('a','b','c'),name varchar(60));

insert into t3 select * from t2;

save_master_pos;

connection slave;

sync_with_master;

select * from t1;

select * from t3;

connection master;

drop table t1;

drop table t2;

drop table t3;

create table t1(a int, b int, unique(b));

save_master_pos;

connection slave;

sync_with_master;

# See if slave stops when there's a duplicate entry for key error in LOAD DATA

insert into t1 values(1,10);

connection master;

load data infile '../std_data_ln/rpl_loaddata.dat' into table t1;

save_master_pos;

connection slave;

# The SQL slave thread should be stopped now.

--source include/wait_for_slave_sql_to_stop.inc

# Skip the bad event and see if error is cleared in SHOW SLAVE STATUS by START

# SLAVE, even though we are not executing any event (as sql_slave_skip_counter

# takes us directly to the end of the relay log).

set global sql_slave_skip_counter=1;

start slave;

sync_with_master;

--replace_result $MASTER_MYPORT MASTER_PORT

--replace_column 1 # 8 # 9 # 16 # 23 # 33 #

--query_vertical show slave status;

# Trigger error again to test CHANGE MASTER

connection master;

set sql_log_bin=0;

delete from t1;

set sql_log_bin=1;

load data infile '../std_data_ln/rpl_loaddata.dat' into table t1;

save_master_pos;

connection slave;

# The SQL slave thread should be stopped now.

# Exec_Master_Log_Pos should point to the start of Execute event

# for last load data.

--source include/wait_for_slave_sql_to_stop.inc

# CHANGE MASTER and see if error is cleared in SHOW SLAVE STATUS.

stop slave;

change master to master_user='test';

change master to master_user='root';

--replace_result $MASTER_MYPORT MASTER_PORT

--replace_column 1 # 8 # 9 # 16 # 23 # 33 #

--query_vertical show slave status;

# Trigger error again to test RESET SLAVE

100

101

set global sql_slave_skip_counter=1;

102

start slave;

103

sync_with_master;

104

connection master;

105

set sql_log_bin=0;

106

delete from t1;

107

set sql_log_bin=1;

108

load data infile '../std_data_ln/rpl_loaddata.dat' into table t1;

109

save_master_pos;

110

connection slave;

111

# The SQL slave thread should be stopped now.

112

--source include/wait_for_slave_sql_to_stop.inc

113

114

# RESET SLAVE and see if error is cleared in SHOW SLAVE STATUS.

115

stop slave;

116

reset slave;

117

--replace_result $MASTER_MYPORT MASTER_PORT

118

--replace_column 1 # 8 # 9 # 16 # 23 # 33 #

119

--query_vertical show slave status;

120

121

# Finally, see if logging is done ok on master for a failing LOAD DATA INFILE

122

123

connection master;

124

reset master;

125

eval create table t2 (day date,id int(9),category enum('a','b','c'),name varchar(60),

126

unique(day)) engine=$engine_type; # no transactions

127

--error ER_DUP_ENTRY

128

load data infile '../std_data_ln/rpl_loaddata2.dat' into table t2 fields

129

terminated by ',' optionally enclosed by '%' escaped by '@' lines terminated by

130

'\n##\n' starting by '>' ignore 1 lines;

131

select * from t2;

132

save_master_pos;

133

connection slave;

134

start slave;

135

sync_with_master;

136

select * from t2;

137

138

# verify that if no error on slave, this is an error

139

140

alter table t2 drop key day;

141

connection master;

142

delete from t2;

143

--error ER_DUP_ENTRY

144

load data infile '../std_data_ln/rpl_loaddata2.dat' into table t2 fields

145

terminated by ',' optionally enclosed by '%' escaped by '@' lines terminated by

146

'\n##\n' starting by '>' ignore 1 lines;

147

connection slave;

148

--source include/wait_for_slave_sql_to_stop.inc

149

drop table t2;

150

connection master;

151

drop table t2;

152

drop table t1;

153

154

# BUG#17233 LOAD DATA INFILE: failure causes mysqld dbug_assert, binlog not flushed

155

CREATE TABLE t1 (word CHAR(20) NOT NULL PRIMARY KEY) ENGINE=INNODB;

156

157

--error ER_DUP_ENTRY

158

LOAD DATA INFILE "../std_data_ln/words.dat" INTO TABLE t1;

159

160

--disable_warnings

161

DROP TABLE IF EXISTS t1;

162

--enable_warnings

163

164

# End of 4.1 tests

Older »