Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
M
MariaDB
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Analytics
Analytics
CI / CD
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
nexedi
MariaDB
Commits
f6c996f0
Commit
f6c996f0
authored
Jul 09, 2006
by
guilhem@gbichot3.local
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
post-merge fixes
parent
57ced262
Changes
2
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
15 additions
and
18 deletions
+15
-18
mysql-test/r/rpl_switch_stm_row_mixed.result
mysql-test/r/rpl_switch_stm_row_mixed.result
+2
-0
sql/sql_insert.cc
sql/sql_insert.cc
+13
-18
No files found.
mysql-test/r/rpl_switch_stm_row_mixed.result
View file @
f6c996f0
...
@@ -286,6 +286,8 @@ master-bin.000001 # Table_map 1 # table_id: # (mysqltest1.t2)
...
@@ -286,6 +286,8 @@ master-bin.000001 # Table_map 1 # table_id: # (mysqltest1.t2)
master-bin.000001 # Write_rows 1 # table_id: # flags: STMT_END_F
master-bin.000001 # Write_rows 1 # table_id: # flags: STMT_END_F
master-bin.000001 # Table_map 1 # table_id: # (mysqltest1.t2)
master-bin.000001 # Table_map 1 # table_id: # (mysqltest1.t2)
master-bin.000001 # Write_rows 1 # table_id: # flags: STMT_END_F
master-bin.000001 # Write_rows 1 # table_id: # flags: STMT_END_F
master-bin.000001 # Table_map 1 # table_id: # (mysqltest1.t2)
master-bin.000001 # Write_rows 1 # table_id: # flags: STMT_END_F
master-bin.000001 # Query 1 # use `mysqltest1`; create table t12 (a int, b float)
master-bin.000001 # Query 1 # use `mysqltest1`; create table t12 (a int, b float)
master-bin.000001 # Table_map 1 # table_id: # (mysqltest1.t12)
master-bin.000001 # Table_map 1 # table_id: # (mysqltest1.t12)
master-bin.000001 # Write_rows 1 # table_id: # flags: STMT_END_F
master-bin.000001 # Write_rows 1 # table_id: # flags: STMT_END_F
...
...
sql/sql_insert.cc
View file @
f6c996f0
...
@@ -2066,9 +2066,19 @@ bool delayed_insert::handle_inserts(void)
...
@@ -2066,9 +2066,19 @@ bool delayed_insert::handle_inserts(void)
}
}
if
(
row
->
log_query
&&
row
->
query
.
str
!=
NULL
&&
mysql_bin_log
.
is_open
())
if
(
row
->
log_query
&&
row
->
query
.
str
!=
NULL
&&
mysql_bin_log
.
is_open
())
{
/*
If the query has several rows to insert, only the first row will come
here. In row-based binlogging, this means that the first row will be
written to binlog as one Table_map event and one Rows event (due to an
event flush done in binlog_query()), then all other rows of this query
will be binlogged together as one single Table_map event and one
single Rows event.
*/
thd
.
binlog_query
(
THD
::
ROW_QUERY_TYPE
,
thd
.
binlog_query
(
THD
::
ROW_QUERY_TYPE
,
row
->
query
.
str
,
row
->
query
.
length
,
row
->
query
.
str
,
row
->
query
.
length
,
FALSE
,
FALSE
);
FALSE
,
FALSE
);
}
if
(
table
->
s
->
blob_fields
)
if
(
table
->
s
->
blob_fields
)
free_delayed_insert_blobs
(
table
);
free_delayed_insert_blobs
(
table
);
...
@@ -2744,22 +2754,6 @@ static TABLE *create_table_from_items(THD *thd, HA_CREATE_INFO *create_info,
...
@@ -2744,22 +2754,6 @@ static TABLE *create_table_from_items(THD *thd, HA_CREATE_INFO *create_info,
}
}
class
MY_HOOKS
:
public
TABLEOP_HOOKS
{
public:
MY_HOOKS
(
select_create
*
x
)
:
ptr
(
x
)
{
}
virtual
void
do_prelock
(
TABLE
**
tables
,
uint
count
)
{
if
(
ptr
->
get_thd
()
->
current_stmt_binlog_row_based
&&
!
(
ptr
->
get_create_info
()
->
options
&
HA_LEX_CREATE_TMP_TABLE
))
ptr
->
binlog_show_create_table
(
tables
,
count
);
}
private:
select_create
*
ptr
;
};
int
int
select_create
::
prepare
(
List
<
Item
>
&
values
,
SELECT_LEX_UNIT
*
u
)
select_create
::
prepare
(
List
<
Item
>
&
values
,
SELECT_LEX_UNIT
*
u
)
{
{
...
@@ -2772,8 +2766,9 @@ select_create::prepare(List<Item> &values, SELECT_LEX_UNIT *u)
...
@@ -2772,8 +2766,9 @@ select_create::prepare(List<Item> &values, SELECT_LEX_UNIT *u)
MY_HOOKS
(
select_create
*
x
)
:
ptr
(
x
)
{
}
MY_HOOKS
(
select_create
*
x
)
:
ptr
(
x
)
{
}
virtual
void
do_prelock
(
TABLE
**
tables
,
uint
count
)
virtual
void
do_prelock
(
TABLE
**
tables
,
uint
count
)
{
{
if
(
ptr
->
get_thd
()
->
current_stmt_binlog_row_based
)
if
(
ptr
->
get_thd
()
->
current_stmt_binlog_row_based
&&
ptr
->
binlog_show_create_table
(
tables
,
count
);
!
(
ptr
->
get_create_info
()
->
options
&
HA_LEX_CREATE_TMP_TABLE
))
ptr
->
binlog_show_create_table
(
tables
,
count
);
}
}
private:
private:
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment