提交 3355ad51 编写于 作者: X Xiaoyu Wang

enh: insert client optimize

上级 b420bf4c
...@@ -1464,10 +1464,16 @@ static int32_t parseInsertBody(SInsertParseContext* pCxt) { ...@@ -1464,10 +1464,16 @@ static int32_t parseInsertBody(SInsertParseContext* pCxt) {
} }
STableDataBlocks* dataBuf = NULL; STableDataBlocks* dataBuf = NULL;
CHECK_CODE(getDataBlockFromList(pCxt->pTableBlockHashObj, &pCxt->pTableMeta->uid, sizeof(pCxt->pTableMeta->uid), if (pCxt->pComCxt->async) {
TSDB_DEFAULT_PAYLOAD_SIZE, sizeof(SSubmitBlk), CHECK_CODE(getDataBlockFromList(pCxt->pTableBlockHashObj, &pCxt->pTableMeta->uid, sizeof(pCxt->pTableMeta->uid),
getTableInfo(pCxt->pTableMeta).rowSize, pCxt->pTableMeta, &dataBuf, NULL, TSDB_DEFAULT_PAYLOAD_SIZE, sizeof(SSubmitBlk),
&pCxt->createTblReq)); getTableInfo(pCxt->pTableMeta).rowSize, pCxt->pTableMeta, &dataBuf, NULL,
&pCxt->createTblReq));
} else {
CHECK_CODE(getDataBlockFromList(pCxt->pTableBlockHashObj, tbFName, strlen(tbFName), TSDB_DEFAULT_PAYLOAD_SIZE,
sizeof(SSubmitBlk), getTableInfo(pCxt->pTableMeta).rowSize, pCxt->pTableMeta,
&dataBuf, NULL, &pCxt->createTblReq));
}
if (NULL != pBoundColsStart) { if (NULL != pBoundColsStart) {
char* pCurrPos = pCxt->pSql; char* pCurrPos = pCxt->pSql;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册