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

fix mysql_test case result

Browse Source
This commit is contained in:
yishenglanlingzui
2022-11-13 12:15:53 +08:00
committed by wangzelin.wzl
parent e38aace24d
commit 715aa49d82
1 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/sql/engine/expr/ob_expr_to_outfile_row.cpp
View File

@ -43,9 +43,9 @@ int ObExprToOutfileRow::calc_result_typeN(ObExprResType &type,
{ {
//objs[0] field_str varchar //objs[0] field_str varchar
//objs[1] line_str varchar //objs[1] line_str varchar
//objs[2] closed_cht char //objs[2] closed_cht char
//objs[3] is_optional bool //objs[3] is_optional bool
//objs[4] escaped_cht char //objs[4] escaped_cht char
//objs[5:] params //objs[5:] params
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
UNUSED(type_ctx); UNUSED(type_ctx);
@ -90,9 +90,9 @@ int ObExprToOutfileRow::cg_expr(ObExprCGCtx &, const ObRawExpr &, ObExpr &expr)
} }
return ret; return ret;
} }
int ObExprToOutfileRow::extend_buffer(ObExprOutFileInfo &out_info, int ObExprToOutfileRow::extend_buffer(ObExprOutFileInfo &out_info,
ObIAllocator &allocator) ObIAllocator &allocator)
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
int64_t old_len = out_info.buf_len_; int64_t old_len = out_info.buf_len_;
@ -160,9 +160,9 @@ int ObExprToOutfileRow::to_outfile_str(const ObExpr &expr, ObEvalCtx &ctx, ObDat
LOG_WARN("evaluate parameters values failed", K(ret)); LOG_WARN("evaluate parameters values failed", K(ret));
} else { } else {
ObExprOutFileInfo *out_info = NULL; ObExprOutFileInfo *out_info = NULL;
auto rt_ctx_id = static_cast<uint64_t>(expr.expr_ctx_id_); auto rt_ctx_id = static_cast<uint64_t>(expr.expr_ctx_id_);
if (NULL == (out_info = static_cast<ObExprOutFileInfo *> if (NULL == (out_info = static_cast<ObExprOutFileInfo *>
(ctx.exec_ctx_.get_expr_op_ctx(rt_ctx_id)))) { (ctx.exec_ctx_.get_expr_op_ctx(rt_ctx_id)))) {
if (OB_FAIL(ctx.exec_ctx_.create_expr_op_ctx(rt_ctx_id, out_info))) { if (OB_FAIL(ctx.exec_ctx_.create_expr_op_ctx(rt_ctx_id, out_info))) {
LOG_WARN("failed to create operator ctx", K(ret)); LOG_WARN("failed to create operator ctx", K(ret));
} else if (OB_FAIL(calc_outfile_info(expr, ctx, } else if (OB_FAIL(calc_outfile_info(expr, ctx,