Merge spetrunia@bk-internal.mysql.com:/home/bk/mysql-4.1
into mysql.com:/dbdata/psergey/mysql-4.1-merge-fix
This commit is contained in:
commit
e06ac0e5ab
@ -100,5 +100,4 @@ tags:
|
|||||||
# Test installation
|
# Test installation
|
||||||
|
|
||||||
test:
|
test:
|
||||||
cd mysql-test ; ./mysql-test-run
|
cd mysql-test; ./mysql-test-run && ./mysql-test-run --ps-protocol
|
||||||
|
|
||||||
|
@ -78,6 +78,13 @@ a
|
|||||||
1
|
1
|
||||||
2
|
2
|
||||||
drop table t1, t2;
|
drop table t1, t2;
|
||||||
|
create table t1(a int);
|
||||||
|
insert into t1 values(1),(1);
|
||||||
|
reset master;
|
||||||
|
create table t2(unique(a)) select a from t1;
|
||||||
|
ERROR 23000: Duplicate entry '1' for key 1
|
||||||
|
show binlog events;
|
||||||
|
drop table t1;
|
||||||
create table t1 (a int not null);
|
create table t1 (a int not null);
|
||||||
create table t2 (a int not null);
|
create table t2 (a int not null);
|
||||||
insert into t1 values (1);
|
insert into t1 values (1);
|
||||||
|
@ -1416,7 +1416,9 @@ Load_log_event::Load_log_event(THD *thd_arg, sql_exchange *ex,
|
|||||||
List<Item> &fields_arg,
|
List<Item> &fields_arg,
|
||||||
enum enum_duplicates handle_dup,
|
enum enum_duplicates handle_dup,
|
||||||
bool using_trans)
|
bool using_trans)
|
||||||
:Log_event(thd_arg, 0, using_trans), thread_id(thd_arg->thread_id),
|
:Log_event(thd_arg, !thd_arg->tmp_table_used ?
|
||||||
|
0 : LOG_EVENT_THREAD_SPECIFIC_F, using_trans),
|
||||||
|
thread_id(thd_arg->thread_id),
|
||||||
slave_proxy_id(thd_arg->variables.pseudo_thread_id),
|
slave_proxy_id(thd_arg->variables.pseudo_thread_id),
|
||||||
num_fields(0),fields(0),
|
num_fields(0),fields(0),
|
||||||
field_lens(0),field_block_len(0),
|
field_lens(0),field_block_len(0),
|
||||||
@ -1606,6 +1608,9 @@ void Load_log_event::print(FILE* file, bool short_form, char* last_db,
|
|||||||
commented ? "# " : "",
|
commented ? "# " : "",
|
||||||
db);
|
db);
|
||||||
|
|
||||||
|
if (flags & LOG_EVENT_THREAD_SPECIFIC_F)
|
||||||
|
fprintf(file,"%sSET @@session.pseudo_thread_id=%lu;\n",
|
||||||
|
commented ? "# " : "", (ulong)thread_id);
|
||||||
fprintf(file, "%sLOAD DATA ",
|
fprintf(file, "%sLOAD DATA ",
|
||||||
commented ? "# " : "");
|
commented ? "# " : "");
|
||||||
if (check_fname_outside_temp_buf())
|
if (check_fname_outside_temp_buf())
|
||||||
|
@ -4757,7 +4757,8 @@ replicating a LOAD DATA INFILE command.",
|
|||||||
(gptr*) &delayed_queue_size, (gptr*) &delayed_queue_size, 0, GET_ULONG,
|
(gptr*) &delayed_queue_size, (gptr*) &delayed_queue_size, 0, GET_ULONG,
|
||||||
REQUIRED_ARG, DELAYED_QUEUE_SIZE, 1, ~0L, 0, 1, 0},
|
REQUIRED_ARG, DELAYED_QUEUE_SIZE, 1, ~0L, 0, 1, 0},
|
||||||
{"expire_logs_days", OPT_EXPIRE_LOGS_DAYS,
|
{"expire_logs_days", OPT_EXPIRE_LOGS_DAYS,
|
||||||
"Binary logs will be rotated after expire-log-days days ",
|
"If non-zero, binary logs will be purged after expire_logs_days "
|
||||||
|
"days; possible purges happen at startup and at binary log rotation.",
|
||||||
(gptr*) &expire_logs_days,
|
(gptr*) &expire_logs_days,
|
||||||
(gptr*) &expire_logs_days, 0, GET_ULONG,
|
(gptr*) &expire_logs_days, 0, GET_ULONG,
|
||||||
REQUIRED_ARG, 0, 0, 99, 0, 1, 0},
|
REQUIRED_ARG, 0, 0, 99, 0, 1, 0},
|
||||||
|
Loading…
x
Reference in New Issue
Block a user