fix: taosbenchmark code refactor

src/benchData.c

@@ -1461,8 +1461,15 @@ int generateRandData(SSuperTable *stbInfo, char *sampleDataBuf,
     return -1;
 }
 
-int prepareChildTblSampleData(SDataBase* database, SSuperTable* stbInfo) {
-    return -1;
+static BArray *initChildCols(int colsSize) {
+    BArray *childCols = benchArrayInit(colsSize,
+                                       sizeof(ChildField));
+    for (int col = 0; col < colsSize; col++) {
+        ChildField *childCol = benchCalloc(
+                1, sizeof(ChildField), true);
+        benchArrayPush(childCols, childCol);
+    }
+    return childCols;
 }
 
 int prepareSampleData(SDataBase* database, SSuperTable* stbInfo) {
@@ -1523,13 +1530,7 @@ int prepareSampleData(SDataBase* database, SSuperTable* stbInfo) {
             for (int64_t child = 0; child < stbInfo->childTblCount; child++) {
                 SChildTable *childTbl = stbInfo->childTblArray[child];
                 if (STMT_IFACE == stbInfo->iface) {
-                    childTbl->childCols = benchArrayInit(stbInfo->cols->size,
-                                                         sizeof(ChildField));
-                    for (int col = 0; col < stbInfo->cols->size; col++) {
-                        ChildField *childCol = benchCalloc(
-                                1, sizeof(ChildField), true);
-                        benchArrayPush(childTbl->childCols, childCol);
-                    }
+                    childTbl->childCols = initChildCols(stbInfo->cols->size);
                 }
                 childTbl->sampleDataBuf =
                     benchCalloc(
@@ -1609,13 +1610,7 @@ int prepareSampleData(SDataBase* database, SSuperTable* stbInfo) {
                     return -1;
                 }
                 if (STMT_IFACE == stbInfo->iface) {
-                    childTbl->childCols = benchArrayInit(stbInfo->cols->size,
-                                                         sizeof(ChildField));
-                    for (int col = 0; col < stbInfo->cols->size; col++) {
-                        ChildField *childCol = benchCalloc(
-                                1, sizeof(ChildField), true);
-                        benchArrayPush(childTbl->childCols, childCol);
-                    }
+                    childTbl->childCols = initChildCols(stbInfo->cols->size);
                 }
                 childTbl->useOwnSample = true;
                 debugPrint("sampleDataBuf: %s\n", childTbl->sampleDataBuf);

src/benchInsert.c

@@ -1813,9 +1813,7 @@ static int32_t prepareProgressDataSmlJson(
 }
 
 static int32_t prepareProgressDataSmlLine(
-    threadInfo *pThreadInfo,
-    uint64_t tableSeq,
-    char *sampleDataBuf,
+    threadInfo *pThreadInfo, uint64_t tableSeq, char *sampleDataBuf,
     int64_t *timestamp, uint64_t i, char *ttl) {
     // prepareProgressDataSmlLine
     SSuperTable *stbInfo = pThreadInfo->stbInfo;
@@ -1828,11 +1826,9 @@ static int32_t prepareProgressDataSmlLine(
                 pThreadInfo->lines[j],
                 stbInfo->lenOfCols + stbInfo->lenOfTags,
                 "%s %s %" PRId64 "",
-                pThreadInfo
-                ->sml_tags[(int)tableSeq -
-                pThreadInfo->start_table_from],
-                sampleDataBuf +
-                pos * stbInfo->lenOfCols,
+                pThreadInfo->sml_tags[tableSeq
+                    - pThreadInfo->start_table_from],
+                sampleDataBuf + pos * stbInfo->lenOfCols,
                 *timestamp);
         pos++;
         if (pos >= g_arguments->prepared_rand) {
@@ -1851,9 +1847,7 @@ static int32_t prepareProgressDataSmlLine(
 }
 
 static int32_t prepareProgressDataSmlTelnet(
-    threadInfo *pThreadInfo,
-    uint64_t tableSeq,
-    char *sampleDataBuf,
+    threadInfo *pThreadInfo, uint64_t tableSeq, char *sampleDataBuf,
     int64_t *timestamp, uint64_t i, char *ttl) {
     // prepareProgressDataSmlTelnet
     SSuperTable *stbInfo = pThreadInfo->stbInfo;
@@ -1868,10 +1862,9 @@ static int32_t prepareProgressDataSmlTelnet(
                 "%s %" PRId64 " %s %s", stbInfo->stbName,
                 *timestamp,
                 sampleDataBuf
-                + pos * stbInfo->lenOfCols,
-                pThreadInfo
-                ->sml_tags[(int)tableSeq
-                -pThreadInfo->start_table_from]);
+                    + pos * stbInfo->lenOfCols,
+                pThreadInfo->sml_tags[tableSeq
+                    -pThreadInfo->start_table_from]);
         pos++;
         if (pos >= g_arguments->prepared_rand) {
             pos = 0;