This commit is contained in:
chenhuiming
2023-04-13 16:25:00 +08:00
parent d624f1b3f2
commit 4a35ecd899
8 changed files with 13 additions and 13 deletions

View File

@ -22,7 +22,7 @@ enum ObExprInfoFlag
{ {
IS_CONST = 0x0, // const expression, e.g. 1.2, 'abc' IS_CONST = 0x0, // const expression, e.g. 1.2, 'abc'
IS_COLUMN, // column expression, e.g. C1, T1.C1 IS_COLUMN, // column expression, e.g. C1, T1.C1
IS_STATIC_PARAM, // vaiable expression, e.g. ? IS_STATIC_PARAM, // variable expression, e.g. ?
IS_AGG, // aggregate function, e.g. max, avg IS_AGG, // aggregate function, e.g. max, avg
IS_FUNC, // system function IS_FUNC, // system function
IS_IN, IS_IN,

View File

@ -154,7 +154,7 @@ struct ObSelectIntoItem
ObItemType into_type_; ObItemType into_type_;
common::ObObj outfile_name_; common::ObObj outfile_name_;
common::ObObj filed_str_; // filed terminated str common::ObObj filed_str_; // filed terminated str
common::ObObj line_str_; // line teminated str common::ObObj line_str_; // line terminated str
common::ObSEArray<common::ObString, 16> user_vars_; // user variables common::ObSEArray<common::ObString, 16> user_vars_; // user variables
common::ObSEArray<sql::ObRawExpr*, 16> pl_vars_; // pl variables common::ObSEArray<sql::ObRawExpr*, 16> pl_vars_; // pl variables
char closed_cht_; // all fileds, "123","ab" char closed_cht_; // all fileds, "123","ab"

View File

@ -548,7 +548,7 @@ int ObQueryHint::reset_duplicate_qb_name()
if (OB_UNLIKELY(OB_HASH_NOT_EXIST != ret)) { if (OB_UNLIKELY(OB_HASH_NOT_EXIST != ret)) {
LOG_WARN("get stmt id from hash map failed", K(ret)); LOG_WARN("get stmt id from hash map failed", K(ret));
} else if (OB_FAIL(qb_name_map_.set_refactored(qb_names.qb_names_.at(0), i))) { } else if (OB_FAIL(qb_name_map_.set_refactored(qb_names.qb_names_.at(0), i))) {
LOG_WARN("faield to add name map", K(ret)); LOG_WARN("failed to add name map", K(ret));
} }
} else if (OB_UNLIKELY(idx < 0 || idx >= i)) { } else if (OB_UNLIKELY(idx < 0 || idx >= i)) {
ret = OB_ERR_UNEXPECTED; ret = OB_ERR_UNEXPECTED;
@ -704,7 +704,7 @@ int ObQueryHint::print_outline_data(PlanText &plan_text) const
bool is_oneline = plan_text.is_oneline_; bool is_oneline = plan_text.is_oneline_;
if (OB_UNLIKELY(1 < stmt_id_hints_.count())) { if (OB_UNLIKELY(1 < stmt_id_hints_.count())) {
ret = OB_ERR_UNEXPECTED; ret = OB_ERR_UNEXPECTED;
LOG_WARN("unexpected stmt id hitns for outline data", K(ret), K(stmt_id_hints_)); LOG_WARN("unexpected stmt id hints for outline data", K(ret), K(stmt_id_hints_));
} else if (OB_FAIL(BUF_PRINTF("%sBEGIN_OUTLINE_DATA", ObQueryHint::get_outline_indent(is_oneline)))) { } else if (OB_FAIL(BUF_PRINTF("%sBEGIN_OUTLINE_DATA", ObQueryHint::get_outline_indent(is_oneline)))) {
} else if (1 == stmt_id_hints_.count() && } else if (1 == stmt_id_hints_.count() &&
OB_FAIL(stmt_id_hints_.at(0).print_hints(plan_text, true))) { OB_FAIL(stmt_id_hints_.at(0).print_hints(plan_text, true))) {

View File

@ -167,7 +167,7 @@ struct ObQueryHint {
int64_t outline_stmt_id_; int64_t outline_stmt_id_;
ObSEArray<ObHints, 8, common::ModulePageAllocator, true> qb_hints_; // hints with qb name ObSEArray<ObHints, 8, common::ModulePageAllocator, true> qb_hints_; // hints with qb name
ObSEArray<ObHints, 8, common::ModulePageAllocator, true> stmt_id_hints_; // hints without qb name, used before transform ObSEArray<ObHints, 8, common::ModulePageAllocator, true> stmt_id_hints_; // hints without qb name, used before transform
ObSEArray<const ObHint*, 8, common::ModulePageAllocator, true> trans_list_; // tranform hints from outline data, need keep order ObSEArray<const ObHint*, 8, common::ModulePageAllocator, true> trans_list_; // transform hints from outline data, need keep order
ObSEArray<const ObHint*, 8, common::ModulePageAllocator, true> outline_trans_hints_; // tranform hints to generate outline data ObSEArray<const ObHint*, 8, common::ModulePageAllocator, true> outline_trans_hints_; // tranform hints to generate outline data
ObSEArray<const ObHint*, 8, common::ModulePageAllocator, true> used_trans_hints_; ObSEArray<const ObHint*, 8, common::ModulePageAllocator, true> used_trans_hints_;
ObSEArray<QbNames, 8, common::ModulePageAllocator, true> stmt_id_map_; // stmt id -> qb name list, position is stmt id ObSEArray<QbNames, 8, common::ModulePageAllocator, true> stmt_id_map_; // stmt id -> qb name list, position is stmt id

View File

@ -133,7 +133,7 @@ int ObSharedExprChecker::init(ObDMLStmt &stmt)
} }
if (OB_SUCC(ret)) { if (OB_SUCC(ret)) {
if (OB_FAIL(stmt_expr_set.destroy())) { if (OB_FAIL(stmt_expr_set.destroy())) {
LOG_WARN("failed to detroy stmt expr set", K(ret)); LOG_WARN("failed to destroy stmt expr set", K(ret));
} }
} }
return ret; return ret;

View File

@ -159,7 +159,7 @@ extern ObRawExpr *USELESS_POINTER;
#define IS_SPATIAL_EXPR(op) \ #define IS_SPATIAL_EXPR(op) \
((op) >= T_FUN_SYS_ST_LONGITUDE && (op) <= T_FUN_SYS_ST_LATITUDE) ((op) >= T_FUN_SYS_ST_LONGITUDE && (op) <= T_FUN_SYS_ST_LATITUDE)
// ObSqlBitSet is a simple bitset, in order to avoid memory explosure // ObSqlBitSet is a simple bitset, in order to avoid memory exposure
// ObBitSet is too large just for a simple bitset // ObBitSet is too large just for a simple bitset
const static int64_t DEFAULT_SQL_BITSET_SIZE = 32; const static int64_t DEFAULT_SQL_BITSET_SIZE = 32;
template<int64_t N = DEFAULT_SQL_BITSET_SIZE, template<int64_t N = DEFAULT_SQL_BITSET_SIZE,
@ -202,7 +202,7 @@ public:
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
if (!other.is_valid()) { if (!other.is_valid()) {
desc_.init_errcode_ = other.desc_.init_errcode_; desc_.init_errcode_ = other.desc_.init_errcode_;
SQL_RESV_LOG(WARN, "other not intied", K(other.desc_.init_errcode_)); SQL_RESV_LOG(WARN, "other not initied", K(other.desc_.init_errcode_));
} else if (OB_FAIL(init_block_allocator())) { } else if (OB_FAIL(init_block_allocator())) {
desc_.init_errcode_ = ret; desc_.init_errcode_ = ret;
SQL_RESV_LOG(WARN, "failed to init block allocator", K(ret)); SQL_RESV_LOG(WARN, "failed to init block allocator", K(ret));
@ -1608,7 +1608,7 @@ struct ObResolveContext
bool is_for_pivot_; bool is_for_pivot_;
bool is_for_dynamic_sql_; bool is_for_dynamic_sql_;
bool is_for_dbms_sql_; bool is_for_dbms_sql_;
TgTimingEvent tg_timing_event_; // for msyql trigger TgTimingEvent tg_timing_event_; // for mysql trigger
uint64_t view_ref_id_; uint64_t view_ref_id_;
bool is_variable_allowed_; bool is_variable_allowed_;
}; };
@ -3331,7 +3331,7 @@ private:
//use for udf function info //use for udf function info
share::schema::ObUDFMeta udf_meta_; share::schema::ObUDFMeta udf_meta_;
bool is_nested_aggr_; bool is_nested_aggr_;
bool is_need_deserialize_row_;// for topk histogram and hybrid histogram computaion bool is_need_deserialize_row_;// for topk histogram and hybrid histogram computation
ObRawExpr *pl_agg_udf_expr_;//for pl agg udf expr ObRawExpr *pl_agg_udf_expr_;//for pl agg udf expr
}; };
@ -4674,7 +4674,7 @@ public:
SQL_RESV_LOG(WARN, "failed to check stack overflow", K(ret)); SQL_RESV_LOG(WARN, "failed to check stack overflow", K(ret));
} else if (is_overflow) { } else if (is_overflow) {
ret = OB_SIZE_OVERFLOW; ret = OB_SIZE_OVERFLOW;
SQL_RESV_LOG(WARN, "too deep recusive", K(ret)); SQL_RESV_LOG(WARN, "too deep recursive", K(ret));
} else if (OB_FAIL(proxy_->create_raw_expr(expr_type, raw_expr))) { } else if (OB_FAIL(proxy_->create_raw_expr(expr_type, raw_expr))) {
SQL_RESV_LOG(WARN, "failed to create raw expr by pl factory", K(ret)); SQL_RESV_LOG(WARN, "failed to create raw expr by pl factory", K(ret));
} else { } else {

View File

@ -377,7 +377,7 @@ int ObRawExprDeduceType::calc_result_type(ObNonTerminalRawExpr &expr,
// 以防calc_result_typeX没有对其进行设置 // 以防calc_result_typeX没有对其进行设置
// 理想情况下,不应该要这个循环,所有calc_type的设置都在calc_result_typeX中完成 // 理想情况下,不应该要这个循环,所有calc_type的设置都在calc_result_typeX中完成
// For avg(), internally it will call 'divison', which requires that both input are // For avg(), internally it will call 'division', which requires that both input are
// casted into number. However, this requirements are not remembered in the input_types // casted into number. However, this requirements are not remembered in the input_types
// for the avg() expression but as the calc_type for the input expression itself. This // for the avg() expression but as the calc_type for the input expression itself. This
// demands that we set the calculation type here. // demands that we set the calculation type here.

View File

@ -167,7 +167,7 @@ private:
char *buf_; char *buf_;
int64_t buf_len_; int64_t buf_len_;
// avoid to update pos_ between different printers(mainly ObRawExprPrinter // avoid to update pos_ between different printers(mainly ObRawExprPrinter
// and ObSelectStmtPrinter), we definate pointer of pos_ rather than object // and ObSelectStmtPrinter), we definite pointer of pos_ rather than object
int64_t *pos_; int64_t *pos_;
ObStmtScope scope_; ObStmtScope scope_;
bool only_column_namespace_; bool only_column_namespace_;