Commit 8a1675c8 authored by bell@sanja.is.com.ua's avatar bell@sanja.is.com.ua

Merge sanja.is.com.ua:/home/bell/mysql/bk/mysql-4.1

into sanja.is.com.ua:/home/bell/mysql/bk/work-rand-4.1
parents 293bb8fe 574b6acb
...@@ -795,21 +795,17 @@ static int execute_commands(MYSQL *mysql,int argc, char **argv) ...@@ -795,21 +795,17 @@ static int execute_commands(MYSQL *mysql,int argc, char **argv)
} }
else else
{ {
sprintf(buff,"UPDATE mysql.user SET password='%s' WHERE user='%s' and" /*
" host=substring_index(user(),_utf8\"@\",-1)", We don't try to execute 'update mysql.user set..'
crypted_pw, user); because we can't perfectly find out the host
if (mysql_query(mysql,buff)) */
{ my_printf_error(0,"\n"
my_printf_error(0,"unable to update user table; error: '%s'", "You cannot use 'password' command as mysqld runs\n"
MYF(ME_BELL),mysql_error(mysql)); " with grant tables disabled (was started with"
return -1; " --skip-grant-tables).\n"
} "Use: \"mysqladmin flush-privileges password '*'\""
if (mysql_query(mysql,"set sql_log_off=0")) " instead", MYF(ME_BELL));
{ return -1;
my_printf_error(0, "Can't turn on logging; error: '%s'",
MYF(ME_BELL),mysql_error(mysql));
return -1;
}
} }
} }
argc--; argv++; argc--; argv++;
......
...@@ -28,6 +28,11 @@ ...@@ -28,6 +28,11 @@
#include <my_sys.h> #include <my_sys.h>
#include <m_string.h> #include <m_string.h>
#include <errno.h> #include <errno.h>
#ifndef EOVERFLOW
#define EOVERFLOW 84
#endif
#ifdef MSDOS #ifdef MSDOS
#include <share.h> /* Neaded for sopen() */ #include <share.h> /* Neaded for sopen() */
#endif #endif
......
...@@ -60,6 +60,7 @@ log. */ ...@@ -60,6 +60,7 @@ log. */
#define OS_FILE_CREATE 52 #define OS_FILE_CREATE 52
#define OS_FILE_OVERWRITE 53 #define OS_FILE_OVERWRITE 53
#define OS_FILE_OPEN_RAW 54 #define OS_FILE_OPEN_RAW 54
#define OS_FILE_CREATE_PATH 55
#define OS_FILE_READ_ONLY 333 #define OS_FILE_READ_ONLY 333
#define OS_FILE_READ_WRITE 444 #define OS_FILE_READ_WRITE 444
...@@ -228,7 +229,9 @@ os_file_create_simple( ...@@ -228,7 +229,9 @@ os_file_create_simple(
string */ string */
ulint create_mode,/* in: OS_FILE_OPEN if an existing file is opened ulint create_mode,/* in: OS_FILE_OPEN if an existing file is opened
(if does not exist, error), or OS_FILE_CREATE if a new (if does not exist, error), or OS_FILE_CREATE if a new
file is created (if exists, error) */ file is created (if exists, error), or
OS_FILE_CREATE_PATH if new file (if exists, error) and
subdirectories along its path are created (if needed)*/
ulint access_type,/* in: OS_FILE_READ_ONLY or OS_FILE_READ_WRITE */ ulint access_type,/* in: OS_FILE_READ_ONLY or OS_FILE_READ_WRITE */
ibool* success);/* out: TRUE if succeed, FALSE if error */ ibool* success);/* out: TRUE if succeed, FALSE if error */
/******************************************************************** /********************************************************************
...@@ -421,6 +424,59 @@ os_file_write( ...@@ -421,6 +424,59 @@ os_file_write(
ulint offset_high,/* in: most significant 32 bits of ulint offset_high,/* in: most significant 32 bits of
offset */ offset */
ulint n); /* in: number of bytes to write */ ulint n); /* in: number of bytes to write */
/***********************************************************************
Check the existence and type of the given file. */
ibool
os_file_status(
/*===========*/
/* out: TRUE if call succeeded */
char * path, /* in: pathname of the file */
ibool * exists, /* out: TRUE if file exists */
os_file_type_t* type); /* out: type of the file (if it exists) */
/********************************************************************
The function os_file_dirname returns a directory component of a
null-terminated pathname string. In the usual case, dirname returns
the string up to, but not including, the final '/', and basename
is the component following the final '/'. Trailing '/' charac­
ters are not counted as part of the pathname.
If path does not contain a slash, dirname returns the string ".".
Concatenating the string returned by dirname, a "/", and the basename
yields a complete pathname.
The return value is a copy of the directory component of the pathname.
The copy is allocated from heap. It is the caller responsibility
to free it after it is no longer needed.
The following list of examples (taken from SUSv2) shows the strings
returned by dirname and basename for different paths:
path dirname basename
"/usr/lib" "/usr" "lib"
"/usr/" "/" "usr"
"usr" "." "usr"
"/" "/" "/"
"." "." "."
".." "." ".."
*/
char*
os_file_dirname(
/*============*/
/* out, own: directory component of the
pathname */
char* path); /* in: pathname */
/********************************************************************
Creates all missing subdirectories along the given path. */
ibool
os_file_create_subdirs_if_needed(
/*=============================*/
/* out: TRUE if call succeeded
FALSE otherwise */
char* path); /* in: path name */
/**************************************************************************** /****************************************************************************
Initializes the asynchronous io system. Creates separate aio array for Initializes the asynchronous io system. Creates separate aio array for
non-ibuf read and write, a third aio array for the ibuf i/o, with just one non-ibuf read and write, a third aio array for the ibuf i/o, with just one
......
...@@ -96,6 +96,15 @@ ut_str_catenate( ...@@ -96,6 +96,15 @@ ut_str_catenate(
char* str1, /* in: null-terminated string */ char* str1, /* in: null-terminated string */
char* str2); /* in: null-terminated string */ char* str2); /* in: null-terminated string */
/************************************************************************** /**************************************************************************
Return a copy of the given string. The returned string must be freed
using mem_free. */
char*
ut_strdup(
/*======*/
/* out, own: cnull-terminated string */
char* str); /* in: null-terminated string */
/**************************************************************************
Checks if a null-terminated string contains a certain character. */ Checks if a null-terminated string contains a certain character. */
ibool ibool
......
...@@ -6,6 +6,8 @@ The interface to the operating system file i/o primitives ...@@ -6,6 +6,8 @@ The interface to the operating system file i/o primitives
Created 10/21/1995 Heikki Tuuri Created 10/21/1995 Heikki Tuuri
*******************************************************/ *******************************************************/
#include <sys/stat.h>
#include "os0file.h" #include "os0file.h"
#include "os0sync.h" #include "os0sync.h"
#include "os0thread.h" #include "os0thread.h"
...@@ -716,7 +718,9 @@ os_file_create_simple( ...@@ -716,7 +718,9 @@ os_file_create_simple(
string */ string */
ulint create_mode,/* in: OS_FILE_OPEN if an existing file is opened ulint create_mode,/* in: OS_FILE_OPEN if an existing file is opened
(if does not exist, error), or OS_FILE_CREATE if a new (if does not exist, error), or OS_FILE_CREATE if a new
file is created (if exists, error) */ file is created (if exists, error), or
OS_FILE_CREATE_PATH if new file (if exists, error) and
subdirectories along its path are created (if needed)*/
ulint access_type,/* in: OS_FILE_READ_ONLY or OS_FILE_READ_WRITE */ ulint access_type,/* in: OS_FILE_READ_ONLY or OS_FILE_READ_WRITE */
ibool* success)/* out: TRUE if succeed, FALSE if error */ ibool* success)/* out: TRUE if succeed, FALSE if error */
{ {
...@@ -734,6 +738,14 @@ try_again: ...@@ -734,6 +738,14 @@ try_again:
create_flag = OPEN_EXISTING; create_flag = OPEN_EXISTING;
} else if (create_mode == OS_FILE_CREATE) { } else if (create_mode == OS_FILE_CREATE) {
create_flag = CREATE_NEW; create_flag = CREATE_NEW;
} else if (create_mode == OS_FILE_CREATE_PATH) {
/* create subdirs along the path if needed */
*success = os_file_create_subdirs_if_needed(name);
if (!*success) {
ut_error;
}
create_flag = CREATE_NEW;
create_mode = OS_FILE_CREATE;
} else { } else {
create_flag = 0; create_flag = 0;
ut_error; ut_error;
...@@ -787,6 +799,14 @@ try_again: ...@@ -787,6 +799,14 @@ try_again:
} }
} else if (create_mode == OS_FILE_CREATE) { } else if (create_mode == OS_FILE_CREATE) {
create_flag = O_RDWR | O_CREAT | O_EXCL; create_flag = O_RDWR | O_CREAT | O_EXCL;
} else if (create_mode == OS_FILE_CREATE_PATH) {
/* create subdirs along the path if needed */
*success = os_file_create_subdirs_if_needed(name);
if (!*success) {
return (-1);
}
create_flag = O_RDWR | O_CREAT | O_EXCL;
create_mode = OS_FILE_CREATE;
} else { } else {
create_flag = 0; create_flag = 0;
ut_error; ut_error;
...@@ -2114,6 +2134,185 @@ retry: ...@@ -2114,6 +2134,185 @@ retry:
#endif #endif
} }
/***********************************************************************
Check the existence and type of the given file. */
ibool
os_file_status(
/*===========*/
/* out: TRUE if call succeeded */
char* path, /* in: pathname of the file */
ibool* exists, /* out: TRUE if file exists */
os_file_type_t* type) /* out: type of the file (if it exists) */
{
#ifdef __WIN__
int ret;
struct _stat statinfo;
ret = _stat(path, &statinfo);
if (ret && (errno == ENOENT || errno == ENOTDIR)) {
/* file does not exist */
*exists = FALSE;
return(TRUE);
} else if (ret) {
/* file exists, but stat call failed */
os_file_handle_error_no_exit(0, path, "stat");
return(FALSE);
}
if (_S_IFDIR & statinfo.st_mode) {
*type = OS_FILE_TYPE_DIR;
} else if (_S_IFREG & statinfo.st_mode) {
*type = OS_FILE_TYPE_FILE;
} else {
*type = OS_FILE_TYPE_UNKNOWN;
}
*exists = TRUE;
return(TRUE);
#else
int ret;
struct stat statinfo;
ret = stat(path, &statinfo);
if (ret && (errno == ENOENT || errno == ENOTDIR)) {
/* file does not exist */
*exists = FALSE;
return(TRUE);
} else if (ret) {
/* file exists, but stat call failed */
os_file_handle_error_no_exit(0, path, "stat");
return(FALSE);
}
if (S_ISDIR(statinfo.st_mode)) {
*type = OS_FILE_TYPE_DIR;
} else if (S_ISLNK(statinfo.st_mode)) {
*type = OS_FILE_TYPE_LINK;
} else if (S_ISREG(statinfo.st_mode)) {
*type = OS_FILE_TYPE_FILE;
} else {
*type = OS_FILE_TYPE_UNKNOWN;
}
*exists = TRUE;
return(TRUE);
#endif
}
/* path name separator character */
#ifdef __WIN__
# define OS_FILE_PATH_SEPARATOR '\\'
#else
# define OS_FILE_PATH_SEPARATOR '/'
#endif
/********************************************************************
The function os_file_dirname returns a directory component of a
null-terminated pathname string. In the usual case, dirname returns
the string up to, but not including, the final '/', and basename
is the component following the final '/'. Trailing '/' charac­
ters are not counted as part of the pathname.
If path does not contain a slash, dirname returns the string ".".
Concatenating the string returned by dirname, a "/", and the basename
yields a complete pathname.
The return value is a copy of the directory component of the pathname.
The copy is allocated from heap. It is the caller responsibility
to free it after it is no longer needed.
The following list of examples (taken from SUSv2) shows the strings
returned by dirname and basename for different paths:
path dirname basename
"/usr/lib" "/usr" "lib"
"/usr/" "/" "usr"
"usr" "." "usr"
"/" "/" "/"
"." "." "."
".." "." ".."
*/
char*
os_file_dirname(
/*============*/
/* out, own: directory component of the
pathname */
char* path) /* in: pathname */
{
char* dir;
int i, length, last_slash;
/* find the offset of the last slash */
length = ut_strlen(path);
for (i = length - 1; i >= 0 && path[i] != OS_FILE_PATH_SEPARATOR; i++);
last_slash = i;
if (last_slash < 0) {
/* no slash in the path, return "." */
return(ut_strdup((char*)"."));
}
/* ok, there is a slash */
if (last_slash == 0) {
/* last slash is the first char of the path */
return(ut_strdup((char*)"/"));
}
/* non-trivial directory component */
dir = ut_strdup(path);
dir[last_slash] = 0;
return(dir);
}
/********************************************************************
Creates all missing subdirectories along the given path. */
ibool
os_file_create_subdirs_if_needed(
/*=============================*/
/* out: TRUE if call succeeded
FALSE otherwise */
char* path) /* in: path name */
{
char* subdir;
static char rootdir[2] = { OS_FILE_PATH_SEPARATOR, 0 };
ibool success, subdir_exists;
os_file_type_t type;
subdir = os_file_dirname(path);
if (0 == strcmp(subdir, rootdir) || 0 == strcmp(subdir, ".")) {
/* subdir is root or cwd, nothing to do */
ut_free(subdir);
return(TRUE);
}
/* test if subdir exists */
success = os_file_status(subdir, &subdir_exists, &type);
if (success && !subdir_exists) {
/* subdir does not exist, create it */
success = os_file_create_subdirs_if_needed(subdir);
if (!success) {
ut_free(subdir);
return(FALSE);
}
success = os_file_create_directory(subdir, FALSE);
}
ut_free(subdir);
return(success);
}
/******************************************************************** /********************************************************************
Returns a pointer to the nth slot in the aio array. */ Returns a pointer to the nth slot in the aio array. */
static static
......
...@@ -282,3 +282,27 @@ ut_str_contains( ...@@ -282,3 +282,27 @@ ut_str_contains(
return(FALSE); return(FALSE);
} }
/**************************************************************************
Return a copy of the given string. The returned string must be freed
using mem_free. */
char*
ut_strdup(
/*======*/
/* out, own: cnull-terminated string */
char* str) /* in: null-terminated string */
{
ulint len;
char* copy;
len = ut_strlen(str);
copy = mem_alloc(len + 1);
ut_memcpy(copy, str, len);
copy[len] = 0;
return(copy);
}
...@@ -19,6 +19,9 @@ hex(inet_aton('127.1')) ...@@ -19,6 +19,9 @@ hex(inet_aton('127.1'))
select hex(inet_aton('127.1.1')); select hex(inet_aton('127.1.1'));
hex(inet_aton('127.1.1')) hex(inet_aton('127.1.1'))
7F010001 7F010001
select length(uuid()), charset(uuid()), length(unhex(replace(uuid(),_utf8'-',_utf8'')));
length(uuid()) charset(uuid()) length(unhex(replace(uuid(),_utf8'-',_utf8'')))
36 utf8 16
select length(format('nan', 2)) > 0; select length(format('nan', 2)) > 0;
length(format('nan', 2)) > 0 length(format('nan', 2)) > 0
1 1
......
...@@ -407,12 +407,12 @@ select @a, @b; ...@@ -407,12 +407,12 @@ select @a, @b;
@a @b @a @b
2 1 2 1
set @@global.global.key_buffer_size= 1; set @@global.global.key_buffer_size= 1;
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 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 'key_buffer_size= 1' at line 1
set GLOBAL global.key_buffer_size= 1; set GLOBAL global.key_buffer_size= 1;
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 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 'key_buffer_size= 1' at line 1
SELECT @@global.global.key_buffer_size; SELECT @@global.global.key_buffer_size;
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 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 'key_buffer_size' at line 1
SELECT @@global.session.key_buffer_size; SELECT @@global.session.key_buffer_size;
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 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 'key_buffer_size' at line 1
SELECT @@global.local.key_buffer_size; SELECT @@global.local.key_buffer_size;
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 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 'key_buffer_size' at line 1
...@@ -12,6 +12,8 @@ select hex(inet_aton('127')); ...@@ -12,6 +12,8 @@ select hex(inet_aton('127'));
select hex(inet_aton('127.1')); select hex(inet_aton('127.1'));
select hex(inet_aton('127.1.1')); select hex(inet_aton('127.1.1'));
select length(uuid()), charset(uuid()), length(unhex(replace(uuid(),_utf8'-',_utf8'')));
# #
# Test for core dump with nan # Test for core dump with nan
# #
......
...@@ -289,13 +289,13 @@ select @a, @b; ...@@ -289,13 +289,13 @@ select @a, @b;
# #
# Bug#2586:Disallow global/session/local as structured var. instance names # Bug#2586:Disallow global/session/local as structured var. instance names
# #
--error 1149 --error 1064
set @@global.global.key_buffer_size= 1; set @@global.global.key_buffer_size= 1;
--error 1149 --error 1064
set GLOBAL global.key_buffer_size= 1; set GLOBAL global.key_buffer_size= 1;
--error 1149 --error 1064
SELECT @@global.global.key_buffer_size; SELECT @@global.global.key_buffer_size;
--error 1149 --error 1064
SELECT @@global.session.key_buffer_size; SELECT @@global.session.key_buffer_size;
--error 1149 --error 1064
SELECT @@global.local.key_buffer_size; SELECT @@global.local.key_buffer_size;
...@@ -107,7 +107,7 @@ bool test_if_int(const char *str, int length, const char *int_end, ...@@ -107,7 +107,7 @@ bool test_if_int(const char *str, int length, const char *int_end,
return 1; return 1;
} }
#ifdef NOT_USED
static bool test_if_real(const char *str,int length, CHARSET_INFO *cs) static bool test_if_real(const char *str,int length, CHARSET_INFO *cs)
{ {
cs= system_charset_info; // QQ move test_if_real into CHARSET_INFO struct cs= system_charset_info; // QQ move test_if_real into CHARSET_INFO struct
...@@ -159,7 +159,7 @@ static bool test_if_real(const char *str,int length, CHARSET_INFO *cs) ...@@ -159,7 +159,7 @@ static bool test_if_real(const char *str,int length, CHARSET_INFO *cs)
} }
return 1; return 1;
} }
#endif
static inline uint field_length_without_space(const char *ptr, uint length) static inline uint field_length_without_space(const char *ptr, uint length)
{ {
...@@ -2273,7 +2273,7 @@ int Field_float::store(const char *from,uint len,CHARSET_INFO *cs) ...@@ -2273,7 +2273,7 @@ int Field_float::store(const char *from,uint len,CHARSET_INFO *cs)
int err; int err;
char *end; char *end;
double nr= my_strntod(cs,(char*) from,len,&end,&err); double nr= my_strntod(cs,(char*) from,len,&end,&err);
if (!err && (!current_thd->count_cuted_fields || end-from==len)) if (!err && (!current_thd->count_cuted_fields || end-from==(int)len))
{ {
return Field_float::store(nr); return Field_float::store(nr);
} }
...@@ -2570,8 +2570,8 @@ int Field_double::store(const char *from,uint len,CHARSET_INFO *cs) ...@@ -2570,8 +2570,8 @@ int Field_double::store(const char *from,uint len,CHARSET_INFO *cs)
{ {
int err; int err;
char *end; char *end;
double nr= my_strntod(cs,(char*) from,len,&end,&err); double nr= my_strntod(cs,(char*) from,len,&end,&err);
if (!err && (!current_thd->count_cuted_fields || end-from==len)) if (!err && (!current_thd->count_cuted_fields || end-from==(int)len))
{ {
return Field_double::store(nr); return Field_double::store(nr);
} }
......
...@@ -2973,12 +2973,6 @@ Item *get_system_var(THD *thd, enum_var_type var_type, LEX_STRING name, ...@@ -2973,12 +2973,6 @@ Item *get_system_var(THD *thd, enum_var_type var_type, LEX_STRING name,
(uint) strlen(server_version), (uint) strlen(server_version),
system_charset_info); system_charset_info);
if (name.str && component.str && check_reserved_words(&name))
{
net_printf(thd, ER_SYNTAX_ERROR);
return 0;
}
Item *item; Item *item;
sys_var *var; sys_var *var;
char buff[MAX_SYS_VAR_LENGTH*2+4+8], *pos; char buff[MAX_SYS_VAR_LENGTH*2+4+8], *pos;
......
...@@ -2508,7 +2508,7 @@ simple_expr: ...@@ -2508,7 +2508,7 @@ simple_expr:
$$= new Item_func_set_collation($1, $$= new Item_func_set_collation($1,
new Item_string($3.str, new Item_string($3.str,
$3.length, $3.length,
YYTHD->charset())); YYTHD->charset()));
} }
| literal | literal
| param_marker | param_marker
...@@ -2524,6 +2524,12 @@ simple_expr: ...@@ -2524,6 +2524,12 @@ simple_expr:
} }
| '@' '@' opt_var_ident_type ident_or_text opt_component | '@' '@' opt_var_ident_type ident_or_text opt_component
{ {
if ($4.str && $5.str && check_reserved_words(&$4))
{
yyerror(ER(ER_SYNTAX_ERROR));
YYABORT;
}
if (!($$= get_system_var(YYTHD, (enum_var_type) $3, $4, $5))) if (!($$= get_system_var(YYTHD, (enum_var_type) $3, $4, $5)))
YYABORT; YYABORT;
} }
...@@ -5041,7 +5047,7 @@ internal_variable_name: ...@@ -5041,7 +5047,7 @@ internal_variable_name:
{ {
if (check_reserved_words(&$1)) if (check_reserved_words(&$1))
{ {
net_printf(YYTHD, ER_SYNTAX_ERROR); yyerror(ER(ER_SYNTAX_ERROR));
YYABORT; YYABORT;
} }
sys_var *tmp=find_sys_var($3.str, $3.length); sys_var *tmp=find_sys_var($3.str, $3.length);
......
...@@ -29,10 +29,6 @@ ...@@ -29,10 +29,6 @@
#include "my_base.h" /* Includes errno.h */ #include "my_base.h" /* Includes errno.h */
#include "m_ctype.h" #include "m_ctype.h"
#ifndef EOVERFLOW
#define EOVERFLOW 84
#endif
static double scaler10[] = { static double scaler10[] = {
1.0, 1e10, 1e20, 1e30, 1e40, 1e50, 1e60, 1e70, 1e80, 1e90 1.0, 1e10, 1e20, 1e30, 1e40, 1e50, 1e60, 1e70, 1e80, 1e90
}; };
......
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