diff --git a/src/client/src/tscParseInsert.c b/src/client/src/tscParseInsert.c index c2ce81992c322b253aeec48601823be34eebb46c..df4ccca9bc6e106f50e5999ceaa652bd4e4c54cd 100644 --- a/src/client/src/tscParseInsert.c +++ b/src/client/src/tscParseInsert.c @@ -1475,88 +1475,6 @@ static void parseFileSendDataBlock(void *param, TAOS_RES *tres, int code) { } } -static UNUSED_FUNC int tscInsertDataFromFile(SSqlObj *pSql, FILE *fp, char *tmpTokenBuf) { - size_t readLen = 0; - char * line = NULL; - int32_t maxRows = 0; - SSqlCmd * pCmd = &pSql->cmd; - int numOfRows = 0; - int32_t code = 0; - - STableMetaInfo *pTableMetaInfo = tscGetTableMetaInfoFromCmd(pCmd, pCmd->clauseIndex, 0); - STableMeta * pTableMeta = pTableMetaInfo->pTableMeta; - STableComInfo tinfo = tscGetTableInfo(pTableMeta); - - assert(pCmd->numOfClause == 1); - - int32_t rowSize = tinfo.rowSize; - - pCmd->pDataBlocks = taosArrayInit(4, POINTER_BYTES); - STableDataBlocks *pTableDataBlock = NULL; - - int32_t ret = tscCreateDataBlock(TSDB_PAYLOAD_SIZE, rowSize, sizeof(SSubmitBlk), pTableMetaInfo->name, pTableMeta, &pTableDataBlock); - if (ret != TSDB_CODE_SUCCESS) { - return ret; - } - - taosArrayPush(pCmd->pDataBlocks, &pTableDataBlock); - - code = tscAllocateMemIfNeed(pTableDataBlock, rowSize, &maxRows); - if (TSDB_CODE_SUCCESS != code) return -1; - - int count = 0; - SParsedDataColInfo spd = {.numOfCols = tinfo.numOfColumns}; - SSchema * pSchema = tscGetTableSchema(pTableMeta); - - tscSetAssignedColumnInfo(&spd, pSchema, tinfo.numOfColumns); - - size_t n = 0; - while ((readLen = getline(&line, &n, fp)) != -1) { - // line[--readLen] = '\0'; - if (('\r' == line[readLen - 1]) || ('\n' == line[readLen - 1])) line[--readLen] = 0; - if (readLen == 0) continue; // fang, <= to == - - char *lineptr = line; - strtolower(line, line); - - int32_t len = tsParseOneRowData(&lineptr, pTableDataBlock, pSchema, &spd, pCmd->payload, tinfo.precision, &code, tmpTokenBuf); - if (len <= 0 || pTableDataBlock->numOfParams > 0) { - pSql->res.code = code; - return code; - } - - pTableDataBlock->size += len; - - count++; - if (count >= maxRows) { - if ((code = doPackSendDataBlock(pSql, count, pTableDataBlock)) != TSDB_CODE_SUCCESS) { - return code; - } - - pTableDataBlock = taosArrayGetP(pCmd->pDataBlocks, 0); - pTableDataBlock->size = sizeof(SSubmitBlk); - pTableDataBlock->rowSize = tinfo.rowSize; - - numOfRows += pSql->res.numOfRows; - pSql->res.numOfRows = 0; - count = 0; - } - } - - if (count > 0) { - if ((code = doPackSendDataBlock(pSql, count, pTableDataBlock)) != TSDB_CODE_SUCCESS) { - return code; - } - - numOfRows += pSql->res.numOfRows; - pSql->res.numOfRows = 0; - } - - if (line) tfree(line); - - return numOfRows; -} - void tscProcessMultiVnodesImportFromFile(SSqlObj *pSql) { SSqlCmd *pCmd = &pSql->cmd; if (pCmd->command != TSDB_SQL_INSERT) {