mirror of
https://github.com/MariaDB/server.git
synced 2025-08-01 03:47:19 +03:00
Merge whalegate.ndb.mysql.com:/home/tomas/mysql-5.1
into whalegate.ndb.mysql.com:/home/tomas/mysql-5.1-new-ndb-merge
This commit is contained in:
@ -74,6 +74,7 @@ typedef struct st_myrg_info
|
||||
LIST open_list;
|
||||
QUEUE by_key;
|
||||
ulong *rec_per_key_part; /* for sql optimizing */
|
||||
pthread_mutex_t mutex;
|
||||
} MYRG_INFO;
|
||||
|
||||
|
||||
|
@ -8,6 +8,10 @@ drop table if exists t3;
|
||||
drop table if exists t4;
|
||||
--enable_warnings
|
||||
|
||||
SET @test_character_set= 'cp932';
|
||||
SET @test_collation= 'cp932_japanese_ci';
|
||||
-- source include/ctype_common.inc
|
||||
|
||||
set names cp932;
|
||||
set character_set_database = cp932;
|
||||
|
||||
|
@ -53,11 +53,13 @@ DROP TABLE t1;
|
||||
|
||||
#
|
||||
# Bug #31070: crash during conversion of charsets
|
||||
# Bug #32726: crash with cast in order by clause and cp932 charset
|
||||
#
|
||||
create table t1 (a set('a') not null);
|
||||
insert into t1 values (),();
|
||||
select cast(a as char(1)) from t1;
|
||||
select a sounds like a from t1;
|
||||
select 1 from t1 order by cast(a as char(1));
|
||||
drop table t1;
|
||||
|
||||
DROP DATABASE d1;
|
||||
|
@ -12687,3 +12687,10 @@ CREATE TABLE t1(a VARCHAR(510)) ENGINE = ARCHIVE;
|
||||
INSERT INTO t1(a) VALUES ('');
|
||||
SELECT * FROM t1 ORDER BY a;
|
||||
DROP TABLE t1;
|
||||
CREATE TABLE t1(a INT NOT NULL AUTO_INCREMENT, b BLOB, KEY(a)) ENGINE=archive;
|
||||
INSERT INTO t1 VALUES (NULL, NULL),(NULL, NULL);
|
||||
FLUSH TABLE t1;
|
||||
SELECT * FROM t1 ORDER BY a;
|
||||
a b
|
||||
1 NULL
|
||||
2 NULL
|
||||
|
@ -5364,13 +5364,19 @@ BIN(a)
|
||||
0
|
||||
drop table t1;
|
||||
create table t1(a enum('foo','bar') default null) engine=csv;
|
||||
ERROR HY000: Can't create table 'test.t1' (errno: -1)
|
||||
ERROR 42000: The storage engine for the table doesn't support nullable columns
|
||||
create table t1(a enum('foo','bar') default 'foo') engine=csv;
|
||||
ERROR HY000: Can't create table 'test.t1' (errno: -1)
|
||||
ERROR 42000: The storage engine for the table doesn't support nullable columns
|
||||
create table t1(a enum('foo','bar') default 'foo' not null) engine=csv;
|
||||
insert into t1 values();
|
||||
select * from t1;
|
||||
a
|
||||
foo
|
||||
drop table t1;
|
||||
CREATE TABLE t1(a INT) ENGINE=CSV;
|
||||
ERROR 42000: The storage engine for the table doesn't support nullable columns
|
||||
SHOW WARNINGS;
|
||||
Level Code Message
|
||||
Error 1178 The storage engine for the table doesn't support nullable columns
|
||||
Error 1005 Can't create table 'test.t1' (errno: 138)
|
||||
End of 5.1 tests
|
||||
|
@ -64,6 +64,10 @@ select a sounds like a from t1;
|
||||
a sounds like a
|
||||
1
|
||||
1
|
||||
select 1 from t1 order by cast(a as char(1));
|
||||
1
|
||||
1
|
||||
1
|
||||
drop table t1;
|
||||
DROP DATABASE d1;
|
||||
USE test;
|
||||
|
@ -64,6 +64,10 @@ select a sounds like a from t1;
|
||||
a sounds like a
|
||||
1
|
||||
1
|
||||
select 1 from t1 order by cast(a as char(1));
|
||||
1
|
||||
1
|
||||
1
|
||||
drop table t1;
|
||||
DROP DATABASE d1;
|
||||
USE test;
|
||||
|
@ -64,6 +64,10 @@ select a sounds like a from t1;
|
||||
a sounds like a
|
||||
1
|
||||
1
|
||||
select 1 from t1 order by cast(a as char(1));
|
||||
1
|
||||
1
|
||||
1
|
||||
drop table t1;
|
||||
DROP DATABASE d1;
|
||||
USE test;
|
||||
|
@ -64,6 +64,10 @@ select a sounds like a from t1;
|
||||
a sounds like a
|
||||
1
|
||||
1
|
||||
select 1 from t1 order by cast(a as char(1));
|
||||
1
|
||||
1
|
||||
1
|
||||
drop table t1;
|
||||
DROP DATABASE d1;
|
||||
USE test;
|
||||
|
@ -2599,6 +2599,10 @@ select a sounds like a from t1;
|
||||
a sounds like a
|
||||
1
|
||||
1
|
||||
select 1 from t1 order by cast(a as char(1));
|
||||
1
|
||||
1
|
||||
1
|
||||
drop table t1;
|
||||
DROP DATABASE d1;
|
||||
USE test;
|
||||
|
@ -250,6 +250,11 @@ SELECT HEX(a) FROM t1;
|
||||
HEX(a)
|
||||
1
|
||||
DROP TABLE t1;
|
||||
CREATE TABLE t1 (a INT);
|
||||
INSERT DELAYED INTO t1 SET b= b();
|
||||
ERROR 42S22: Unknown column 'b' in 'field list'
|
||||
DROP TABLE t1;
|
||||
End of 5.0 tests
|
||||
DROP TABLE IF EXISTS t1,t2;
|
||||
SET SQL_MODE='NO_AUTO_VALUE_ON_ZERO';
|
||||
CREATE TABLE `t1` (
|
||||
@ -279,3 +284,4 @@ ERROR 22007: Incorrect date value: '0000-00-00' for column 'f1' at row 1
|
||||
INSERT DELAYED INTO t2 VALUES (0,'2007-00-00');
|
||||
ERROR 22007: Incorrect date value: '2007-00-00' for column 'f1' at row 1
|
||||
DROP TABLE t1,t2;
|
||||
End of 5.1 tests
|
||||
|
@ -78,10 +78,10 @@ FROM INFORMATION_SCHEMA.EVENTS
|
||||
WHERE EVENT_SCHEMA=DATABASE() AND EVENT_NAME='event_2';
|
||||
IF(TIME_TO_SEC(TIMEDIFF(ENDS,STARTS))=6, 'OK', 'ERROR')
|
||||
OK
|
||||
SELECT IF(LAST_EXECUTED-ENDS < 3, 'OK', 'ERROR')
|
||||
SELECT IF(LAST_EXECUTED-ENDS <= 0, 'OK', 'ERROR')
|
||||
FROM INFORMATION_SCHEMA.EVENTS
|
||||
WHERE EVENT_SCHEMA=DATABASE() AND EVENT_NAME='event_2';
|
||||
IF(LAST_EXECUTED-ENDS < 3, 'OK', 'ERROR')
|
||||
IF(LAST_EXECUTED-ENDS <= 0, 'OK', 'ERROR')
|
||||
OK
|
||||
"Already dropped because ended. Therefore an error."
|
||||
DROP EVENT event_3;
|
||||
|
@ -212,6 +212,13 @@ test
|
||||
SELECT NAME_CONST('test', 'test');
|
||||
test
|
||||
test
|
||||
CREATE TABLE t1(a INT);
|
||||
INSERT INTO t1 VALUES (), (), ();
|
||||
SELECT NAME_CONST(a, '1') FROM t1;
|
||||
ERROR HY000: Incorrect arguments to NAME_CONST
|
||||
SET INSERT_ID= NAME_CONST(a, a);
|
||||
ERROR HY000: Incorrect arguments to NAME_CONST
|
||||
DROP TABLE t1;
|
||||
create table t1 (a int not null);
|
||||
insert into t1 values (-1), (-2);
|
||||
select min(a) from t1 group by inet_ntoa(a);
|
||||
|
37
mysql-test/r/merge_innodb.result
Normal file
37
mysql-test/r/merge_innodb.result
Normal file
@ -0,0 +1,37 @@
|
||||
DROP TABLE IF EXISTS t1, t2, t3, t4, t5;
|
||||
CREATE TABLE t1 (c1 varchar(100)) ENGINE=MyISAM;
|
||||
CREATE TABLE t2 (c1 varchar(100)) ENGINE=MyISAM;
|
||||
CREATE TABLE t3 (c1 varchar(100)) ENGINE=InnoDB;
|
||||
INSERT INTO t1 VALUES ('Ann'), ('Alice');
|
||||
INSERT INTO t2 VALUES ('Bob'), ('Brian');
|
||||
INSERT INTO t3 VALUES ('Chris'), ('Charlie');
|
||||
CREATE TABLE t4 (c1 varchar(100)) ENGINE=MRG_MYISAM UNION=(t1,t2)
|
||||
INSERT_METHOD=LAST;
|
||||
CREATE TABLE t5 (c1 varchar(100)) ENGINE=MRG_MYISAM UNION=(t1,t3)
|
||||
INSERT_METHOD=LAST;
|
||||
SELECT * FROM t5;
|
||||
ERROR HY000: Unable to open underlying table which is differently defined or of non-MyISAM type or doesn't exist
|
||||
SELECT * FROM t4;
|
||||
c1
|
||||
Ann
|
||||
Alice
|
||||
Bob
|
||||
Brian
|
||||
ALTER TABLE t2 ENGINE=InnoDB;
|
||||
SELECT * FROM t4;
|
||||
ERROR HY000: Unable to open underlying table which is differently defined or of non-MyISAM type or doesn't exist
|
||||
DELETE FROM t2 LIMIT 1;
|
||||
SELECT * FROM t4;
|
||||
ERROR HY000: Unable to open underlying table which is differently defined or of non-MyISAM type or doesn't exist
|
||||
INSERT INTO t4 VALUES ('Beware');
|
||||
ERROR HY000: Unable to open underlying table which is differently defined or of non-MyISAM type or doesn't exist
|
||||
SELECT * FROM t4;
|
||||
ERROR HY000: Unable to open underlying table which is differently defined or of non-MyISAM type or doesn't exist
|
||||
SELECT * FROM t2;
|
||||
c1
|
||||
Brian
|
||||
SELECT * FROM t1;
|
||||
c1
|
||||
Ann
|
||||
Alice
|
||||
DROP TABLE t1, t2, t3, t4, t5;
|
@ -1307,4 +1307,51 @@ ERROR 42000: You have an error in your SQL syntax; check the manual that corresp
|
||||
ALTER TABLE t1 ANALYZE PARTITION p1 EXTENDED;
|
||||
ERROR 42000: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'EXTENDED' at line 1
|
||||
DROP TABLE t1;
|
||||
CREATE TABLE t1 (s1 BIGINT UNSIGNED)
|
||||
PARTITION BY RANGE (s1) (
|
||||
PARTITION p0 VALUES LESS THAN (0),
|
||||
PARTITION p1 VALUES LESS THAN (1),
|
||||
PARTITION p2 VALUES LESS THAN (18446744073709551615)
|
||||
);
|
||||
INSERT INTO t1 VALUES (0), (18446744073709551614);
|
||||
INSERT INTO t1 VALUES (18446744073709551615);
|
||||
ERROR HY000: Table has no partition for value 18446744073709551615
|
||||
DROP TABLE t1;
|
||||
CREATE TABLE t1 (s1 BIGINT UNSIGNED)
|
||||
PARTITION BY RANGE (s1) (
|
||||
PARTITION p0 VALUES LESS THAN (0),
|
||||
PARTITION p1 VALUES LESS THAN (1),
|
||||
PARTITION p2 VALUES LESS THAN (18446744073709551614),
|
||||
PARTITION p3 VALUES LESS THAN MAXVALUE
|
||||
);
|
||||
INSERT INTO t1 VALUES (-1), (0), (18446744073709551613),
|
||||
(18446744073709551614), (18446744073709551615);
|
||||
Warnings:
|
||||
Warning 1264 Out of range value for column 's1' at row 1
|
||||
SELECT * FROM t1;
|
||||
s1
|
||||
0
|
||||
0
|
||||
18446744073709551613
|
||||
18446744073709551614
|
||||
18446744073709551615
|
||||
SELECT * FROM t1 WHERE s1 = 0;
|
||||
s1
|
||||
0
|
||||
0
|
||||
SELECT * FROM t1 WHERE s1 = 18446744073709551614;
|
||||
s1
|
||||
18446744073709551614
|
||||
SELECT * FROM t1 WHERE s1 = 18446744073709551615;
|
||||
s1
|
||||
18446744073709551615
|
||||
DROP TABLE t1;
|
||||
CREATE TABLE t1 (s1 BIGINT UNSIGNED)
|
||||
PARTITION BY RANGE (s1) (
|
||||
PARTITION p0 VALUES LESS THAN (0),
|
||||
PARTITION p1 VALUES LESS THAN (1),
|
||||
PARTITION p2 VALUES LESS THAN (18446744073709551615),
|
||||
PARTITION p3 VALUES LESS THAN MAXVALUE
|
||||
);
|
||||
DROP TABLE t1;
|
||||
End of 5.1 tests
|
||||
|
@ -1,4 +1,16 @@
|
||||
drop table if exists t1;
|
||||
CREATE TABLE t1 (c1 INT)
|
||||
PARTITION BY HASH (c1)
|
||||
PARTITIONS 15;
|
||||
INSERT INTO t1 VALUES (1), (2), (3), (4), (5);
|
||||
ALTER TABLE t1 COALESCE PARTITION 13;
|
||||
DROP TABLE t1;
|
||||
CREATE TABLE t1 (c1 INT)
|
||||
PARTITION BY LINEAR HASH (c1)
|
||||
PARTITIONS 5;
|
||||
INSERT INTO t1 VALUES (1), (2), (3), (4), (5);
|
||||
ALTER TABLE t1 COALESCE PARTITION 3;
|
||||
DROP TABLE t1;
|
||||
create table t1 (a int unsigned)
|
||||
partition by hash(a div 2)
|
||||
partitions 4;
|
||||
|
@ -1,3 +1,15 @@
|
||||
# Bug#32948
|
||||
CREATE TABLE t1 (c1 INT, PRIMARY KEY (c1)) ENGINE=INNODB;
|
||||
CREATE TABLE t2 (c1 INT, PRIMARY KEY (c1),
|
||||
FOREIGN KEY (c1) REFERENCES t1 (c1)
|
||||
ON DELETE CASCADE)
|
||||
ENGINE=INNODB;
|
||||
ALTER TABLE t1 PARTITION BY HASH(c1) PARTITIONS 5;
|
||||
ERROR 23000: Cannot delete or update a parent row: a foreign key constraint fails
|
||||
ALTER TABLE t1 ENGINE=MyISAM;
|
||||
ERROR 23000: Cannot delete or update a parent row: a foreign key constraint fails
|
||||
DROP TABLE t2;
|
||||
DROP TABLE t1;
|
||||
create table t1 (a int) engine=innodb partition by hash(a) ;
|
||||
show table status like 't1';
|
||||
Name Engine Version Row_format Rows Avg_row_length Data_length Max_data_length Index_length Data_free Auto_increment Create_time Update_time Check_time Collation Checksum Create_options Comment
|
||||
|
@ -2,6 +2,80 @@ drop table if exists t1;
|
||||
drop table if exists t2;
|
||||
drop table if exists t3;
|
||||
drop table if exists t4;
|
||||
SET @test_character_set= 'cp932';
|
||||
SET @test_collation= 'cp932_japanese_ci';
|
||||
SET @safe_character_set_server= @@character_set_server;
|
||||
SET @safe_collation_server= @@collation_server;
|
||||
SET character_set_server= @test_character_set;
|
||||
SET collation_server= @test_collation;
|
||||
CREATE DATABASE d1;
|
||||
USE d1;
|
||||
CREATE TABLE t1 (c CHAR(10), KEY(c));
|
||||
SHOW FULL COLUMNS FROM t1;
|
||||
Field Type Collation Null Key Default Extra Privileges Comment
|
||||
c char(10) cp932_japanese_ci YES MUL NULL
|
||||
INSERT INTO t1 VALUES ('aaa'),('aaaa'),('aaaaa');
|
||||
SELECT c as want3results FROM t1 WHERE c LIKE 'aaa%';
|
||||
want3results
|
||||
aaa
|
||||
aaaa
|
||||
aaaaa
|
||||
DROP TABLE t1;
|
||||
CREATE TABLE t1 (c1 varchar(15), KEY c1 (c1(2)));
|
||||
SHOW FULL COLUMNS FROM t1;
|
||||
Field Type Collation Null Key Default Extra Privileges Comment
|
||||
c1 varchar(15) cp932_japanese_ci YES MUL NULL
|
||||
INSERT INTO t1 VALUES ('location'),('loberge'),('lotre'),('boabab');
|
||||
SELECT c1 as want3results from t1 where c1 like 'l%';
|
||||
want3results
|
||||
location
|
||||
loberge
|
||||
lotre
|
||||
SELECT c1 as want3results from t1 where c1 like 'lo%';
|
||||
want3results
|
||||
location
|
||||
loberge
|
||||
lotre
|
||||
SELECT c1 as want1result from t1 where c1 like 'loc%';
|
||||
want1result
|
||||
location
|
||||
SELECT c1 as want1result from t1 where c1 like 'loca%';
|
||||
want1result
|
||||
location
|
||||
SELECT c1 as want1result from t1 where c1 like 'locat%';
|
||||
want1result
|
||||
location
|
||||
SELECT c1 as want1result from t1 where c1 like 'locati%';
|
||||
want1result
|
||||
location
|
||||
SELECT c1 as want1result from t1 where c1 like 'locatio%';
|
||||
want1result
|
||||
location
|
||||
SELECT c1 as want1result from t1 where c1 like 'location%';
|
||||
want1result
|
||||
location
|
||||
DROP TABLE t1;
|
||||
create table t1 (a set('a') not null);
|
||||
insert into t1 values (),();
|
||||
Warnings:
|
||||
Warning 1364 Field 'a' doesn't have a default value
|
||||
select cast(a as char(1)) from t1;
|
||||
cast(a as char(1))
|
||||
|
||||
|
||||
select a sounds like a from t1;
|
||||
a sounds like a
|
||||
1
|
||||
1
|
||||
select 1 from t1 order by cast(a as char(1));
|
||||
1
|
||||
1
|
||||
1
|
||||
drop table t1;
|
||||
DROP DATABASE d1;
|
||||
USE test;
|
||||
SET character_set_server= @safe_character_set_server;
|
||||
SET collation_server= @safe_collation_server;
|
||||
set names cp932;
|
||||
set character_set_database = cp932;
|
||||
CREATE TABLE t1(c1 CHAR(1)) DEFAULT CHARACTER SET = cp932;
|
||||
|
@ -2,6 +2,80 @@ drop table if exists t1;
|
||||
drop table if exists t2;
|
||||
drop table if exists t3;
|
||||
drop table if exists t4;
|
||||
SET @test_character_set= 'cp932';
|
||||
SET @test_collation= 'cp932_japanese_ci';
|
||||
SET @safe_character_set_server= @@character_set_server;
|
||||
SET @safe_collation_server= @@collation_server;
|
||||
SET character_set_server= @test_character_set;
|
||||
SET collation_server= @test_collation;
|
||||
CREATE DATABASE d1;
|
||||
USE d1;
|
||||
CREATE TABLE t1 (c CHAR(10), KEY(c));
|
||||
SHOW FULL COLUMNS FROM t1;
|
||||
Field Type Collation Null Key Default Extra Privileges Comment
|
||||
c char(10) cp932_japanese_ci YES MUL NULL
|
||||
INSERT INTO t1 VALUES ('aaa'),('aaaa'),('aaaaa');
|
||||
SELECT c as want3results FROM t1 WHERE c LIKE 'aaa%';
|
||||
want3results
|
||||
aaa
|
||||
aaaa
|
||||
aaaaa
|
||||
DROP TABLE t1;
|
||||
CREATE TABLE t1 (c1 varchar(15), KEY c1 (c1(2)));
|
||||
SHOW FULL COLUMNS FROM t1;
|
||||
Field Type Collation Null Key Default Extra Privileges Comment
|
||||
c1 varchar(15) cp932_japanese_ci YES MUL NULL
|
||||
INSERT INTO t1 VALUES ('location'),('loberge'),('lotre'),('boabab');
|
||||
SELECT c1 as want3results from t1 where c1 like 'l%';
|
||||
want3results
|
||||
location
|
||||
loberge
|
||||
lotre
|
||||
SELECT c1 as want3results from t1 where c1 like 'lo%';
|
||||
want3results
|
||||
location
|
||||
loberge
|
||||
lotre
|
||||
SELECT c1 as want1result from t1 where c1 like 'loc%';
|
||||
want1result
|
||||
location
|
||||
SELECT c1 as want1result from t1 where c1 like 'loca%';
|
||||
want1result
|
||||
location
|
||||
SELECT c1 as want1result from t1 where c1 like 'locat%';
|
||||
want1result
|
||||
location
|
||||
SELECT c1 as want1result from t1 where c1 like 'locati%';
|
||||
want1result
|
||||
location
|
||||
SELECT c1 as want1result from t1 where c1 like 'locatio%';
|
||||
want1result
|
||||
location
|
||||
SELECT c1 as want1result from t1 where c1 like 'location%';
|
||||
want1result
|
||||
location
|
||||
DROP TABLE t1;
|
||||
create table t1 (a set('a') not null);
|
||||
insert into t1 values (),();
|
||||
Warnings:
|
||||
Warning 1364 Field 'a' doesn't have a default value
|
||||
select cast(a as char(1)) from t1;
|
||||
cast(a as char(1))
|
||||
|
||||
|
||||
select a sounds like a from t1;
|
||||
a sounds like a
|
||||
1
|
||||
1
|
||||
select 1 from t1 order by cast(a as char(1));
|
||||
1
|
||||
1
|
||||
1
|
||||
drop table t1;
|
||||
DROP DATABASE d1;
|
||||
USE test;
|
||||
SET character_set_server= @safe_character_set_server;
|
||||
SET collation_server= @safe_collation_server;
|
||||
set names cp932;
|
||||
set character_set_database = cp932;
|
||||
CREATE TABLE t1(c1 CHAR(1)) DEFAULT CHARACTER SET = cp932;
|
||||
|
@ -1589,3 +1589,12 @@ SELECT * FROM t1 ORDER BY a;
|
||||
--enable_result_log
|
||||
|
||||
DROP TABLE t1;
|
||||
|
||||
#
|
||||
# BUG#31833 - ORDER BY leads to wrong result when ARCHIVE, BLOB and table
|
||||
# cache is full
|
||||
#
|
||||
CREATE TABLE t1(a INT NOT NULL AUTO_INCREMENT, b BLOB, KEY(a)) ENGINE=archive;
|
||||
INSERT INTO t1 VALUES (NULL, NULL),(NULL, NULL);
|
||||
FLUSH TABLE t1;
|
||||
SELECT * FROM t1 ORDER BY a;
|
||||
|
@ -1755,9 +1755,9 @@ insert into t1 values();
|
||||
select BIN(a) from t1;
|
||||
drop table t1;
|
||||
# We prevent creation of table with nullable ENUM
|
||||
--error ER_CANT_CREATE_TABLE
|
||||
--error ER_CHECK_NOT_IMPLEMENTED
|
||||
create table t1(a enum('foo','bar') default null) engine=csv;
|
||||
--error ER_CANT_CREATE_TABLE
|
||||
--error ER_CHECK_NOT_IMPLEMENTED
|
||||
create table t1(a enum('foo','bar') default 'foo') engine=csv;
|
||||
# Enum columns must be specified as NOT NULL
|
||||
create table t1(a enum('foo','bar') default 'foo' not null) engine=csv;
|
||||
@ -1765,5 +1765,12 @@ insert into t1 values();
|
||||
select * from t1;
|
||||
drop table t1;
|
||||
|
||||
#
|
||||
# BUG#32817 - though CSV is marked as supported create table is rejected
|
||||
# with error 1005.
|
||||
#
|
||||
--error ER_CHECK_NOT_IMPLEMENTED
|
||||
CREATE TABLE t1(a INT) ENGINE=CSV;
|
||||
SHOW WARNINGS;
|
||||
|
||||
--echo End of 5.1 tests
|
||||
|
@ -243,6 +243,16 @@ FLUSH TABLE t1;
|
||||
SELECT HEX(a) FROM t1;
|
||||
DROP TABLE t1;
|
||||
|
||||
#
|
||||
# Bug #32676: insert delayed crash with wrong column and function specified
|
||||
#
|
||||
CREATE TABLE t1 (a INT);
|
||||
--error ER_BAD_FIELD_ERROR
|
||||
INSERT DELAYED INTO t1 SET b= b();
|
||||
DROP TABLE t1;
|
||||
|
||||
--echo End of 5.0 tests
|
||||
|
||||
#
|
||||
# Bug#27358 INSERT DELAYED does not honour SQL_MODE of the client
|
||||
#
|
||||
@ -275,3 +285,4 @@ INSERT DELAYED INTO t2 VALUES (0,'0000-00-00');
|
||||
INSERT DELAYED INTO t2 VALUES (0,'2007-00-00');
|
||||
DROP TABLE t1,t2;
|
||||
|
||||
--echo End of 5.1 tests
|
||||
|
@ -16,7 +16,6 @@ ctype_big5 : BUG#26711 2007-06-21 Lars Test has never worked on Do
|
||||
|
||||
federated_transactions : Bug#29523 Transactions do not work
|
||||
events : Bug#32664 events.test fails randomly
|
||||
events_scheduling : Bug#29830 Test case 'events_scheduling' fails on Mac OS X and Windows
|
||||
lowercase_table3 : Bug#32667 lowercase_table3.test reports to error log
|
||||
kill : Bug#29149: Test "kill" fails on Windows
|
||||
innodb_mysql : Bug#32724: innodb_mysql.test fails randomly
|
||||
|
@ -87,7 +87,7 @@ SELECT IF(TIME_TO_SEC(TIMEDIFF(ENDS,STARTS))=6, 'OK', 'ERROR')
|
||||
FROM INFORMATION_SCHEMA.EVENTS
|
||||
WHERE EVENT_SCHEMA=DATABASE() AND EVENT_NAME='event_2';
|
||||
|
||||
SELECT IF(LAST_EXECUTED-ENDS < 3, 'OK', 'ERROR')
|
||||
SELECT IF(LAST_EXECUTED-ENDS <= 0, 'OK', 'ERROR')
|
||||
FROM INFORMATION_SCHEMA.EVENTS
|
||||
WHERE EVENT_SCHEMA=DATABASE() AND EVENT_NAME='event_2';
|
||||
|
||||
|
@ -213,6 +213,17 @@ SELECT NAME_CONST('test', 1.0);
|
||||
SELECT NAME_CONST('test', -1.0);
|
||||
SELECT NAME_CONST('test', 'test');
|
||||
|
||||
#
|
||||
# Bug #32559: connection hangs on query with name_const
|
||||
#
|
||||
CREATE TABLE t1(a INT);
|
||||
INSERT INTO t1 VALUES (), (), ();
|
||||
--error ER_WRONG_ARGUMENTS
|
||||
SELECT NAME_CONST(a, '1') FROM t1;
|
||||
--error ER_WRONG_ARGUMENTS
|
||||
SET INSERT_ID= NAME_CONST(a, a);
|
||||
DROP TABLE t1;
|
||||
|
||||
#
|
||||
# Bug #31349: ERROR 1062 (23000): Duplicate entry '' for key 'group_key'
|
||||
#
|
||||
|
@ -1,5 +1,5 @@
|
||||
#
|
||||
# test of MERGE TABLES
|
||||
# Test of MERGE TABLES
|
||||
#
|
||||
|
||||
--disable_warnings
|
||||
|
41
mysql-test/t/merge_innodb.test
Normal file
41
mysql-test/t/merge_innodb.test
Normal file
@ -0,0 +1,41 @@
|
||||
# t/merge_innodb.test
|
||||
#
|
||||
# Tests with MERGE tables over InnoDB tables
|
||||
#
|
||||
|
||||
--source include/have_innodb.inc
|
||||
|
||||
--disable_warnings
|
||||
DROP TABLE IF EXISTS t1, t2, t3, t4, t5;
|
||||
--enable_warnings
|
||||
|
||||
#
|
||||
# Bug#30491 - MERGE doesn't report error when one table is Innodb
|
||||
#
|
||||
CREATE TABLE t1 (c1 varchar(100)) ENGINE=MyISAM;
|
||||
CREATE TABLE t2 (c1 varchar(100)) ENGINE=MyISAM;
|
||||
CREATE TABLE t3 (c1 varchar(100)) ENGINE=InnoDB;
|
||||
INSERT INTO t1 VALUES ('Ann'), ('Alice');
|
||||
INSERT INTO t2 VALUES ('Bob'), ('Brian');
|
||||
INSERT INTO t3 VALUES ('Chris'), ('Charlie');
|
||||
CREATE TABLE t4 (c1 varchar(100)) ENGINE=MRG_MYISAM UNION=(t1,t2)
|
||||
INSERT_METHOD=LAST;
|
||||
CREATE TABLE t5 (c1 varchar(100)) ENGINE=MRG_MYISAM UNION=(t1,t3)
|
||||
INSERT_METHOD=LAST;
|
||||
--error ER_WRONG_MRG_TABLE
|
||||
SELECT * FROM t5;
|
||||
SELECT * FROM t4;
|
||||
ALTER TABLE t2 ENGINE=InnoDB;
|
||||
--error ER_WRONG_MRG_TABLE
|
||||
SELECT * FROM t4;
|
||||
DELETE FROM t2 LIMIT 1;
|
||||
--error ER_WRONG_MRG_TABLE
|
||||
SELECT * FROM t4;
|
||||
--error ER_WRONG_MRG_TABLE
|
||||
INSERT INTO t4 VALUES ('Beware');
|
||||
--error ER_WRONG_MRG_TABLE
|
||||
SELECT * FROM t4;
|
||||
SELECT * FROM t2;
|
||||
SELECT * FROM t1;
|
||||
DROP TABLE t1, t2, t3, t4, t5;
|
||||
|
@ -1556,4 +1556,42 @@ ALTER TABLE t1 OPTIMIZE PARTITION p1 EXTENDED;
|
||||
ALTER TABLE t1 ANALYZE PARTITION p1 EXTENDED;
|
||||
DROP TABLE t1;
|
||||
|
||||
#
|
||||
# Bug #29258: Partitions: search fails for maximum unsigned bigint
|
||||
#
|
||||
CREATE TABLE t1 (s1 BIGINT UNSIGNED)
|
||||
PARTITION BY RANGE (s1) (
|
||||
PARTITION p0 VALUES LESS THAN (0),
|
||||
PARTITION p1 VALUES LESS THAN (1),
|
||||
PARTITION p2 VALUES LESS THAN (18446744073709551615)
|
||||
);
|
||||
INSERT INTO t1 VALUES (0), (18446744073709551614);
|
||||
--error ER_NO_PARTITION_FOR_GIVEN_VALUE
|
||||
INSERT INTO t1 VALUES (18446744073709551615);
|
||||
DROP TABLE t1;
|
||||
|
||||
CREATE TABLE t1 (s1 BIGINT UNSIGNED)
|
||||
PARTITION BY RANGE (s1) (
|
||||
PARTITION p0 VALUES LESS THAN (0),
|
||||
PARTITION p1 VALUES LESS THAN (1),
|
||||
PARTITION p2 VALUES LESS THAN (18446744073709551614),
|
||||
PARTITION p3 VALUES LESS THAN MAXVALUE
|
||||
);
|
||||
INSERT INTO t1 VALUES (-1), (0), (18446744073709551613),
|
||||
(18446744073709551614), (18446744073709551615);
|
||||
SELECT * FROM t1;
|
||||
SELECT * FROM t1 WHERE s1 = 0;
|
||||
SELECT * FROM t1 WHERE s1 = 18446744073709551614;
|
||||
SELECT * FROM t1 WHERE s1 = 18446744073709551615;
|
||||
DROP TABLE t1;
|
||||
|
||||
CREATE TABLE t1 (s1 BIGINT UNSIGNED)
|
||||
PARTITION BY RANGE (s1) (
|
||||
PARTITION p0 VALUES LESS THAN (0),
|
||||
PARTITION p1 VALUES LESS THAN (1),
|
||||
PARTITION p2 VALUES LESS THAN (18446744073709551615),
|
||||
PARTITION p3 VALUES LESS THAN MAXVALUE
|
||||
);
|
||||
DROP TABLE t1;
|
||||
|
||||
--echo End of 5.1 tests
|
||||
|
@ -9,6 +9,22 @@
|
||||
drop table if exists t1;
|
||||
--enable_warnings
|
||||
|
||||
#
|
||||
# Bug#30822: crash when COALESCE
|
||||
#
|
||||
CREATE TABLE t1 (c1 INT)
|
||||
PARTITION BY HASH (c1)
|
||||
PARTITIONS 15;
|
||||
INSERT INTO t1 VALUES (1), (2), (3), (4), (5);
|
||||
ALTER TABLE t1 COALESCE PARTITION 13;
|
||||
DROP TABLE t1;
|
||||
CREATE TABLE t1 (c1 INT)
|
||||
PARTITION BY LINEAR HASH (c1)
|
||||
PARTITIONS 5;
|
||||
INSERT INTO t1 VALUES (1), (2), (3), (4), (5);
|
||||
ALTER TABLE t1 COALESCE PARTITION 3;
|
||||
DROP TABLE t1;
|
||||
|
||||
#
|
||||
# More partition pruning tests, especially on interval walking
|
||||
#
|
||||
|
@ -1,6 +1,21 @@
|
||||
--source include/have_partition.inc
|
||||
--source include/have_innodb.inc
|
||||
|
||||
# Bug#32948 - FKs allowed to reference partitioned table
|
||||
#
|
||||
-- echo # Bug#32948
|
||||
CREATE TABLE t1 (c1 INT, PRIMARY KEY (c1)) ENGINE=INNODB;
|
||||
CREATE TABLE t2 (c1 INT, PRIMARY KEY (c1),
|
||||
FOREIGN KEY (c1) REFERENCES t1 (c1)
|
||||
ON DELETE CASCADE)
|
||||
ENGINE=INNODB;
|
||||
--error ER_ROW_IS_REFERENCED
|
||||
ALTER TABLE t1 PARTITION BY HASH(c1) PARTITIONS 5;
|
||||
--error ER_ROW_IS_REFERENCED
|
||||
ALTER TABLE t1 ENGINE=MyISAM;
|
||||
DROP TABLE t2;
|
||||
DROP TABLE t1;
|
||||
|
||||
#
|
||||
# Bug #14673: Wrong InnoDB default row format
|
||||
#
|
||||
|
@ -1649,8 +1649,6 @@ err:
|
||||
void
|
||||
Event_queue_element::mark_last_executed(THD *thd)
|
||||
{
|
||||
thd->set_current_time();
|
||||
|
||||
last_executed= (my_time_t) thd->query_start();
|
||||
last_executed_changed= TRUE;
|
||||
|
||||
|
@ -1531,6 +1531,14 @@ int ha_partition::copy_partitions(ulonglong *copied, ulonglong *deleted)
|
||||
longlong func_value;
|
||||
DBUG_ENTER("ha_partition::copy_partitions");
|
||||
|
||||
if (m_part_info->linear_hash_ind)
|
||||
{
|
||||
if (m_part_info->part_type == HASH_PARTITION)
|
||||
set_linear_hash_mask(m_part_info, m_part_info->no_parts);
|
||||
else
|
||||
set_linear_hash_mask(m_part_info, m_part_info->no_subparts);
|
||||
}
|
||||
|
||||
while (reorg_part < m_reorged_parts)
|
||||
{
|
||||
handler *file= m_reorged_file[reorg_part];
|
||||
@ -3983,7 +3991,8 @@ int ha_partition::handle_unordered_next(uchar *buf, bool is_next_same)
|
||||
}
|
||||
else if (!(error= file->index_next(buf)))
|
||||
{
|
||||
if (compare_key(end_range) <= 0)
|
||||
if (!(file->table_flags() & HA_READ_ORDER) ||
|
||||
compare_key(end_range) <= 0)
|
||||
{
|
||||
m_last_part= m_part_spec.start_part;
|
||||
DBUG_RETURN(0); // Row was in range
|
||||
@ -4060,7 +4069,8 @@ int ha_partition::handle_unordered_scan_next_partition(uchar * buf)
|
||||
}
|
||||
if (!error)
|
||||
{
|
||||
if (compare_key(end_range) <= 0)
|
||||
if (!(file->table_flags() & HA_READ_ORDER) ||
|
||||
compare_key(end_range) <= 0)
|
||||
{
|
||||
m_last_part= i;
|
||||
DBUG_RETURN(0);
|
||||
|
@ -1637,13 +1637,22 @@ public:
|
||||
virtual int repair_partitions(THD *thd)
|
||||
{ return HA_ERR_WRONG_COMMAND; }
|
||||
|
||||
/* lock_count() can be more than one if the table is a MERGE */
|
||||
/**
|
||||
@note lock_count() can return > 1 if the table is MERGE or partitioned.
|
||||
*/
|
||||
virtual uint lock_count(void) const { return 1; }
|
||||
/**
|
||||
Is not invoked for non-transactional temporary tables.
|
||||
|
||||
@note store_lock() can return more than one lock if the table is MERGE
|
||||
or partitioned.
|
||||
|
||||
@note that one can NOT rely on table->in_use in store_lock(). It may
|
||||
refer to a different thread if called from mysql_lock_abort_for_thread().
|
||||
|
||||
@note If the table is MERGE, store_lock() can return less locks
|
||||
than lock_count() claimed. This can happen when the MERGE children
|
||||
are not attached when this is called from another thread.
|
||||
*/
|
||||
virtual THR_LOCK_DATA **store_lock(THD *thd,
|
||||
THR_LOCK_DATA **to,
|
||||
|
12
sql/item.cc
12
sql/item.cc
@ -1240,7 +1240,17 @@ bool Item_name_const::is_null()
|
||||
|
||||
Item::Type Item_name_const::type() const
|
||||
{
|
||||
return value_item->type();
|
||||
/*
|
||||
As
|
||||
1. one can try to create the Item_name_const passing non-constant
|
||||
arguments, although it's incorrect and
|
||||
2. the type() method can be called before the fix_fields() to get
|
||||
type information for a further type cast, e.g.
|
||||
if (item->type() == FIELD_ITEM)
|
||||
((Item_field *) item)->...
|
||||
we return NULL_ITEM in the case to avoid wrong casting.
|
||||
*/
|
||||
return valid_args ? value_item->type() : NULL_ITEM;
|
||||
}
|
||||
|
||||
|
||||
|
@ -1242,11 +1242,13 @@ class Item_name_const : public Item
|
||||
{
|
||||
Item *value_item;
|
||||
Item *name_item;
|
||||
bool valid_args;
|
||||
public:
|
||||
Item_name_const(Item *name_arg, Item *val):
|
||||
value_item(val), name_item(name_arg)
|
||||
{
|
||||
if(!value_item->basic_const_item())
|
||||
if (!(valid_args= name_item->basic_const_item() &
|
||||
value_item->basic_const_item()))
|
||||
my_error(ER_WRONG_ARGUMENTS, MYF(0), "NAME_CONST");
|
||||
Item::maybe_null= TRUE;
|
||||
}
|
||||
|
20
sql/lock.cc
20
sql/lock.cc
@ -847,9 +847,6 @@ static MYSQL_LOCK *get_lock_data(THD *thd, TABLE **table_ptr, uint count,
|
||||
locks= locks_buf= sql_lock->locks= (THR_LOCK_DATA**) (sql_lock + 1);
|
||||
to= table_buf= sql_lock->table= (TABLE**) (locks + tables * 2);
|
||||
sql_lock->table_count=lock_count;
|
||||
sql_lock->lock_count=tables;
|
||||
DBUG_PRINT("info", ("sql_lock->table_count %d sql_lock->lock_count %d",
|
||||
sql_lock->table_count, sql_lock->lock_count));
|
||||
|
||||
for (i=0 ; i < count ; i++)
|
||||
{
|
||||
@ -889,6 +886,23 @@ static MYSQL_LOCK *get_lock_data(THD *thd, TABLE **table_ptr, uint count,
|
||||
for ( ; org_locks != locks ; org_locks++)
|
||||
(*org_locks)->debug_print_param= (void *) table;
|
||||
}
|
||||
/*
|
||||
We do not use 'tables', because there are cases where store_lock()
|
||||
returns less locks than lock_count() claimed. This can happen when
|
||||
a FLUSH TABLES tries to abort locks from a MERGE table of another
|
||||
thread. When that thread has just opened the table, but not yet
|
||||
attached its children, it cannot return the locks. lock_count()
|
||||
always returns the number of locks that an attached table has.
|
||||
This is done to avoid the reverse situation: If lock_count() would
|
||||
return 0 for a non-attached MERGE table, and that table becomes
|
||||
attached between the calls to lock_count() and store_lock(), then
|
||||
we would have allocated too little memory for the lock data. Now
|
||||
we may allocate too much, but better safe than memory overrun.
|
||||
And in the FLUSH case, the memory is released quickly anyway.
|
||||
*/
|
||||
sql_lock->lock_count= locks - locks_buf;
|
||||
DBUG_PRINT("info", ("sql_lock->table_count %d sql_lock->lock_count %d",
|
||||
sql_lock->table_count, sql_lock->lock_count));
|
||||
DBUG_RETURN(sql_lock);
|
||||
}
|
||||
|
||||
|
@ -524,6 +524,13 @@ bool partition_info::check_range_constants()
|
||||
current_largest= part_range_value;
|
||||
range_int_array[i]= part_range_value;
|
||||
}
|
||||
else if (defined_max_value &&
|
||||
current_largest == part_range_value &&
|
||||
part_range_value == LONGLONG_MAX &&
|
||||
i == (no_parts - 1))
|
||||
{
|
||||
range_int_array[i]= part_range_value;
|
||||
}
|
||||
else
|
||||
{
|
||||
my_error(ER_RANGE_NOT_INCREASING_ERROR, MYF(0));
|
||||
|
@ -8414,7 +8414,7 @@ int abort_and_upgrade_lock(ALTER_PARTITION_PARAM_TYPE *lpt)
|
||||
We also downgrade locks after the upgrade to WRITE_ONLY
|
||||
*/
|
||||
|
||||
/* purecov: begin unused */
|
||||
/* purecov: begin deadcode */
|
||||
void close_open_tables_and_downgrade(ALTER_PARTITION_PARAM_TYPE *lpt)
|
||||
{
|
||||
VOID(pthread_mutex_lock(&LOCK_open));
|
||||
|
@ -574,7 +574,7 @@ bool mysql_insert(THD *thd,TABLE_LIST *table_list,
|
||||
bool log_on= ((thd->options & OPTION_BIN_LOG) ||
|
||||
(!(thd->security_ctx->master_access & SUPER_ACL)));
|
||||
#endif
|
||||
thr_lock_type lock_type = table_list->lock_type;
|
||||
thr_lock_type lock_type;
|
||||
Item *unused_conds= 0;
|
||||
DBUG_ENTER("mysql_insert");
|
||||
|
||||
@ -609,6 +609,7 @@ bool mysql_insert(THD *thd,TABLE_LIST *table_list,
|
||||
if (open_and_lock_tables(thd, table_list))
|
||||
DBUG_RETURN(TRUE);
|
||||
}
|
||||
lock_type= table_list->lock_type;
|
||||
|
||||
thd->proc_info="init";
|
||||
thd->used_tables=0;
|
||||
@ -626,7 +627,6 @@ bool mysql_insert(THD *thd,TABLE_LIST *table_list,
|
||||
|
||||
/* mysql_prepare_insert set table_list->table if it was not set */
|
||||
table= table_list->table;
|
||||
lock_type= table_list->lock_type;
|
||||
|
||||
context= &thd->lex->select_lex.context;
|
||||
/*
|
||||
|
@ -1402,7 +1402,7 @@ static void set_up_partition_func_pointers(partition_info *part_info)
|
||||
NONE
|
||||
*/
|
||||
|
||||
static void set_linear_hash_mask(partition_info *part_info, uint no_parts)
|
||||
void set_linear_hash_mask(partition_info *part_info, uint no_parts)
|
||||
{
|
||||
uint mask;
|
||||
|
||||
@ -2834,8 +2834,8 @@ int get_partition_id_range(partition_info *part_info,
|
||||
loc_part_id++;
|
||||
*part_id= (uint32)loc_part_id;
|
||||
if (loc_part_id == max_partition &&
|
||||
range_array[loc_part_id] != LONGLONG_MAX &&
|
||||
part_func_value >= range_array[loc_part_id])
|
||||
part_func_value >= range_array[loc_part_id] &&
|
||||
!part_info->defined_max_value)
|
||||
DBUG_RETURN(HA_ERR_NO_PARTITION_FOUND);
|
||||
|
||||
DBUG_PRINT("exit",("partition: %d", *part_id));
|
||||
@ -2941,7 +2941,13 @@ uint32 get_partition_id_range_for_endpoint(partition_info *part_info,
|
||||
}
|
||||
if (left_endpoint)
|
||||
{
|
||||
if (part_func_value >= range_array[loc_part_id])
|
||||
longlong bound= range_array[loc_part_id];
|
||||
/*
|
||||
In case of PARTITION p VALUES LESS THAN MAXVALUE
|
||||
the maximum value is in the current partition.
|
||||
*/
|
||||
if (part_func_value > bound ||
|
||||
(part_func_value == bound && !part_info->defined_max_value))
|
||||
loc_part_id++;
|
||||
}
|
||||
else
|
||||
|
@ -65,6 +65,7 @@ int get_part_for_delete(const uchar *buf, const uchar *rec0,
|
||||
void prune_partition_set(const TABLE *table, part_id_range *part_spec);
|
||||
bool check_partition_info(partition_info *part_info,handlerton **eng_type,
|
||||
TABLE *table, handler *file, HA_CREATE_INFO *info);
|
||||
void set_linear_hash_mask(partition_info *part_info, uint no_parts);
|
||||
bool fix_partition_func(THD *thd, TABLE *table, bool create_table_ind);
|
||||
char *generate_partition_syntax(partition_info *part_info,
|
||||
uint *buf_length, bool use_sql_alloc,
|
||||
|
@ -5979,7 +5979,8 @@ view_err:
|
||||
goto err;
|
||||
new_db_type= create_info->db_type;
|
||||
|
||||
if (new_db_type != old_db_type &&
|
||||
if ((new_db_type != old_db_type ||
|
||||
alter_info->flags & ALTER_PARTITION) &&
|
||||
!table->file->can_switch_engines())
|
||||
{
|
||||
my_error(ER_ROW_IS_REFERENCED, MYF(0));
|
||||
|
@ -262,7 +262,7 @@ void check_header(azio_stream *s)
|
||||
if (len) s->inbuf[0] = s->stream.next_in[0];
|
||||
errno = 0;
|
||||
len = (uInt)my_read(s->file, (uchar *)s->inbuf + len, AZ_BUFSIZE_READ >> len, MYF(0));
|
||||
if (len == 0) s->z_err = Z_ERRNO;
|
||||
if (len == (uInt)-1) s->z_err = Z_ERRNO;
|
||||
s->stream.avail_in += len;
|
||||
s->stream.next_in = s->inbuf;
|
||||
if (s->stream.avail_in < 2) {
|
||||
|
@ -473,14 +473,6 @@ int ha_tina::encode_quote(uchar *buf)
|
||||
const char *end_ptr;
|
||||
const bool was_null= (*field)->is_null();
|
||||
|
||||
/*
|
||||
CSV does not support nulls. ::create() prevents creation of a table
|
||||
with nullable columns so if we encounter them here, there is a bug.
|
||||
This may only occur if the frm was created by an older version of
|
||||
mysqld which permitted table creation with nullable columns.
|
||||
*/
|
||||
DBUG_ASSERT(!(*field)->maybe_null());
|
||||
|
||||
/*
|
||||
assistance for backwards compatibility in production builds.
|
||||
note: this will not work for ENUM columns.
|
||||
@ -1494,7 +1486,10 @@ int ha_tina::create(const char *name, TABLE *table_arg,
|
||||
for (Field **field= table_arg->s->field; *field; field++)
|
||||
{
|
||||
if ((*field)->real_maybe_null())
|
||||
DBUG_RETURN(-1);
|
||||
{
|
||||
my_error(ER_CHECK_NOT_IMPLEMENTED, MYF(0), "nullable columns");
|
||||
DBUG_RETURN(HA_ERR_UNSUPPORTED);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
@ -901,7 +901,14 @@ int ha_myisammrg::external_lock(THD *thd, int lock_type)
|
||||
|
||||
uint ha_myisammrg::lock_count(void) const
|
||||
{
|
||||
DBUG_ASSERT(this->file->children_attached);
|
||||
/*
|
||||
Return the real lock count even if the children are not attached.
|
||||
This method is used for allocating memory. If we would return 0
|
||||
to another thread (e.g. doing FLUSH TABLE), and attach the children
|
||||
before the other thread calls store_lock(), then we would return
|
||||
more locks in store_lock() than we claimed by lock_count(). The
|
||||
other tread would overrun its memory.
|
||||
*/
|
||||
return file->tables;
|
||||
}
|
||||
|
||||
@ -911,7 +918,24 @@ THR_LOCK_DATA **ha_myisammrg::store_lock(THD *thd,
|
||||
enum thr_lock_type lock_type)
|
||||
{
|
||||
MYRG_TABLE *open_table;
|
||||
DBUG_ASSERT(this->file->children_attached);
|
||||
|
||||
/*
|
||||
This method can be called while another thread is attaching the
|
||||
children. If the processor reorders instructions or write to memory,
|
||||
'children_attached' could be set before 'open_tables' has all the
|
||||
pointers to the children. Use of a mutex here and in
|
||||
myrg_attach_children() forces consistent data.
|
||||
*/
|
||||
pthread_mutex_lock(&this->file->mutex);
|
||||
|
||||
/*
|
||||
When MERGE table is open, but not yet attached, other threads
|
||||
could flush it, which means call mysql_lock_abort_for_thread()
|
||||
on this threads TABLE. 'children_attached' is FALSE in this
|
||||
situaton. Since the table is not locked, return no lock data.
|
||||
*/
|
||||
if (!this->file->children_attached)
|
||||
goto end; /* purecov: tested */
|
||||
|
||||
for (open_table=file->open_tables ;
|
||||
open_table != file->end_table ;
|
||||
@ -921,6 +945,9 @@ THR_LOCK_DATA **ha_myisammrg::store_lock(THD *thd,
|
||||
if (lock_type != TL_IGNORE && open_table->table->lock.type == TL_UNLOCK)
|
||||
open_table->table->lock.type=lock_type;
|
||||
}
|
||||
|
||||
end:
|
||||
pthread_mutex_unlock(&this->file->mutex);
|
||||
return to;
|
||||
}
|
||||
|
||||
|
@ -58,6 +58,7 @@ int myrg_close(MYRG_INFO *info)
|
||||
pthread_mutex_lock(&THR_LOCK_open);
|
||||
myrg_open_list=list_delete(myrg_open_list,&info->open_list);
|
||||
pthread_mutex_unlock(&THR_LOCK_open);
|
||||
VOID(pthread_mutex_destroy(&info->mutex));
|
||||
my_free((uchar*) info,MYF(0));
|
||||
if (error)
|
||||
{
|
||||
|
@ -33,7 +33,7 @@
|
||||
myrg_attach_children(). Please duplicate changes in these
|
||||
functions or make common sub-functions.
|
||||
*/
|
||||
/* purecov: begin unused */
|
||||
/* purecov: begin deadcode */ /* not used in MySQL server */
|
||||
|
||||
MYRG_INFO *myrg_open(const char *name, int mode, int handle_locking)
|
||||
{
|
||||
@ -171,6 +171,7 @@ MYRG_INFO *myrg_open(const char *name, int mode, int handle_locking)
|
||||
|
||||
VOID(my_close(fd,MYF(0)));
|
||||
end_io_cache(&file);
|
||||
VOID(pthread_mutex_init(&m_info->mutex, MY_MUTEX_INIT_FAST));
|
||||
m_info->open_list.data=(void*) m_info;
|
||||
pthread_mutex_lock(&THR_LOCK_open);
|
||||
myrg_open_list=list_add(myrg_open_list,&m_info->open_list);
|
||||
@ -328,6 +329,7 @@ MYRG_INFO *myrg_parent_open(const char *parent_name,
|
||||
|
||||
end_io_cache(&file_cache);
|
||||
VOID(my_close(fd, MYF(0)));
|
||||
VOID(pthread_mutex_init(&m_info->mutex, MY_MUTEX_INIT_FAST));
|
||||
|
||||
m_info->open_list.data= (void*) m_info;
|
||||
pthread_mutex_lock(&THR_LOCK_open);
|
||||
@ -393,6 +395,14 @@ int myrg_attach_children(MYRG_INFO *m_info, int handle_locking,
|
||||
DBUG_ENTER("myrg_attach_children");
|
||||
DBUG_PRINT("myrg", ("handle_locking: %d", handle_locking));
|
||||
|
||||
/*
|
||||
This function can be called while another thread is trying to abort
|
||||
locks of this MERGE table. If the processor reorders instructions or
|
||||
write to memory, 'children_attached' could be set before
|
||||
'open_tables' has all the pointers to the children. Use of a mutex
|
||||
here and in ha_myisammrg::store_lock() forces consistent data.
|
||||
*/
|
||||
pthread_mutex_lock(&m_info->mutex);
|
||||
rc= 1;
|
||||
errpos= 0;
|
||||
file_offset= 0;
|
||||
@ -464,6 +474,7 @@ int myrg_attach_children(MYRG_INFO *m_info, int handle_locking,
|
||||
m_info->keys= min_keys;
|
||||
m_info->last_used_table= m_info->open_tables;
|
||||
m_info->children_attached= TRUE;
|
||||
pthread_mutex_unlock(&m_info->mutex);
|
||||
DBUG_RETURN(0);
|
||||
|
||||
err:
|
||||
@ -473,6 +484,7 @@ err:
|
||||
my_free((char*) m_info->rec_per_key_part, MYF(0));
|
||||
m_info->rec_per_key_part= NULL;
|
||||
}
|
||||
pthread_mutex_unlock(&m_info->mutex);
|
||||
my_errno= save_errno;
|
||||
DBUG_RETURN(1);
|
||||
}
|
||||
@ -494,6 +506,8 @@ err:
|
||||
int myrg_detach_children(MYRG_INFO *m_info)
|
||||
{
|
||||
DBUG_ENTER("myrg_detach_children");
|
||||
/* For symmetry with myrg_attach_children() we use the mutex here. */
|
||||
pthread_mutex_lock(&m_info->mutex);
|
||||
if (m_info->tables)
|
||||
{
|
||||
/* Do not attach/detach an empty child list. */
|
||||
@ -504,6 +518,7 @@ int myrg_detach_children(MYRG_INFO *m_info)
|
||||
m_info->del= 0;
|
||||
m_info->data_file_length= 0;
|
||||
m_info->options= 0;
|
||||
pthread_mutex_unlock(&m_info->mutex);
|
||||
DBUG_RETURN(0);
|
||||
}
|
||||
|
||||
|
@ -5360,12 +5360,12 @@ my_wc_mb_cp932(CHARSET_INFO *cs __attribute__((unused)),
|
||||
static int
|
||||
my_mb_wc_cp932(CHARSET_INFO *cs __attribute__((unused)),
|
||||
my_wc_t *pwc, const uchar *s, const uchar *e){
|
||||
int hi=s[0];
|
||||
int hi;
|
||||
|
||||
if (s >= e)
|
||||
return MY_CS_TOOSMALL;
|
||||
|
||||
if (hi < 0x80)
|
||||
if ((hi= s[0]) < 0x80)
|
||||
{
|
||||
pwc[0]=hi;
|
||||
return 1;
|
||||
|
Reference in New Issue
Block a user