import {TDRestConnection} from "../TDengineRest";

let conn = new TDRestConnection({host: 'u195', user: 'root', pass: 'taosdata', port: 6041});
let cursor = conn.cursor();

// (async () => {
//   result = await cursor.query("drop database if exists  node_rest").catch(e=>console.log(e))
//   result.toString()
// })()

const createDB = "create database if not exists  node_rest";
const dropDB = "drop database if exists  node_rest";
const createTBL = "CREATE STABLE if not exists node_rest.meters3 (ts timestamp, current float, voltage int, phase float) TAGS (location binary(64), groupId int)";
const dropTBL = "drop table if exists node_rest.meters ";
const insert = "INSERT INTO node_rest.d1001 USING node_rest.meters TAGS (\"Beijng.Chaoyang\", 2) VALUES (now, 10.2, 219, 0.32) ";
const select = "select * from node_rest.d1001 ";
const selectStbl = "select * from node_rest.meters";

async function execute(sql) {
  console.log("SQL:" + sql);
  result = await cursor.query(sql);
  result.toString()
};

(async () => {
  await execute(createDB);
  await execute(createTBL);
  await execute(insert);
  await execute(select);
  await execute(selectStbl);
  await execute(dropDB);
})()