Merge pull request #688 from taosdata/feature/grafana_plugin
fix grafana bugs
This commit is contained in:
commit
6da3459841
|
@ -92,7 +92,7 @@ bool gcBuildQueryJson(HttpContext *pContext, HttpSqlCmd *cmd, TAOS_RES *result,
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
bool us = taos_result_precision(result) == TSDB_TIME_PRECISION_MICRO;
|
int precision = taos_result_precision(result);
|
||||||
|
|
||||||
// such as select count(*) from sys.cpu
|
// such as select count(*) from sys.cpu
|
||||||
// such as select count(*) from sys.cpu group by ipaddr
|
// such as select count(*) from sys.cpu group by ipaddr
|
||||||
|
@ -151,7 +151,7 @@ bool gcBuildQueryJson(HttpContext *pContext, HttpSqlCmd *cmd, TAOS_RES *result,
|
||||||
snprintf(target, HTTP_GC_TARGET_SIZE, "%s%s", aliasBuffer, (char *)row[groupFields]);
|
snprintf(target, HTTP_GC_TARGET_SIZE, "%s%s", aliasBuffer, (char *)row[groupFields]);
|
||||||
break;
|
break;
|
||||||
case TSDB_DATA_TYPE_TIMESTAMP:
|
case TSDB_DATA_TYPE_TIMESTAMP:
|
||||||
if (us) {
|
if (precision == TSDB_TIME_PRECISION_MILLI) {
|
||||||
snprintf(target, HTTP_GC_TARGET_SIZE, "%s%ld", aliasBuffer, *((int64_t *) row[groupFields]));
|
snprintf(target, HTTP_GC_TARGET_SIZE, "%s%ld", aliasBuffer, *((int64_t *) row[groupFields]));
|
||||||
} else {
|
} else {
|
||||||
snprintf(target, HTTP_GC_TARGET_SIZE, "%s%ld", aliasBuffer, *((int64_t *) row[groupFields]) / 1000);
|
snprintf(target, HTTP_GC_TARGET_SIZE, "%s%ld", aliasBuffer, *((int64_t *) row[groupFields]) / 1000);
|
||||||
|
@ -210,7 +210,11 @@ bool gcBuildQueryJson(HttpContext *pContext, HttpSqlCmd *cmd, TAOS_RES *result,
|
||||||
httpJsonStringForTransMean(jsonBuf, row[i], fields[i].bytes);
|
httpJsonStringForTransMean(jsonBuf, row[i], fields[i].bytes);
|
||||||
break;
|
break;
|
||||||
case TSDB_DATA_TYPE_TIMESTAMP:
|
case TSDB_DATA_TYPE_TIMESTAMP:
|
||||||
httpJsonInt64(jsonBuf, *((int64_t *)row[i]));
|
if (precision == TSDB_TIME_PRECISION_MILLI) { //ms
|
||||||
|
httpJsonInt64(jsonBuf, *((int64_t *)row[i]));
|
||||||
|
} else {
|
||||||
|
httpJsonInt64(jsonBuf, *((int64_t *)row[i]) / 1000);
|
||||||
|
}
|
||||||
break;
|
break;
|
||||||
default:
|
default:
|
||||||
httpJsonString(jsonBuf, "invalidcol", 10);
|
httpJsonString(jsonBuf, "invalidcol", 10);
|
||||||
|
|
Loading…
Reference in New Issue