Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
taosdata
TDengine
提交
96d12323
TDengine
项目概览
taosdata
/
TDengine
1 年多 前同步成功
通知
1185
Star
22016
Fork
4786
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
1
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
TDengine
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
1
Issue
1
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
提交
96d12323
编写于
11月 18, 2021
作者:
S
shenglian zhou
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
change numOfInputs of function node from uint8_t to int32_t
上级
0f78b09f
变更
3
显示空白变更内容
内联
并排
Showing
3 changed file
with
9 addition
and
9 deletion
+9
-9
src/client/src/tscSQLParser.c
src/client/src/tscSQLParser.c
+1
-1
src/common/inc/texpr.h
src/common/inc/texpr.h
+2
-2
src/common/src/texpr.c
src/common/src/texpr.c
+6
-6
未找到文件。
src/client/src/tscSQLParser.c
浏览文件 @
96d12323
...
...
@@ -9590,7 +9590,7 @@ int32_t exprTreeFromSqlExpr(SSqlCmd* pCmd, tExprNode **pExpr, const tSqlExpr* pS
SArray
*
paramList
=
pSqlExpr
->
Expr
.
paramList
;
size_t
paramSize
=
paramList
?
taosArrayGetSize
(
paramList
)
:
0
;
if
(
paramSize
>
0
)
{
(
*
pExpr
)
->
_func
.
numChildren
=
(
uint8
_t
)
paramSize
;
(
*
pExpr
)
->
_func
.
numChildren
=
(
int32
_t
)
paramSize
;
(
*
pExpr
)
->
_func
.
pChildren
=
(
tExprNode
**
)
calloc
(
paramSize
,
sizeof
(
tExprNode
*
));
}
for
(
int32_t
i
=
0
;
i
<
paramSize
;
++
i
)
{
...
...
src/common/inc/texpr.h
浏览文件 @
96d12323
...
...
@@ -73,7 +73,7 @@ typedef struct {
char
*
data
;
}
tExprOperandInfo
;
typedef
void
(
*
_expr_scalar_function_t
)(
int16_t
functionId
,
tExprOperandInfo
*
pInputs
,
uint8
_t
numInputs
,
tExprOperandInfo
*
pOutput
,
int32_t
order
);
typedef
void
(
*
_expr_scalar_function_t
)(
int16_t
functionId
,
tExprOperandInfo
*
pInputs
,
int32
_t
numInputs
,
tExprOperandInfo
*
pOutput
,
int32_t
order
);
_expr_scalar_function_t
getExprScalarFunction
(
uint16_t
scalar
);
...
...
@@ -126,7 +126,7 @@ typedef struct tExprNode {
struct
{
int16_t
functionId
;
uint8
_t
numChildren
;
int32
_t
numChildren
;
struct
tExprNode
**
pChildren
;
}
_func
;
};
...
...
src/common/src/texpr.c
浏览文件 @
96d12323
...
...
@@ -321,7 +321,7 @@ void exprTreeInternalNodeTraverse(tExprNode *pExpr, int32_t numOfRows, tExprOper
void
exprTreeFunctionNodeTraverse
(
tExprNode
*
pExpr
,
int32_t
numOfRows
,
tExprOperandInfo
*
output
,
void
*
param
,
int32_t
order
,
char
*
(
*
getSourceDataBlock
)(
void
*
,
const
char
*
,
int32_t
))
{
uint8
_t
numChildren
=
pExpr
->
_func
.
numChildren
;
int32
_t
numChildren
=
pExpr
->
_func
.
numChildren
;
if
(
numChildren
==
0
)
{
_expr_scalar_function_t
scalarFn
=
getExprScalarFunction
(
pExpr
->
_func
.
functionId
);
output
->
type
=
pExpr
->
resultType
;
...
...
@@ -526,7 +526,7 @@ static void exprTreeToBinaryImpl(SBufferWriter* bw, tExprNode* expr) {
exprTreeToBinaryImpl
(
bw
,
expr
->
_node
.
pRight
);
}
else
if
(
expr
->
nodeType
==
TSQL_NODE_FUNC
)
{
tbufWriteInt16
(
bw
,
expr
->
_func
.
functionId
);
tbufWrite
Uint8
(
bw
,
expr
->
_func
.
numChildren
);
tbufWrite
Int32
(
bw
,
expr
->
_func
.
numChildren
);
for
(
int
i
=
0
;
i
<
expr
->
_func
.
numChildren
;
++
i
)
{
exprTreeToBinaryImpl
(
bw
,
expr
->
_func
.
pChildren
[
i
]);
}
...
...
@@ -599,7 +599,7 @@ static tExprNode* exprTreeFromBinaryImpl(SBufferReader* br) {
assert
(
pExpr
->
_node
.
pLeft
!=
NULL
&&
pExpr
->
_node
.
pRight
!=
NULL
);
}
else
if
(
pExpr
->
nodeType
==
TSQL_NODE_FUNC
)
{
pExpr
->
_func
.
functionId
=
tbufReadInt16
(
br
);
pExpr
->
_func
.
numChildren
=
tbufRead
Uint8
(
br
);
pExpr
->
_func
.
numChildren
=
tbufRead
Int32
(
br
);
pExpr
->
_func
.
pChildren
=
(
tExprNode
**
)
calloc
(
pExpr
->
_func
.
numChildren
,
sizeof
(
tExprNode
*
));
for
(
int
i
=
0
;
i
<
pExpr
->
_func
.
numChildren
;
++
i
)
{
pExpr
->
_func
.
pChildren
[
i
]
=
exprTreeFromBinaryImpl
(
br
);
...
...
@@ -1040,7 +1040,7 @@ int32_t exprValidateMathNode(tExprNode *pExpr) {
return
TSDB_CODE_SUCCESS
;
}
void
vectorConcat
(
int16_t
functionId
,
tExprOperandInfo
*
pInputs
,
uint8
_t
numInputs
,
tExprOperandInfo
*
pOutput
,
int32_t
order
)
{
void
vectorConcat
(
int16_t
functionId
,
tExprOperandInfo
*
pInputs
,
int32
_t
numInputs
,
tExprOperandInfo
*
pOutput
,
int32_t
order
)
{
assert
(
functionId
==
TSDB_FUNC_SCALAR_CONCAT
&&
numInputs
>=
2
&&
order
==
TSDB_ORDER_ASC
);
for
(
int
i
=
0
;
i
<
numInputs
;
++
i
)
{
assert
(
pInputs
[
i
].
numOfRows
==
1
||
pInputs
[
i
].
numOfRows
==
pOutput
->
numOfRows
);
...
...
@@ -1080,7 +1080,7 @@ void vectorConcat(int16_t functionId, tExprOperandInfo* pInputs, uint8_t numInpu
free
(
inputData
);
}
void
vectorLength
(
int16_t
functionId
,
tExprOperandInfo
*
pInputs
,
uint8
_t
numInputs
,
tExprOperandInfo
*
pOutput
,
int32_t
order
)
{
void
vectorLength
(
int16_t
functionId
,
tExprOperandInfo
*
pInputs
,
int32
_t
numInputs
,
tExprOperandInfo
*
pOutput
,
int32_t
order
)
{
assert
(
functionId
==
TSDB_FUNC_SCALAR_LENGTH
&&
numInputs
==
1
&&
order
==
TSDB_ORDER_ASC
);
char
*
data0
=
NULL
;
...
...
@@ -1102,7 +1102,7 @@ void vectorLength(int16_t functionId, tExprOperandInfo *pInputs, uint8_t numInpu
}
}
void
vectorMathFunc
(
int16_t
functionId
,
tExprOperandInfo
*
pInputs
,
uint8
_t
numInputs
,
tExprOperandInfo
*
pOutput
,
int32_t
order
)
{
void
vectorMathFunc
(
int16_t
functionId
,
tExprOperandInfo
*
pInputs
,
int32
_t
numInputs
,
tExprOperandInfo
*
pOutput
,
int32_t
order
)
{
for
(
int
i
=
0
;
i
<
numInputs
;
++
i
)
{
assert
(
pInputs
[
i
].
numOfRows
==
1
||
pInputs
[
i
].
numOfRows
==
pOutput
->
numOfRows
);
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录