odbtest/test/atemp/client/odbclient_test.go

package client_test

import (
	"fmt"
	"os"
	"strings"
	"testing"
	"time"

	"git.wecise.com/wecise/odb-go/odb"
	"gitee.com/wecisecode/util/logger"
	"gitee.com/wecisecode/util/set/strset"
	//"git.wecise.com/wecise/odbserver/odb/upsertupsert"
)

var odbcfg *odb.Config

func init() {
	odbpath := os.Getenv("ODBPATH")
	if odbpath == "" {
		odbpath = "47.92.151.165:11001"
	}
	odbpaths := strset.New(strings.Split(odbpath, ",")...).List()
	keyspace := os.Getenv("KEYSPACE")
	if keyspace == "" {
		keyspace = "ooootest"
	}

	odbcfg = &odb.Config{
		Hosts:    odbpaths,
		Keyspace: keyspace,
		User:     fmt.Sprint("测试客户端"),
		Pass:     "********",
		PoolSize: 20,
		Debug:    true,
	}
}

func getClient() (c odb.Client, err error) {
	client, err := odb.NewClient(odbcfg)
	if err != nil {
		return nil, err
	}
	return client, nil
}

func TestClient2(t *testing.T) {
	time.Sleep(2 * time.Second)

	client, err := getClient()
	if err != nil {
		logger.Error(err)
	}
	defer func() {
		if err := client.Close(); err != nil {
			logger.Error(err)
		}
	}()

	//_, err = client.Query(`insert into /test/bucketpromdb (id, prom) values (?, ?)`, "bucketpromdb:wecise11", []map[string]interface{}{ map[string]interface{}{ "__name__":"key1", "__value__":2, "__timestamp__":"2024-08-27 11:24:17", "disk":"/opt/matrix", "CPU":"CPU1"}} ).Do()
	_, err = client.Query(`insert into /test/bucketpromdb (id, prom) values (?, ?)`, "bucketpromdb:wecise11", []map[string]interface{}{map[string]interface{}{"__name__": "key1", "__value__": 2, "__timestamp__": 1724729057000, "disk": "/opt/matrix", "CPU": "CPU1"}}).Do()

	if err != nil {
		logger.Error(err)
	}

}