1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
|
# ==== Purpose ====
#
# The purpose of this test script is to test the behavior of
# CREATE..SELECT with a partition table
#
# ==== Implementation ===
# Create a table using CREATE..SELECT clause based on a partition table
# and test for INSERT in the new table
#
# ==== References ====
#
# WL#12168:Add Partition Information into the Binary Log
#
--source include/have_binlog_format_row.inc
--source include/master-slave.inc
--echo #### Create a table using CREATE..SELECT clause #####
CREATE TABLE store (store_id INT) PARTITION BY RANGE (store_id) ( PARTITION p0 VALUES LESS THAN (10), PARTITION p1 VALUES LESS THAN (20));
--source include/save_binlog_position.inc
INSERT INTO store VALUES (5);
INSERT INTO store VALUES (12);
# Check if the partition_id is correctly logged for this event.
--let $expected_partition_id = 0;1
--source suite/rpl/include/rpl_partition_info.inc
# Create the table using CREATE..SELECT based on a partitioned table
--source include/save_binlog_position.inc
CREATE TABLE emp (m INT) PARTITION BY RANGE (store_id) ( PARTITION p0 VALUES LESS THAN (10), PARTITION p1 VALUES LESS THAN (20))
SELECT store_id FROM store;
#Check if the rows inserted in table emp from table store has the correct partition_id info
--let $expected_partition_id = 0;1
--source suite/rpl/include/rpl_partition_info.inc
--let $store_table_count = `SELECT COUNT(PARTITION_ORDINAL_POSITION) FROM INFORMATION_SCHEMA.PARTITIONS WHERE TABLE_NAME = 'store'`
--let $emp_table_count = `SELECT COUNT(PARTITION_ORDINAL_POSITION) FROM INFORMATION_SCHEMA.PARTITIONS WHERE TABLE_NAME = 'emp'`
# Check if the number of partition is same in both tables
--let $assert_text= Check that the partition count is same in both tables
--let $assert_cond= $store_table_count = $emp_table_count
--source include/assert.inc
let $wait_condition = SELECT COUNT(*) = 1 FROM INFORMATION_SCHEMA.PARTITIONS WHERE TABLE_NAME = "emp" AND PARTITION_NAME ="p0";
--source include/wait_condition_or_abort.inc
let $wait_condition = SELECT COUNT(*) = 1 FROM INFORMATION_SCHEMA.PARTITIONS WHERE TABLE_NAME = "emp" AND PARTITION_NAME ="p1";
--source include/wait_condition_or_abort.inc
# Check if the partition_id is correctly logged for this event.
--source include/save_binlog_position.inc
INSERT INTO emp values (3, 12);
--let $expected_partition_id = 1
--source suite/rpl/include/rpl_partition_info.inc
--source include/save_binlog_position.inc
INSERT INTO emp values (4, 6), (5, 13) ;
# Check if the partition_id is correctly logged for this event.
--let $expected_partition_id = 0;1
--source suite/rpl/include/rpl_partition_info.inc
DROP TABLE store;
DROP TABLE emp;
RESET MASTER;
--source include/rpl_end.inc
|
