Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
taosdata
TDengine
提交
d59db2e5
TDengine
项目概览
taosdata
/
TDengine
大约 2 年 前同步成功
通知
1192
Star
22018
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看板
提交
d59db2e5
编写于
12月 09, 2021
作者:
C
Cary Xu
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
code optimization
上级
e191450d
变更
1
隐藏空白更改
内联
并排
Showing
1 changed file
with
3 addition
and
3 deletion
+3
-3
src/client/src/tscParseInsert.c
src/client/src/tscParseInsert.c
+3
-3
未找到文件。
src/client/src/tscParseInsert.c
浏览文件 @
d59db2e5
...
@@ -454,7 +454,7 @@ int tsParseOneRow(char **str, STableDataBlocks *pDataBlocks, int16_t timePrec, b
...
@@ -454,7 +454,7 @@ int tsParseOneRow(char **str, STableDataBlocks *pDataBlocks, int16_t timePrec, b
char
*
row
=
pDataBlocks
->
pData
+
char
*
row
=
pDataBlocks
->
pData
+
((
*
isConverted
)
?
(
pDataBlocks
->
size
-
rowSize
)
:
pDataBlocks
->
size
);
// skip the SSubmitBlk header
((
*
isConverted
)
?
(
pDataBlocks
->
size
-
rowSize
)
:
pDataBlocks
->
size
);
// skip the SSubmitBlk header
*
isConverted
=
false
;
*
isConverted
=
false
;
SParsedDataColInfo
*
spd
=
&
pDataBlocks
->
boundColumnInfo
;
SParsedDataColInfo
*
spd
=
&
pDataBlocks
->
boundColumnInfo
;
STableMeta
*
pTableMeta
=
pDataBlocks
->
pTableMeta
;
STableMeta
*
pTableMeta
=
pDataBlocks
->
pTableMeta
;
SSchema
*
schema
=
tscGetTableSchema
(
pTableMeta
);
SSchema
*
schema
=
tscGetTableSchema
(
pTableMeta
);
...
@@ -672,7 +672,7 @@ int32_t tsParseValues(char **str, STableDataBlocks *pDataBlock, int maxRows, SIn
...
@@ -672,7 +672,7 @@ int32_t tsParseValues(char **str, STableDataBlocks *pDataBlock, int maxRows, SIn
}
}
if
(
isConverted
)
{
if
(
isConverted
)
{
void
*
convertedSMemRow
=
pDataBlock
->
pData
+
pDataBlock
->
size
;
void
*
convertedSMemRow
=
pDataBlock
->
pData
+
pDataBlock
->
size
;
memcpy
(
convertedSMemRow
-
extendedRowSize
,
convertedSMemRow
,
extendedRowSize
);
memcpy
(
convertedSMemRow
-
extendedRowSize
,
convertedSMemRow
,
memRowTLen
(
convertedSMemRow
)
);
}
}
if
((
*
numOfRows
)
<=
0
)
{
if
((
*
numOfRows
)
<=
0
)
{
...
@@ -1775,7 +1775,7 @@ static void parseFileSendDataBlock(void *param, TAOS_RES *tres, int32_t numOfRow
...
@@ -1775,7 +1775,7 @@ static void parseFileSendDataBlock(void *param, TAOS_RES *tres, int32_t numOfRow
}
}
if
(
isConverted
)
{
if
(
isConverted
)
{
void
*
convertedSMemRow
=
pTableDataBlock
->
pData
+
pTableDataBlock
->
size
;
void
*
convertedSMemRow
=
pTableDataBlock
->
pData
+
pTableDataBlock
->
size
;
memcpy
(
convertedSMemRow
-
extendedRowSize
,
convertedSMemRow
,
extendedRowSize
);
memcpy
(
convertedSMemRow
-
extendedRowSize
,
convertedSMemRow
,
memRowTLen
(
convertedSMemRow
)
);
}
}
tfree
(
tokenBuf
);
tfree
(
tokenBuf
);
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录