Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
taosdata
TDengine
提交
f09cb2e6
T
TDengine
项目概览
taosdata
/
TDengine
接近 2 年 前同步成功
通知
1191
Star
22018
Fork
4786
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
1
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
T
TDengine
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
1
Issue
1
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
提交
f09cb2e6
编写于
12月 09, 2021
作者:
wmmhello
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
fix ci error in windows
上级
509845f5
变更
2
隐藏空白更改
内联
并排
Showing
2 changed file
with
10 addition
and
10 deletion
+10
-10
src/query/src/qFilter.c
src/query/src/qFilter.c
+4
-4
src/tsdb/src/tsdbRead.c
src/tsdb/src/tsdbRead.c
+6
-6
未找到文件。
src/query/src/qFilter.c
浏览文件 @
f09cb2e6
...
...
@@ -2964,7 +2964,7 @@ static FORCE_INLINE bool filterExecuteImplIsNull(void *pinfo, int32_t numOfRows,
if
(
!
colData
){
// for json->'key' is null
(
*
p
)[
i
]
=
1
;
}
else
if
(
*
(
char
*
)
colData
==
TSDB_DATA_TYPE_JSON
){
// for json is null
colData
+=
CHAR_BYTES
;
colData
=
POINTER_SHIFT
(
colData
,
CHAR_BYTES
)
;
(
*
p
)[
i
]
=
isNull
(
colData
,
info
->
cunits
[
uidx
].
dataType
);
}
else
{
(
*
p
)[
i
]
=
0
;
...
...
@@ -2999,7 +2999,7 @@ static FORCE_INLINE bool filterExecuteImplNotNull(void *pinfo, int32_t numOfRows
if
(
!
colData
)
{
// for json->'key' is not null
(
*
p
)[
i
]
=
0
;
}
else
if
(
*
(
char
*
)
colData
==
TSDB_DATA_TYPE_JSON
){
// for json is not null
colData
+=
CHAR_BYTES
;
colData
=
POINTER_SHIFT
(
colData
,
CHAR_BYTES
)
;
(
*
p
)[
i
]
=
!
isNull
(
colData
,
info
->
cunits
[
uidx
].
dataType
);
}
else
{
// for json->'key' is not null
(
*
p
)[
i
]
=
1
;
...
...
@@ -3019,7 +3019,7 @@ static FORCE_INLINE bool filterExecuteImplNotNull(void *pinfo, int32_t numOfRows
static
void
doJsonCompare
(
SFilterComUnit
*
cunit
,
int8_t
*
result
,
void
*
colData
){
if
(
cunit
->
optr
==
TSDB_RELATION_MATCH
||
cunit
->
optr
==
TSDB_RELATION_NMATCH
){
uint8_t
jsonType
=
*
(
char
*
)
colData
;
char
*
realData
=
colData
+
CHAR_BYTES
;
char
*
realData
=
POINTER_SHIFT
(
colData
,
CHAR_BYTES
)
;
if
(
jsonType
!=
TSDB_DATA_TYPE_NCHAR
){
*
result
=
false
;
}
else
{
...
...
@@ -3036,7 +3036,7 @@ static void doJsonCompare(SFilterComUnit *cunit, int8_t *result, void* colData){
}
}
else
if
(
cunit
->
optr
==
TSDB_RELATION_LIKE
){
uint8_t
jsonType
=
*
(
char
*
)
colData
;
char
*
realData
=
colData
+
CHAR_BYTES
;
char
*
realData
=
POINTER_SHIFT
(
colData
,
CHAR_BYTES
)
;
if
(
jsonType
!=
TSDB_DATA_TYPE_NCHAR
){
*
result
=
false
;
}
else
{
...
...
src/tsdb/src/tsdbRead.c
浏览文件 @
f09cb2e6
...
...
@@ -3559,8 +3559,8 @@ static int32_t tableGroupComparFn(const void *p1, const void *p2, const void *pa
bytes
=
pCol
->
bytes
;
type
=
pCol
->
type
;
if
(
type
==
TSDB_DATA_TYPE_JSON
){
f1
=
getJsonTagValueElment
(
pTable1
,
pColIndex
->
name
,
strlen
(
pColIndex
->
name
),
NULL
,
TSDB_MAX_JSON_TAGS_LEN
);
f2
=
getJsonTagValueElment
(
pTable2
,
pColIndex
->
name
,
strlen
(
pColIndex
->
name
),
NULL
,
TSDB_MAX_JSON_TAGS_LEN
);
f1
=
getJsonTagValueElment
(
pTable1
,
pColIndex
->
name
,
(
int32_t
)
strlen
(
pColIndex
->
name
),
NULL
,
TSDB_MAX_JSON_TAGS_LEN
);
f2
=
getJsonTagValueElment
(
pTable2
,
pColIndex
->
name
,
(
int32_t
)
strlen
(
pColIndex
->
name
),
NULL
,
TSDB_MAX_JSON_TAGS_LEN
);
}
else
{
f1
=
tdGetKVRowValOfCol
(
pTable1
->
tagVal
,
pCol
->
colId
);
f2
=
tdGetKVRowValOfCol
(
pTable2
->
tagVal
,
pCol
->
colId
);
...
...
@@ -4110,7 +4110,7 @@ static int32_t queryByJsonTag(STable* pTable, void* filterInfo, SArray* res){
tsdbError
(
"json key not exist, no candidate table"
);
return
TSDB_CODE_SUCCESS
;
}
int32
_t
size
=
taosArrayGetSize
(
tabList
);
size
_t
size
=
taosArrayGetSize
(
tabList
);
int8_t
*
addToResult
=
NULL
;
for
(
int
i
=
0
;
i
<
size
;
i
++
){
JsonMapValue
*
data
=
taosArrayGet
(
tabList
,
i
);
...
...
@@ -4155,7 +4155,7 @@ void* getJsonTagValueElment(void* data, char* key, int32_t keyLen, char* dst, in
void
*
result
=
tsdbGetJsonTagValue
(
data
,
keyMd5
,
TSDB_MAX_JSON_KEY_MD5_LEN
,
NULL
);
if
(
result
==
NULL
){
// json key no result
if
(
!
dst
)
return
NULL
;
*
(
char
*
)
dst
=
TSDB_DATA_TYPE_JSON
;
*
dst
=
TSDB_DATA_TYPE_JSON
;
setNull
(
dst
+
CHAR_BYTES
,
TSDB_DATA_TYPE_JSON
,
0
);
return
dst
;
}
...
...
@@ -4182,7 +4182,7 @@ void* getJsonTagValueElment(void* data, char* key, int32_t keyLen, char* dst, in
void
getJsonTagValueAll
(
void
*
data
,
void
*
dst
,
int16_t
bytes
)
{
char
*
json
=
parseTagDatatoJson
(
data
);
char
*
tagData
=
dst
+
CHAR_BYTES
;
char
*
tagData
=
POINTER_SHIFT
(
dst
,
CHAR_BYTES
)
;
*
(
char
*
)
dst
=
TSDB_DATA_TYPE_JSON
;
if
(
json
==
NULL
){
setNull
(
tagData
,
TSDB_DATA_TYPE_JSON
,
0
);
...
...
@@ -4267,7 +4267,7 @@ char* parseTagDatatoJson(void *p){
cJSON_AddItemToObject
(
json
,
tagJsonKey
,
value
);
}
else
if
(
type
==
TSDB_DATA_TYPE_BIGINT
){
int64_t
jsonVd
=
*
(
int64_t
*
)(
realData
);
cJSON
*
value
=
cJSON_CreateNumber
(
jsonVd
);
cJSON
*
value
=
cJSON_CreateNumber
(
(
double
)
jsonVd
);
if
(
value
==
NULL
)
{
goto
end
;
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录