release/src/router/mysql/mysql-test/suite/rpl/t/rpl_row_sp005.test

   1 #############################################################################
   2 # Original Author: JBM                                                      #
   3 # Original Date: Aug/15/2005                                                #
   4 # Updated: Aug/29/2005: Removed sleeps                                      #
   5 #############################################################################
   6 # Test: Tests SPs with cursors, flow logic, and alter sp. In addition the   #
   7 #       tests SPs with insert and update operations.                        #
   8 #############################################################################
   9 # 2006-02-08 By JBM added ORDER BY for use with NDB engine
  10 #############################################################################
  11
  12 # Includes
  13 -- source include/have_binlog_format_row.inc
  14 -- source include/master-slave.inc
  15
  16
  17 # Begin clean up test section
  18 connection master;
  19 --disable_warnings
  20 DROP PROCEDURE IF EXISTS test.p1;
  21 DROP PROCEDURE IF EXISTS test.p2;
  22 DROP TABLE IF EXISTS test.t2;
  23 DROP TABLE IF EXISTS test.t1;
  24 DROP TABLE IF EXISTS test.t3;
  25 --enable_warnings
  26 # End of cleanup
  27
  28 # Begin test section 1
  29 CREATE TABLE IF NOT EXISTS test.t1(id INT, data CHAR(16),PRIMARY KEY(id));
  30 CREATE TABLE IF NOT EXISTS test.t2(id2 INT,PRIMARY KEY(id2));
  31 CREATE TABLE IF NOT EXISTS test.t3(id3 INT,PRIMARY KEY(id3), c CHAR(16));
  32
  33 delimiter |;
  34 CREATE PROCEDURE test.p1()
  35 BEGIN
  36 DECLARE done INT DEFAULT 0;
  37   DECLARE spa CHAR(16);
  38   DECLARE spb,spc INT;
  39   DECLARE cur1 CURSOR FOR SELECT id,data FROM test.t1 ORDER BY id;
  40   DECLARE cur2 CURSOR FOR SELECT id2 FROM test.t2 ORDER BY id2;
  41   DECLARE CONTINUE HANDLER FOR SQLSTATE '02000' SET done = 1;
  42
  43   OPEN cur1;
  44   OPEN cur2;
  45
  46   REPEAT
  47     FETCH cur1 INTO spb, spa;
  48     FETCH cur2 INTO spc;
  49     IF NOT done THEN
  50        IF spb < spc THEN
  51           INSERT INTO test.t3 VALUES (spb,spa);
  52        ELSE
  53           INSERT INTO test.t3 VALUES (spc,spa);
  54        END IF;
  55     END IF;
  56   UNTIL done END REPEAT;
  57
  58   CLOSE cur1;
  59   CLOSE cur2;
  60 END|
  61 CREATE PROCEDURE test.p2()
  62 BEGIN
  63   INSERT INTO test.t1 VALUES (4,'MySQL'),(20,'ROCKS'),(11,'Texas'),(10,'kyle');
  64   INSERT INTO test.t2 VALUES (4),(2),(1),(3);
  65   UPDATE test.t1 SET id=id+4 WHERE id=4;
  66 END|
  67 delimiter ;|
  68
  69 let $message=< ---- Master selects-- >;
  70 --source include/show_msg.inc
  71 CALL test.p2();
  72 SELECT * FROM test.t1 ORDER BY id;
  73 SELECT * FROM test.t2 ORDER BY id2;
  74
  75 let $message=< ---- Slave selects-- >;
  76 --source include/show_msg.inc
  77 save_master_pos;
  78 connection slave;
  79 sync_with_master;
  80 SELECT * FROM test.t1 ORDER BY id;
  81 SELECT * FROM test.t2 ORDER BY id2;
  82
  83 let $message=< ---- Master selects-- >;
  84 --source include/show_msg.inc
  85 connection master;
  86 CALL test.p1();
  87
  88 let $wait_condition= SELECT COUNT(*) = 4 FROM t3;
  89 --source include/wait_condition.inc
  90 save_master_pos;
  91 SELECT * FROM test.t3 ORDER BY id3;
  92
  93 let $message=< ---- Slave selects-- >;
  94 --source include/show_msg.inc
  95 connection slave;
  96 sync_with_master;
  97 SELECT * FROM test.t3 ORDER BY id3;
  98
  99 connection master;
 100
 101 ALTER PROCEDURE test.p1 MODIFIES SQL DATA;
 102 #show binlog events;
 103
 104 # Cleanup
 105
 106 connection master;
 107 DROP PROCEDURE IF EXISTS test.p1;
 108 DROP PROCEDURE IF EXISTS test.p2;
 109 DROP TABLE IF EXISTS test.t1;
 110 DROP TABLE IF EXISTS test.t2;
 111 DROP TABLE IF EXISTS test.t3;
 112 sync_slave_with_master;
 113
 114 # End of 5.0 test case
 115 --source include/rpl_end.inc