[tomato.git] / release / src / router / mysql / mysql-test / suite / rpl / r / rpl_loaddata_concurrent.result
| blob | d1c7bf65624ec6191991f3e198c1835cd1e8f170 |
1 CREATE TABLE t1 (c1 char(50));
2 LOAD DATA INFILE '../../std_data/words.dat' INTO TABLE t1;
3 LOAD DATA CONCURRENT INFILE '../../std_data/words.dat' INTO TABLE t1;
4 show binlog events from <binlog_start>;
5 Log_name Pos Event_type Server_id End_log_pos Info
6 master-bin.000001 # Query # # use `test`; CREATE TABLE t1 (c1 char(50))
7 master-bin.000001 # Begin_load_query # # ;file_id=#;block_len=#
8 master-bin.000001 # Execute_load_query # # use `test`; LOAD DATA INFILE '../../std_data/words.dat' INTO TABLE `t1` FIELDS TERMINATED BY '\t' ENCLOSED BY '' ESCAPED BY '\\' LINES TERMINATED BY '\n' (`c1`) ;file_id=#
9 master-bin.000001 # Begin_load_query # # ;file_id=#;block_len=#
10 master-bin.000001 # Execute_load_query # # use `test`; LOAD DATA CONCURRENT INFILE '../../std_data/words.dat' INTO TABLE `t1` FIELDS TERMINATED BY '\t' ENCLOSED BY '' ESCAPED BY '\\' LINES TERMINATED BY '\n' (`c1`) ;file_id=#
11 DROP TABLE t1;
12 include/master-slave.inc
13 [connection master]
14 select last_insert_id();
15 last_insert_id()
16 0
17 create table t1(a int not null auto_increment, b int, primary key(a) );
18 load data CONCURRENT infile '../../std_data/rpl_loaddata.dat' into table t1;
19 select last_insert_id();
20 last_insert_id()
21 1
22 create temporary table t2 (day date,id int(9),category enum('a','b','c'),name varchar(60));
23 load data CONCURRENT infile '../../std_data/rpl_loaddata2.dat' into table t2 fields terminated by ',' optionally enclosed by '%' escaped by '@' lines terminated by '\n##\n' starting by '>' ignore 1 lines;
24 create table t3 (day date,id int(9),category enum('a','b','c'),name varchar(60));
25 insert into t3 select * from t2;
26 select * from t1;
27 a b
28 1 10
29 2 15
30 select * from t3;
31 day id category name
32 2003-02-22 2461 b a a a @ % \b ' " a
33 2003-03-22 2161 c asdf
34 2003-03-22 2416 a bbbbb
35 drop table t1;
36 drop table t2;
37 drop table t3;
38 create table t1(a int, b int, unique(b));
39 insert into t1 values(1,10);
40 load data CONCURRENT infile '../../std_data/rpl_loaddata.dat' into table t1;
41 call mtr.add_suppression("Slave SQL.*Error .Duplicate entry .10. for key .b.. on query.* Error_code: 1062");
42 call mtr.add_suppression("Slave SQL.*Query caused different errors on master and slave.*Error on master:.*error code=1062.*Error on slave:.*Error_code: 0");
43 include/wait_for_slave_sql_error_and_skip.inc [errno=1062]
44 include/check_slave_no_error.inc
45 set sql_log_bin=0;
46 delete from t1;
47 set sql_log_bin=1;
48 load data CONCURRENT infile '../../std_data/rpl_loaddata.dat' into table t1;
49 include/wait_for_slave_sql_error.inc [errno=1062]
50 include/stop_slave_io.inc
51 change master to master_user='test';
52 change master to master_user='root';
53 include/check_slave_no_error.inc
54 set global sql_slave_skip_counter=1;
55 start slave;
56 set sql_log_bin=0;
57 delete from t1;
58 set sql_log_bin=1;
59 load data CONCURRENT infile '../../std_data/rpl_loaddata.dat' into table t1;
60 include/wait_for_slave_sql_error.inc [errno=1062]
61 stop slave;
62 reset slave;
63 include/check_slave_no_error.inc
64 reset master;
65 create table t2 (day date,id int(9),category enum('a','b','c'),name varchar(60),
66 unique(day)) engine=MyISAM;
67 load data CONCURRENT infile '../../std_data/rpl_loaddata2.dat' into table t2 fields
68 terminated by ',' optionally enclosed by '%' escaped by '@' lines terminated by
69 '\n##\n' starting by '>' ignore 1 lines;
70 ERROR 23000: Duplicate entry '2003-03-22' for key 'day'
71 select * from t2;
72 day id category name
73 2003-02-22 2461 b a a a @ % \b ' " a
74 2003-03-22 2161 c asdf
75 start slave;
76 select * from t2;
77 day id category name
78 2003-02-22 2461 b a a a @ % \b ' " a
79 2003-03-22 2161 c asdf
80 alter table t2 drop key day;
81 delete from t2;
82 load data CONCURRENT infile '../../std_data/rpl_loaddata2.dat' into table t2 fields
83 terminated by ',' optionally enclosed by '%' escaped by '@' lines terminated by
84 '\n##\n' starting by '>' ignore 1 lines;
85 ERROR 23000: Duplicate entry '2003-03-22' for key 'day'
86 include/wait_for_slave_sql_to_stop.inc
87 drop table t1, t2;
88 include/stop_slave_io.inc
89 drop table t1, t2;
90 CREATE TABLE t1 (word CHAR(20) NOT NULL PRIMARY KEY) ENGINE=INNODB;
91 LOAD DATA CONCURRENT INFILE "../../std_data/words.dat" INTO TABLE t1;
92 ERROR 23000: Duplicate entry 'Aarhus' for key 'PRIMARY'
93 DROP TABLE IF EXISTS t1;
94 include/rpl_reset.inc
95 drop database if exists b48297_db1;
96 drop database if exists b42897_db2;
97 create database b48297_db1;
98 create database b42897_db2;
99 use b48297_db1;
100 CREATE TABLE t1 (c1 VARCHAR(256)) engine=MyISAM;;
101 use b42897_db2;
102 ### assertion: works with cross-referenced database
103 LOAD DATA CONCURRENT LOCAL INFILE 'MYSQLTEST_VARDIR/std_data/loaddata5.dat' INTO TABLE b48297_db1.t1;
104 use b48297_db1;
105 ### assertion: works with fully qualified name on current database
106 LOAD DATA CONCURRENT LOCAL INFILE 'MYSQLTEST_VARDIR/std_data/loaddata5.dat' INTO TABLE b48297_db1.t1;
107 ### assertion: works without fully qualified name on current database
108 LOAD DATA CONCURRENT LOCAL INFILE 'MYSQLTEST_VARDIR/std_data/loaddata5.dat' INTO TABLE t1;
109 ### create connection without default database
110 ### connect (conn2,localhost,root,,*NO-ONE*);
111 ### assertion: works without stating the default database
112 LOAD DATA CONCURRENT LOCAL INFILE 'MYSQLTEST_VARDIR/std_data/loaddata5.dat' INTO TABLE b48297_db1.t1;
113 ### disconnect and switch back to master connection
114 use b48297_db1;
115 include/diff_tables.inc [master:b48297_db1.t1, slave:b48297_db1.t1]
116 DROP DATABASE b48297_db1;
117 DROP DATABASE b42897_db2;
118 include/rpl_reset.inc
119 use test;
120 CREATE TABLE t1 (`key` TEXT, `text` TEXT);
121 LOAD DATA INFILE '../../std_data/loaddata2.dat' REPLACE INTO TABLE `t1` FIELDS TERMINATED BY ',';
122 SELECT * FROM t1;
123 key text
124 Field A 'Field B'
125 Field 1 'Field 2'
126 Field 3 'Field 4'
127 'Field 5' 'Field 6'
128 Field 6 'Field 7'
129 DROP TABLE t1;
130 include/rpl_end.inc