Commit aee2b62c authored by unknown's avatar unknown

Merge bk-internal:/home/bk/mysql-5.1-maint

into  neptunus.(none):/home/msvensson/mysql/mysql-5.1-maint


sql/mysql_priv.h:
  Auto merged
sql/sql_class.h:
  Auto merged
sql/sql_parse.cc:
  Auto merged
sql/sql_table.cc:
  Auto merged
parents f3bac9cf a4804e51
...@@ -854,3 +854,45 @@ Table Create Table ...@@ -854,3 +854,45 @@ Table Create Table
`c1` int(11) DEFAULT NULL `c1` int(11) DEFAULT NULL
) ENGINE=MyISAM DEFAULT CHARSET=latin1 ) ENGINE=MyISAM DEFAULT CHARSET=latin1
DROP TABLE `#sql2`, `@0023sql1`; DROP TABLE `#sql2`, `@0023sql1`;
DROP TABLE IF EXISTS t1;
DROP TABLE IF EXISTS t2;
CREATE TABLE t1 (
int_field INTEGER UNSIGNED NOT NULL,
char_field CHAR(10),
INDEX(`int_field`)
);
DESCRIBE t1;
Field Type Null Key Default Extra
int_field int(10) unsigned NO MUL
char_field char(10) YES NULL
SHOW INDEXES FROM t1;
Table Non_unique Key_name Seq_in_index Column_name Collation Cardinality Sub_part Packed Null Index_type Comment
t1 1 int_field 1 int_field A NULL NULL NULL BTREE
INSERT INTO t1 VALUES (1, "edno"), (1, "edno"), (2, "dve"), (3, "tri"), (5, "pet");
"Non-copy data change - new frm, but old data and index files"
ALTER TABLE t1
CHANGE int_field unsigned_int_field INTEGER UNSIGNED NOT NULL,
RENAME t2;
SELECT * FROM t1 ORDER BY int_field;
ERROR 42S02: Table 'test.t1' doesn't exist
SELECT * FROM t2 ORDER BY unsigned_int_field;
unsigned_int_field char_field
1 edno
1 edno
2 dve
3 tri
5 pet
DESCRIBE t2;
Field Type Null Key Default Extra
unsigned_int_field int(10) unsigned NO MUL
char_field char(10) YES NULL
DESCRIBE t2;
Field Type Null Key Default Extra
unsigned_int_field int(10) unsigned NO MUL
char_field char(10) YES NULL
ALTER TABLE t2 MODIFY unsigned_int_field BIGINT UNSIGNED NOT NULL;
DESCRIBE t2;
Field Type Null Key Default Extra
unsigned_int_field bigint(20) unsigned NO MUL
char_field char(10) YES NULL
DROP TABLE t2;
...@@ -948,6 +948,71 @@ DROP USER 'mysqltest_1'@'localhost'; ...@@ -948,6 +948,71 @@ DROP USER 'mysqltest_1'@'localhost';
use test; use test;
create user mysqltest1_thisisreallytoolong; create user mysqltest1_thisisreallytoolong;
ERROR HY000: String 'mysqltest1_thisisreallytoolong' is too long for user name (should be no longer than 16) ERROR HY000: String 'mysqltest1_thisisreallytoolong' is too long for user name (should be no longer than 16)
CREATE DATABASE mysqltest1;
CREATE TABLE mysqltest1.t1 (
int_field INTEGER UNSIGNED NOT NULL,
char_field CHAR(10),
INDEX(`int_field`)
);
CREATE TABLE mysqltest1.t2 (int_field INT);
"Now check that we require equivalent grants for "
"RENAME TABLE and ALTER TABLE"
CREATE USER mysqltest_1@localhost;
GRANT SELECT ON mysqltest1.t1 TO mysqltest_1@localhost;
SELECT USER();
USER()
mysqltest_1@localhost
SHOW GRANTS;
Grants for mysqltest_1@localhost
GRANT USAGE ON *.* TO 'mysqltest_1'@'localhost'
GRANT SELECT ON `mysqltest1`.`t1` TO 'mysqltest_1'@'localhost'
RENAME TABLE t1 TO t2;
ERROR 42000: ALTER command denied to user 'mysqltest_1'@'localhost' for table 't1'
ALTER TABLE t1 RENAME TO t2;
ERROR 42000: DROP,ALTER command denied to user 'mysqltest_1'@'localhost' for table 't1'
GRANT DROP ON mysqltest1.t1 TO mysqltest_1@localhost;
RENAME TABLE t1 TO t2;
ERROR 42000: ALTER command denied to user 'mysqltest_1'@'localhost' for table 't1'
ALTER TABLE t1 RENAME TO t2;
ERROR 42000: ALTER command denied to user 'mysqltest_1'@'localhost' for table 't1'
GRANT ALTER ON mysqltest1.t1 TO mysqltest_1@localhost;
SHOW GRANTS;
Grants for mysqltest_1@localhost
GRANT USAGE ON *.* TO 'mysqltest_1'@'localhost'
GRANT SELECT, DROP, ALTER ON `mysqltest1`.`t1` TO 'mysqltest_1'@'localhost'
RENAME TABLE t1 TO t2;
ERROR 42000: INSERT,CREATE command denied to user 'mysqltest_1'@'localhost' for table 't2'
ALTER TABLE t1 RENAME TO t2;
ERROR 42000: INSERT,CREATE command denied to user 'mysqltest_1'@'localhost' for table 't2'
GRANT INSERT, CREATE ON mysqltest1.t1 TO mysqltest_1@localhost;
SHOW GRANTS;
Grants for mysqltest_1@localhost
GRANT USAGE ON *.* TO 'mysqltest_1'@'localhost'
GRANT SELECT, INSERT, CREATE, DROP, ALTER ON `mysqltest1`.`t1` TO 'mysqltest_1'@'localhost'
GRANT INSERT, SELECT, CREATE, ALTER, DROP ON mysqltest1.t2 TO mysqltest_1@localhost;
DROP TABLE mysqltest1.t2;
SHOW GRANTS;
Grants for mysqltest_1@localhost
GRANT USAGE ON *.* TO 'mysqltest_1'@'localhost'
GRANT SELECT, INSERT, CREATE, DROP, ALTER ON `mysqltest1`.`t2` TO 'mysqltest_1'@'localhost'
GRANT SELECT, INSERT, CREATE, DROP, ALTER ON `mysqltest1`.`t1` TO 'mysqltest_1'@'localhost'
RENAME TABLE t1 TO t2;
RENAME TABLE t2 TO t1;
ALTER TABLE t1 RENAME TO t2;
ALTER TABLE t2 RENAME TO t1;
REVOKE DROP, INSERT ON mysqltest1.t1 FROM mysqltest_1@localhost;
REVOKE DROP, INSERT ON mysqltest1.t2 FROM mysqltest_1@localhost;
SHOW GRANTS;
Grants for mysqltest_1@localhost
GRANT USAGE ON *.* TO 'mysqltest_1'@'localhost'
GRANT SELECT, CREATE, ALTER ON `mysqltest1`.`t2` TO 'mysqltest_1'@'localhost'
GRANT SELECT, CREATE, ALTER ON `mysqltest1`.`t1` TO 'mysqltest_1'@'localhost'
RENAME TABLE t1 TO t2;
ERROR 42000: INSERT command denied to user 'mysqltest_1'@'localhost' for table 't2'
ALTER TABLE t1 RENAME TO t2;
ERROR 42000: DROP command denied to user 'mysqltest_1'@'localhost' for table 't1'
DROP USER mysqltest_1@localhost;
DROP DATABASE mysqltest1;
GRANT CREATE ON mysqltest.* TO 1234567890abcdefGHIKL@localhost; GRANT CREATE ON mysqltest.* TO 1234567890abcdefGHIKL@localhost;
ERROR HY000: String '1234567890abcdefGHIKL' is too long for user name (should be no longer than 16) ERROR HY000: String '1234567890abcdefGHIKL' is too long for user name (should be no longer than 16)
GRANT CREATE ON mysqltest.* TO some_user_name@1234567890abcdefghij1234567890abcdefghij1234567890abcdefghijQWERTY; GRANT CREATE ON mysqltest.* TO some_user_name@1234567890abcdefghij1234567890abcdefghij1234567890abcdefghijQWERTY;
......
...@@ -101,7 +101,7 @@ create table mysqltest.t1 (name char(15)); ...@@ -101,7 +101,7 @@ create table mysqltest.t1 (name char(15));
insert into mysqltest.t1 (name) values ("mysqltest"); insert into mysqltest.t1 (name) values ("mysqltest");
select * from t1; select * from t1;
select * from mysqltest.t1; select * from mysqltest.t1;
--error 1050 --error ER_TABLE_EXISTS_ERROR
alter table t1 rename mysqltest.t1; alter table t1 rename mysqltest.t1;
select * from t1; select * from t1;
select * from mysqltest.t1; select * from mysqltest.t1;
...@@ -231,9 +231,9 @@ DROP TABLE t1; ...@@ -231,9 +231,9 @@ DROP TABLE t1;
# BUG#4717 - check for valid table names # BUG#4717 - check for valid table names
# #
create table t1 (a int); create table t1 (a int);
--error 1103 --error ER_WRONG_TABLE_NAME
alter table t1 rename to ``; alter table t1 rename to ``;
--error 1103 --error ER_WRONG_TABLE_NAME
rename table t1 to ``; rename table t1 to ``;
drop table t1; drop table t1;
...@@ -325,14 +325,14 @@ drop table t1; ...@@ -325,14 +325,14 @@ drop table t1;
CREATE TABLE t1 (a int PRIMARY KEY, b INT UNIQUE); CREATE TABLE t1 (a int PRIMARY KEY, b INT UNIQUE);
ALTER TABLE t1 DROP PRIMARY KEY; ALTER TABLE t1 DROP PRIMARY KEY;
SHOW CREATE TABLE t1; SHOW CREATE TABLE t1;
--error 1091 --error ER_CANT_DROP_FIELD_OR_KEY
ALTER TABLE t1 DROP PRIMARY KEY; ALTER TABLE t1 DROP PRIMARY KEY;
DROP TABLE t1; DROP TABLE t1;
# BUG#3899 # BUG#3899
create table t1 (a int, b int, key(a)); create table t1 (a int, b int, key(a));
insert into t1 values (1,1), (2,2); insert into t1 values (1,1), (2,2);
--error 1091 --error ER_CANT_DROP_FIELD_OR_KEY
alter table t1 drop key no_such_key; alter table t1 drop key no_such_key;
alter table t1 drop key a; alter table t1 drop key a;
drop table t1; drop table t1;
...@@ -343,7 +343,7 @@ drop table t1; ...@@ -343,7 +343,7 @@ drop table t1;
# Some platforms (Mac OS X, Windows) will send the error message using small letters. # Some platforms (Mac OS X, Windows) will send the error message using small letters.
CREATE TABLE T12207(a int) ENGINE=MYISAM; CREATE TABLE T12207(a int) ENGINE=MYISAM;
--replace_result t12207 T12207 --replace_result t12207 T12207
--error 1031 --error ER_ILLEGAL_HA
ALTER TABLE T12207 DISCARD TABLESPACE; ALTER TABLE T12207 DISCARD TABLESPACE;
DROP TABLE T12207; DROP TABLE T12207;
...@@ -367,7 +367,7 @@ drop table t1; ...@@ -367,7 +367,7 @@ drop table t1;
# shorter than packed field length. # shorter than packed field length.
# #
create table t1 ( a timestamp ); create table t1 ( a timestamp );
--error 1089 --error ER_WRONG_SUB_KEY
alter table t1 add unique ( a(1) ); alter table t1 add unique ( a(1) );
drop table t1; drop table t1;
...@@ -477,7 +477,7 @@ create table t1 (c1 int); ...@@ -477,7 +477,7 @@ create table t1 (c1 int);
# Move table to other database. # Move table to other database.
alter table t1 rename mysqltest.t1; alter table t1 rename mysqltest.t1;
# Assure that it has moved. # Assure that it has moved.
--error 1051 --error ER_BAD_TABLE_ERROR
drop table t1; drop table t1;
# Move table back. # Move table back.
alter table mysqltest.t1 rename t1; alter table mysqltest.t1 rename t1;
...@@ -491,7 +491,7 @@ use mysqltest; ...@@ -491,7 +491,7 @@ use mysqltest;
# Drop the current db. This de-selects any db. # Drop the current db. This de-selects any db.
drop database mysqltest; drop database mysqltest;
# Now test for correct message. # Now test for correct message.
--error 1046 --error ER_NO_DB_ERROR
alter table test.t1 rename t1; alter table test.t1 rename t1;
# Check that explicit qualifying works even with no selected db. # Check that explicit qualifying works even with no selected db.
alter table test.t1 rename test.t1; alter table test.t1 rename test.t1;
...@@ -650,3 +650,39 @@ INSERT INTO `@0023sql1` VALUES (2); ...@@ -650,3 +650,39 @@ INSERT INTO `@0023sql1` VALUES (2);
SHOW CREATE TABLE `#sql2`; SHOW CREATE TABLE `#sql2`;
SHOW CREATE TABLE `@0023sql1`; SHOW CREATE TABLE `@0023sql1`;
DROP TABLE `#sql2`, `@0023sql1`; DROP TABLE `#sql2`, `@0023sql1`;
#
# Bug #22369: Alter table rename combined with other alterations causes lost tables
#
# This problem happens if the data change is compatible.
# Changing to the same type is compatible for example.
#
--disable_warnings
DROP TABLE IF EXISTS t1;
DROP TABLE IF EXISTS t2;
--enable_warnings
CREATE TABLE t1 (
int_field INTEGER UNSIGNED NOT NULL,
char_field CHAR(10),
INDEX(`int_field`)
);
DESCRIBE t1;
SHOW INDEXES FROM t1;
INSERT INTO t1 VALUES (1, "edno"), (1, "edno"), (2, "dve"), (3, "tri"), (5, "pet");
--echo "Non-copy data change - new frm, but old data and index files"
ALTER TABLE t1
CHANGE int_field unsigned_int_field INTEGER UNSIGNED NOT NULL,
RENAME t2;
--error ER_NO_SUCH_TABLE
SELECT * FROM t1 ORDER BY int_field;
SELECT * FROM t2 ORDER BY unsigned_int_field;
DESCRIBE t2;
DESCRIBE t2;
ALTER TABLE t2 MODIFY unsigned_int_field BIGINT UNSIGNED NOT NULL;
DESCRIBE t2;
DROP TABLE t2;
...@@ -35,3 +35,6 @@ synchronization : Bug#24529 Test 'synchronization' fails on Mac pushb ...@@ -35,3 +35,6 @@ synchronization : Bug#24529 Test 'synchronization' fails on Mac pushb
#ndb_binlog_ddl_multi : BUG#18976 2006-04-10 kent CRBR: multiple binlog, second binlog may miss schema log events #ndb_binlog_ddl_multi : BUG#18976 2006-04-10 kent CRBR: multiple binlog, second binlog may miss schema log events
ndb_binlog_discover : bug#21806 2006-08-24 ndb_binlog_discover : bug#21806 2006-08-24
ndb_autodiscover3 : bug#21806 ndb_autodiscover3 : bug#21806
flush2 : Bug#24805 Pushbuild can't handle test with --disable-log-bin
...@@ -437,3 +437,70 @@ EXPLAIN SELECT DISTINCT a,a FROM t1 WHERE b < 12 ORDER BY a; ...@@ -437,3 +437,70 @@ EXPLAIN SELECT DISTINCT a,a FROM t1 WHERE b < 12 ORDER BY a;
SELECT DISTINCT a,a FROM t1 WHERE b < 12 ORDER BY a; SELECT DISTINCT a,a FROM t1 WHERE b < 12 ORDER BY a;
DROP TABLE t1; DROP TABLE t1;
# The test case for bug#20836 should be re-enabled when bug#16861 is resolved
# The results for the test should be the same as in 4.1.
#
#Bug #20836: Selecting into variables results in wrong results being returned
#
#--disable_warnings
#DROP TABLE IF EXISTS t1;
#--enable_warnings
#
#CREATE TABLE t1 (id INT NOT NULL, fruit_id INT NOT NULL, fruit_name varchar(20)
#default NULL);
#
#INSERT INTO t1 VALUES (1,1,'ORANGE');
#INSERT INTO t1 VALUES (2,2,'APPLE');
#INSERT INTO t1 VALUES (3,2,'APPLE');
#INSERT INTO t1 VALUES (4,3,'PEAR');
#
#SELECT DISTINCT fruit_id, fruit_name INTO @v1, @v2 FROM t1 WHERE fruit_name =
#'APPLE';
#SELECT @v1, @v2;
#
#SELECT DISTINCT fruit_id, fruit_name INTO @v3, @v4 FROM t1 GROUP BY fruit_id,
#fruit_name HAVING fruit_name = 'APPLE';
#SELECT @v3, @v4;
#
#SELECT DISTINCT @v5:= fruit_id, @v6:= fruit_name INTO @v7, @v8 FROM t1 WHERE
#fruit_name = 'APPLE';
#SELECT @v5, @v6, @v7, @v8;
#
#SELECT DISTINCT @v5 + fruit_id, CONCAT(@v6, fruit_name) INTO @v9, @v10 FROM t1
#WHERE fruit_name = 'APPLE';
#SELECT @v5, @v6, @v7, @v8, @v9, @v10;
#
#SELECT DISTINCT @v11:= @v5 + fruit_id, @v12:= CONCAT(@v6, fruit_name) INTO
#@v13, @v14 FROM t1 WHERE fruit_name = 'APPLE';
#SELECT @v11, @v12, @v13, @v14;
#
#SELECT DISTINCT @v13, @v14 INTO @v15, @v16 FROM t1 WHERE fruit_name = 'APPLE';
#SELECT @v15, @v16;
#
#SELECT DISTINCT 2 + 2, 'Bob' INTO @v17, @v18 FROM t1 WHERE fruit_name =
#'APPLE';
#SELECT @v17, @v18;
#
#--disable_warnings
#DROP TABLE IF EXISTS t2;
#--enable_warnings
#
#CREATE TABLE t2 (fruit_id INT NOT NULL, fruit_name varchar(20)
#default NULL);
#
#SELECT DISTINCT fruit_id, fruit_name INTO OUTFILE
#'../tmp/data1.tmp' FROM t1 WHERE fruit_name = 'APPLE';
#LOAD DATA INFILE '../tmp/data1.tmp' INTO TABLE t2;
#--exec rm $MYSQL_TEST_DIR/var/tmp/data1.tmp
#
#SELECT DISTINCT @v19:= fruit_id, @v20:= fruit_name INTO OUTFILE
#'../tmp/data2.tmp' FROM t1 WHERE fruit_name = 'APPLE';
#LOAD DATA INFILE '../tmp/data2.tmp' INTO TABLE t2;
#--exec rm $MYSQL_TEST_DIR/var/tmp/data2.tmp
#
#SELECT @v19, @v20;
#SELECT * FROM t2;
#
#DROP TABLE t1;
#DROP TABLE t2;
...@@ -822,6 +822,82 @@ create user mysqltest1_thisisreallytoolong; ...@@ -822,6 +822,82 @@ create user mysqltest1_thisisreallytoolong;
# statements. # statements.
# #
#
# Bug #22369: Alter table rename combined with other alterations causes lost tables
#
CREATE DATABASE mysqltest1;
CREATE TABLE mysqltest1.t1 (
int_field INTEGER UNSIGNED NOT NULL,
char_field CHAR(10),
INDEX(`int_field`)
);
CREATE TABLE mysqltest1.t2 (int_field INT);
--echo "Now check that we require equivalent grants for "
--echo "RENAME TABLE and ALTER TABLE"
CREATE USER mysqltest_1@localhost;
GRANT SELECT ON mysqltest1.t1 TO mysqltest_1@localhost;
--connect (conn42,localhost,mysqltest_1,,mysqltest1);
SELECT USER();
SHOW GRANTS;
--error ER_TABLEACCESS_DENIED_ERROR
RENAME TABLE t1 TO t2;
--error ER_TABLEACCESS_DENIED_ERROR
ALTER TABLE t1 RENAME TO t2;
--disconnect conn42
--connection default
GRANT DROP ON mysqltest1.t1 TO mysqltest_1@localhost;
--connect (conn42,localhost,mysqltest_1,,mysqltest1);
--error ER_TABLEACCESS_DENIED_ERROR
RENAME TABLE t1 TO t2;
--error ER_TABLEACCESS_DENIED_ERROR
ALTER TABLE t1 RENAME TO t2;
--disconnect conn42
--connection default
GRANT ALTER ON mysqltest1.t1 TO mysqltest_1@localhost;
--connect (conn42,localhost,mysqltest_1,,mysqltest1);
SHOW GRANTS;
--error ER_TABLEACCESS_DENIED_ERROR
RENAME TABLE t1 TO t2;
--error ER_TABLEACCESS_DENIED_ERROR
ALTER TABLE t1 RENAME TO t2;
--disconnect conn42
--connection default
GRANT INSERT, CREATE ON mysqltest1.t1 TO mysqltest_1@localhost;
--connect (conn42,localhost,mysqltest_1,,mysqltest1);
SHOW GRANTS;
--error ER_TABLEACCESS_DENIED_ERROR
--disconnect conn42
--connection default
GRANT INSERT, SELECT, CREATE, ALTER, DROP ON mysqltest1.t2 TO mysqltest_1@localhost;
DROP TABLE mysqltest1.t2;
--connect (conn42,localhost,mysqltest_1,,mysqltest1);
SHOW GRANTS;
RENAME TABLE t1 TO t2;
RENAME TABLE t2 TO t1;
ALTER TABLE t1 RENAME TO t2;
ALTER TABLE t2 RENAME TO t1;
--disconnect conn42
--connection default
REVOKE DROP, INSERT ON mysqltest1.t1 FROM mysqltest_1@localhost;
REVOKE DROP, INSERT ON mysqltest1.t2 FROM mysqltest_1@localhost;
--connect (conn42,localhost,mysqltest_1,,mysqltest1);
SHOW GRANTS;
--error ER_TABLEACCESS_DENIED_ERROR
RENAME TABLE t1 TO t2;
--error ER_TABLEACCESS_DENIED_ERROR
ALTER TABLE t1 RENAME TO t2;
--disconnect conn42
--connection default
DROP USER mysqltest_1@localhost;
DROP DATABASE mysqltest1;
# Working with database-level privileges. # Working with database-level privileges.
--error ER_WRONG_STRING_LENGTH --error ER_WRONG_STRING_LENGTH
......
...@@ -1839,6 +1839,7 @@ uint build_table_filename(char *buff, size_t bufflen, const char *db, ...@@ -1839,6 +1839,7 @@ uint build_table_filename(char *buff, size_t bufflen, const char *db,
#define FN_FROM_IS_TMP (1 << 0) #define FN_FROM_IS_TMP (1 << 0)
#define FN_TO_IS_TMP (1 << 1) #define FN_TO_IS_TMP (1 << 1)
#define FN_IS_TMP (FN_FROM_IS_TMP | FN_TO_IS_TMP) #define FN_IS_TMP (FN_FROM_IS_TMP | FN_TO_IS_TMP)
#define NO_FRM_RENAME (1 << 2)
/* from hostname.cc */ /* from hostname.cc */
struct in_addr; struct in_addr;
......
...@@ -1613,13 +1613,7 @@ bool select_exists_subselect::send_data(List<Item> &items) ...@@ -1613,13 +1613,7 @@ bool select_exists_subselect::send_data(List<Item> &items)
int select_dumpvar::prepare(List<Item> &list, SELECT_LEX_UNIT *u) int select_dumpvar::prepare(List<Item> &list, SELECT_LEX_UNIT *u)
{ {
List_iterator_fast<Item> li(list);
List_iterator_fast<my_var> gl(var_list);
Item *item;
local_vars.empty(); // Clear list if SP
unit= u; unit= u;
row_count= 0;
if (var_list.elements != list.elements) if (var_list.elements != list.elements)
{ {
...@@ -1627,39 +1621,13 @@ int select_dumpvar::prepare(List<Item> &list, SELECT_LEX_UNIT *u) ...@@ -1627,39 +1621,13 @@ int select_dumpvar::prepare(List<Item> &list, SELECT_LEX_UNIT *u)
ER(ER_WRONG_NUMBER_OF_COLUMNS_IN_SELECT), MYF(0)); ER(ER_WRONG_NUMBER_OF_COLUMNS_IN_SELECT), MYF(0));
return 1; return 1;
} }
while ((item=li++))
{
my_var *mv= gl++;
if (mv->local)
{
Item_splocal *var= new Item_splocal(mv->s, mv->offset, mv->type);
(void)local_vars.push_back(var);
#ifndef DBUG_OFF
var->m_sp= mv->sp;
#endif
}
else
{
Item_func_set_user_var *var= new Item_func_set_user_var(mv->s, item);
/*
Item_func_set_user_var can't substitute something else on its place =>
0 can be passed as last argument (reference on item)
Item_func_set_user_var can't be fixed after creation, so we do not
check var->fixed
*/
var->fix_fields(thd, 0);
var->fix_length_and_dec();
vars.push_back(var);
}
}
return 0; return 0;
} }
void select_dumpvar::cleanup() void select_dumpvar::cleanup()
{ {
vars.empty(); row_count= 0;
row_count=0;
} }
...@@ -1968,13 +1936,10 @@ Statement_map::~Statement_map() ...@@ -1968,13 +1936,10 @@ Statement_map::~Statement_map()
bool select_dumpvar::send_data(List<Item> &items) bool select_dumpvar::send_data(List<Item> &items)
{ {
List_iterator_fast<Item_func_set_user_var> li(vars); List_iterator_fast<my_var> var_li(var_list);
List_iterator_fast<Item_splocal> var_li(local_vars);
List_iterator_fast<my_var> my_li(var_list);
List_iterator<Item> it(items); List_iterator<Item> it(items);
Item_func_set_user_var *xx; Item *item;
Item_splocal *yy; my_var *mv;
my_var *zz;
DBUG_ENTER("select_dumpvar::send_data"); DBUG_ENTER("select_dumpvar::send_data");
if (unit->offset_limit_cnt) if (unit->offset_limit_cnt)
...@@ -1987,24 +1952,27 @@ bool select_dumpvar::send_data(List<Item> &items) ...@@ -1987,24 +1952,27 @@ bool select_dumpvar::send_data(List<Item> &items)
my_message(ER_TOO_MANY_ROWS, ER(ER_TOO_MANY_ROWS), MYF(0)); my_message(ER_TOO_MANY_ROWS, ER(ER_TOO_MANY_ROWS), MYF(0));
DBUG_RETURN(1); DBUG_RETURN(1);
} }
while ((zz=my_li++) && (it++)) while ((mv= var_li++) && (item= it++))
{
if (zz->local)
{ {
if ((yy=var_li++)) if (mv->local)
{ {
if (thd->spcont->set_variable(current_thd, yy->get_var_idx(), if (thd->spcont->set_variable(thd, mv->offset, &item))
it.ref()))
DBUG_RETURN(1); DBUG_RETURN(1);
} }
}
else else
{ {
if ((xx=li++)) Item_func_set_user_var *suv= new Item_func_set_user_var(mv->s, item);
{
xx->check(0); /*
xx->update(); Item_func_set_user_var can't substitute something else on its
} place => NULL may be passed as last argument (reference on
item) Item_func_set_user_var can't be fixed after creation, so
we do not check var->fixed
*/
suv->fix_fields(thd, 0);
suv->check(0);
suv->update();
} }
} }
DBUG_RETURN(0); DBUG_RETURN(0);
......
...@@ -2182,9 +2182,7 @@ class select_dumpvar :public select_result_interceptor { ...@@ -2182,9 +2182,7 @@ class select_dumpvar :public select_result_interceptor {
ha_rows row_count; ha_rows row_count;
public: public:
List<my_var> var_list; List<my_var> var_list;
List<Item_func_set_user_var> vars; select_dumpvar() { var_list.empty(); row_count= 0;}
List<Item_splocal> local_vars;
select_dumpvar(void) { var_list.empty(); local_vars.empty(); vars.empty(); row_count=0;}
~select_dumpvar() {} ~select_dumpvar() {}
int prepare(List<Item> &list, SELECT_LEX_UNIT *u); int prepare(List<Item> &list, SELECT_LEX_UNIT *u);
bool send_data(List<Item> &items); bool send_data(List<Item> &items);
......
...@@ -3144,8 +3144,11 @@ mysql_execute_command(THD *thd) ...@@ -3144,8 +3144,11 @@ mysql_execute_command(THD *thd)
{ {
ulong priv=0; ulong priv=0;
ulong priv_needed= ALTER_ACL; ulong priv_needed= ALTER_ACL;
/* We also require DROP priv for ALTER TABLE ... DROP PARTITION */ /*
if (lex->alter_info.flags & ALTER_DROP_PARTITION) We also require DROP priv for ALTER TABLE ... DROP PARTITION, as well
as for RENAME TO, as being done by SQLCOM_RENAME_TABLE
*/
if (lex->alter_info.flags & (ALTER_DROP_PARTITION | ALTER_RENAME))
priv_needed|= DROP_ACL; priv_needed|= DROP_ACL;
/* Must be set in the parser */ /* Must be set in the parser */
......
...@@ -3654,10 +3654,12 @@ make_unique_key_name(const char *field_name,KEY *start,KEY *end) ...@@ -3654,10 +3654,12 @@ make_unique_key_name(const char *field_name,KEY *start,KEY *end)
flags flags for build_table_filename(). flags flags for build_table_filename().
FN_FROM_IS_TMP old_name is temporary. FN_FROM_IS_TMP old_name is temporary.
FN_TO_IS_TMP new_name is temporary. FN_TO_IS_TMP new_name is temporary.
NO_FRM_RENAME Don't rename the FRM file
but only the table in the storage engine.
RETURN RETURN
0 OK FALSE OK
!= 0 Error TRUE Error
*/ */
bool bool
...@@ -3706,7 +3708,7 @@ mysql_rename_table(handlerton *base, const char *old_db, ...@@ -3706,7 +3708,7 @@ mysql_rename_table(handlerton *base, const char *old_db,
if (!file || !(error=file->rename_table(from_base, to_base))) if (!file || !(error=file->rename_table(from_base, to_base)))
{ {
if (rename_file_ext(from,to,reg_ext)) if (!(flags & NO_FRM_RENAME) && rename_file_ext(from,to,reg_ext))
{ {
error=my_errno; error=my_errno;
/* Restore old file name */ /* Restore old file name */
...@@ -5247,6 +5249,51 @@ bool alter_table_manage_keys(TABLE *table, int indexes_were_disabled, ...@@ -5247,6 +5249,51 @@ bool alter_table_manage_keys(TABLE *table, int indexes_were_disabled,
/* /*
Alter table Alter table
SYNOPSIS
mysql_alter_table()
thd Thread handle
new_db If there is a RENAME clause
new_name If there is a RENAME clause
lex_create_info Information from the parsing phase. Since some
clauses are common to CREATE and ALTER TABLE, the
data is stored in lex->create_info. The non-common
is stored in lex->alter_info.
table_list The table to change.
fields lex->create_list - List of fields to be changed,
added or dropped.
keys lex->key_list - List of keys to be changed, added or
dropped.
order_num How many ORDER BY fields has been specified.
order List of fields to ORDER BY.
ignore Whether we have ALTER IGNORE TABLE
alter_info Information from the parsing phase specific to ALTER
TABLE and not shared with CREATE TABLE.
do_send_ok Whether to call send_ok() on success.
DESCRIPTION
This is a veery long function and is everything but the kitchen sink :)
It is used to alter a table and not only by ALTER TABLE but also
CREATE|DROP INDEX are mapped on this function.
When the ALTER TABLE statement just does a RENAME or ENABLE|DISABLE KEYS,
or both, then this function short cuts its operation by renaming
the table and/or enabling/disabling the keys. In this case, the FRM is
not changed, directly by mysql_alter_table. However, if there is a
RENAME + change of a field, or an index, the short cut is not used.
See how `fields` is used to generate the new FRM regarding the structure
of the fields. The same is done for the indices of the table.
Important is the fact, that this function tries to do as little work as
possible, by finding out whether a intermediate table is needed to copy
data into and when finishing the altering to use it as the original table.
For this reason the function compare_tables() is called, which decides
based on all kind of data how similar are the new and the original
tables.
RETURN VALUES
FALSE OK
TRUE Error
*/ */
bool mysql_alter_table(THD *thd,char *new_db, char *new_name, bool mysql_alter_table(THD *thd,char *new_db, char *new_name,
...@@ -5265,7 +5312,7 @@ bool mysql_alter_table(THD *thd,char *new_db, char *new_name, ...@@ -5265,7 +5312,7 @@ bool mysql_alter_table(THD *thd,char *new_db, char *new_name,
char reg_path[FN_REFLEN+1]; char reg_path[FN_REFLEN+1];
ha_rows copied,deleted; ha_rows copied,deleted;
uint db_create_options, used_fields; uint db_create_options, used_fields;
handlerton *old_db_type, *new_db_type; handlerton *old_db_type, *new_db_type, *save_old_db_type;
legacy_db_type table_type; legacy_db_type table_type;
HA_CREATE_INFO *create_info; HA_CREATE_INFO *create_info;
frm_type_enum frm_type; frm_type_enum frm_type;
...@@ -5569,7 +5616,7 @@ bool mysql_alter_table(THD *thd,char *new_db, char *new_name, ...@@ -5569,7 +5616,7 @@ bool mysql_alter_table(THD *thd,char *new_db, char *new_name,
DBUG_RETURN(error); DBUG_RETURN(error);
} }
/* Full alter table */ /* We have to do full alter table */
/* Let new create options override the old ones */ /* Let new create options override the old ones */
if (!(used_fields & HA_CREATE_USED_MIN_ROWS)) if (!(used_fields & HA_CREATE_USED_MIN_ROWS))
...@@ -6088,8 +6135,8 @@ bool mysql_alter_table(THD *thd,char *new_db, char *new_name, ...@@ -6088,8 +6135,8 @@ bool mysql_alter_table(THD *thd,char *new_db, char *new_name,
old data and index files. Create also symlinks to point at old data and index files. Create also symlinks to point at
the new tables. the new tables.
Copy data. Copy data.
At end, rename temporary tables and symlinks to temporary table At end, rename intermediate tables, and symlinks to intermediate
to final table name. table, to final table name.
Remove old table and old symlinks Remove old table and old symlinks
If rename is made to another database: If rename is made to another database:
...@@ -6150,6 +6197,7 @@ bool mysql_alter_table(THD *thd,char *new_db, char *new_name, ...@@ -6150,6 +6197,7 @@ bool mysql_alter_table(THD *thd,char *new_db, char *new_name,
/* table is a normal table: Create temporary table in same directory */ /* table is a normal table: Create temporary table in same directory */
build_table_filename(path, sizeof(path), new_db, tmp_name, "", build_table_filename(path, sizeof(path), new_db, tmp_name, "",
FN_IS_TMP); FN_IS_TMP);
/* Open our intermediate table */
new_table=open_temporary_table(thd, path, new_db, tmp_name,0); new_table=open_temporary_table(thd, path, new_db, tmp_name,0);
} }
if (!new_table) if (!new_table)
...@@ -6366,7 +6414,7 @@ bool mysql_alter_table(THD *thd,char *new_db, char *new_name, ...@@ -6366,7 +6414,7 @@ bool mysql_alter_table(THD *thd,char *new_db, char *new_name,
if (new_table) if (new_table)
{ {
/* close temporary table that will be the new table */ /* Close the intermediate table that will be the new table */
intern_close_table(new_table); intern_close_table(new_table);
my_free((gptr) new_table,MYF(0)); my_free((gptr) new_table,MYF(0));
} }
...@@ -6380,7 +6428,7 @@ bool mysql_alter_table(THD *thd,char *new_db, char *new_name, ...@@ -6380,7 +6428,7 @@ bool mysql_alter_table(THD *thd,char *new_db, char *new_name,
/* /*
Data is copied. Now we rename the old table to a temp name, Data is copied. Now we rename the old table to a temp name,
rename the new one to the old name, remove all entries from the old table rename the new one to the old name, remove all entries about the old table
from the cache, free all locks, close the old table and remove it. from the cache, free all locks, close the old table and remove it.
*/ */
...@@ -6407,7 +6455,7 @@ bool mysql_alter_table(THD *thd,char *new_db, char *new_name, ...@@ -6407,7 +6455,7 @@ bool mysql_alter_table(THD *thd,char *new_db, char *new_name,
{ {
/* /*
Win32 and InnoDB can't drop a table that is in use, so we must Win32 and InnoDB can't drop a table that is in use, so we must
close the original table at before doing the rename close the original table before doing the rename
*/ */
table->s->version= 0; // Force removal of table def table->s->version= 0; // Force removal of table def
close_cached_table(thd, table); close_cached_table(thd, table);
...@@ -6421,6 +6469,21 @@ bool mysql_alter_table(THD *thd,char *new_db, char *new_name, ...@@ -6421,6 +6469,21 @@ bool mysql_alter_table(THD *thd,char *new_db, char *new_name,
error=0; error=0;
save_old_db_type= old_db_type;
/*
This leads to the storage engine (SE) not being notified for renames in
mysql_rename_table(), because we just juggle with the FRM and nothing
more. If we have an intermediate table, then we notify the SE that
it should become the actual table. Later, we will recycle the old table.
However, in case of ALTER TABLE RENAME there might be no intermediate
table. This is when the old and new tables are compatible, according to
compare_table(). Then, we need one additional call to
mysql_rename_table() with flag NO_FRM_RENAME, which does nothing else but
actual rename in the SE and the FRM is not touched. Note that, if the
table is renamed and the SE is also changed, then an intermediate table
is created and the additional call will not take place.
*/
if (!need_copy_table) if (!need_copy_table)
new_db_type=old_db_type= NULL; // this type cannot happen in regular ALTER new_db_type=old_db_type= NULL; // this type cannot happen in regular ALTER
if (mysql_rename_table(old_db_type, db, table_name, db, old_name, if (mysql_rename_table(old_db_type, db, table_name, db, old_name,
...@@ -6432,6 +6495,9 @@ bool mysql_alter_table(THD *thd,char *new_db, char *new_name, ...@@ -6432,6 +6495,9 @@ bool mysql_alter_table(THD *thd,char *new_db, char *new_name,
else if (mysql_rename_table(new_db_type,new_db,tmp_name,new_db, else if (mysql_rename_table(new_db_type,new_db,tmp_name,new_db,
new_alias, FN_FROM_IS_TMP) || new_alias, FN_FROM_IS_TMP) ||
(new_name != table_name || new_db != db) && // we also do rename (new_name != table_name || new_db != db) && // we also do rename
(need_copy_table ||
mysql_rename_table(save_old_db_type, db, table_name, new_db,
new_alias, NO_FRM_RENAME)) &&
Table_triggers_list::change_table_name(thd, db, table_name, Table_triggers_list::change_table_name(thd, db, table_name,
new_db, new_alias)) new_db, new_alias))
{ {
...@@ -6442,6 +6508,7 @@ bool mysql_alter_table(THD *thd,char *new_db, char *new_name, ...@@ -6442,6 +6508,7 @@ bool mysql_alter_table(THD *thd,char *new_db, char *new_name,
VOID(mysql_rename_table(old_db_type, db, old_name, db, alias, VOID(mysql_rename_table(old_db_type, db, old_name, db, alias,
FN_FROM_IS_TMP)); FN_FROM_IS_TMP));
} }
if (error) if (error)
{ {
/* /*
...@@ -6473,6 +6540,7 @@ bool mysql_alter_table(THD *thd,char *new_db, char *new_name, ...@@ -6473,6 +6540,7 @@ bool mysql_alter_table(THD *thd,char *new_db, char *new_name,
goto err; goto err;
} }
} }
if (thd->lock || new_name != table_name || no_table_reopen) // True if WIN32 if (thd->lock || new_name != table_name || no_table_reopen) // True if WIN32
{ {
/* /*
...@@ -6539,10 +6607,7 @@ bool mysql_alter_table(THD *thd,char *new_db, char *new_name, ...@@ -6539,10 +6607,7 @@ bool mysql_alter_table(THD *thd,char *new_db, char *new_name,
DBUG_ASSERT(!(mysql_bin_log.is_open() && thd->current_stmt_binlog_row_based && DBUG_ASSERT(!(mysql_bin_log.is_open() && thd->current_stmt_binlog_row_based &&
(create_info->options & HA_LEX_CREATE_TMP_TABLE))); (create_info->options & HA_LEX_CREATE_TMP_TABLE)));
write_bin_log(thd, TRUE, thd->query, thd->query_length); write_bin_log(thd, TRUE, thd->query, thd->query_length);
/*
TODO RONM: This problem needs to handled for Berkeley DB partitions
as well
*/
if (ha_check_storage_engine_flag(old_db_type,HTON_FLUSH_AFTER_RENAME)) if (ha_check_storage_engine_flag(old_db_type,HTON_FLUSH_AFTER_RENAME))
{ {
/* /*
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment