package main

import (
	"database/sql"
	"fmt"
	_ "github.com/taosdata/driver-go/v3/taosSql"
	"log"
	"time"
)

func main() {
	var taosDSN = "root:taosdata@tcp(192.168.0.153:6030)/test"
	taos, err := sql.Open("taosSql", taosDSN)
	if err != nil {
		log.Fatalln("failed to connect TDengine, err:", err)
		return
	}
	defer taos.Close()

	rows, err := taos.Query("select * from test1")
	if err != nil {
		fmt.Println("failed to select from table, err:", err)
		return
	}

	// 测试读取数据
	defer rows.Close()
	for rows.Next() {
		var r struct {
			ts time.Time
			a  int
		}
		err := rows.Scan(&r.ts, &r.a)
		if err != nil {
			fmt.Println("scan error:\n", err)
			return
		}
		fmt.Println(r.ts, "---", r.a)
	}

	// 测试查询统计数据
	rows2, err := taos.Exec("select sum(a) from test1")
	if err != nil {
		fmt.Println("failed to select from table, err:", err)
		return
	}
	for rows.Next() {
		var r struct {
			ts time.Time
			a  int
		}
		err := rows.Scan(&r.ts, &r.a)
		if err != nil {
			fmt.Println("scan error:\n", err)
			return
		}
		fmt.Println(r.ts, "---", r.a)
	}
}