const taos = require('td2.0-connector');
//const taos = require('../../../src/connector/nodejs/');


var host = null;
var port = 6030;
for(var i = 2; i < global.process.argv.length; i++){
	var key = global.process.argv[i].split("=")[0];
	var value = global.process.argv[i].split("=")[1];
	
	if("host" == key){
		host = value;
	}
	if("port" == key){
		port = value;
	}
}

if(host == null){
	console.log("Usage: node nodejsChecker.js host=<hostname> port=<port>");
	process.exit(0);
}

// establish connection
var conn = taos.connect({host:host, user:"root", password:"taosdata",port:port});
var cursor = conn.cursor(); 
// create database
executeSql("create database if not exists test", 0);
// use db
executeSql("use test", 0);
// drop table
executeSql("drop table if exists test.weather", 0);
// create table
executeSql("create table if not exists test.weather(ts timestamp, temperature float, humidity int)", 0);
// insert
executeSql("insert into test.weather (ts, temperature, humidity) values(now, 20.5, 34)", 1);
// select
executeQuery("select * from test.weather");
// close connection
conn.close();

function executeQuery(sql){
	var start = new Date().getTime();
	var promise = cursor.query(sql, true);
	var end = new Date().getTime();
	promise.then(function(result){
		printSql(sql, result != null,(end - start));
		result.pretty();
	});
}

function executeSql(sql, affectRows){
	var start = new Date().getTime();
	var promise = cursor.execute(sql);
	var end = new Date().getTime();
	printSql(sql, promise == affectRows, (end - start));
}

function printSql(sql, succeed, cost){
	console.log("[ "+(succeed ? "OK" : "ERROR!")+" ] time cost: " + cost + " ms, execute statement ====> " + sql);
}