Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
M
MariaDB
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Analytics
Analytics
CI / CD
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
nexedi
MariaDB
Commits
9d8a155a
Commit
9d8a155a
authored
Jul 24, 2008
by
Magnus Svensson
Browse files
Options
Browse Files
Download
Plain Diff
merge
parents
5f776d3d
cfd57e58
Changes
4
Hide whitespace changes
Inline
Side-by-side
Showing
4 changed files
with
66 additions
and
9 deletions
+66
-9
.bzrignore
.bzrignore
+3
-0
mysql-test/include/wait_for_slave_io_to_start.inc
mysql-test/include/wait_for_slave_io_to_start.inc
+19
-0
mysql-test/suite/rpl/r/rpl_stm_until.result
mysql-test/suite/rpl/r/rpl_stm_until.result
+8
-0
mysql-test/suite/rpl/t/rpl_stm_until.test
mysql-test/suite/rpl/t/rpl_stm_until.test
+36
-9
No files found.
.bzrignore
View file @
9d8a155a
...
@@ -2095,10 +2095,13 @@ sql/.libs/udf_example.lai
...
@@ -2095,10 +2095,13 @@ sql/.libs/udf_example.lai
sql/.libs/udf_example.so.0
sql/.libs/udf_example.so.0
sql/.libs/udf_example.so.0.0.0
sql/.libs/udf_example.so.0.0.0
sql/client.c
sql/client.c
sql/Doxyfile
sql/f.c
sql/f.c
sql/gen_lex_hash
sql/gen_lex_hash
sql/gmon.out
sql/gmon.out
sql/handlerton.cc
sql/handlerton.cc
sql/html
sql/latex
sql/lex_hash.h
sql/lex_hash.h
sql/link_sources
sql/link_sources
sql/max/*
sql/max/*
...
...
mysql-test/include/wait_for_slave_io_to_start.inc
0 → 100644
View file @
9d8a155a
# ==== Purpose ====
#
# Waits until the IO thread of the current connection has started and
# connected to the master (i.e., until SHOW SLAVE STATUS returns Yes
# in the Slave_IO_Running field), or until a timeout is reached.
#
# ==== Usage ====
#
# source include/wait_for_slave_io_to_start.inc;
#
# Parameters to this macro are $slave_timeout and
# $slave_keep_connection. See wait_for_slave_param.inc for
# descriptions.
let
$slave_param
=
Slave_IO_Running
;
let
$slave_param_value
=
Yes
;
let
$slave_error_message
=
Failed
while
waiting
for
slave
IO
thread
to
start
;
source
include
/
wait_for_slave_param
.
inc
;
let
$slave_error_message
=
;
mysql-test/suite/rpl/r/rpl_stm_until.result
View file @
9d8a155a
...
@@ -4,7 +4,10 @@ reset master;
...
@@ -4,7 +4,10 @@ reset master;
reset slave;
reset slave;
drop table if exists t1,t2,t3,t4,t5,t6,t7,t8,t9;
drop table if exists t1,t2,t3,t4,t5,t6,t7,t8,t9;
start slave;
start slave;
[on slave]
include/stop_slave.inc
include/stop_slave.inc
==== Create some events on master ====
[on master]
create table t1(n int not null auto_increment primary key);
create table t1(n int not null auto_increment primary key);
insert into t1 values (1),(2),(3),(4);
insert into t1 values (1),(2),(3),(4);
drop table t1;
drop table t1;
...
@@ -12,6 +15,8 @@ create table t2(n int not null auto_increment primary key);
...
@@ -12,6 +15,8 @@ create table t2(n int not null auto_increment primary key);
insert into t2 values (1),(2);
insert into t2 values (1),(2);
insert into t2 values (3),(4);
insert into t2 values (3),(4);
drop table t2;
drop table t2;
==== Replicate one event at a time on slave ====
[on slave]
start slave until master_log_file='master-bin.000001', master_log_pos=323;
start slave until master_log_file='master-bin.000001', master_log_pos=323;
select * from t1;
select * from t1;
n
n
...
@@ -149,6 +154,8 @@ Last_IO_Error #
...
@@ -149,6 +154,8 @@ Last_IO_Error #
Last_SQL_Errno 0
Last_SQL_Errno 0
Last_SQL_Error
Last_SQL_Error
start slave;
start slave;
[on master]
[on slave]
include/stop_slave.inc
include/stop_slave.inc
start slave until master_log_file='master-bin.000001', master_log_pos=776;
start slave until master_log_file='master-bin.000001', master_log_pos=776;
SHOW SLAVE STATUS;
SHOW SLAVE STATUS;
...
@@ -190,6 +197,7 @@ Last_IO_Errno #
...
@@ -190,6 +197,7 @@ Last_IO_Errno #
Last_IO_Error #
Last_IO_Error #
Last_SQL_Errno 0
Last_SQL_Errno 0
Last_SQL_Error
Last_SQL_Error
==== Test various error conditions ====
start slave until master_log_file='master-bin', master_log_pos=561;
start slave until master_log_file='master-bin', master_log_pos=561;
ERROR HY000: Incorrect parameter or combination of parameters for START SLAVE UNTIL
ERROR HY000: Incorrect parameter or combination of parameters for START SLAVE UNTIL
start slave until master_log_file='master-bin.000001', master_log_pos=561, relay_log_pos=12;
start slave until master_log_file='master-bin.000001', master_log_pos=561, relay_log_pos=12;
...
...
mysql-test/suite/rpl/t/rpl_stm_until.test
View file @
9d8a155a
# ==== Purpose ====
#
# Verify that START SLAVE UNTIL replicates until the given binlog
# position but not longer. Verify that START SLAVE UNTIL with various
# incorrect arguments gives an error.
#
# ==== Method ====
#
# On master, create a table and insert some rows. On slave, START
# SLAVE UNTIL so that it reads one event at a time, and check the
# table and the slave status each time.
#
# Then, on slave, run START SLAVE UNTIL with incorrect arguments and
# verify that it gives an error.
#
# ==== Related bugs ====
#
# Bug in this test: BUG#37717: rpl.rpl_stm_until 'stmt' fails sporadically on pushbuild
--
source
include
/
have_binlog_format_mixed_or_statement
.
inc
--
source
include
/
have_binlog_format_mixed_or_statement
.
inc
--
source
include
/
master
-
slave
.
inc
--
source
include
/
master
-
slave
.
inc
# Test is dependent on binlog positions
# Test is dependent on binlog positions
# prepare version for substitutions
# Stop slave before it starts replication. Also sync with master
let
$VERSION
=
`select version()`
;
# to avoid nondeterministic behaviour.
--
echo
[
on
slave
]
# stop slave before he will start replication also sync with master
# for avoiding undetermenistic behaviour
sync_slave_with_master
;
sync_slave_with_master
;
--
source
include
/
stop_slave
.
inc
--
source
include
/
stop_slave
.
inc
--
echo
====
Create
some
events
on
master
====
--
echo
[
on
master
]
connection
master
;
connection
master
;
# create some events on master
create
table
t1
(
n
int
not
null
auto_increment
primary
key
);
create
table
t1
(
n
int
not
null
auto_increment
primary
key
);
insert
into
t1
values
(
1
),(
2
),(
3
),(
4
);
insert
into
t1
values
(
1
),(
2
),(
3
),(
4
);
drop
table
t1
;
drop
table
t1
;
...
@@ -21,9 +40,13 @@ insert into t2 values (1),(2);
...
@@ -21,9 +40,13 @@ insert into t2 values (1),(2);
insert
into
t2
values
(
3
),(
4
);
insert
into
t2
values
(
3
),(
4
);
drop
table
t2
;
drop
table
t2
;
--
echo
====
Replicate
one
event
at
a
time
on
slave
====
# try to replicate all queries until drop of t1
# try to replicate all queries until drop of t1
--
echo
[
on
slave
]
connection
slave
;
connection
slave
;
start
slave
until
master_log_file
=
'master-bin.000001'
,
master_log_pos
=
323
;
start
slave
until
master_log_file
=
'master-bin.000001'
,
master_log_pos
=
323
;
--
source
include
/
wait_for_slave_io_to_start
.
inc
--
source
include
/
wait_for_slave_sql_to_stop
.
inc
--
source
include
/
wait_for_slave_sql_to_stop
.
inc
# here table should be still not deleted
# here table should be still not deleted
select
*
from
t1
;
select
*
from
t1
;
...
@@ -31,6 +54,7 @@ source include/show_slave_status2.inc;
...
@@ -31,6 +54,7 @@ source include/show_slave_status2.inc;
# this should fail right after start
# this should fail right after start
start
slave
until
master_log_file
=
'master-no-such-bin.000001'
,
master_log_pos
=
291
;
start
slave
until
master_log_file
=
'master-no-such-bin.000001'
,
master_log_pos
=
291
;
--
source
include
/
wait_for_slave_io_to_start
.
inc
--
source
include
/
wait_for_slave_sql_to_stop
.
inc
--
source
include
/
wait_for_slave_sql_to_stop
.
inc
# again this table should be still not deleted
# again this table should be still not deleted
select
*
from
t1
;
select
*
from
t1
;
...
@@ -38,24 +62,28 @@ source include/show_slave_status2.inc;
...
@@ -38,24 +62,28 @@ source include/show_slave_status2.inc;
# try replicate all up to and not including the second insert to t2;
# try replicate all up to and not including the second insert to t2;
start
slave
until
relay_log_file
=
'slave-relay-bin.000004'
,
relay_log_pos
=
746
;
start
slave
until
relay_log_file
=
'slave-relay-bin.000004'
,
relay_log_pos
=
746
;
--
source
include
/
wait_for_slave_io_to_start
.
inc
--
source
include
/
wait_for_slave_sql_to_stop
.
inc
--
source
include
/
wait_for_slave_sql_to_stop
.
inc
select
*
from
t2
;
select
*
from
t2
;
source
include
/
show_slave_status2
.
inc
;
source
include
/
show_slave_status2
.
inc
;
# clean up
# clean up
start
slave
;
start
slave
;
--
echo
[
on
master
]
connection
master
;
connection
master
;
--
echo
[
on
slave
]
sync_slave_with_master
;
sync_slave_with_master
;
--
source
include
/
stop_slave
.
inc
--
source
include
/
stop_slave
.
inc
# this should stop immediately as we are already there
# this should stop immediately as we are already there
start
slave
until
master_log_file
=
'master-bin.000001'
,
master_log_pos
=
776
;
start
slave
until
master_log_file
=
'master-bin.000001'
,
master_log_pos
=
776
;
--
source
include
/
wait_for_slave_io_to_start
.
inc
--
source
include
/
wait_for_slave_sql_to_stop
.
inc
--
source
include
/
wait_for_slave_sql_to_stop
.
inc
# here the sql slave thread should be stopped
--
replace_result
bin
.
000005
bin
.
000004
bin
.
000006
bin
.
000004
bin
.
000007
bin
.
000004
--
replace_result
bin
.
000005
bin
.
000004
bin
.
000006
bin
.
000004
bin
.
000007
bin
.
000004
source
include
/
show_slave_status2
.
inc
;
source
include
/
show_slave_status2
.
inc
;
#testing various error conditions
--
echo
====
Test
various
error
conditions
====
--
error
1277
--
error
1277
start
slave
until
master_log_file
=
'master-bin'
,
master_log_pos
=
561
;
start
slave
until
master_log_file
=
'master-bin'
,
master_log_pos
=
561
;
--
error
1277
--
error
1277
...
@@ -70,4 +98,3 @@ start slave until relay_log_file='slave-relay-bin.000002', master_log_pos=561;
...
@@ -70,4 +98,3 @@ start slave until relay_log_file='slave-relay-bin.000002', master_log_pos=561;
start
slave
sql_thread
;
start
slave
sql_thread
;
start
slave
until
master_log_file
=
'master-bin.000001'
,
master_log_pos
=
776
;
start
slave
until
master_log_file
=
'master-bin.000001'
,
master_log_pos
=
776
;
# End of 4.1 tests
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment