Skip to content

T
TDengine

慢慢CG / TDengine
与 Fork 源项目一致

Fork自 taosdata / TDengine

通知 1
Star 0
Fork 0
T
TDengine
提交 9e7feb03 编写于 作者: Z zhaoyanggh
浏览文件
操作

change type

上级 4c541e8c
隐藏空白更改
内联 并排
Showing with 18 addition and 16 deletion
src/kit/taosdemo/taosdemo.c
浏览文件 @ 9e7feb03
...@@ -4740,7 +4740,7 @@ static void *insertSchemaless(void *sargs) { ...@@ -4740,7 +4740,7 @@ static void *insertSchemaless(void *sargs) {
"%s,id=\"%s%ld\"", stbInfo->stbName, "%s,id=\"%s%ld\"", stbInfo->stbName,
stbInfo->childTblPrefix, stbInfo->childTblPrefix,
t + pThreadInfo->start_table_from); t + pThreadInfo->start_table_from);
for (uint64_t j = 0; j < stbInfo->tagCount; j++) { for (int j = 0; j < stbInfo->tagCount; j++) {
tstrncpy(smlHead[t] + dataLen, ",", 2); tstrncpy(smlHead[t] + dataLen, ",", 2);
dataLen += 1; dataLen += 1;
switch (stbInfo->tags[j].data_type) { switch (stbInfo->tags[j].data_type) {
...@@ -4752,57 +4752,57 @@ static void *insertSchemaless(void *sargs) { ...@@ -4752,57 +4752,57 @@ static void *insertSchemaless(void *sargs) {
case TSDB_DATA_TYPE_BOOL: case TSDB_DATA_TYPE_BOOL:
dataLen += dataLen +=
snprintf(smlHead[t] + dataLen, MAX_LINE_SIZE - dataLen, snprintf(smlHead[t] + dataLen, MAX_LINE_SIZE - dataLen,
"t%ld=%s", j, rand_bool_str()); "T%d=%s", j, rand_bool_str());
break; break;
case TSDB_DATA_TYPE_TINYINT: case TSDB_DATA_TYPE_TINYINT:
dataLen += dataLen +=
snprintf(smlHead[t] + dataLen, MAX_LINE_SIZE - dataLen, snprintf(smlHead[t] + dataLen, MAX_LINE_SIZE - dataLen,
"t%ld=%si8", j, rand_tinyint_str()); "T%d=%si8", j, rand_tinyint_str());
break; break;
case TSDB_DATA_TYPE_UTINYINT: case TSDB_DATA_TYPE_UTINYINT:
dataLen += dataLen +=
snprintf(smlHead[t] + dataLen, MAX_LINE_SIZE - dataLen, snprintf(smlHead[t] + dataLen, MAX_LINE_SIZE - dataLen,
"t%ld=%su8", j, rand_utinyint_str()); "T%d=%su8", j, rand_utinyint_str());
break; break;
case TSDB_DATA_TYPE_SMALLINT: case TSDB_DATA_TYPE_SMALLINT:
dataLen += dataLen +=
snprintf(smlHead[t] + dataLen, MAX_LINE_SIZE - dataLen, snprintf(smlHead[t] + dataLen, MAX_LINE_SIZE - dataLen,
"t%ld=%si16", j, rand_smallint_str()); "T%d=%si16", j, rand_smallint_str());
break; break;
case TSDB_DATA_TYPE_USMALLINT: case TSDB_DATA_TYPE_USMALLINT:
dataLen += dataLen +=
snprintf(smlHead[t] + dataLen, MAX_LINE_SIZE - dataLen, snprintf(smlHead[t] + dataLen, MAX_LINE_SIZE - dataLen,
"t%ld=%su16", j, rand_usmallint_str()); "T%d=%su16", j, rand_usmallint_str());
break; break;
case TSDB_DATA_TYPE_INT: case TSDB_DATA_TYPE_INT:
dataLen += dataLen +=
snprintf(smlHead[t] + dataLen, MAX_LINE_SIZE - dataLen, snprintf(smlHead[t] + dataLen, MAX_LINE_SIZE - dataLen,
"t%ld=%si32", j, rand_int_str()); "T%d=%si32", j, rand_int_str());
break; break;
case TSDB_DATA_TYPE_UINT: case TSDB_DATA_TYPE_UINT:
dataLen += dataLen +=
snprintf(smlHead[t] + dataLen, MAX_LINE_SIZE - dataLen, snprintf(smlHead[t] + dataLen, MAX_LINE_SIZE - dataLen,
"t%ld=%su32", j, rand_uint_str()); "T%d=%su32", j, rand_uint_str());
break; break;
case TSDB_DATA_TYPE_BIGINT: case TSDB_DATA_TYPE_BIGINT:
dataLen += dataLen +=
snprintf(smlHead[t] + dataLen, MAX_LINE_SIZE - dataLen, snprintf(smlHead[t] + dataLen, MAX_LINE_SIZE - dataLen,
"t%ld=%si64", j, rand_bigint_str()); "T%d=%si64", j, rand_bigint_str());
break; break;
case TSDB_DATA_TYPE_UBIGINT: case TSDB_DATA_TYPE_UBIGINT:
dataLen += dataLen +=
snprintf(smlHead[t] + dataLen, MAX_LINE_SIZE - dataLen, snprintf(smlHead[t] + dataLen, MAX_LINE_SIZE - dataLen,
"t%ld=%su64", j, rand_ubigint_str()); "T%d=%su64", j, rand_ubigint_str());
break; break;
case TSDB_DATA_TYPE_FLOAT: case TSDB_DATA_TYPE_FLOAT:
dataLen += dataLen +=
snprintf(smlHead[t] + dataLen, MAX_LINE_SIZE - dataLen, snprintf(smlHead[t] + dataLen, MAX_LINE_SIZE - dataLen,
"t%ld=%sf32", j, rand_float_str()); "T%d=%sf32", j, rand_float_str());
break; break;
case TSDB_DATA_TYPE_DOUBLE: case TSDB_DATA_TYPE_DOUBLE:
dataLen += dataLen +=
snprintf(smlHead[t] + dataLen, MAX_LINE_SIZE - dataLen, snprintf(smlHead[t] + dataLen, MAX_LINE_SIZE - dataLen,
"t%ld=%sf64", j, rand_double_str()); "T%d=%sf64", j, rand_double_str());
break; break;
case TSDB_DATA_TYPE_BINARY: case TSDB_DATA_TYPE_BINARY:
case TSDB_DATA_TYPE_NCHAR: case TSDB_DATA_TYPE_NCHAR:
...@@ -4822,11 +4822,11 @@ static void *insertSchemaless(void *sargs) { ...@@ -4822,11 +4822,11 @@ static void *insertSchemaless(void *sargs) {
if (stbInfo->tags[j].data_type == TSDB_DATA_TYPE_BINARY) { if (stbInfo->tags[j].data_type == TSDB_DATA_TYPE_BINARY) {
dataLen += snprintf(smlHead[t] + dataLen, dataLen += snprintf(smlHead[t] + dataLen,
MAX_DATA_SIZE - dataLen, MAX_DATA_SIZE - dataLen,
"t%ld=\"%s\"", j, buf); "T%d=\"%s\"", j, buf);
} else { } else {
dataLen += snprintf(smlHead[t] + dataLen, dataLen += snprintf(smlHead[t] + dataLen,
MAX_DATA_SIZE - dataLen, MAX_DATA_SIZE - dataLen,
"t%ld=L\"%s\"", j, buf); "T%d=L\"%s\"", j, buf);
} }
tmfree(buf); tmfree(buf);
break; break;
...@@ -6035,7 +6035,8 @@ static bool getMetaFromInsertJsonFile(cJSON *root) { ...@@ -6035,7 +6035,8 @@ static bool getMetaFromInsertJsonFile(cJSON *root) {
} }
// cJSON* maxtablesPerVnode= cJSON_GetObjectItem(dbinfo, // cJSON* maxtablesPerVnode= cJSON_GetObjectItem(dbinfo,
// "maxtablesPerVnode"); if (maxtablesPerVnode && maxtablesPerVnode->type // "maxtablesPerVnode"); if (maxtablesPerVnode &&
// maxtablesPerVnode->type
// == cJSON_Number) { // == cJSON_Number) {
// g_Dbs.db[i].dbCfg.maxtablesPerVnode = maxtablesPerVnode->valueint; // g_Dbs.db[i].dbCfg.maxtablesPerVnode = maxtablesPerVnode->valueint;
//} else if (!maxtablesPerVnode) { //} else if (!maxtablesPerVnode) {
...@@ -6889,7 +6890,8 @@ static bool getMetaFromQueryJsonFile(cJSON *root) { ...@@ -6889,7 +6890,8 @@ static bool getMetaFromQueryJsonFile(cJSON *root) {
} }
// cJSON* subTblCnt = cJSON_GetObjectItem(superQuery, // cJSON* subTblCnt = cJSON_GetObjectItem(superQuery,
// "childtable_count"); if (subTblCnt && subTblCnt->type == cJSON_Number) // "childtable_count"); if (subTblCnt && subTblCnt->type ==
// cJSON_Number)
// { // {
// g_queryInfo.superQueryInfo.childTblCount = subTblCnt->valueint; // g_queryInfo.superQueryInfo.childTblCount = subTblCnt->valueint;
//} else if (!subTblCnt) { //} else if (!subTblCnt) {
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或