[modify timestamp]
This commit is contained in:
parent
397faaff11
commit
761369e1f7
|
@ -108,11 +108,11 @@ int main(int argc, char *argv[])
|
||||||
|
|
||||||
printf("start to insert...\n");
|
printf("start to insert...\n");
|
||||||
gettimeofday(&systemTime, NULL);
|
gettimeofday(&systemTime, NULL);
|
||||||
//st = systemTime.tv_sec * 1000000 + systemTime.tv_usec;
|
st = systemTime.tv_sec * 1000000 + systemTime.tv_usec;
|
||||||
|
|
||||||
for (i = 0; i<numOfTables; ++i) {
|
for (i = 0; i<numOfTables; ++i) {
|
||||||
// insert records in asynchronous API
|
// insert records in asynchronous API
|
||||||
sprintf(sql, "insert into %s values(now, 0)", tableList[i].name);
|
sprintf(sql, "insert into %s values(%ld, 0)", tableList[i].name, 1546300800000 + i);
|
||||||
taos_query_a(taos, sql, taos_insert_call_back, (void *)(tableList + i));
|
taos_query_a(taos, sql, taos_insert_call_back, (void *)(tableList + i));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -174,7 +174,7 @@ void taos_insert_call_back(void *param, TAOS_RES *tres, int code)
|
||||||
|
|
||||||
if (pTable->rowsTried < points) {
|
if (pTable->rowsTried < points) {
|
||||||
// for this demo, insert another record
|
// for this demo, insert another record
|
||||||
sprintf(sql, "insert into %s values(now+%da, %d)", pTable->name, pTable->rowsTried, pTable->rowsTried);
|
sprintf(sql, "insert into %s values(%ld, %d)", pTable->name, 1546300800000+pTable->rowsTried*1000, pTable->rowsTried);
|
||||||
taos_query_a(pTable->taos, sql, taos_insert_call_back, (void *)pTable);
|
taos_query_a(pTable->taos, sql, taos_insert_call_back, (void *)pTable);
|
||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
|
|
|
@ -68,7 +68,7 @@ int main(int argc, char *argv[]) {
|
||||||
// insert 10 records
|
// insert 10 records
|
||||||
int i = 0;
|
int i = 0;
|
||||||
for (i = 0; i < 10; ++i) {
|
for (i = 0; i < 10; ++i) {
|
||||||
sprintf(qstr, "insert into m1 values (now+%ds, %d)", i, i * 10);
|
sprintf(qstr, "insert into m1 values (%ld, %d)", 1546300800000 + i * 1000, i * 10);
|
||||||
if (taos_query(taos, qstr)) {
|
if (taos_query(taos, qstr)) {
|
||||||
printf("failed to insert row: %i, reason:%s\n", i, taos_errstr(taos));
|
printf("failed to insert row: %i, reason:%s\n", i, taos_errstr(taos));
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue