odbtest/test/prepare/testprepare/prepare_test.go

package testprepare_test

import (
	"fmt"
	"testing"
	"time"

	"git.wecise.com/wecise/mring"
	"git.wecise.com/wecise/odbserver/odb"
	"git.wecise.com/wecise/odbserver/odb/notify"
	"git.wecise.com/wecise/odbserver/odb/test"
	"gitee.com/wecisecode/util/logger"
	"gitee.com/wecisecode/util/merrs"
)

func TestPrepare(t *testing.T) {
	odb.ODB = odb.NewOMDB()
	odb.MRingHandle = mring.Default()

	option := &odb.Option{Cache: notify.CacheAll, Keyspace: "matrix", DisableInitialHostLookup: true, DisableNotify: true}
	g, err := test.NewG(option)

	if err != nil {
		logger.Error(err.Error())
		return
	} else {
		defer g.Close()
	}

	logger.SetConsole(true)
	logger.SetLevel(logger.TRACE)

	stat, err := g.Prepare(`select id from /matrix/ldap where id in ?`)
	if err != nil {
		logger.Errorf("%v", err)
		return
	}

	ids := []string{}
	for i := 1; i <= 10000; i++ {
		ids = append(ids, fmt.Sprint(i))
	}
	data, meta, err := stat.Exec(ids)

	if err != nil {
		logger.Errorf("%v", err)
		return
	}

	logger.Info(merrs.New(merrs.Map{"data": data, "meta": meta}))

	time.Sleep(5 * time.Second)

	logger.Info("ok")
}