demo.c 3.0 KB
Newer Older
H
hzcheng 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22
/*
 * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
 *
 * This program is free software: you can use, redistribute, and/or modify
 * it under the terms of the GNU Affero General Public License, version 3
 * or later ("AGPL"), as published by the Free Software Foundation.
 *
 * This program is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
 * FITNESS FOR A PARTICULAR PURPOSE.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
 */

// TAOS standard API example. The same syntax as MySQL, but only a subet
// to compile: gcc -o demo demo.c -ltaos

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
23
#include <taos.h>  // TAOS header file
H
hzcheng 已提交
24 25 26 27 28 29 30

void taosMsleep(int mseconds);

int main(int argc, char *argv[]) {
  TAOS *    taos;
  char      qstr[1024];
  TAOS_RES *result;
H
hjxilinx 已提交
31
  
H
hzcheng 已提交
32 33 34 35 36
  // connect to server
  if (argc < 2) {
    printf("please input server-ip \n");
    return 0;
  }
H
hjxilinx 已提交
37
  
H
hzcheng 已提交
38 39
  // init TAOS
  taos_init();
H
hjxilinx 已提交
40
  
H
hzcheng 已提交
41 42 43 44 45 46
  taos = taos_connect(argv[1], "root", "taosdata", NULL, 0);
  if (taos == NULL) {
    printf("failed to connect to server, reason:%s\n", taos_errstr(taos));
    exit(1);
  }
  printf("success to connect to server\n");
H
hjxilinx 已提交
47 48
  
  
H
hzcheng 已提交
49 50 51 52 53 54
  taos_query(taos, "drop database demo");
  if (taos_query(taos, "create database demo") != 0) {
    printf("failed to create database, reason:%s\n", taos_errstr(taos));
    exit(1);
  }
  printf("success to create database\n");
H
hjxilinx 已提交
55
  
H
hzcheng 已提交
56
  taos_query(taos, "use demo");
H
hjxilinx 已提交
57
  
H
hzcheng 已提交
58 59 60 61 62 63
  // create table
  if (taos_query(taos, "create table m1 (ts timestamp, speed int)") != 0) {
    printf("failed to create table, reason:%s\n", taos_errstr(taos));
    exit(1);
  }
  printf("success to create table\n");
H
hjxilinx 已提交
64
  
H
hzcheng 已提交
65 66
  // sleep for one second to make sure table is created on data node
  // taosMsleep(1000);
H
hjxilinx 已提交
67
  
H
hzcheng 已提交
68 69 70
  // insert 10 records
  int i = 0;
  for (i = 0; i < 10; ++i) {
H
huili 已提交
71
    sprintf(qstr, "insert into m1 values (%ld, %d)", 1546300800000 + i * 1000, i * 10);
H
hzcheng 已提交
72 73 74 75 76 77
    if (taos_query(taos, qstr)) {
      printf("failed to insert row: %i, reason:%s\n", i, taos_errstr(taos));
    }
    //sleep(1);
  }
  printf("success to insert rows, total %d rows\n", i);
H
hjxilinx 已提交
78
  
H
hzcheng 已提交
79 80 81 82 83 84
  // query the records
  sprintf(qstr, "SELECT * FROM m1");
  if (taos_query(taos, qstr) != 0) {
    printf("failed to select, reason:%s\n", taos_errstr(taos));
    exit(1);
  }
H
hjxilinx 已提交
85
  
H
hzcheng 已提交
86
  result = taos_use_result(taos);
H
hjxilinx 已提交
87
  
H
hzcheng 已提交
88 89 90 91
  if (result == NULL) {
    printf("failed to get result, reason:%s\n", taos_errstr(taos));
    exit(1);
  }
H
hjxilinx 已提交
92 93
  
  TAOS_ROW    row;
H
hzcheng 已提交
94 95 96 97
  int         rows = 0;
  int         num_fields = taos_field_count(taos);
  TAOS_FIELD *fields = taos_fetch_fields(result);
  char        temp[256];
H
hjxilinx 已提交
98
  
H
hjxilinx 已提交
99 100 101 102 103 104 105 106
  printf("select * from table, result:\n");
  // fetch the records row by row
  while ((row = taos_fetch_row(result))) {
    rows++;
    taos_print_row(temp, row, fields, num_fields);
    printf("%s\n", temp);
  }
  
H
hzcheng 已提交
107 108 109 110
  taos_free_result(result);
  printf("====demo end====\n\n");
  return getchar();
}