fix typos
This commit is contained in:
@ -1422,7 +1422,7 @@ int ObDelUpdLogPlan::allocate_pdml_insert_as_top(ObLogicalOperator *&top,
|
|||||||
LOG_WARN("get unexpected null", K(ret));
|
LOG_WARN("get unexpected null", K(ret));
|
||||||
}
|
}
|
||||||
if (OB_FAIL(insert_op->compute_property())) {
|
if (OB_FAIL(insert_op->compute_property())) {
|
||||||
LOG_WARN("failed to compute propery", K(ret));
|
LOG_WARN("failed to compute property", K(ret));
|
||||||
} else {
|
} else {
|
||||||
top = insert_op;
|
top = insert_op;
|
||||||
}
|
}
|
||||||
|
|||||||
@ -75,7 +75,7 @@ private:
|
|||||||
ObSEArray<bool, 4> is_null_prop_; // need case when for a expr
|
ObSEArray<bool, 4> is_null_prop_; // need case when for a expr
|
||||||
ObArray<ObRawExpr *> not_null_const_;
|
ObArray<ObRawExpr *> not_null_const_;
|
||||||
int64_t pullup_flag_; // the methods uesd when pulling up the ja query
|
int64_t pullup_flag_; // the methods uesd when pulling up the ja query
|
||||||
ObRawExpr *not_null_expr_; // not null expr of subquery if corelated join happened
|
ObRawExpr *not_null_expr_; // not null expr of subquery if correlated join happened
|
||||||
ObRawExpr *parent_expr_of_query_ref; // parent expr need to be modified for vector subquery comparison
|
ObRawExpr *parent_expr_of_query_ref; // parent expr need to be modified for vector subquery comparison
|
||||||
bool limit_for_exists_;
|
bool limit_for_exists_;
|
||||||
int64_t limit_value_;
|
int64_t limit_value_;
|
||||||
|
|||||||
@ -51,7 +51,7 @@ int ObTransformCountToExists::transform_one_stmt(common::ObIArray<ObParentDMLStm
|
|||||||
ret = OB_ERR_UNEXPECTED;
|
ret = OB_ERR_UNEXPECTED;
|
||||||
LOG_WARN("get unexpected null", K(ret));
|
LOG_WARN("get unexpected null", K(ret));
|
||||||
} else if (OB_FAIL(cond_exprs.assign(stmt->get_condition_exprs()))) {
|
} else if (OB_FAIL(cond_exprs.assign(stmt->get_condition_exprs()))) {
|
||||||
LOG_WARN("failed to assgin where condition exprs", K(ret));
|
LOG_WARN("failed to assign where condition exprs", K(ret));
|
||||||
} else if (OB_FAIL(collect_trans_params(stmt, cond_exprs, trans_params))) {
|
} else if (OB_FAIL(collect_trans_params(stmt, cond_exprs, trans_params))) {
|
||||||
LOG_WARN("failed to transform count to exists", K(ret));
|
LOG_WARN("failed to transform count to exists", K(ret));
|
||||||
} else if (trans_params.empty()) {
|
} else if (trans_params.empty()) {
|
||||||
|
|||||||
@ -315,7 +315,7 @@ int ObTransformLeftJoinToAnti::trans_stmt_to_anti(ObDMLStmt *stmt, JoinedTable *
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
// do in-place modification
|
// do in-place modification
|
||||||
// a shared expr in semi_condition may be modified by the above replacemenet,
|
// a shared expr in semi_condition may be modified by the above replacement,
|
||||||
// we revert the replacement in the following.
|
// we revert the replacement in the following.
|
||||||
if (OB_SUCC(ret)) {
|
if (OB_SUCC(ret)) {
|
||||||
ObRawExprCopier copier(*ctx_->expr_factory_);
|
ObRawExprCopier copier(*ctx_->expr_factory_);
|
||||||
@ -337,7 +337,7 @@ int ObTransformLeftJoinToAnti::trans_stmt_to_anti(ObDMLStmt *stmt, JoinedTable *
|
|||||||
} else if (OB_FAIL(stmt->update_column_item_rel_id())) {
|
} else if (OB_FAIL(stmt->update_column_item_rel_id())) {
|
||||||
LOG_WARN("failed to update column item rel id", K(ret));
|
LOG_WARN("failed to update column item rel id", K(ret));
|
||||||
} else if (OB_FAIL(stmt->formalize_stmt(ctx_->session_info_))) {
|
} else if (OB_FAIL(stmt->formalize_stmt(ctx_->session_info_))) {
|
||||||
LOG_WARN("failed to formlize stmt", K(ret));
|
LOG_WARN("failed to formalize stmt", K(ret));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return ret;
|
return ret;
|
||||||
@ -353,9 +353,9 @@ int ObTransformLeftJoinToAnti::clear_for_update(TableItem *table) {
|
|||||||
table->for_update_ = false;
|
table->for_update_ = false;
|
||||||
} else if (table->is_joined_table()) {
|
} else if (table->is_joined_table()) {
|
||||||
if (OB_FAIL(clear_for_update(static_cast<JoinedTable*>(table)->left_table_))) {
|
if (OB_FAIL(clear_for_update(static_cast<JoinedTable*>(table)->left_table_))) {
|
||||||
LOG_WARN("fail to cleanr for update", K(ret));
|
LOG_WARN("fail to clear for update", K(ret));
|
||||||
} else if (OB_FAIL(clear_for_update(static_cast<JoinedTable*>(table)->right_table_))) {
|
} else if (OB_FAIL(clear_for_update(static_cast<JoinedTable*>(table)->right_table_))) {
|
||||||
LOG_WARN("fail to cleanr for update", K(ret));
|
LOG_WARN("fail to clear for update", K(ret));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -523,7 +523,7 @@ int ObTransformLeftJoinToAnti::check_can_be_trans(ObDMLStmt *stmt,
|
|||||||
JoinedTable *right_joined_table = static_cast<JoinedTable *>(right_table);
|
JoinedTable *right_joined_table = static_cast<JoinedTable *>(right_table);
|
||||||
if (is_contain(right_joined_table->single_table_ids_, table_info->table_id_)) {
|
if (is_contain(right_joined_table->single_table_ids_, table_info->table_id_)) {
|
||||||
is_table_valid = false;
|
is_table_valid = false;
|
||||||
OPT_TRACE("right table is dml targe table");
|
OPT_TRACE("right table is dml target table");
|
||||||
}
|
}
|
||||||
} else if (table_info->table_id_ == right_table->table_id_) {
|
} else if (table_info->table_id_ == right_table->table_id_) {
|
||||||
is_table_valid = false;
|
is_table_valid = false;
|
||||||
|
|||||||
@ -51,7 +51,7 @@ class ObAggFunRawExpr;
|
|||||||
* select min(v.c1) from (select pk from t1 where pk is not null order by pk limit 1)
|
* select min(v.c1) from (select pk from t1 where pk is not null order by pk limit 1)
|
||||||
*
|
*
|
||||||
* rewrite requests:
|
* rewrite requests:
|
||||||
* 1. max/min aggragate on a column of table, and this column is a index or the first nonconst column of index.
|
* 1. max/min aggregate on a column of table, and this column is a index or the first nonconst column of index.
|
||||||
* 2. select stmt is scalar group by and hasn't limit.
|
* 2. select stmt is scalar group by and hasn't limit.
|
||||||
* 3. just deal single table yet.
|
* 3. just deal single table yet.
|
||||||
*/
|
*/
|
||||||
|
|||||||
@ -49,7 +49,7 @@ private:
|
|||||||
ObRawExpr *any_expr_;
|
ObRawExpr *any_expr_;
|
||||||
ObRawExpr *all_expr_;
|
ObRawExpr *all_expr_;
|
||||||
ObStmtMapInfo map_info_;
|
ObStmtMapInfo map_info_;
|
||||||
TransformFlag trans_flag_ = DEFAULT; //defalut value;
|
TransformFlag trans_flag_ = DEFAULT; //default value;
|
||||||
|
|
||||||
TO_STRING_KV(K(exists_expr_),
|
TO_STRING_KV(K(exists_expr_),
|
||||||
K(not_exists_expr_),
|
K(not_exists_expr_),
|
||||||
|
|||||||
Reference in New Issue
Block a user