hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[CP] fix reconstruct sql for insert all bug

Browse Source
This commit is contained in:
zzg19950727
2022-12-08 08:06:37 +00:00
committed by ob-robot
parent 2529298832
commit 20da72c3ab
2 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/sql/ob_insert_all_stmt_printer.cpp
View File

@ -211,7 +211,7 @@ int ObInsertAllStmtPrinter::print_subquery(const ObInsertAllStmt *insert_stmt)
} else { } else {
ObSelectStmtPrinter printer(buf_, buf_len_, pos_, ObSelectStmtPrinter printer(buf_, buf_len_, pos_,
static_cast<const ObSelectStmt*>(sub_select_stmt), static_cast<const ObSelectStmt*>(sub_select_stmt),
print_params_, NULL, false); print_params_, NULL, false, false, true);
if (OB_FAIL(printer.do_print())) { if (OB_FAIL(printer.do_print())) {
LOG_WARN("failed to print sub select printer", K(ret)); LOG_WARN("failed to print sub select printer", K(ret));
} }
@ -256,7 +256,8 @@ int ObInsertAllStmtPrinter::print_into_table_values(const ObInsertAllStmt *inser
DATA_PRINTF("("); DATA_PRINTF("(");
for (int64_t p = 0; OB_SUCC(ret) && p < col_count; ++p) { for (int64_t p = 0; OB_SUCC(ret) && p < col_count; ++p) {
if (OB_FAIL(expr_printer_.do_print(table_info.values_vector_.at(k * col_count + p), if (OB_FAIL(expr_printer_.do_print(table_info.values_vector_.at(k * col_count + p),
T_INSERT_SCOPE))) { T_INSERT_SCOPE,
true))) {
LOG_WARN("fail to print where expr", K(ret)); LOG_WARN("fail to print where expr", K(ret));
} else { } else {
DATA_PRINTF(","); DATA_PRINTF(",");

2
src/sql/ob_insert_stmt_printer.cpp
View File

@ -231,7 +231,7 @@ int ObInsertStmtPrinter::print_subquery(const ObInsertStmt *insert_stmt)
} else { } else {
ObSelectStmtPrinter printer(buf_, buf_len_, pos_, ObSelectStmtPrinter printer(buf_, buf_len_, pos_,
static_cast<const ObSelectStmt*>(sub_select_stmt), static_cast<const ObSelectStmt*>(sub_select_stmt),
print_params_, NULL, false); print_params_, NULL, false, false, true);
if (OB_FAIL(printer.do_print())) { if (OB_FAIL(printer.do_print())) {
LOG_WARN("failed to print sub select printer", K(ret)); LOG_WARN("failed to print sub select printer", K(ret));
} }