odbtest/test/atemp/client/odbcon_test.go

package client

import (
	"testing"
	"time"

	"git.wecise.com/wecise/odb-go/odb"
	"gitee.com/wecisecode/util/logger"
)

func Test_ODBC(t *testing.T) {
	var err, lasterr error
	var client odb.Client
	for client == nil {
		client, err = odb.NewClient(&odb.Config{
			Keyspace: "matrix",
			Hosts:    []string{"127.0.0.1:11001"},
		})
		if err != nil {
			if lasterr == nil || err.Error() != lasterr.Error() {
				logger.Error(err)
				lasterr = err
			}
			time.Sleep(3 * time.Second)
		}
	}
	for {

		res, err := client.Query(`select id from /matrix/ limit 3`).Do() // mql
		if err != nil {
			logger.Error(err)
		} else {
			for i, d := range res.Data {
				logger.Info("got data", i, d["id"])
			}
		}
		time.Sleep(1 * time.Second)
	}
}